Sort incoming requests by urgency into Supabase and a team sheet

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

SHEET_ID = "your-spreadsheet-id"
SUPABASE = "https://your-project.supabase.co/rest/v1"

def sb(method, path, **kw):
    key = credentials.secret("SUPABASE_KEY")
    r = http.request(method, f"{SUPABASE}/{path}", **kw, headers={"apikey": key, "Authorization": f"Bearer {key}", "Prefer": "return=representation,resolution=merge-duplicates"})
    return r.raise_for_status() or (r.json() if r.content else None)

SCHEMA = {"type": "object", "properties": {"urgency": {"enum": ["urgent", "soon", "routine", "review"]}, "type": {"type": "string"}}}

@on_event
def handle(event):
    req = event.json or {}
    c = ai.generate(f"Classify this maintenance request. Urgent = safety risk or active damage.\n{req.get('message', '')[:2000]}",
                    json_schema=SCHEMA, max_output_tokens=40).json
    row = sb("POST", "requests", json={"name": req.get("name"), "phone": req.get("phone"), "address": req.get("address"),
                                         "message": req.get("message"), **c, "event_id": event.event_id})[0]
    build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Dispatch!A:F", valueInputOption="RAW", body={"values": [[
        datetime.now(timezone.utc).isoformat(timespec="minutes"), c["urgency"], c["type"], req.get("name"), req.get("address"), row["id"]]]}).execute()
    if c["urgency"] == "urgent":
        notify.slack(f":rotating_light: Urgent {c['type']}: {req.get('name')}, {req.get('address')} – {req.get('message', '')[:200]}", channel="#dispatch")
    return {"id": row["id"], **c}