Log WhatsApp requests in a sheet with a category

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import datetime, timezone
from clickruntime import on_event, credentials, http, ai

SHEET_ID = "your-spreadsheet-id"
SCHEMA = {"type": "object", "properties": {"category": {"type": "string"}, "urgency": {"type": "string", "enum": ["high", "normal", "low"]}}, "required": ["category", "urgency"]}
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):
    vals = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).spreadsheets().values()
    for phone, text in incoming(event):
        r = ai.generate(text[:1500], system="Classify this request. Category: Maintenance, IT, HR or Billing.", json_schema=SCHEMA, max_output_tokens=30).json
        ref = "R" + datetime.now(timezone.utc).strftime("%y%m%d%H%M%S")
        row = [ref, datetime.now(timezone.utc).isoformat(timespec="minutes"), phone, text, r["category"], r["urgency"]]
        vals.append(spreadsheetId=SHEET_ID, range="Requests!A:F", valueInputOption="RAW", body={"values": [row]}).execute()
        wa(phone, f"Thanks, we've logged your request. Your reference is {ref}.")
    return {"ok": True}