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
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125import { beforeEach, describe, expect, test } from "@openstatus/test-utils";// The double stands in for @slack/web-api via the test import map.import { WebClient } from "@slack/web-api";
import { slackTestState } from "@/libs/test/doubles/slack-test-state";
import { channelContextTooling, contextChannelId, contextUserId, forgetContext, recallContext, rememberContext,} from "./channel-context";
const redisStore = (globalThis as Record<string, unknown>) .__testRedisStore as Map<string, string>;
describe("reading the context payload", () => { test("takes the authorizing human, not the bot", () => { expect( contextUserId([ { user_id: "B9", is_bot: true }, { user_id: "U1", is_bot: false }, ]), ).toBe("U1"); });
test("falls back to any authorization carrying a user", () => { expect(contextUserId([{ user_id: "U2" }])).toBe("U2"); expect(contextUserId([])).toBeUndefined(); expect(contextUserId(undefined)).toBeUndefined(); });
test("takes the first channel, since entities are ranked by relevance", () => { expect( contextChannelId([ { type: "slack#/types/user_id", value: "U9" }, { type: "slack#/types/channel_id", value: "C_FIRST" }, { type: "slack#/types/channel_id", value: "C_SECOND" }, ]), ).toBe("C_FIRST"); });
test("has nothing to report for an empty context", () => { expect(contextChannelId([])).toBeUndefined(); expect(contextChannelId(undefined)).toBeUndefined(); expect( contextChannelId([{ type: "slack#/types/channel_id" }]), ).toBeUndefined(); });});
describe("the remembered channel", () => { beforeEach(() => redisStore.clear());
test("round-trips per user and can be cleared", async () => { expect(await recallContext("T1", "U1")).toBeUndefined();
await rememberContext("T1", "U1", "C_INCIDENT"); expect(await recallContext("T1", "U1")).toBe("C_INCIDENT"); expect(await recallContext("T1", "U2")).toBeUndefined();
await forgetContext("T1", "U1"); expect(await recallContext("T1", "U1")).toBeUndefined(); });});
describe("the read_slack_channel tool", () => { beforeEach(() => { slackTestState.calls = []; slackTestState.historyImpl = () => Promise.resolve({ messages: [ { user: "U2", text: "second", ts: "2.0" }, { user: "U1", text: "first", ts: "1.0" }, ], }); });
function tooling() { return channelContextTooling({ slack: new WebClient("xoxb-test"), channelId: "C_INCIDENT", }); }
test("names the channel in a form Slack renders", () => { const { contextNote } = tooling(); expect(contextNote).toContain("<#C_INCIDENT>"); expect(contextNote).toContain("/invite @openstatus"); });
test("returns the discussion oldest first", async () => { const { tools } = tooling(); // biome-ignore lint/suspicious/noExplicitAny: AI SDK tool execute shape const result = (await (tools.read_slack_channel as any).execute({})) as { messages: Array<{ text: string }>; };
// Slack hands back newest first; a summary reads forwards. expect(result.messages.map((m) => m.text)).toEqual(["first", "second"]); });
test("hands a missing membership back as data, not an exception", async () => { slackTestState.historyImpl = () => { const err = new Error("An API error occurred: not_in_channel"); Object.assign(err, { code: "slack_webapi_platform_error", data: { ok: false, error: "not_in_channel" }, }); return Promise.reject(err); };
const { tools } = tooling(); // biome-ignore lint/suspicious/noExplicitAny: AI SDK tool execute shape const result = (await (tools.read_slack_channel as any).execute({})) as { error: string; };
// The model needs to explain this, so it must not blow up the turn. expect(result.error).toBe("not_in_channel"); });});