Merge branch 'chore/add-postman-queue-rate-limit' into donotmerge/staging-load-test

Author: pregnantboy

packages/backend/src/apps/postman/common/throw-errors.ts

@@ -92,13 +92,11 @@ export function throwPostmanStepError({
     }
     case 'RATE-LIMITED':
       // this will be auto-retried later on
-      throw new StepError(
-        'Rate limit exceeded',
-        'Too many emails are being sent. Please wait for a while before retrying.',
-        position,
-        appName,
-        error,
-      )
+      throw new RetriableError({
+        error: error.details,
+        delayInMs: 'default',
+        delayType: 'queue',
+      })
     case 'INVALID-ATTACHMENT':
       throw new StepError(
         'Unsupported attachment file type',

packages/backend/src/apps/postman/index.ts

@@ -1,8 +1,7 @@
 import { IApp } from '@plumber/types'
 
-import { getGenericAppQueue } from '@/queues/helpers/get-generic-app-queue'
-
 import actions from './actions'
+import queue from './queue'
 
 const app: IApp = {
   name: 'Email by Postman',
@@ -21,7 +20,7 @@ const app: IApp = {
     url: 'https://demo.arcade.software/VppMAbGKfFXFEsKxnKiw?embed&show_copy_link=true',
     title: 'Setting up Email by Postman',
   },
-  queue: getGenericAppQueue('POSTMAN_EMAIL'),
+  queue,
   category: 'communication',
 }
 

packages/backend/src/apps/postman/queue/index.ts

@@ -0,0 +1,13 @@
+import type { IAppQueue } from '@plumber/types'
+
+import appConfig from '@/config/app'
+
+const queueSettings = {
+  queueRateLimit: {
+    duration: 1000,
+    max: appConfig.postman.rateLimit,
+  },
+  isQueueDelayable: true,
+} satisfies IAppQueue
+
+export default queueSettings

packages/backend/src/config/queues.ts

@@ -1,5 +1,5 @@
 export const QUEUE_CONCURRENCY = {
-  POSTMAN_EMAIL: 3,
+  // POSTMAN_EMAIL: 3, // overridden in app config
   SLACK: 3,
   TELEGRAM: 3,
 }