diff --git a/packages/firebase/src/config.ts b/packages/firebase/src/config.ts index ac0926980..e0dda5cc7 100644 --- 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 index 60b2746cc..e864350c6 100644 --- 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 index 598b8eeed..bbaa4296b 100644 --- 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(); });