Refactor to replace `EchoCancellingAudioCapture` with `AudioCapture` across the codebase for improved clarity and flexibility

src/voice_dialogue/__init__.py

@@ -5,7 +5,7 @@ from .core.constants import (
     text_input_queue,
     audio_output_queue
 )
-from .services.audio.capture import EchoCancellingAudioCapture
+from .services.audio.capture import AudioCapture
 from .services.audio.generator import TTSAudioGenerator
 from .services.audio.generators.models import tts_config_registry
 from .services.audio.player import AudioStreamPlayer

src/voice_dialogue/api/core/service_factories.py

@@ -2,7 +2,7 @@ from voice_dialogue.core.constants import (
     transcribed_text_queue, text_input_queue, audio_output_queue,
     audio_frames_queue, user_voice_queue, websocket_message_queue
 )
-from voice_dialogue.services.audio import EchoCancellingAudioCapture, TTSAudioGenerator, AudioStreamPlayer
+from voice_dialogue.services.audio import AudioCapture, TTSAudioGenerator, AudioStreamPlayer
 from voice_dialogue.services.audio.generators import BaseTTSConfig, tts_config_registry
 from voice_dialogue.services.speech import SpeechStateMonitor, ASRWorker
 from voice_dialogue.services.text.generator import LLMResponseGenerator
@@ -13,9 +13,9 @@ class ServiceFactories:
     """服务工厂类，封装所有服务的创建逻辑"""
 
     @staticmethod
-    def create_audio_capture() -> EchoCancellingAudioCapture:
+    def create_audio_capture() -> AudioCapture:
         """创建音频捕获服务"""
-        return EchoCancellingAudioCapture(
+        return AudioCapture(
             audio_frames_queue=audio_frames_queue
         )
 

src/voice_dialogue/core/launcher.py

@@ -14,7 +14,7 @@ from voice_dialogue.core.constants import (
     text_input_queue,
     audio_output_queue
 )
-from voice_dialogue.services.audio.capture import EchoCancellingAudioCapture
+from voice_dialogue.services.audio.capture import AudioCapture
 from voice_dialogue.services.audio.generator import TTSAudioGenerator
 from voice_dialogue.services.audio.player import AudioStreamPlayer
 from voice_dialogue.services.speech.monitor import SpeechStateMonitor
@@ -61,7 +61,7 @@ def launch_system(
     threads = []
 
     # 音频采集
-    audio_frame_probe = EchoCancellingAudioCapture(audio_frames_queue=audio_frames_queue)
+    audio_frame_probe = AudioCapture(audio_frames_queue=audio_frames_queue)
     audio_frame_probe.start()
     threads.append(audio_frame_probe)
 

src/voice_dialogue/services/audio/__init__.py

@@ -1,9 +1,9 @@
-from .capture import EchoCancellingAudioCapture
+from .capture import AudioCapture
 from .generator import TTSAudioGenerator
 from .player import AudioStreamPlayer
 
 __all__ = (
-    "EchoCancellingAudioCapture",
+    "AudioCapture",
     "TTSAudioGenerator",
     "AudioStreamPlayer",
 )

src/voice_dialogue/services/audio/capture.py

@@ -6,6 +6,7 @@
 import ctypes
 import threading
 import time
+from multiprocessing import Queue
 
 import numpy as np
 
@@ -14,18 +15,22 @@ from voice_dialogue.core.base import BaseThread
 from voice_dialogue.utils.logger import logger
 
 
-class EchoCancellingAudioCapture(BaseThread):
+class AudioCapture(BaseThread):
     """
     回声消除音频捕获器
     使用原生 C 库进行音频捕获，支持回声消除和语音活动检测
     """
 
-    def __init__(self, group=None, target=None, name=None, args=(), kwargs=None, *, daemon=None,
-                 audio_frames_queue):
+    def __init__(
+            self, group=None, target=None, name=None, args=(), kwargs=None, *, daemon=None,
+            audio_frames_queue: Queue = None,
+            enable_echo_cancellation: bool = True,
+    ):
         super().__init__(group, target, name, args, kwargs, daemon=daemon)
 
         self.audio_frames_queue = audio_frames_queue
         self._pause_event = threading.Event()
+        self._enable_echo_cancellation = enable_echo_cancellation
 
     @property
     def is_paused(self):