feat: update

Author: Lzw655

ports/esp32/main_esp32s3_box3/scripts/rpc_client.py

@@ -0,0 +1,62 @@
+import asyncio
+import json
+
+async def send_rpc_request(host: str, port: int, request: dict) -> dict:
+    try:
+        print(f"Connecting to {host}:{port}...")
+        # 使用位置参数而不是关键字参数
+        reader, writer = await asyncio.open_connection(host, port)
+
+        request_str = json.dumps(request) + "\n"
+        print(f"Sending request: {request_str.strip()}")
+        writer.write(request_str.encode())
+        await writer.drain()
+
+        # Wait for response line
+        print("Waiting for response...")
+        response_line = await reader.readline()
+
+        writer.close()
+        await writer.wait_closed()
+
+        if response_line:
+            try:
+                response = json.loads(response_line.decode())
+                print(f"Received response: {json.dumps(response)}")
+                return response
+            except ValueError as e:  # 兼容 MicroPython
+                print(f"JSON decode error: {str(e)}")
+                return {}
+        else:
+            print("No response received.")
+            return {}
+
+    except Exception as e:
+        print(f"RPC Request Failed: {str(e)}")
+        return {}
+
+async def main():
+    host = "127.0.0.1"  # ⚠️ 替换为实际 IP 地址
+
+    wifi_request = {
+        "method": "wifi.scan",
+        "params": {},
+        "id": 1
+    }
+
+    media_request = {
+        "method": "media.play",
+        "params": {},
+        "id": 2
+    }
+
+    print("Requesting WiFi scan...")
+    wifi_response = await send_rpc_request(host, 8080, wifi_request)
+    print(wifi_response)
+
+    print("Requesting Media play...")
+    media_response = await send_rpc_request(host, 8081, media_request)
+    print(media_response)
+
+if __name__ == "__main__":
+    asyncio.run(main())