feat(firebase): Check env.STORE_EVENTS_CRONTAB to customize events …

…checked crontab (every min)
ecomplus · Oct 25, 2023 · d89e67a · d89e67a
1 parent fdc91a2
commit d89e67a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 7 deletions.
diff --git a/packages/firebase/src/config.ts b/packages/firebase/src/config.ts
@@ -53,6 +53,7 @@ const {
   SSR_DEPLOY_TIMEOUT_SECONDS,
   SSR_DEPLOY_MIN_INSTANCES,
   MODULES_DEPLOY_MEMORY,
+  API_EVENTS_DELAYED_MS,
 } = process.env;
 
 let settingsContentFile = SETTINGS_FILEPATH && existsSync(SETTINGS_FILEPATH)
@@ -80,7 +81,9 @@ const mergeConfig = {
     memory: (MODULES_DEPLOY_MEMORY as '256MiB' | '512MiB' | '1GiB' | '2GiB') || '512MiB',
   },
   apiEvents: {
-    delayedMs: 1000 * 60 * 5,
+    delayedMs: API_EVENTS_DELAYED_MS
+      ? parseInt(API_EVENTS_DELAYED_MS, 10)
+      : 1000 * 60 * 5,
     disabledEvents,
   },
   apps: {

diff --git a/packages/firebase/src/handlers/check-store-events.ts b/packages/firebase/src/handlers/check-store-events.ts
@@ -154,11 +154,9 @@ export default async () => {
       if (lastNonOrdersTimestamp) {
         if (actionName === 'delayed') {
           // Defines the limits for getting events with predefined delay
-          const delayMs = process.env.API_EVENTS_DELAYED_MS
-            ? (parseInt(process.env.API_EVENTS_DELAYED_MS, 10))
-            : apiEvents.delayedMs;
-          params['timestamp>'] = new Date(lastNonOrdersTimestamp - delayMs).toISOString();
-          params['timestamp<'] = new Date(timestamp - delayMs).toISOString();
+          const { delayedMs } = apiEvents;
+          params['timestamp>'] = new Date(lastNonOrdersTimestamp - delayedMs).toISOString();
+          params['timestamp<'] = new Date(timestamp - delayedMs).toISOString();
         } else {
           params['timestamp>'] = new Date(lastNonOrdersTimestamp).toISOString();
         }

diff --git a/packages/firebase/src/index.ts b/packages/firebase/src/index.ts
@@ -14,7 +14,7 @@ const functionBuilder = functions
   });
 
 export const cronStoreEvents = functionBuilder.pubsub
-  .schedule('* * * * *')
+  .schedule(process.env.STORE_EVENTS_CRONTAB || '* * * * *')
   .onRun(() => {
     return checkStoreEvents();
   });