Save important Slack messages to Notion

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

DATABASE_ID = "your-saved-messages-database-id"

@on_trigger
def run(event):
    slack = WebClient(token=credentials.connection("slack", "work"))
    saved = set(state.get("saved") or [])
    items = slack.reactions_list(full=True, limit=100)["items"]
    new = [i for i in items if i["type"] == "message"
           and any(r["name"] == "bookmark" for r in i["message"].get("reactions", []))
           and f"{i['channel']}:{i['message']['ts']}" not in saved]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    for i in new:
        text = i["message"]["text"]
        link = slack.chat_getPermalink(channel=i["channel"], message_ts=i["message"]["ts"])["permalink"]
        tags = ai.generate(text[:2000], max_output_tokens=30, system="Give 1-3 short topic tags, comma separated.").text
        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": text[:100]}}]},
                      "Link": {"url": link},
                      "Tags": {"multi_select": [{"name": t.strip()[:50]} for t in tags.split(",") if t.strip()]}}})
        saved.add(f"{i['channel']}:{i['message']['ts']}")
    state.set("saved", sorted(saved)[-1000:])
    return {"saved": len(new)}