Copy new Stripe payouts to Google Sheets

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, report_fetched

SHEET_ID = "your-spreadsheet-id"

def stripe(path, **params):
    r = http.get(f"https://api.stripe.com/v1/{path}", params=params,
                 auth=(credentials.secret("STRIPE_API_KEY"), ""))
    r.raise_for_status()
    return r.json()

def sheets():
    return build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")),
                 cache_discovery=False).spreadsheets()

@on_trigger
def run(event):
    since = state.get("last_created") or 0
    payouts = [p for p in stripe("payouts", limit=100, **{"created[gt]": since})["data"]]
    report_fetched(len(payouts))
    if not payouts:
        return {"new": 0}
    rows = []
    for p in sorted(payouts, key=lambda p: p["created"]):
        txns = stripe("balance_transactions", payout=p["id"], limit=100)["data"]
        fees = sum(t["fee"] for t in txns) / 100
        charges = sum(1 for t in txns if t["type"] in ("charge", "payment"))
        refunds = sum(1 for t in txns if t["type"] in ("refund", "payment_refund"))
        arrival = datetime.fromtimestamp(p["arrival_date"], timezone.utc).date().isoformat()
        rows.append([arrival, p["id"], p["amount"] / 100, p["currency"].upper(), fees, charges, refunds, p["status"]])
    sheets().values().append(spreadsheetId=SHEET_ID, range="Payouts!A:H", valueInputOption="USER_ENTERED",
                             body={"values": rows}).execute()
    state.set("last_created", max(p["created"] for p in payouts))
    return {"new": len(rows)}