Feature/activity logger

backend/repository/activityRepository.js

@@ -47,7 +47,41 @@ async function getLoginDataTimerange(start, end) {
 
 async function getLoginDataByUser() {}
 
-async function logDatabaseChange() {}
+/*
+Insert a row into changeLog which keeps track of every time the database is changed.
+*/
+async function logDatabaseChange(
+  tableName,
+  recordId,
+  userId,
+  changeType,
+  changedColumns,
+  oldValues,
+  newValues
+) {
+  const query = `
+    INSERT INTO changeLog (changedTable, recordId, userId, changeType, changedColumns, oldValues, newValues)
+    VALUES (?, ?, ?, ?, ?, ?, ?)
+  `;
+  const values = [
+    tableName,
+    recordId,
+    userId,
+    changeType,
+    changedColumns,
+    oldValues,
+    newValues,
+  ];
+
+  try {
+    await pool.query(query, values);
+    console.log("Change logged successfully.");
+  } catch (error) {
+    // throw error to be caught by service
+    console.log("activity repository error when logging change: ", error);
+    throw error;
+  }
+}
 
 async function getDatabaseChangeTimerange() {}
 
@@ -56,4 +90,5 @@ async function getDatabaseChangeByUser() {}
 module.exports = {
   logSuccessfulLogin,
   getLoginDataTimerange,
+  logDatabaseChange,
 };