Back up Telegram bot messages to GitHub

import base64, json
from clickruntime import on_trigger, credentials, http, state

REPO, OWNER_CHAT = "yourname/telegram-backup", "123456789"

def gh(method, path, **kw):
    r = http.request(method, f"https://api.github.com{path}", headers={
        "Authorization": f"Bearer {credentials.connection('github', 'work')}", "Accept": "application/vnd.github+json"}, **kw)
    r.raise_for_status()
    return r.json() if r.content else None

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

@on_trigger
def run(event):
    update = event.get("json") or {}
    msg = update.get("message") or update.get("channel_post")
    if msg:  # webhook
        buf = state.get("buffer") or []
        buf.append(msg)
        state.set("buffer", buf)
        return {"buffered": len(buf)}
    buf = state.get("buffer") or []  # daily 02:00
    if not buf:
        tg("sendMessage", chat_id=OWNER_CHAT, text="Backup done: no new messages")
        return {"saved": 0}
    from datetime import datetime, timezone
    day = datetime.fromtimestamp(buf[0]["date"], timezone.utc).strftime("%Y-%m-%d")
    path = f"messages/{day}.jsonl"
    body = "\n".join(json.dumps(m, ensure_ascii=False, sort_keys=True) for m in buf) + "\n"
    try:
        existing = gh("GET", f"/repos/{REPO}/contents/{path}")
        body = base64.b64decode(existing["content"]).decode() + body
    except Exception:
        existing = None
    res = gh("PUT", f"/repos/{REPO}/contents/{path}", json={"message": f"Backup {len(buf)} Telegram messages ({day})",
             "content": base64.b64encode(body.encode()).decode(), **({"sha": existing["sha"]} if existing else {})})
    state.set("buffer", [])
    chats = len({m["chat"]["id"] for m in buf})
    tg("sendMessage", chat_id=OWNER_CHAT, text=f"Backup done: {len(buf)} messages from {chats} chats\n{path}\n{res['commit']['html_url']}",
       disable_web_page_preview=True)
    return {"saved": len(buf)}