Collect ideas from Slack in Notion

from slack_sdk import WebClient
from clickruntime import on_trigger, credentials, http, state, ai, report_fetched

CHANNEL_ID = "C0123IDEAS"
DATABASE_ID = "your-ideas-database-id"

@on_trigger
def run(event):
    slack = WebClient(token=credentials.connection("slack", "work"))
    msgs = [m for m in slack.conversations_history(channel=CHANNEL_ID, oldest=state.get("oldest") or "0", limit=50)["messages"]
            if not m.get("bot_id") and m.get("subtype") is None]
    report_fetched(len(msgs))
    if not msgs:
        return {"new": 0}
    for m in reversed(msgs):
        idea = ai.generate(m["text"][:2000], max_output_tokens=250,
                           json_schema={"type": "object", "properties": {"title": {"type": "string"}, "brief": {"type": "string"},
                                        "tags": {"type": "array", "items": {"type": "string"}}}}).json
        page = http.post("https://api.notion.com/v1/pages",
                         headers={"Authorization": f"Bearer {credentials.secret('NOTION_TOKEN')}", "Notion-Version": "2022-06-28"},
                         json={"parent": {"database_id": DATABASE_ID}, "properties": {
                             "Name": {"title": [{"text": {"content": idea["title"][:200]}}]},
                             "Brief": {"rich_text": [{"text": {"content": idea["brief"][:2000]}}]},
                             "Tags": {"multi_select": [{"name": t[:50]} for t in idea["tags"][:3]]}}}).json()
        slack.chat_postMessage(channel=CHANNEL_ID, thread_ts=m["ts"], text=f"💡 Saved to Ideas: {page['url']}")
    state.set("oldest", msgs[0]["ts"])
    return {"saved": len(msgs)}