Collect daily standups by Mattermost DM

import time
from datetime import datetime
from clickruntime import on_trigger, credentials, http, state

BASE = "https://chat.acme.com/api/v4"
TEAM_ID, ENG_CHANNEL_ID, STANDUP_CHANNEL_ID = "teamid123", "engchannel123", "standupchannel123"
QUESTIONS = "Standup: what did you do yesterday, what's next, anything blocking?"

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.secret('MATTERMOST_TOKEN')}"}
    me = http.get(f"{BASE}/users/me", headers=h).json()["id"]
    if datetime.utcnow().hour < 10:  # 9am run: send the questions
        members = http.get(f"{BASE}/channels/{ENG_CHANNEL_ID}/members", params={"per_page": 200}, headers=h).json()
        dms = {}
        for m in members:
            if m["user_id"] == me:
                continue
            dm = http.post(f"{BASE}/channels/direct", json=[me, m["user_id"]], headers=h).json()["id"]
            http.post(f"{BASE}/posts", json={"channel_id": dm, "message": QUESTIONS}, headers=h)
            dms[m["user_id"]] = dm
        state.set("standup", {"asked_at": int(time.time() * 1000), "dms": dms})
        return {"asked": len(dms)}
    s = state.get("standup") or {"dms": {}}
    report = []
    for user_id, dm in s["dms"].items():
        posts = http.get(f"{BASE}/channels/{dm}/posts", params={"since": s["asked_at"]}, headers=h).json()["posts"]
        answers = [p["message"] for p in posts.values() if p["user_id"] == user_id]
        name = http.get(f"{BASE}/users/{user_id}", headers=h).json()["username"]
        report.append(f"**@{name}**\n" + ("\n".join(answers) or "_no answer_"))
    http.post(f"{BASE}/posts", json={"channel_id": STANDUP_CHANNEL_ID, "message": "\n\n".join(report)}, headers=h)
    return {"answered": len(report)}