[ORCT-163] Enhance synchronisation logic (#178)

Author: xsalonx

app/application.js

@@ -69,6 +69,9 @@ class RunConditionTableApplication {
             await this.databaseManager.migrate();
             await this.httpServer.listen();
             await this.databaseService.healthcheckInsertData();
+            if (config.syncTaskAtStart) {
+                this.syncManager.setSyncAllTask();
+            }
         } catch (error) {
             this.logger.error(`Error while starting RCT app: ${error}`);
             await this.stop();

app/config/index.js

@@ -23,6 +23,7 @@ module.exports = Object.freeze({
     winston: ResProvider.winston(),
     database: require('./database.js'),
     syncTaskAtStart: ResProvider.envOrDef('RCT_SYNC_TASK_AT_START', false, Boolean),
+    syncPeriod: ResProvider.envOrDef('RCT_SYNC_PERIOD', 12 * 60 * 60 * 1000, Number),
     rctData: require('./rct-data'),
     public: require('./public.js'),
 

app/config/rct-data/healthcheckQueries.js

@@ -39,7 +39,7 @@ const metaObj = {
     },
 };
 
-const queryForName = (name) => `SELECT name, val, extract(epoch from "updated_at") as "udatedAt" FROM meta WHERE name = '${name}'`;
+const queryForName = (name) => `SELECT name, val, extract(epoch from "updated_at") as "updatedAt" FROM meta WHERE name = '${name}'`;
 const updateForName = (name, val) => `INSERT INTO meta (name, val, "updated_at") values ('${name}', '${val}', now()) 
                                         ON conflict (name) do update set val = EXCLUDED.val, "updated_at" = now();`;
 

app/lib/alimonitor-services/SyncManager.js

@@ -44,17 +44,23 @@ class SyncManager {
             await this.services.monalisaService.setSyncTask();
             await this.services.monalisaServiceMC.setSyncTask();
             await this.setInDBSyncOk();
+            this.logger.info('Synchronization completed');
         } catch {
             await this.setInDBSyncFailure();
         }
     }
 
     async setSyncAllTask() {
-        const syncPeriod = 12 * 60 * 60 * 1000; // Twice per day [ms]
-        const last_sync = this.getLastSyncMetadata();
-        const firstSyncDelay = last_sync.val === 'ok' ?
-            syncPeriod - (Date.now() - (last_sync.updatedAt || 0) * 1000)
-            : 1000;// Gives server 1 sec before sync task starts;
+        const { syncPeriod } = config;
+        const last_sync = await this.getLastSyncMetadata();
+        const firstSyncDelay = last_sync?.val === 'ok' ?
+            syncPeriod - (Date.now() - (last_sync?.updatedAt || 0) * 1000)
+            : 3000;// Gives server 1 sec before sync task starts;
+        const hours = Math.floor(firstSyncDelay / 60 / 60 / 1000);
+        const minutes = Math.floor((firstSyncDelay - hours * 60 * 60 * 1000) / 60 / 1000);
+        const seconds = Math.floor((firstSyncDelay - (hours * 60 + minutes) * 60 * 1000) / 1000);
+
+        this.logger.info(`Next synchronization in ${hours} h ${minutes} min ${seconds} sec`);
 
         setTimeout(() => {
             this.syncAll();

docker/dev.env

@@ -17,6 +17,7 @@ RCT_JWT_EXPIRATION=${RCT_JWT_EXPIRATION:-2h}
 
 ## external services connections
 RCT_SYNC_TASK_AT_START=${RCT_SYNC_TASK_AT_START:-false}
+RCT_SYNC_PERIOD=${RCT_SYNC_PERIOD:-}
 
 RCT_CERT_PATH=${RCT_CERT_PATH:-}
 ALIMONITOR_PASSPHRASE=${ALIMONITOR_PASSPHRASE:-}