Get a weekly digest of Slack and Teams discussions

import re, time
from datetime import datetime, timedelta, timezone
from slack_sdk import WebClient
from clickruntime import on_trigger, credentials, http, ai, notify

SLACK_CHANNEL = "C0123456789"
TEAM_ID, CHANNEL_ID = "your-team-id", "your-channel-id"

@on_trigger
def run(event):
    week_ago = datetime.now(timezone.utc) - timedelta(days=7)
    slack = WebClient(token=credentials.connection("slack", "work")).conversations_history(channel=SLACK_CHANNEL, oldest=str(week_ago.timestamp()), limit=500)
    lines = [f"[Slack] {m.get('text', '')}" for m in reversed(slack["messages"])]
    teams = http.get(f"https://graph.microsoft.com/v1.0/teams/{TEAM_ID}/channels/{CHANNEL_ID}/messages",
                     headers={"Authorization": f"Bearer {credentials.connection('microsoft', 'work')}"}).json().get("value", [])
    lines += [f"[Teams] {re.sub('<[^>]+>', '', m['body']['content'])}" for m in teams if m["createdDateTime"] >= week_ago.isoformat()[:19]]
    if not lines:
        return {"messages": 0}
    try:
        digest = ai.generate("\n".join(l[:500] for l in lines)[:60000], system="List decisions made, then open questions with who raised them. Be brief.", max_output_tokens=1200).text
    except ai.AIError as e:
        digest = f"{len(lines)} messages this week; AI summary unavailable ({e.code})."
    notify.email_me("Weekly product discussions digest", digest)
    return {"messages": len(lines)}