Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 6 additions & 13 deletions software/src/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
import ujson as json

logger = getLogger(__name__)

perv_emoj="sleep"

class Application(object):

Expand Down Expand Up @@ -54,6 +54,8 @@ def __init__(self):
self.__record_thread_stop_event = Event()
self.__voice_activity_event = Event()
self.__keyword_spotting_event = Event()

self.perv_emoj="sleep"



Expand Down Expand Up @@ -92,10 +94,12 @@ def __working_thread_handler(self):
self.start_kws()

def __chat_process(self):
global perv_emoj
self.start_vad()
try:
with self.__protocol:
self.__protocol.hello()
perv_emoj="sleep"
self.__protocol.wakeword_detected("小智")
is_listen_flag = False
buffer = [] # 用于缓存最近5帧
Expand Down Expand Up @@ -166,14 +170,6 @@ def handle_stt_message(data, msg):

def handle_tts_message(self, msg):
pass
# state = msg["state"]
# if state == "start":
# sys_bus.publish("update_status","speaking")
# elif state == "stop":
# sys_bus.publish("update_status","listening")
# else:
# pass
# raise NotImplementedError("handle_tts_message not implemented")



Expand Down Expand Up @@ -211,9 +207,6 @@ def handle_mcp_message(self, msg):
def handle_llm_message(data, msg):
emoj_value = msg["emotion"]
global perv_emoj
if 'perv_emoj' not in globals():
perv_emoj = None

if perv_emoj != emoj_value:
print("emoj_value: ", emoj_value)
sys_bus.publish("update_emoji", emoj_value)
Expand All @@ -238,6 +231,6 @@ def run(self):


if __name__ == "__main__":
sys_bus.publish("update_screen","init_screen")
sys_bus.publish("update_screen",perv_emoj)
app = Application()
app.run()