fix: device cannot recover to listening when the llm and tts fail

Author: L-jasmine

src/services/ws/stable/mod.rs

@@ -152,13 +152,21 @@ async fn run_session(
         let llm_fut = llm::chat(tts_req_tx, chunks_tx, chat_session, text);
         let send_audio_fut = handle_tts_requests(chunks_rx, session);
 
-        let _ = tokio::try_join!(llm_fut, send_audio_fut)?;
-
-        log::info!(
-            "{}:{:x} session processing done for this input",
-            session.id,
-            session.request_id
-        );
+        let r = tokio::try_join!(llm_fut, send_audio_fut);
+        if let Err(e) = r {
+            log::error!(
+                "{}:{:x} error during llm or tts handling: {}",
+                session.id,
+                session.request_id,
+                e
+            );
+        } else {
+            log::info!(
+                "{}:{:x} session processing done for this input",
+                session.id,
+                session.request_id
+            );
+        }
 
         session
             .cmd_tx

src/services/ws/stable/tts.rs

@@ -176,9 +176,22 @@ impl TTSSessionPool {
     }
 
     pub async fn run_loop(&mut self, mut rx: TTSRequestRx) -> anyhow::Result<()> {
+        let mut sucess_workers = 0;
         for i in 0..self.workers {
-            let session = self.create_session().await?;
-            tokio::spawn(Self::run_session(i as u128, session, self.tx.clone()));
+            match self.create_session().await {
+                Ok(session) => {
+                    tokio::spawn(Self::run_session(i as u128, session, self.tx.clone()));
+                    sucess_workers += 1;
+                }
+                Err(e) => {
+                    log::error!("create tts session[{i}] error: {}", e);
+                    continue;
+                }
+            };
+        }
+
+        if sucess_workers == 0 {
+            return Err(anyhow::anyhow!("no available tts session worker"));
         }
 
         while let Some(tts_req) = rx.recv().await {