apunkt/dograh
1
0
Fork 0
mirror of https://github.com/dograh-hq/dograh.git synced 2026-06-13 08:15:21 +02:00
Code Issues Projects Releases Packages Wiki Activity

exotel support fix

Browse source
This commit is contained in:
Hridayesh Gupta 2026-05-12 23:41:53 +05:30
parent 6ae16fd43a
commit 72545eff24
2 changed files with 39 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

10
api/services/telephony/providers/exotel/provider.py
View file

@ -120,14 +120,20 @@ class ExotelProvider(TelephonyProvider):
data.update(kwargs)
endpoint = f"{self._calls_url()}/connect.json"
log_data = {k: v for k, v in data.items()} # shallow copy for logging
logger.info(
f"[Exotel] Initiating outbound call to {to_number} "
f"via CallerID={caller_id}, workflow_run_id={workflow_run_id}"
f"[Exotel] POST {endpoint}\n"
f" From={log_data.get('From')} CallerId={log_data.get('CallerId')}\n"
f" Url={log_data.get('Url')}\n"
f" StatusCallback={log_data.get('StatusCallback')}"
)
async with aiohttp.ClientSession() as session:
async with session.post(endpoint, data=data) as response:
response_text = await response.text()
logger.info(
f"[Exotel] Response HTTP {response.status}: {response_text[:500]}"
)
if response.status not in (200, 201, 202):
logger.error(
f"[Exotel] Calls/connect failed: "

51
api/services/telephony/providers/exotel/routes.py
View file

@ -43,30 +43,41 @@ async def exotel_stream(websocket: WebSocket):
"""
await websocket.accept()
# ------------------------------------------------------------------
# 1. Read the start event
# ------------------------------------------------------------------
try:
raw = await websocket.receive_text()
except WebSocketDisconnect:
logger.warning("[Exotel stream] WebSocket disconnected before start event")
return
# Exotel sends 'connected' first, then 'start' — same as Twilio.
# Loop until we get the 'start' event (skip 'connected' and any other preamble).
start_msg = None
for _ in range(5): # safety limit
try:
raw = await websocket.receive_text()
except WebSocketDisconnect:
logger.warning("[Exotel stream] WebSocket disconnected before start event")
return
logger.info(f"[Exotel stream] Start message raw: {raw}")
logger.info(f"[Exotel stream] Received message raw: {raw}")
try:
start_msg = json.loads(raw)
except json.JSONDecodeError:
logger.error(f"[Exotel stream] Non-JSON start message: {raw}")
await websocket.close(code=4400, reason="Expected JSON start event")
return
try:
msg = json.loads(raw)
except json.JSONDecodeError:
logger.error(f"[Exotel stream] Non-JSON message: {raw}")
await websocket.close(code=4400, reason="Expected JSON")
return
event_type = (start_msg.get("event") or start_msg.get("Event") or "").lower()
if event_type != "start":
logger.error(
f"[Exotel stream] Expected 'start' event, got: {event_type!r}. "
f"Full message: {start_msg}"
event_type = (msg.get("event") or msg.get("Event") or "").lower()
if event_type == "connected":
logger.info("[Exotel stream] Got 'connected' event, waiting for 'start'...")
continue
if event_type == "start":
start_msg = msg
break
logger.warning(
f"[Exotel stream] Unexpected event {event_type!r} before start, skipping."
)
if start_msg is None:
logger.error("[Exotel stream] Never received 'start' event from Exotel")
await websocket.close(code=4400, reason="Expected start event")
return