add error handling to openai api

chat_service.py

@@ -105,29 +105,57 @@ I fell off the pink step, and I had an accident.
         self._messages.append({"role": "user", "content": prompt})
         agent_response = ""
         current_sentence = ""
-
-        response = await openai.ChatCompletion.acreate(
-            model=self._model_id,
-            messages=self._messages,
-            temperature=1.0,  # use 1.0 for debugging/deterministic results
-            stream=True
-        )
-
-        async for chunk in response:
-            if cancel_event.is_set():
+        delay = 0.1
+
+        while True:
+            try:
+                response = await openai.ChatCompletion.acreate(
+                    model=self._model_id,
+                    messages=self._messages,
+                    temperature=1.0,  # use 1.0 for debugging/deterministic results
+                    stream=True
+                )
+
+                async for chunk in response:
+                    if cancel_event.is_set():
+                        return
+                    chunk_message = chunk['choices'][0]['delta']
+                    if 'content' in chunk_message:
+                        chunk_text = chunk_message['content']
+                        current_sentence += chunk_text
+                        agent_response += chunk_text
+                        text_to_speak = self._should_we_send_to_voice(current_sentence)
+                        if text_to_speak:
+                            yield text_to_speak
+                            current_sentence = current_sentence[len(text_to_speak):]
+
+                if cancel_event.is_set():
+                    return
+                if len(current_sentence) > 0:
+                    yield current_sentence
+                self._messages.append({"role": "assistant", "content": agent_response})
                 return
-            chunk_message = chunk['choices'][0]['delta']
-            if 'content' in chunk_message:
-                chunk_text = chunk_message['content']
-                current_sentence += chunk_text
-                agent_response += chunk_text
-                text_to_speak = self._should_we_send_to_voice(current_sentence)
-                if text_to_speak:
-                    yield text_to_speak
-                    current_sentence = current_sentence[len(text_to_speak):]
-
-        if cancel_event.is_set():
-            return
-        if len(current_sentence) > 0:
-            yield current_sentence
-        self._messages.append({"role": "assistant", "content": agent_response})
+
+            except openai.error.APIError as e:
+                print(f"OpenAI API returned an API Error: {e}")
+                print(f"Retrying in {delay} seconds...")
+                await asyncio.sleep(delay)
+                delay *= 2
+
+            except openai.error.APIConnectionError as e:
+                print(f"Failed to connect to OpenAI API: {e}")
+                print(f"Retrying in {delay} seconds...")
+                await asyncio.sleep(delay)
+                delay *= 2
+
+            except openai.error.RateLimitError as e:
+                print(f"OpenAI API request exceeded rate limit: {e}")
+                print(f"Retrying in {delay} seconds...")
+                await asyncio.sleep(delay)
+                delay *= 2
+
+            except Exception as e:
+                print(f"OpenAI API unknown error: {e}")
+                print(f"Retrying in {delay} seconds...")
+                await asyncio.sleep(delay)
+                delay *= 2