From 5a300c5140eeb8d29891dedb4f99951351f52d56 Mon Sep 17 00:00:00 2001
From: IrvingGao <1729854488@qq.com>
Date: Tue, 18 Jun 2024 20:30:03 +0800
Subject: [PATCH] [client] fix bugs

---
 takway/clients/web_socket_client_utils.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/takway/clients/web_socket_client_utils.py b/takway/clients/web_socket_client_utils.py
index f2dc218..47b3fde 100644
--- a/takway/clients/web_socket_client_utils.py
+++ b/takway/clients/web_socket_client_utils.py
@@ -270,6 +270,10 @@ class WebSocketClinet:
                         # 睡眠 or 监听状态
                         if self.sleep_event.is_set() or self.listening_event.is_set():
                             break
+                        if self.interrupt_event.is_set():
+                            self.interrupt_event.clear()
+                            print(f"{datetime.now()}: conversation interrupt (input).")
+                            break
                     if board == 'orangepi':
                         recorder.hardware.set_led_off("red")
                     # 重新计时
@@ -424,6 +428,7 @@ class WebSocketClinet:
                     # print(f"listening_event: {self.listening_event.is_set()}, speaking_event: {self.speaking_event.is_set()}")
                     break  # 如果没有接收到消息，则退出循环
             client.close_client()
+            print(f"{datetime.now()}: web socket client closed.")
     
     
     def audio_play_process(self):