From 3d6bf5b1919d18090fc8aebbf8d41c5238a44cbb Mon Sep 17 00:00:00 2001 From: 4t145 Date: Wed, 22 Jan 2025 15:03:39 +0800 Subject: [PATCH] set default value for ws connection's codec --- backend/middlewares/event/src/api/ca/event_connect_api.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/middlewares/event/src/api/ca/event_connect_api.rs b/backend/middlewares/event/src/api/ca/event_connect_api.rs index 4f98db5f..d3d22938 100644 --- a/backend/middlewares/event/src/api/ca/event_connect_api.rs +++ b/backend/middlewares/event/src/api/ca/event_connect_api.rs @@ -26,14 +26,14 @@ impl EventConnectApi { /// /// 连接客户端节点 #[oai(path = "/", method = "get")] - async fn ws_process(&self, node_id: Query, codec: Query, websocket: WebSocket) -> Result { + async fn ws_process(&self, node_id: Query, codec: Query>, websocket: WebSocket) -> Result { let peer_id = NodeId::from_base64(&node_id).map_err(|e| tardis::web::poem::Error::from_string(e.to_string(), StatusCode::BAD_REQUEST))?; let config = EdgeConfig { peer_id, peer_auth: EdgeAuth::default(), }; let _ctx = self.register_serv.get_ctx(peer_id).await.map_err(|e| tardis::web::poem::Error::from_string(e.to_string(), StatusCode::UNAUTHORIZED))?; - let codec = match codec.0.to_lowercase().as_str() { + let codec = match codec.0.as_deref().unwrap_or("json").to_lowercase().as_str() { "json" => DynCodec::new(codec::Json), "bincode" => DynCodec::new(codec::Bincode), _ => return Err(tardis::web::poem::Error::from_string("unsupported codec", StatusCode::BAD_REQUEST)),