Update app.py

app.py

@@ -1,7 +1,7 @@
 #!/usr/bin/env python3
 #
-#  san_integration_script.py (v4 - API Fix)
-#  ========================================
+#  san_integration_script.py (v5 - Provider Format Fix)
+#  ======================================================
 #  Description:
 #  - Establishes a real-time, two-way audio bridge between a SAN system
 #    and the Millis AI platform.
@@ -12,8 +12,10 @@
 #    it originally specified.
 #
 #  Changes in this version:
-#  - Fixed `ImportError` by changing the import from `starlette.websockets`
-#    from the old `State` to the new `WebSocketState`.
+#  - Fixed the `reverse-media` event payload to match the provider's
+#    expected format (simplified JSON, lowercase 'callid').
+#  - Fixed `ImportError` by changing `starlette.websockets.State` to
+#    `starlette.websockets.WebSocketState`.
 #  - Updated the final connection check to use `WebSocketState.DISCONNECTED`.
 #  -------------------------------------------------------------------
 
@@ -32,7 +34,7 @@ from websockets.connection import State as WsState
 from fastapi import FastAPI, WebSocket, WebSocketDisconnect
 import uvicorn
 
-# *** KEY CHANGE 1: Import WebSocketState instead of State ***
+# Import WebSocketState instead of State
 from starlette.websockets import WebSocketState
 
 # ---------- Logging Configuration -----------------------------------------
@@ -184,14 +186,17 @@ class RealTimeAudioProcessor:
                 payload = base64.b64encode(chunk_resampled).decode()
                 sent_packets += 1
                 if sent_packets % 100 == 1:
-                    logger.info(f"⬆️  Sending upstream audio packet #{sent_packets} to SAN using format {self.media_format}...")
+                    logger.info(f"⬆️  Sending upstream audio packet #{sent_packets} to SAN...")
+
+                ### --- FIX: Modified the JSON payload to match the provider's simple format --- ###
                 await client_ws.send_json({
                     "event": "reverse-media",
-                    "streamId": self.stream_id,
-                    "callId": self.call_id,
-                    "mediaFormat": self.media_format,
+                    "callid": self.call_id,  # Changed from "callId" to "callid"
                     "payload": payload,
+                    # Removed "streamId" and "mediaFormat" fields
                 })
+                ### --- END FIX --- ###
+
             except Exception as e:
                 logger.error(f"❌ Error in _pump_outbound_to_carrier: {e}")
                 break
@@ -282,7 +287,6 @@ async def media_socket(ws: WebSocket):
         logger.error(f"❌ Unhandled error in media_socket: {e}", exc_info=True)
     finally:
         await stop_processor(processor, tasks)
-        # *** KEY CHANGE 2: Use WebSocketState for the check ***
         if ws.client_state != WebSocketState.DISCONNECTED:
             await ws.close()
         logger.info("✅ Cleanup complete for this WebSocket connection.")
@@ -292,5 +296,6 @@ async def health():
     return {"status": "ok", "timestamp": datetime.now().isoformat()}
 
 if __name__ == "__main__":
-    print("🚀 Starting SAN to Millis AI Integration Server (v4 - API Fix)...")
+    print("🚀 Starting SAN to Millis AI Integration Server (v5 - Provider Format Fix)...")
     uvicorn.run(app, host="0.0.0.0", port=7860)
+