test demo

Author: 陈志和

src/OTA_test.py

@@ -31,8 +31,8 @@ def __init__(self,mac):
                 "iccid": "89860125801125426850"
             }
         }
-        self.url = "https://api.tenclass.net/xiaozhi/ota/"
-        # self.url ="http://xiaozhi.pandastroller.com:8002/xiaozhi/ota/"
+        # self.url = "https://api.tenclass.net/xiaozhi/ota/"
+        self.url ="http://xiaozhi.pandastroller.com:8002/xiaozhi/ota/"
         self.response = None
         self.UDP_IP = None
         self.UDP_PORT = None

src/main.py src/_main.pysrc/main.py renamed to src/_main.py

@@ -9,6 +9,7 @@
 from usr.threading import Thread, Event, Condition
 from usr.logging import getLogger
 import sys_bus
+import _thread
 # from usr import UI
 
 
@@ -114,26 +115,27 @@ def __init__(self):
         self.__record_thread_stop_event = Event()
         self.__voice_activity_event = Event()
         self.__keyword_spotting_event = Event()
-
+        
     def __record_thread_handler(self):
         """纯粹是为了kws&vad能识别才起的线程持续读音频"""
         logger.debug("record thread handler enter")
         while not self.__record_thread_stop_event.is_set():
             self.audio_manager.opus_read()
             utime.sleep_ms(5)
         logger.debug("record thread handler exit")
+        
 
     def start_kws(self):
         self.audio_manager.start_kws()
         self.__record_thread_stop_event.clear()
         self.__record_thread = Thread(target=self.__record_thread_handler)
         self.__record_thread.start(stack_size=64)
-    
+        
     def stop_kws(self):
         self.__record_thread_stop_event.set()
         self.__record_thread.join()
         self.audio_manager.stop_kws()
-
+        
     def start_vad(self):
         self.audio_manager.start_vad()
 
@@ -199,9 +201,9 @@ def on_keyword_spotting(self, state):
             self.__keyword_spotting_event.set()
 
     def on_voice_activity_detection(self, state):
-        # gc.collect()
         logger.info("on_voice_activity_detection: {}".format(state))
         if state == 1:
+            # gc.collect()
             # self.__protocol.abort()
             self.__voice_activity_event.set()  # 有人声
         else:
@@ -215,7 +217,8 @@ def on_json_message(self, msg):
         return getattr(self, "handle_{}_message".format(msg["type"]))(msg)
 
     def handle_stt_message(data, msg):
-        raise NotImplementedError("handle_stt_message not implemented")
+        print("stt数据",msg)
+        # raise NotImplementedError("handle_stt_message not implemented")
 
     def handle_tts_message(self, msg):
         state = msg["state"]
@@ -225,16 +228,21 @@ def handle_tts_message(self, msg):
             self.wifi_green_led.off()
         else:
             pass
-        raise NotImplementedError("handle_tts_message not implemented")
+        print("tts数据",msg)
+        # raise NotImplementedError("handle_tts_message not implemented")
 
 #"happy" "cool"  "angry"  "think"
 # ... existing code ...
     def handle_llm_message(data, msg):
         raise NotImplementedError("handle_llm_message not implemented")
 
     def handle_iot_message(data, msg):
-        raise NotImplementedError("handle_iot_message not implemented")
+        print("iot数据",msg)
+        # raise NotImplementedError("handle_iot_message not implemented")
 
+    def handle_error_message(data, msg):
+        print("error数据",msg)
+        # raise NotImplementedError("handle_error_message not implemented")
 
     def run(self):
         self.charge_manager.enable_charge()

src/protocol.py

@@ -6,6 +6,8 @@
 from usr.logging import getLogger
 import sys_bus
 from usr.OTA_test import OTA
+import gc
+
 
 
 
@@ -136,7 +138,7 @@ def connect(self):
         __client__ = ws.Client.connect(
             self.host, 
             headers={
-                "Authorization": "Bearer {}".format(WSS_HOST["websocket"]["token"]),
+                # "Authorization": "Bearer {}".format(WSS_HOST["websocket"]["token"]),
                 "Protocol-Version": PROTOCOL_VERSION,
                 "Device-Id": self.get_mac_address(),
                 "Client-Id": self.generate_uuid()
@@ -213,7 +215,8 @@ def recv(self):
 
             # 对比 text_value 和上次的值是否相同
             if text_value != self.__last_text_value and text_value is not None:
-                print(text_value)  # 仅在不同时打印
+                # print(text_value)  # 仅在不同时打印
+                print("内存：",gc.mem_free())
                 self.__last_text_value = text_value  # 更新为最新的 text_value
         # logger.debug("recv data: ", data)
         return data

src/utils.py

@@ -25,7 +25,7 @@ def __init__(self, channel=0, volume=10, pa_number=29):
         self.aud.setVolume(volume)  # 设置音量
         self.aud.setCallback(self.audio_cb)
         self.rec = audio.Record(channel)
-        self.rec.gain_set(4,9)
+        self.rec.gain_set(3,9)
         self.__skip = 0
 
     # ========== 音频文件 ====================
@@ -75,7 +75,8 @@ def wrapper(state):
                 self.__skip += 1
                 return
             return cb(state)
-        self.rec.vad_set_callback(wrapper)
+        self._callable = wrapper
+        self.rec.vad_set_callback(self._callable)
 
     def end_cb(self, para):
         if(para[0] == "stream"):