File size: 1,878 Bytes
214209a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 | import logging
from fastapi.datastructures import FormData
logger = logging.getLogger(__name__)
def _safe_int(value, fallback=0):
try:
return int(value)
except (TypeError, ValueError):
return fallback
async def handle_incoming_message(form_data: FormData, channel: str) -> str:
"""
Normalizes the inbound webhook and routes it to analysis workers.
Returns the immediate message to send back to the user via TwiML.
"""
sender = str(form_data.get("From", "")).strip()
message_sid = str(form_data.get("MessageSid", "")).strip()
body = str(form_data.get("Body", "")).strip()
num_media = _safe_int(form_data.get("NumMedia", 0), fallback=0)
logger.info(
"Received inbound message channel=%s sender=%s sid=%s num_media=%s",
channel,
sender,
message_sid,
num_media,
)
# Extract Media URLs
media_urls = []
media_types = []
for i in range(num_media):
media_urls.append(form_data.get(f"MediaUrl{i}"))
media_types.append(form_data.get(f"MediaContentType{i}"))
# Minimal Sync response logic
if num_media > 0:
# e.g., Image or Audio -> Route to Image/Audio workers async here
return "Received your media. Analyzing for deepfakes and security threats..."
if body and "http" in body.lower():
# URL detected -> Route to URL phishing worker
return "Extracting URL. Verifying safety against phishing databases..."
if body:
# Standard text -> Route to Text phishing worker
# Fast sync response or immediate analysis ack
# For scaffolding, let's just return a placeholder response
return f"Received text analysis request. Security scan initialized for: {body[:20]}..."
return "CyberShield received your message but could not parse the content."
|