Get a monthly search traffic report in Telegram

from clickruntime import on_trigger, http, credentials, ai

CHAT_ID = "123456789"

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

PROPERTY = "123456789"

def ga(body):
    url = f"https://analyticsdata.googleapis.com/v1beta/properties/{PROPERTY}:runReport"
    return http.post(url, headers={"Authorization": f"Bearer {credentials.connection('google', 'work')}"}, json=body).json().get("rows", [])

MONTHS = [{"startDate": "30daysAgo", "endDate": "yesterday"}, {"startDate": "60daysAgo", "endDate": "31daysAgo"}]
ORGANIC = {"filter": {"fieldName": "sessionDefaultChannelGroup", "stringFilter": {"value": "Organic Search"}}}

@on_trigger
def run(event):
    rows = ga({"dateRanges": MONTHS, "dimensions": [{"name": "landingPage"}], "metrics": [{"name": "sessions"}],
               "dimensionFilter": ORGANIC, "limit": 500})
    pages = {}
    for r in rows:
        page, rng = r["dimensionValues"][0]["value"], r["dimensionValues"][1]["value"]
        pages.setdefault(page, [0, 0])[0 if rng == "date_range_0" else 1] = int(r["metricValues"][0]["value"])
    moves = sorted(((now - before, page, now) for page, (now, before) in pages.items()), reverse=True)
    total_now, total_before = sum(v[0] for v in pages.values()), sum(v[1] for v in pages.values())
    fmt = lambda xs: "\n".join(f"{p}: {n} ({d:+d})" for d, p, n in xs)
    data = f"Organic sessions {total_now} vs {total_before}\n\nGainers:\n{fmt(moves[:5])}\n\nLosers:\n{fmt(moves[-5:][::-1])}"
    note = ai.generate(data, system="In 3 sentences, summarise this month's search traffic and what to do next.", max_output_tokens=200).text
    tg("sendMessage", chat_id=CHAT_ID, text=f"🔎 Search traffic last month\n{note}\n\n{data}"[:4000])
    return {"pages": len(pages)}