From 0900b4cf2a04f9f1bcf76508d2e30b30cb7d3928 Mon Sep 17 00:00:00 2001 From: Del Wang Date: Sat, 26 Apr 2025 15:01:49 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E9=BB=98=E8=AE=A4?= =?UTF-8?q?=E5=BD=95=E9=9F=B3=E5=92=8C=E6=92=AD=E6=94=BE=E9=9F=B3=E9=A2=91?= =?UTF-8?q?=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- packages/server-python/src/server.rs | 29 ++++++++++++++++++++++++++-- 1 file changed, 27 insertions(+), 2 deletions(-) diff --git a/packages/server-python/src/server.rs b/packages/server-python/src/server.rs index 46195ff..b8398f4 100644 --- a/packages/server-python/src/server.rs +++ b/packages/server-python/src/server.rs @@ -1,4 +1,5 @@ use open_xiaoai::base::{AppError, VERSION}; +use open_xiaoai::services::audio::config::AudioConfig; use open_xiaoai::services::connect::data::{Event, Request, Response, Stream}; use open_xiaoai::services::connect::handler::MessageHandler; use open_xiaoai::services::connect::message::{MessageManager, WsStream}; @@ -19,10 +20,34 @@ async fn test() -> Result<(), AppError> { SpeakerManager::play_text("已连接").await?; let _ = RPC::instance() - .call_remote("start_recording", None, None) + .call_remote( + "start_recording", + Some(json!(AudioConfig { + pcm: "noop".into(), + channels: 1, + bits_per_sample: 16, + sample_rate: 16000, + period_size: 1440 / 4, + buffer_size: 1440, + })), + None, + ) .await; - let _ = RPC::instance().call_remote("start_play", None, None).await; + let _ = RPC::instance() + .call_remote( + "start_play", + Some(json!(AudioConfig { + pcm: "noop".into(), + channels: 1, + bits_per_sample: 16, + sample_rate: 24000, + period_size: 1440 / 4, + buffer_size: 1440, + })), + None, + ) + .await; Ok(()) }