Get a weekly Slack report of rising and slowing products

from datetime import date, timedelta
from collections import Counter
from clickruntime import on_trigger, credentials, http, state, notify, ai

STORE = "https://shop.example.com/wp-json/wc/v3"

@on_trigger
def run(event):
    auth = (credentials.secret("WOO_KEY"), credentials.secret("WOO_SECRET"))
    end = date.today() - timedelta(days=date.today().weekday())
    orders = http.get(f"{STORE}/orders", auth=auth, params={"after": f"{end - timedelta(days=7)}T00:00:00",
                      "before": f"{end}T00:00:00", "status": "processing,completed", "per_page": 100}).json()
    week = Counter()
    for o in orders:
        for li in o["line_items"]:
            week[li.get("sku") or li["name"]] += li["quantity"]
    past = state.get("weeks") or []
    avg = {k: sum(w.get(k, 0) for w in past) / len(past) for k in set(week).union(*past)} if past else {}
    rising = [f"{k} {week[k]} (avg {a:.0f})" for k, a in avg.items() if a and week[k] > 1.3 * a]
    risky = [f"{k} {week[k]} (avg {a:.0f})" for k, a in avg.items() if a >= 3 and week[k] < 0.6 * a]
    text = f"Last week: {sum(week.values())} units\nRising: {', '.join(rising) or 'none'}\nAt risk: {', '.join(risky) or 'none'}"
    try:
        text += "\n" + ai.generate(f"Summarise these sales trends in two plain sentences:\n{text}", max_output_tokens=120).text
    except ai.AIError:
        pass
    notify.slack(text, channel="#sales")
    state.set("weeks", (past + [dict(week)])[-4:])
    return {"skus": len(week)}