gaohz
/
TakwayBoard
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[bug] board

This commit is contained in:
IrvingGao 2024-05-23 17:15:25 +08:00
parent ebc7c9452c
commit 7fe7a02777
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
takway/clients/web_socket_client_utils.py
View File

@ -358,10 +358,6 @@ class WebSocketClinet:
if not self.wakeup_event.is_set(): if not self.wakeup_event.is_set():
continue continue
# 切换播放模式
self.listening_event.clear()
self.speaking_event.set()
# 接收数据 # 接收数据
while True: while True:
# 当唤醒状态被关闭时，退出循环 # 当唤醒状态被关闭时，退出循环
@ -370,19 +366,26 @@ class WebSocketClinet:
self.speaking_event.clear() self.speaking_event.clear()
client.close_client() client.close_client()
break break
'''
# 当正在说话时接收到时，默认全是废消息 # 当正在说话时接收到时，默认全是废消息
if self.listening_event.is_set() and not self.speaking_event.is_set(): if self.listening_event.is_set() and not self.speaking_event.is_set():
client.close_client() client.close_client()
break break
'''
response, data_type = client.receive_per_data() response, data_type = client.receive_per_data()
if data_type == dict: if data_type == dict:
print(f"{datetime.now()}: receive json data: {response}") # 打印接收到的消息 print(f"{datetime.now()}: receive json data: {response}") # 打印接收到的消息
# 误识别情况 # 误识别情况
if response['code'] == 201: if response['code'] == 201:
print(f"false audio: wakeup: {self.wakeup_event.is_set()}, interrupt: {self.interrupt_event.is_set()}, listening: {self.listening_event.is_set()}") # 恢复对话状态
continue self.listening_event.set()
self.speaking_event.clear()
break
elif response['code'] == 200:
# 切换播放模式
self.listening_event.clear()
self.speaking_event.set()
elif data_type == bytes: elif data_type == bytes:
# 开始播放 # 开始播放
print(f"{datetime.now()}: receive audio data") print(f"{datetime.now()}: receive audio data")