fix: bailian asr support reconnect

Author: L-jasmine

src/ai/bailian/realtime_asr.rs

@@ -125,6 +125,13 @@ impl ParaformerRealtimeV2Asr {
                     log::debug!("Received message: {:?}", text);
 
                     let response: ResponseMessage = serde_json::from_str(&text)?;
+                    if response.header.task_id != self.task_id {
+                        log::warn!(
+                            "Received message for different task_id: {}",
+                            response.header.task_id
+                        );
+                        continue;
+                    }
 
                     if response.is_task_started() {
                         log::info!("Recognition task started");

src/services/ws/stable/asr.rs

@@ -43,9 +43,19 @@ impl ParaformerASRSession {
                 }
                 ClientMsg::StartChat => {
                     log::info!("`{id}` starting paraformer asr");
-                    self.start_pcm_recognition().await.map_err(|e| {
-                        anyhow::anyhow!("`{id}` error starting paraformer asr: {e}")
-                    })?;
+                    if let Err(e) = self.start_pcm_recognition().await {
+                        log::warn!(
+                            "`{id}` error starting paraformer asr: {e}, attempting to reconnect..."
+                        );
+                        self.reconnect().await.map_err(|e| {
+                            anyhow::anyhow!("`{id}` error reconnecting paraformer asr: {e}")
+                        })?;
+                        log::info!("`{id}` paraformer asr reconnected successfully");
+                        self.start_pcm_recognition().await.map_err(|e| {
+                            anyhow::anyhow!("`{id}` error starting paraformer asr: {e}")
+                        })?;
+                    }
+
                     continue;
                 }
             }