Remind customers on Telegram before their subscription ends

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify

RENEW_URL = "https://northwind.example/renew"
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_trigger
def run(event):
    day = date.today() + timedelta(days=3)
    subs = sb("GET", f"subscriptions?expires_on=eq.{day}&reminder_sent=is.false&chat_id=not.is.null")
    sent, failed = [], []
    for s in subs:
        r = tg("sendMessage", chat_id=s["chat_id"], text=f"Hi {s['name']}, your {s['plan']} subscription ends on {day:%d %B}. "
               f"Renew here to keep access: {RENEW_URL}")
        if r.get("ok"):
            sb("PATCH", f"subscriptions?id=eq.{s['id']}", json={"reminder_sent": True})
            sent.append(s["name"])
        else:
            failed.append(f"{s['name']}: {r.get('description')}")
    if subs:
        notify.email_me(f"Renewal reminders: {len(sent)} sent, {len(failed)} failed", "\n".join(["Sent: " + ", ".join(sent)] + failed))
    return {"sent": len(sent), "failed": len(failed)}