Answer questions in Telegram from your own documents

from clickruntime import on_event, credentials, http, ai
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 {}
    question, chat = msg.get("text"), msg.get("chat", {}).get("id")
    if not question or question.startswith("/start"):
        return {"skipped": True}
    docs = sb("POST", "rpc/match_documents", json={"query_text": question, "match_count": 5})
    context = "\n---\n".join(d["content"][:1500] for d in docs)
    answer = ai.generate(f"Answer using only these passages. If they don't contain the answer, say you don't know and suggest contacting the team.\n"
                         f"{context}\n\nQuestion: {question}", max_output_tokens=600).text
    for i in range(0, len(answer), 4000):
        tg("sendMessage", chat_id=chat, text=answer[i:i + 4000], reply_to_message_id=msg["message_id"] if i == 0 else None)
    return {"chat": chat, "passages": len(docs)}