move and rename

src/eva/assistant/base_server.py

@@ -16,11 +16,11 @@
 from fastapi import FastAPI
 
 from eva.assistant.agentic.audit_log import AuditLog
-from eva.assistant.audio_bridge import FrameworkLogWriter, MetricsLogWriter
+from eva.assistant.pipeline.observers import FrameworkLogWriter, MetricsLogWriter
 from eva.assistant.tools.tool_executor import ToolExecutor
 from eva.models.agents import AgentConfig
 from eva.models.config import ModelConfig
-from eva.utils.audio_utils import save_pcm_as_wav
+from eva.utils.audio_utils import pcm16_mix, save_pcm_as_wav
 from eva.utils.culture import get_initial_message
 from eva.utils.logging import get_logger
 from eva.utils.prompt_manager import PromptManager
@@ -166,8 +166,6 @@ async def stop(self) -> asyncio.Task | None:
                         f"assistant={len(self.assistant_audio_buffer)} "
                         f"diff={diff_ms:.0f}ms — mixed recording may be temporally skewed"
                     )
-                from eva.assistant.audio_bridge import pcm16_mix  # lazy: avoids circular import at module load
-
                 self._audio_buffer = bytearray(
                     pcm16_mix(bytes(self.user_audio_buffer), bytes(self.assistant_audio_buffer))
                 )
@@ -291,8 +289,6 @@ def _save_audio(self) -> None:
                     f"assistant={len(self.assistant_audio_buffer)} "
                     f"diff={diff_ms:.0f}ms — mixed recording may be temporally skewed"
                 )
-            from eva.assistant.audio_bridge import pcm16_mix
-
             self._audio_buffer = bytearray(pcm16_mix(bytes(self.user_audio_buffer), bytes(self.assistant_audio_buffer)))
         elif not self._audio_buffer and self.user_audio_buffer:
             self._audio_buffer = bytearray(self.user_audio_buffer)

src/eva/assistant/elevenlabs_server.py

@@ -33,17 +33,16 @@
 )
 from fastapi import FastAPI, WebSocket, WebSocketDisconnect
 
-from eva.assistant.audio_bridge import (
-    FrameworkLogWriter,
-    MetricsLogWriter,
-    create_twilio_media_message,
-    mulaw_8k_to_pcm16_16k,
-    parse_twilio_media_message,
-)
 from eva.assistant.base_server import AbstractAssistantServer
 from eva.assistant.elevenlabs_audio_interface import TwilioAudioBridge
+from eva.assistant.pipeline.observers import FrameworkLogWriter, MetricsLogWriter
 from eva.models.agents import AgentConfig
 from eva.models.config import ModelConfig
+from eva.utils.audio_utils import (
+    create_twilio_media_message,
+    mulaw_8k_to_pcm16_16k,
+    parse_twilio_media_message,
+)
 from eva.utils.logging import get_logger
 
 logger = get_logger(__name__)

src/eva/assistant/gemini_live_server.py

@@ -26,19 +26,18 @@
 from google import genai
 from google.genai import types
 
-from eva.assistant.audio_bridge import (
-    FrameworkLogWriter,
-    MetricsLogWriter,
+from eva.assistant.base_server import AbstractAssistantServer
+from eva.assistant.pipeline.observers import FrameworkLogWriter, MetricsLogWriter
+from eva.models.agents import AgentConfig
+from eva.models.config import ModelConfig
+from eva.utils.audio_utils import (
     create_twilio_media_message,
     mulaw_8k_to_pcm16_16k,
     mulaw_8k_to_pcm16_24k,
     parse_twilio_media_message,
     pcm16_24k_to_mulaw_8k,
     sync_buffer_to_position,
 )
-from eva.assistant.base_server import AbstractAssistantServer
-from eva.models.agents import AgentConfig
-from eva.models.config import ModelConfig
 from eva.utils.logging import get_logger
 
 logger = get_logger(__name__)

src/eva/assistant/openai_realtime_server.py

@@ -17,16 +17,15 @@
 from fastapi import FastAPI, WebSocket, WebSocketDisconnect
 from openai import AsyncOpenAI
 
-from eva.assistant.audio_bridge import (
-    FrameworkLogWriter,
-    MetricsLogWriter,
+from eva.assistant.base_server import AbstractAssistantServer
+from eva.assistant.pipeline.observers import FrameworkLogWriter, MetricsLogWriter
+from eva.utils.audio_utils import (
     create_twilio_media_message,
     mulaw_8k_to_pcm16_24k,
     parse_twilio_media_message,
     pcm16_24k_to_mulaw_8k,
     sync_buffer_to_position,
 )
-from eva.assistant.base_server import AbstractAssistantServer
 from eva.utils.logging import get_logger
 
 logger = get_logger(__name__)