⚡ (openai) Retry OpenAI call if status code is 503

Closes #529

apps/viewer/src/features/blocks/integrations/openai/executeChatCompletionOpenAIRequest.ts

@@ -42,6 +42,17 @@ export const executeChatCompletionOpenAIRequest = async ({
     return { response, logs }
   } catch (error) {
     if (error instanceof HTTPError) {
+      if (error.response.statusCode === 503) {
+        console.log('OpenAI API error - 503, retrying in 3 seconds')
+        await new Promise((resolve) => setTimeout(resolve, 3000))
+        return executeChatCompletionOpenAIRequest({
+          apiKey,
+          model,
+          messages,
+          temperature,
+          currentLogs: logs,
+        })
+      }
       if (error.response.statusCode === 400) {
         const log = {
           status: 'info',

packages/embeds/js/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@typebot.io/js",
-  "version": "0.0.63",
+  "version": "0.0.64",
   "description": "Javascript library to display typebots on your website",
   "type": "module",
   "main": "dist/index.js",

packages/embeds/js/src/features/blocks/integrations/openai/streamChat.ts

@@ -54,7 +54,7 @@ export const streamChat =
       if (dataString.includes('503 Service Temporarily Unavailable')) {
         if (isRetrying)
           return { error: { message: "Couldn't get streamer data" } }
-        await new Promise((resolve) => setTimeout(resolve, 1000))
+        await new Promise((resolve) => setTimeout(resolve, 3000))
         return streamChat(context)(messages, {
           onStreamedMessage,
           isRetrying: true,

packages/embeds/react/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@typebot.io/react",
-  "version": "0.0.63",
+  "version": "0.0.64",
   "description": "React library to display typebots on your website",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",