reenable gerrit

Author: themarolt

services/apps/cron_service/src/jobs/nangoTrigger.job.ts

@@ -18,7 +18,6 @@ const job: IJobDefinition = {
   name: 'nango-trigger',
   cronTime: IS_DEV_ENV ? CronTime.everyMinute() : CronTime.every(15).minutes(),
   timeout: 5 * 60,
-  enabled: async () => false,
   process: async (ctx) => {
     ctx.log.info('Triggering nango API check as if a webhook was received!')
 

services/apps/nango_webhook_api/src/main.ts

@@ -12,11 +12,12 @@ import { HttpStatusError } from '@crowd/common'
 import { Logger, getChildLogger, getServiceLogger } from '@crowd/logging'
 import { ALL_NANGO_INTEGRATIONS, INangoWebhookPayload, NangoIntegration } from '@crowd/nango'
 import { telemetryExpressMiddleware } from '@crowd/telemetry'
+import { TEMPORAL_CONFIG, WorkflowIdReusePolicy, getTemporalClient } from '@crowd/temporal'
 
 const log = getServiceLogger()
 
 setImmediate(async () => {
-  // const temporal = await getTemporalClient(TEMPORAL_CONFIG())
+  const temporal = await getTemporalClient(TEMPORAL_CONFIG())
 
   const app = express()
 
@@ -49,15 +50,15 @@ setImmediate(async () => {
         'Received nango webhook!',
       )
 
-      // await temporal.workflow.start('processNangoWebhook', {
-      //   taskQueue: 'nango',
-      //   workflowId: `nango-webhook/${payload.providerConfigKey}/${payload.connectionId}/${payload.model}`,
-      //   workflowIdReusePolicy: WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING,
-      //   retry: {
-      //     maximumAttempts: 10,
-      //   },
-      //   args: [payload],
-      // })
+      await temporal.workflow.start('processNangoWebhook', {
+        taskQueue: 'nango',
+        workflowId: `nango-webhook/${payload.providerConfigKey}/${payload.connectionId}/${payload.model}`,
+        workflowIdReusePolicy: WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING,
+        retry: {
+          maximumAttempts: 10,
+        },
+        args: [payload],
+      })
 
       res.sendStatus(204)
     }),