Cleanup of code, consolidating VoiceLive params, minor bug fixes

.env.sample

@@ -65,15 +65,14 @@ AZURE_OPENAI_STT_TTS_KEY=your-azure-speech-service-key                   # Optio
 # Azure Voice Live Integration (Optional - for Azure Voice Live API)
 # ============================================================================
 AZURE_VOICE_LIVE_ENDPOINT=https://your-voice-live-endpoint.voice.azure.com/  # Optional: Azure Voice Live API endpoint
-AZURE_VOICE_LIVE_KEY=optional-key                                        # Optional: Azure Voice Live API key
 AZURE_VOICE_LIVE_API_KEY=your-voice-live-api-key                         # Optional: Alternative API key name
 AZURE_VOICE_LIVE_MODEL=gpt-4o                                            # Optional: Voice Live model deployment (default: gpt-4o)
 AZURE_VOICE_LIVE_API_VERSION=2024-10-01-preview                          # Optional: Voice Live API version
 
 # Azure AI Foundry Integration (Optional)
 AZURE_AI_FOUNDRY_ENDPOINT=https://your-foundry-endpoint.services.ai.azure.com/api/projects/your-project  # Optional: AI Foundry project endpoint
 AI_FOUNDRY_PROJECT_NAME=your-ai-foundry-project                          # Optional: AI Foundry project name
-
+AI_FOUNDRY_AGENT_ID=your-ai-foundry-agent-id                            # Optional: AI Foundry agent ID
 # ============================================================================
 # Base URL Configuration (Required for Webhooks)
 # ============================================================================

.github/workflows/docs.yml

@@ -35,6 +35,11 @@ jobs:
         with:
           python-version: '3.11'
 
+      - name: Install system dependencies
+        run: |
+          sudo apt-get update
+          sudo apt-get install -y portaudio19-dev
+
       - name: Cache dependencies
         uses: actions/cache@v4
         with:

apps/rtagent/backend/api/v1/handlers/acs_media_lifecycle.py

@@ -90,16 +90,17 @@ class ThreadBridge:
     Implements the non-blocking patterns described in the documentation.
     """
 
-    def __init__(self):
+    def __init__(self, call_connection_id: Optional[str] = None):
         """
         Initialize cross-thread communication bridge.
 
         :param main_loop: Main event loop for cross-thread communication
         :type main_loop: Optional[asyncio.AbstractEventLoop]
         """
         self.main_loop: Optional[asyncio.AbstractEventLoop] = None
+        self.call_connection_id = call_connection_id
         # Create shorthand for call connection ID (last 8 chars)
-        self.call_id_short = "unknown"
+        self.call_id_short = call_connection_id[-8:] if call_connection_id else "unknown"
 
     def set_main_loop(
         self, loop: asyncio.AbstractEventLoop, call_connection_id: str = None
@@ -454,6 +455,7 @@ class RouteTurnThread:
 
     def __init__(
         self,
+        call_connection_id: Optional[str],
         speech_queue: asyncio.Queue,
         orchestrator_func: Callable,
         memory_manager: Optional[MemoManager],
@@ -468,11 +470,8 @@ def __init__(
         self.running = False
         self._stopped = False
         # Get call ID shorthand from websocket if available
-        self.call_id_short = (
-            getattr(websocket, "_call_connection_id", "unknown")[-8:]
-            if hasattr(websocket, "_call_connection_id")
-            else "unknown"
-        )
+        self.call_connection_id = call_connection_id
+        self.call_id_short = call_connection_id[-8:] if call_connection_id else "unknown"
 
     async def start(self):
         """Start the route turn processing loop."""
@@ -917,10 +916,11 @@ def __init__(
 
         # Cross-thread communication
         self.speech_queue = asyncio.Queue(maxsize=10)
-        self.thread_bridge = ThreadBridge()
+        self.thread_bridge = ThreadBridge(call_connection_id=self.call_connection_id)
 
         # Initialize threads
         self.route_turn_thread = RouteTurnThread(
+            call_connection_id=self.call_connection_id,
             speech_queue=self.speech_queue,
             orchestrator_func=orchestrator_func,
             memory_manager=memory_manager,

apps/rtagent/backend/config/infrastructure.py

@@ -64,7 +64,8 @@ def __str__(self):
 ACS_ENDPOINT: str = os.getenv("ACS_ENDPOINT", "")
 ACS_CONNECTION_STRING: str = os.getenv("ACS_CONNECTION_STRING", "")
 ACS_SOURCE_PHONE_NUMBER: str = os.getenv("ACS_SOURCE_PHONE_NUMBER", "")
-BASE_URL: str = os.getenv("BASE_URL", "")
+# Base application URL (ensure no trailing slash)
+BASE_URL: str = os.getenv("BASE_URL", "").rstrip("/")
 
 # ACS Streaming configuration
 ACS_STREAMING_MODE: StreamMode = StreamMode(

apps/rtagent/backend/config/voice_config.py

@@ -93,6 +93,9 @@ def get_agent_voice(agent_config_path: str) -> str:
 # AZURE VOICE LIVE SETTINGS
 # ==============================================================================
 
-AZURE_VOICE_LIVE_ENDPOINT = os.getenv("AZURE_VOICE_LIVE_ENDPOINT", "")
-AZURE_VOICE_API_KEY = os.getenv("AZURE_VOICE_API_KEY", "")
+AZURE_VOICE_LIVE_ENDPOINT = os.getenv("AZURE_SPEECH_ENDPOINT", "")
+AZURE_VOICE_API_KEY = os.getenv("AZURE_SPEECH_KEY", "")
 AZURE_VOICE_LIVE_MODEL = os.getenv("AZURE_VOICE_LIVE_MODEL", "gpt-4o")
+# AZURE_VOICE_LIVE_ENDPOINT = os.getenv("AZURE_VOICE_LIVE_ENDPOINT", "")
+# AZURE_VOICE_API_KEY = os.getenv("AZURE_VOICE_API_KEY", "")
+# AZURE_VOICE_LIVE_MODEL = os.getenv("AZURE_VOICE_LIVE_MODEL", "gpt-4o")