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
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115import type { Workspace } from "@openstatus/db/src/schema/workspaces/validation";import type { ServiceContext } from "@openstatus/services";import { generateText, stepCountIs } from "ai";import type { ModelMessage } from "ai";
import { tb } from "@/libs/clients";
import { buildSlackTools } from "./registry-runner";import { buildSystemPrompt } from "./system-prompt";
// Vercel AI Gateway model id. Override via SLACK_AGENT_MODEL when rolling// out a new Sonnet version. Dotted format (`4.6`, not `4-6`) is what the// gateway accepts — see `apps/dashboard/src/app/api/chat/route.ts`.const DEFAULT_MODEL = "anthropic/claude-sonnet-4.6";// `||` (not `??`) so empty / whitespace-only env values fall back to the// default rather than being passed through to `generateText`.const MODEL = process.env.SLACK_AGENT_MODEL?.trim() || DEFAULT_MODEL;
interface SlackThreadMessage { user?: string; bot_id?: string; text?: string;}
// A mention needs list_status_pages + list_page_components before it can draft,// and the model is told to check monitor status first — 5 left no headroom.const MAX_STEPS = 10;
interface AgentResult { text: string; toolResults: Array<{ toolName: string; result: unknown }>; finishReason: string; stepCount: number; /** True when the model used every allowed step — a draft may have been cut off. */ hitStepLimit: boolean;}
function convertThreadToMessages( thread: SlackThreadMessage[], botUserId: string,): ModelMessage[] { const messages: ModelMessage[] = []; for (const msg of thread) { if (!msg.text) continue; if (msg.bot_id || msg.user === botUserId) { messages.push({ role: "assistant", content: msg.text }); } else { messages.push({ role: "user", content: msg.text }); } } // The API requires the first message to have role "user". // Drop any leading assistant messages (e.g. bot confirmations from a prior turn). while (messages.length > 0 && messages[0].role !== "user") { messages.shift(); } return messages;}
export async function runAgent( workspace: Workspace, thread: SlackThreadMessage[], botUserId: string, userText?: string, origin?: { slackUserId: string; teamId: string | undefined },): Promise<AgentResult> { const ctx: ServiceContext = { workspace, actor: { type: "slack", teamId: origin?.teamId ?? "", slackUserId: origin?.slackUserId ?? "", }, tb, }; const tools = buildSlackTools(ctx); let messages = convertThreadToMessages(thread, botUserId);
if (messages.length === 0 && userText) { messages = [{ role: "user" as const, content: userText }]; }
if (messages.length === 0) { return { text: "I couldn't read your message. Please try again.", toolResults: [], finishReason: "unknown", stepCount: 0, hitStepLimit: false, }; }
const result = await generateText({ model: MODEL, system: buildSystemPrompt(workspace.name ?? "Unknown"), messages, tools, stopWhen: stepCountIs(MAX_STEPS), });
const toolResults: AgentResult["toolResults"] = []; for (const step of result.steps) { for (const tc of step.toolResults) { toolResults.push({ toolName: tc.toolName, result: tc.output }); } }
return { text: result.text, toolResults, finishReason: result.finishReason, stepCount: result.steps.length, hitStepLimit: result.steps.length >= MAX_STEPS, };}