fix: missing dateEnd

cheminfo · Dec 13, 2023 · d9112d6 · d9112d6
1 parent 09fcd65
commit d9112d6
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 1 deletion.
diff --git a/docker/src/plugins/compounds/sync/firstCompoundsImport.js b/docker/src/plugins/compounds/sync/firstCompoundsImport.js
@@ -50,6 +50,7 @@ async function firstCompoundImport(connection) {
       { lastDocument },
       'first',
     );
+    progress.dateEnd = Date.now();
     progress.state = 'updated';
     await connection.setProgress(progress);
     // create indexes on the compounds collection

diff --git a/docker/src/plugins/compounds/sync/incrementalCompoundsImport.js b/docker/src/plugins/compounds/sync/incrementalCompoundsImport.js
@@ -58,6 +58,8 @@ async function incrementalCompoundImport(connection) {
         { lastDocument },
         'incremental',
       );
+      progress.dateEnd = Date.now();
+      await connection.setProgress(progress);
     }
     debug.info('Compounds collection updated.');
   } catch (e) {

diff --git a/docker/src/plugins/pubmeds/sync/firstPubmedsImport.js b/docker/src/plugins/pubmeds/sync/firstPubmedsImport.js
@@ -71,6 +71,7 @@ async function firstPubmedImport(connection) {
     );
     // set progress to updated
     progress.state = 'updated';
+    progress.dateEnd = Date.now();
     await connection.setProgress(progress);
     // create indexes
     const collection = await connection.getCollection('pubmeds');

diff --git a/docker/src/plugins/pubmeds/sync/incrementalPubmedsImport.js b/docker/src/plugins/pubmeds/sync/incrementalPubmedsImport.js
@@ -75,6 +75,7 @@ async function incrementalPubmedImport(connection) {
         pmidToCid,
         'incremental',
       );
+      progress.dateEnd = Date.now();
     }
   } catch (e) {
     if (connection) {

diff --git a/docker/src/plugins/substances/sync/firstSubstancesImport.js b/docker/src/plugins/substances/sync/firstSubstancesImport.js
@@ -38,6 +38,7 @@ async function firstSubstanceImport(connection) {
       'first',
     );
     progress.state = 'updating';
+    progress.dateEnd = Date.now();
     await connection.setProgress(progress);
     await importSubstanceFiles(
       connection,

diff --git a/docker/src/plugins/substances/sync/incrementalSubstancesImport.js b/docker/src/plugins/substances/sync/incrementalSubstancesImport.js
@@ -23,7 +23,6 @@ async function incrementalSubstanceImport(connection) {
       allFiles = await syncSubstanceFolder(connection, 'incremental');
     }
     const progress = await connection.getProgress('substances');
-
     if (progress.state !== 'updated') {
       throw new Error('Should never happens.');
     }
@@ -56,6 +55,8 @@ async function incrementalSubstanceImport(connection) {
         { lastDocument },
         'incremental',
       );
+      progress.dateEnd = Date.now();
+      await connection.setProgress(progress);
     }
   } catch (e) {
     if (connection) {