Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
TypeScript
at incident-api
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148import { getLogger } from "@logtape/logtape";import type { WebClient } from "@slack/web-api";
import { redis } from "@/libs/clients";
const logger = getLogger("api-server");
// Slack accepts 200 characters, but the Messages tab shows far fewer before// it elides — a title that only reads in full on hover isn't doing its job.const MAX_TITLE = 60;
/** * Presence means the thread's title is settled: either we set it on the first * turn that produced a subject, or a person renamed it by hand. Both mean the * same thing here — leave it alone. A thread is one incident's whole life, so * the name should be its subject, not whatever the latest turn happened to do. * * The TTL outlives any incident by a wide margin; if it ever does lapse, the * cost is one stale thread getting re-titled on a much later turn. */const TITLE_PREFIX = "slack:title:";const TITLE_TTL_SECONDS = 30 * 24 * 60 * 60;
function titleKey(teamId: string, channel: string, threadTs: string): string { return `${TITLE_PREFIX}${teamId}:${channel}:${threadTs}`;}
export async function isThreadTitled( teamId: string, channel: string, threadTs: string,): Promise<boolean> { return (await redis.get(titleKey(teamId, channel, threadTs))) !== null;}
export async function markThreadTitled( teamId: string, channel: string, threadTs: string,): Promise<void> { await redis.set(titleKey(teamId, channel, threadTs), "1", { ex: TITLE_TTL_SECONDS, });}
/** Cuts on a word boundary, falling back to a hard cut for one long word. */export function truncateTitle(text: string): string { const clean = text.replace(/\s+/g, " ").trim(); if (clean.length <= MAX_TITLE) return clean; const cut = clean.slice(0, MAX_TITLE); const lastSpace = cut.lastIndexOf(" "); const kept = lastSpace > MAX_TITLE / 2 ? cut.slice(0, lastSpace) : cut; return `${kept.trimEnd()}…`;}
export interface TitleSources { /** The write this turn proposed, if any. */ draft?: { toolName: string; input: unknown }; /** Title of the report the draft acts on, for updates and resolutions. */ reportTitle?: string; /** What the user said, mention included — it gets stripped here. */ userText?: string;}
/** * The thread's subject, best source first: * * 1. a drafted report or maintenance title — already written for people to * read, since it is what lands on the status page; * 2. the title of the report an update or resolution acts on; * 3. what the user asked, for turns that produce nothing else. * * Undefined when none of those yield anything: Slack's own default name beats * a title we made up. */export function buildThreadTitle({ draft, reportTitle, userText,}: TitleSources): string | undefined { const drafted = draft && draftTitle(draft); if (drafted) return truncateTitle(drafted); if (reportTitle?.trim()) return truncateTitle(reportTitle); const asked = strippedUserText(userText); return asked ? truncateTitle(asked) : undefined;}
function draftTitle(draft: { toolName: string; input: unknown;}): string | undefined { if (typeof draft.input !== "object" || draft.input === null) return undefined; const title = (draft.input as { title?: unknown }).title; if (typeof title !== "string" || !title.trim()) return undefined; // Planned work reads as an outage in a timeline unless it says otherwise. return draft.toolName === "create_maintenance" ? `Maintenance: ${title}` : title;}
function strippedUserText(text: string | undefined): string | undefined { if (!text) return undefined; const stripped = text .replace(/<@[A-Z0-9]+>/g, " ") .replace(/\s+/g, " ") .trim(); return stripped || undefined;}
/** * Names the thread, once. The marker is claimed before the rename so two turns * racing on one thread can't name it twice, and released when Slack refuses. */export async function renameThread(args: { slack: WebClient; channel: string; threadTs: string; title: string; teamId: string;}): Promise<void> { const { slack, channel, threadTs, title, teamId } = args; const key = titleKey(teamId, channel, threadTs); const claimed = await redis.set(key, "1", { nx: true, ex: TITLE_TTL_SECONDS, }); if (!claimed) return;
try { await slack.agents.sessions.rename({ channel_id: channel, thread_ts: threadTs, title, }); } catch (err) { // Workspaces without agent sessions throw here; the thread simply keeps // the name Slack gives it, and stays eligible for a later turn. await redis.del(key); logger.info("slack could not rename the thread", { error: err, channel, teamId, }); return; } logger.info("slack thread titled", { channel, threadTs, teamId, title });}