Add session validation checks to `player.py` and `generator.py`

- Ensure voice tasks are processed only for the current session by comparing `session_id`.
- Break or skip processing if the session ID mismatches.

src/voice_dialogue/services/audio/generator.py

@@ -3,7 +3,8 @@ from multiprocessing import Queue
 from queue import Empty
 
 from voice_dialogue.core.base import BaseThread
-from voice_dialogue.core.constants import dropped_audio_cache, user_still_speaking_event, voice_state_manager
+from voice_dialogue.core.constants import dropped_audio_cache, user_still_speaking_event, voice_state_manager, \
+    session_manager
 from voice_dialogue.models.voice_task import VoiceTask
 from .generators import tts_manager, BaseTTSConfig
 
@@ -79,6 +80,9 @@ class TTSAudioGenerator(BaseThread):
             if voice_task.id != voice_state_manager.interrupt_task_id:
                 continue
 
+            if voice_task.session_id != session_manager.current_id:
+                continue
+
             voice_task.tts_start_time = time.time()
             tts_generated_sentence_audio = self.tts_instance.synthesize(voice_task.answer_sentence)
             voice_task.tts_generated_sentence_audio = tts_generated_sentence_audio

src/voice_dialogue/services/audio/player.py

@@ -9,7 +9,7 @@ from playsound import playsound
 from voice_dialogue.core.base import BaseThread
 from voice_dialogue.core.constants import (
     user_still_speaking_event, voice_state_manager, dropped_audio_cache, chat_history_cache,
-    silence_over_threshold_event
+    silence_over_threshold_event, session_manager
 )
 from voice_dialogue.models.voice_task import VoiceTask, AnswerDisplayMessage
 from voice_dialogue.utils.logger import logger
@@ -50,6 +50,9 @@ class AudioStreamPlayer(BaseThread):
                 if task_id != voice_state_manager.interrupt_task_id:
                     break
 
+                if voice_task.session_id != session_manager.current_id:
+                    break
+
                 if answer_id in dropped_audio_cache:
                     # print('Drop answer audio')
                     break