Run a Telegram assistant that remembers each user

from clickruntime import on_event, credentials, http, ai

PERSONA = "You are the Northwind running club's friendly training assistant. Keep replies short."
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)

def tg(method, **params):
    return http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/{method}", json=params).json()

@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    if not msg.get("text"):
        return {"skipped": True}
    user = msg["from"]
    sb("POST", "users?on_conflict=id", json={"id": user["id"], "name": user.get("first_name")})
    history = sb("GET", f"messages?user_id=eq.{user['id']}&order=created_at.desc&limit=20")[::-1]
    convo = "\n".join(f"{m['role']}: {m['text']}" for m in history)
    reply = ai.generate(f"{convo}\nuser: {msg['text']}\nassistant:", system=f"{PERSONA} The user's name is {user.get('first_name')}.", max_output_tokens=400).text
    tg("sendMessage", chat_id=msg["chat"]["id"], text=reply)
    sb("POST", "messages", json=[{"user_id": user["id"], "role": "user", "text": msg["text"]}, {"user_id": user["id"], "role": "assistant", "text": reply}])
    return {"user": user["id"], "history": len(history)}