Turn action items in your email into Supabase tasks

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched
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": {"tasks": {"type": "array", "items": {"type": "object", "properties": {
          "title": {"type": "string"}, "owner": {"type": "string"}, "due": {"type": "string"}}}}}}

@on_trigger
def run(event):
    gmail, since = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False), state.get("since") or 0
    q = f"in:inbox -category:promotions after:{since}" if since else "in:inbox newer_than:1h"
    msgs = gmail.users().messages().list(userId="me", q=q).execute().get("messages", [])
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    rows, newest = [], since
    for m in msgs:
        full = gmail.users().messages().get(userId="me", id=m["id"]).execute()
        newest = max(newest, int(full["internalDate"]) // 1000)
        found = ai.generate(f"List tasks (title, owner, due YYYY-MM-DD or empty) in this email, or none:\n{full['snippet']}", json_schema=SCHEMA, max_output_tokens=300).json
        rows += [{**t, "due": t.get("due") or None, "email_id": m["id"]} for t in found.get("tasks", [])]
    if rows:
        sb("POST", "tasks", json=rows)
    state.set("since", newest + 1)
    return {"emails": len(msgs), "tasks": len(rows)}