fix: truncate staging only once

src/tasks/sync-registries.js

@@ -138,6 +138,33 @@ const tryParseJSON = (jsonString, defaultValue) => {
   }
 };
 
+const truncateStaging = async () => {
+  logger.info(`ATTEMPTING TO TRUNCATE STAGING TABLE`);
+
+  let success = false;
+  let attempts = 0;
+  const maxAttempts = 5; // Set a maximum number of attempts to avoid infinite loops
+
+  while (!success && attempts < maxAttempts) {
+    try {
+      await Staging.truncate();
+      success = true; // If truncate succeeds, set success to true to exit the loop
+      logger.info('STAGING TABLE TRUNCATED SUCCESSFULLY');
+    } catch (error) {
+      attempts++;
+      logger.error(
+        `TRUNCATION FAILED ON ATTEMPT ${attempts}: ${error.message}`,
+      );
+      if (attempts < maxAttempts) {
+        logger.info('WAITING 1 SECOND BEFORE RETRYING...');
+        await new Promise((resolve) => setTimeout(resolve, 1000)); // Wait for 1 second
+      } else {
+        logger.error('MAXIMUM TRUNCATION ATTEMPTS REACHED, GIVING UP');
+      }
+    }
+  }
+};
+
 const syncOrganizationAudit = async (organization) => {
   try {
     let afterCommitCallbacks = [];
@@ -385,37 +412,6 @@ const syncOrganizationAudit = async (organization) => {
             }
           }
 
-          if (organization.orgUid === homeOrg?.orgUid) {
-            afterCommitCallbacks.push(async () => {
-              logger.info(`ATTEMPTING TO TRUNCATE STAGING TABLE`);
-
-              let success = false;
-              let attempts = 0;
-              const maxAttempts = 5; // Set a maximum number of attempts to avoid infinite loops
-
-              while (!success && attempts < maxAttempts) {
-                try {
-                  await Staging.truncate();
-                  success = true; // If truncate succeeds, set success to true to exit the loop
-                  logger.info('STAGING TABLE TRUNCATED SUCCESSFULLY');
-                } catch (error) {
-                  attempts++;
-                  logger.error(
-                    `TRUNCATION FAILED ON ATTEMPT ${attempts}: ${error.message}`,
-                  );
-                  if (attempts < maxAttempts) {
-                    logger.info('WAITING 1 SECOND BEFORE RETRYING...');
-                    await new Promise((resolve) => setTimeout(resolve, 1000)); // Wait for 1 second
-                  } else {
-                    logger.error(
-                      'MAXIMUM TRUNCATION ATTEMPTS REACHED, GIVING UP',
-                    );
-                  }
-                }
-              }
-            });
-          }
-
           // Create the Audit record
           await Audit.create(auditData, { transaction, mirrorTransaction });
           await Organization.update(
@@ -430,6 +426,10 @@ const syncOrganizationAudit = async (organization) => {
       }
     };
 
+    if (organization.orgUid === homeOrg?.orgUid) {
+      afterCommitCallbacks.push(truncateStaging);
+    }
+
     await createTransaction(updateTransaction, afterCommitCallbacks);
   } catch (error) {
     logger.error('Error syncing org audit', error);