Log WhatsApp requests in Supabase by category and urgency

from clickruntime import on_event, credentials, http, ai, notify

SCHEMA = {"type": "object", "properties": {"category": {"type": "string", "enum": ["HR", "Service", "Support"]},
          "urgency": {"type": "string", "enum": ["urgent", "normal"]}}, "required": ["category", "urgency"]}
SUPABASE_URL = "https://your-project.supabase.co"
sb = lambda: {"apikey": credentials.secret("SUPABASE_SECRET_KEY"), "Authorization": f"Bearer {credentials.secret('SUPABASE_SECRET_KEY')}"}
WA = "https://graph.facebook.com/v20.0/your-phone-number-id/messages"

def wa(to, text):
    http.post(WA, headers={"Authorization": f"Bearer {credentials.secret('WHATSAPP_TOKEN')}"},
              json={"messaging_product": "whatsapp", "to": to, "type": "text", "text": {"body": text}}).raise_for_status()
def incoming(event):
    changes = [c for e in (event.json or {}).get("entry", []) for c in e.get("changes", [])]
    return [(m["from"], m["text"]["body"]) for c in changes for m in c["value"].get("messages", []) if m.get("type") == "text"]

@on_event
def handle(event):
    for phone, text in incoming(event):
        r = ai.generate(text[:1500], system="Classify this request.", json_schema=SCHEMA, max_output_tokens=30).json
        row = http.post(f"{SUPABASE_URL}/rest/v1/requests", headers={**sb(), "Prefer": "return=representation"},
                        json={"phone": phone, "message": text, **r}).json()[0]
        wa(phone, f"Thanks, we've logged your request. Reference: #{row['id']}")
        if r["urgency"] == "urgent":
            notify.email_me(f"Urgent {r['category']} request #{row['id']}", f"From +{phone}:\n{text}")
    return {"ok": True}