chore: add retry for 429

Author: kevinkim-ogp

packages/backend/src/apps/aisay/__tests__/common/interceptors.error-handlers.test.ts

@@ -97,6 +97,24 @@ describe('AISAY request error handlers', () => {
     vi.restoreAllMocks()
   })
 
+  it('logs an error and jams the entire queue on 429', async () => {
+    mockAxiosAdapterToThrowOnce(429, { 'retry-after': 123 })
+    await http
+      .get('/test-url')
+      .then(() => {
+        expect.unreachable()
+      })
+      .catch((error): void => {
+        expect(error).toBeInstanceOf(RetriableError)
+        expect(error.delayType).toEqual('queue')
+        expect(error.message).toEqual('Rate limited by AISAY.')
+      })
+    expect(mocks.logError).toHaveBeenCalledWith(
+      expect.stringContaining('HTTP 429'),
+      expect.objectContaining({ event: 'aisay-http-429' }),
+    )
+  })
+
   it('logs a warning and throws a RetriableError with default step delay on 503', async () => {
     mockAxiosAdapterToThrowOnce(503)
     await http

packages/backend/src/apps/aisay/common/interceptors/request-error-handler.ts

@@ -8,6 +8,29 @@ type ThrowingHandler = (
   ...args: Parameters<IApp['requestErrorHandler']>
 ) => never
 
+// handle rate limiting
+const handle429: ThrowingHandler = function ($, error) {
+  const retryAfterMs =
+    parseRetryAfterToMs(error.response?.headers?.['retry-after']) ?? 'default'
+
+  logger.error('Received HTTP 429 from AISAY', {
+    event: 'aisay-http-429',
+    clientId: $.auth.data.clientId,
+    baseUrl: error.response.config.baseURL,
+    url: error.response.config.url,
+    flowId: $.flow?.id,
+    stepId: $.step?.id,
+    executionId: $.execution?.id,
+    retryAfterMs: error.response?.headers?.['retry-after'],
+  })
+
+  throw new RetriableError({
+    error: 'Rate limited by AISAY.',
+    delayInMs: retryAfterMs,
+    delayType: 'queue',
+  })
+}
+
 // Retry failures
 const handle503: ThrowingHandler = function ($, error) {
   const status = error.response.status
@@ -34,6 +57,8 @@ const handle503: ThrowingHandler = function ($, error) {
 
 const errorHandler: IApp['requestErrorHandler'] = async function ($, error) {
   switch (error.response.status) {
+    case 429:
+      return handle429($, error)
     case 503:
       return handle503($, error)
   }