Update app.py

app.py

@@ -73,10 +73,17 @@ class OpenAIHandler(AsyncStreamHandler):
     async def receive(self, frame: tuple[int, np.ndarray]) -> None:
         if not self.connection:
             return
-        _, array = frame
-        array = array.squeeze()
-        audio_message = base64.b64encode(array.tobytes()).decode("utf-8")
-        await self.connection.input_audio_buffer.append(audio=audio_message)  # type: ignore
+        try:
+            _, array = frame
+            array = array.squeeze()
+            audio_message = base64.b64encode(array.tobytes()).decode("utf-8")
+            await self.connection.input_audio_buffer.append(audio=audio_message)  # type: ignore
+        except Exception as e:
+            # 연결이 이미 닫혔거나 다른 오류가 발생한 경우 로그만 남기고 계속 진행
+            print(f"Error in receive: {e}")
+            # 연결이 끊어진 것 같으면 connection을 None으로 설정
+            if "ConnectionClosed" in str(e):
+                self.connection = None
 
     async def emit(self) -> tuple[int, np.ndarray] | AdditionalOutputs | None:
         return await wait_for_item(self.output_queue)