Post daily Google Ads results to Slack with drop alerts

from clickruntime import on_trigger, http, credentials, ai, state, notify

CUSTOMER_ID = "1234567890"

def gaql(query):
    headers = {"Authorization": f"Bearer {credentials.connection('google', 'ads')}", "developer-token": credentials.secret("GOOGLE_ADS_DEVELOPER_TOKEN")}
    batches = http.post(f"https://googleads.googleapis.com/v21/customers/{CUSTOMER_ID}/googleAds:searchStream", headers=headers, json={"query": query}).json()
    return [row for b in batches for row in b.get("results", [])]

@on_trigger
def run(event):
    rows = gaql("SELECT campaign.name, metrics.cost_micros, metrics.clicks, metrics.ctr, metrics.conversions FROM campaign "
                "WHERE segments.date DURING YESTERDAY AND campaign.status = 'ENABLED'")
    history, lines, flags = state.get("history") or {}, [], []
    for r in rows:
        name, m = r["campaign"]["name"], r["metrics"]
        today = {"spend": int(m.get("costMicros", 0)) / 1e6, "ctr": float(m.get("ctr", 0)), "conv": float(m.get("conversions", 0))}
        lines.append(f"• {name}: £{today['spend']:,.2f}, {m.get('clicks', 0)} clicks, CTR {today['ctr']:.1%}, {today['conv']:.0f} conv")
        past = history.get(name, [])
        for k in today:
            avg = sum(p[k] for p in past) / len(past) if past else 0
            if avg and abs(today[k] - avg) / avg > 0.4:
                flags.append(f"{name} {k}: {today[k]:,.2f} vs avg {avg:,.2f}")
        history[name] = (past + [today])[-7:]
    text = "*Google Ads yesterday*\n" + "\n".join(lines)
    if flags:
        text += "\n\n⚠️ " + ai.generate("\n".join(flags), system="For each change, say in one line what to check.", max_output_tokens=300).text
    notify.slack(text, channel="#paid")
    state.set("history", history)
    return {"campaigns": len(rows), "flags": len(flags)}