diff --git a/src/controllers/syncController.ts b/src/controllers/syncController.ts index b7861b8..c4f7e7c 100644 --- a/src/controllers/syncController.ts +++ b/src/controllers/syncController.ts @@ -84,6 +84,14 @@ function mapRowToRvOpenitem(row: any) { // Function to process a single database sync async function processDatabaseSync(database: any) { + await db.activity_logs.create({ + data: { + action: "sync_rv_openitem", + status: "start", + message: `Starting sync for database ${database.name} (${database.db_id})`, + extra_json: database, + }, + }); const pool = await getPoolForDbId(database.db_id); const q = "SELECT * FROM rv_openitem"; @@ -191,6 +199,14 @@ async function processDatabaseSync(database: any) { } } } + await db.activity_logs.create({ + data: { + action: "sync_rv_openitem", + status: "success", + message: `Completed sync for database ${database.name} (${database.db_id})`, + extra_json: database, + }, + }); return { inserted: dbInserted, updated: dbUpdated }; }