Turn Slack support messages into Linear tickets

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

CHANNEL_ID = "your-support-channel-id"
TEAM_ID = "your-linear-team-id"
SCHEMA = {"type": "object", "properties": {"title": {"type": "string"}, "summary": {"type": "string"},
          "priority": {"type": "integer"}}, "required": ["title", "summary", "priority"]}
MUTATION = "mutation($i: IssueCreateInput!) { issueCreate(input: $i) { issue { url } } }"

@on_trigger
def run(event):
    slack = WebClient(token=credentials.connection("slack", "work"))
    since = state.get("last_ts") or "0"
    msgs = [m for m in slack.conversations_history(channel=CHANNEL_ID, oldest=since)["messages"] if not m.get("subtype")]
    report_fetched(len(msgs))
    if not msgs:
        return {"summary": "Nothing new"}
    for m in sorted(msgs, key=lambda m: m["ts"]):
        try:
            d = ai.generate(f"Support request:\n{m['text'][:2000]}\nWrite a short title, a summary and a priority from 1 (urgent) to 4 (low).",
                            json_schema=SCHEMA, max_output_tokens=300).json
        except ai.AIError:
            d = {"title": m["text"][:80], "summary": m["text"], "priority": 3}
        r = http.post("https://api.linear.app/graphql", headers={"Authorization": credentials.secret("LINEAR_API_KEY")},
                      json={"query": MUTATION, "variables": {"i": {"teamId": TEAM_ID, "title": d["title"], "description": d["summary"], "priority": d["priority"]}}})
        url = r.json()["data"]["issueCreate"]["issue"]["url"]
        slack.chat_postMessage(channel=CHANNEL_ID, thread_ts=m["ts"], text=f"Logged in Linear: {url}")
        state.set("last_ts", m["ts"])
    return {"summary": f"{len(msgs)} issues created"}