Refactor imports across services: replace `services.core` module references with `core` for consistency and maintainability; remove unused `Queue` imports.

src/VoiceDialogue/api/core/service_factories.py

@@ -1,9 +1,9 @@
-from services.audio import EchoCancellingAudioCapture, TTSAudioGenerator, AudioStreamPlayer
-from services.audio.audio_generator import BaseTTSConfig, tts_config_registry
-from services.core.constants import (
+from core.constants import (
     transcribed_text_queue, text_input_queue, audio_output_queue,
     audio_frames_queue, user_voice_queue
 )
+from services.audio import EchoCancellingAudioCapture, TTSAudioGenerator, AudioStreamPlayer
+from services.audio.audio_generator import BaseTTSConfig, tts_config_registry
 from services.speech import SpeechStateMonitor, ASRWorker
 from services.text.text_generator import LLMResponseGenerator
 from .service_manager import ServiceDefinition

src/VoiceDialogue/{services/core → core}/enums.py

@@ -4,4 +4,4 @@ import enum
 class AudioState(enum.Enum):
     """音频播放状态枚举"""
     DROP = 0
-    PLAYING = 1 
+    PLAYING = 1

src/VoiceDialogue/main.py

@@ -5,17 +5,17 @@ from pathlib import Path
 
 import uvicorn
 
-from services.audio.aec_audio_capture import EchoCancellingAudioCapture
-from services.audio.audio_answer import TTSAudioGenerator
-from services.audio.audio_generator.models import tts_config_registry, TTSConfigType
-from services.audio.audio_player import AudioStreamPlayer
-from services.core.constants import (
+from core.constants import (
     audio_frames_queue,
     user_voice_queue,
     transcribed_text_queue,
     text_input_queue,
     audio_output_queue
 )
+from services.audio.aec_audio_capture import EchoCancellingAudioCapture
+from services.audio.audio_answer import TTSAudioGenerator
+from services.audio.audio_generator.models import tts_config_registry
+from services.audio.audio_player import AudioStreamPlayer
 from services.speech.asr_service import ASRWorker
 from services.speech.speech_monitor import SpeechStateMonitor
 from services.text.text_generator import LLMResponseGenerator

src/VoiceDialogue/services/audio/aec_audio_capture.py

@@ -9,7 +9,7 @@ import time
 import numpy as np
 
 from config.paths import LIBRARIES_PATH
-from services.core.base import BaseThread
+from core.base import BaseThread
 
 
 class EchoCancellingAudioCapture(BaseThread):

src/VoiceDialogue/services/audio/audio_answer.py

@@ -2,9 +2,9 @@ import time
 from multiprocessing import Queue
 from queue import Empty
 
+from core.base import BaseThread
+from core.constants import dropped_audio_cache, user_still_speaking_event, voice_state_manager
 from models.voice_task import VoiceTask
-from services.core.base import BaseThread
-from services.core.constants import dropped_audio_cache, user_still_speaking_event, voice_state_manager
 from .audio_generator import tts_manager, BaseTTSConfig
 
 

src/VoiceDialogue/services/audio/audio_player.py

@@ -1,5 +1,4 @@
 import tempfile
-import time
 from collections import OrderedDict
 from multiprocessing import Queue
 from queue import Empty
@@ -7,12 +6,12 @@ from queue import Empty
 import soundfile as sf
 from playsound import playsound
 
-from models.voice_task import VoiceTask
-from services.core.base import BaseThread
-from services.core.constants import (
+from core.base import BaseThread
+from core.constants import (
     user_still_speaking_event, voice_state_manager, dropped_audio_cache, chat_history_cache,
     silence_over_threshold_event
 )
+from models.voice_task import VoiceTask
 
 
 class AudioStreamPlayer(BaseThread):

src/VoiceDialogue/services/core/queue.py

@@ -1,7 +0,0 @@
-from multiprocessing import Queue
-
-audio_frames_queue = Queue()
-user_voice_queue = Queue()
-transcribed_text_queue = Queue()
-generated_answer_queue = Queue()
-tts_generated_audio_queue = Queue()

src/VoiceDialogue/services/speech/asr_service.py

@@ -4,9 +4,9 @@ from queue import Queue
 
 import numpy as np
 
+from core.base import BaseThread
+from core.constants import user_still_speaking_event, voice_state_manager, dropped_audio_cache
 from models.voice_task import VoiceTask
-from services.core.base import BaseThread
-from services.core.constants import user_still_speaking_event, voice_state_manager, dropped_audio_cache
 from utils.cache import LRUCacheDict
 from .asr import asr_manager
 

src/VoiceDialogue/services/speech/speech_monitor.py

@@ -14,11 +14,11 @@ import librosa
 import numpy as np
 
 from models.voice_task import VoiceTask
-from ..core.base import BaseThread
-from ..core.constants import (
+from core.base import BaseThread
+from core.constants import (
     voice_state_manager, silence_over_threshold_event, user_still_speaking_event, current_session_id
 )
-from ..core.enums import AudioState
+from core.enums import AudioState
 
 
 class SpeechMonitorConfig:

src/VoiceDialogue/services/text/text_generator.py

@@ -6,9 +6,9 @@ from langchain.memory import ConversationBufferWindowMemory
 from langchain_core.chat_history import InMemoryChatMessageHistory
 
 from config import paths
+from core.base import BaseThread
+from core.constants import chat_history_cache
 from models.voice_task import VoiceTask
-from services.core.base import BaseThread
-from services.core.constants import chat_history_cache
 from services.text.langchain_llm import preprocess_sentence_text, \
     create_langchain_chat_llamacpp_instance, create_langchain_pipeline, warmup_langchain_pipeline