Post a daily Chargebee revenue summary to Slack

from datetime import datetime, time as dtime, timedelta
from clickruntime import on_trigger, credentials, http, notify

SITE = "yourcompany"  # yourcompany.chargebee.com

def fetch_all(api, auth, path, key, params):
    out, offset = [], None
    while True:
        body = http.get(f"{api}/{path}", auth=auth, params={**params, "limit": 100, **({"offset": offset} if offset else {})}).json()
        out += [r[key] for r in body["list"]]
        offset = body.get("next_offset")
        if not offset:
            return out

@on_trigger
def run(event):
    api, auth = f"https://{SITE}.chargebee.com/api/v2", (credentials.secret("CHARGEBEE_API_KEY"), "")
    day = datetime.now().date() - timedelta(days=1)
    start = int(datetime.combine(day, dtime.min).timestamp())
    end = start + 86400
    tx = fetch_all(api, auth, "transactions", "transaction", {"date[between]": f"[{start},{end - 1}]"})
    def total(kind, status):
        rows = [t for t in tx if t["type"] == kind and t["status"] == status]
        return sum(t["amount"] for t in rows) / 100, len(rows)
    paid, failed, refunded = total("payment", "success"), total("payment", "failure"), total("refund", "success")
    created = fetch_all(api, auth, "subscriptions", "subscription", {"created_at[between]": f"[{start},{end - 1}]"})
    cancelled = fetch_all(api, auth, "subscriptions", "subscription", {"cancelled_at[between]": f"[{start},{end - 1}]"})
    cur = tx[0]["currency_code"] if tx else "USD"
    notify.slack(f"📊 Chargebee, {day:%a %d %b}\n"
                 f"Collected: {cur} {paid[0]:,.2f} ({paid[1]} payments)\n"
                 f"Failed: {cur} {failed[0]:,.2f} ({failed[1]} payments)\n"
                 f"Refunded: {cur} {refunded[0]:,.2f} ({refunded[1]})\n"
                 f"New subscriptions: {len(created)} · Cancellations: {len(cancelled)}", channel="#revenue")
    return {"collected": paid[0], "new": len(created), "cancelled": len(cancelled)}