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.
4.5 kB · 144 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145import { db, eq } from "@openstatus/db";import { maintenance, page } from "@openstatus/db/src/schema";import { createUser } from "@openstatus/db/src/test/factories";import { expect } from "@std/expect";import { beforeAll, describe, test } from "@std/testing/bdd";
import { createWorkspaceFixture, makeApiKeyCtx, makeSystemCtx, makeUserCtx, withTestTransaction,} from "../../../test/helpers";import { listMaintenancesTool } from "../../agent-tools/maintenance";import type { ServiceContext } from "../../context";import { createMaintenance } from "../create";import { getMaintenance } from "../list";import { updateMaintenance } from "../update";
const TEST_PREFIX = "svc-maintenance-attribution";
let teamCtx: ServiceContext;let ownerId: number;let pageId: number;
beforeAll(async () => { const fixture = await createWorkspaceFixture("team"); ownerId = fixture.userId; teamCtx = makeUserCtx(fixture.workspace, { userId: ownerId }); const row = await db .insert(page) .values({ workspaceId: fixture.workspace.id, title: `${TEST_PREFIX}-page`, description: "", slug: `${TEST_PREFIX}-${fixture.workspace.id}`, customDomain: "", }) .returning() .get(); pageId = row.id;});
function range() { const from = new Date(Date.now() + 60 * 60 * 1000); return { from, to: new Date(from.getTime() + 60 * 60 * 1000) };}
async function create(ctx: ServiceContext, title: string) { const { maintenance } = await createMaintenance({ ctx, input: { title: `${TEST_PREFIX}-${title}`, message: "planned", ...range(), pageId, pageComponentIds: [], }, }); return maintenance;}
describe("maintenance attribution", () => { test("user actor stamps both columns and reads back", async () => { await withTestTransaction(async (tx) => { const ctx = { ...teamCtx, db: tx }; const record = await create(ctx, "user"); expect(record.createdBy).toBe(ownerId); expect(record.updatedBy).toBe(ownerId);
const full = await getMaintenance({ ctx, input: { id: record.id } }); const owner = { id: ownerId, name: "Test User", email: expect.stringContaining("@openstatus.dev"), // the factory stores "", which the projection normalizes to null photoUrl: null, }; expect(full.createdByUser).toEqual(owner); expect(full.updatedByUser).toEqual(owner); }); });
test("agent tool output carries the name only", async () => { await withTestTransaction(async (tx) => { const ctx = { ...teamCtx, db: tx }; const record = await create(ctx, "agent"); const output = await listMaintenancesTool.run({ ctx, input: { pageId, page: 1, perPage: 50 }, }); const item = output.items.find((i) => i.id === record.id); const agentUser = { id: ownerId, name: "Test User" }; expect(item?.createdBy).toEqual(agentUser); expect(item?.updatedBy).toEqual(agentUser); }); });
test("api key without a user and system actor leave NULL", async () => { await withTestTransaction(async (tx) => { const anonKey = { ...makeApiKeyCtx(teamCtx.workspace, { keyId: "k", scopes: ["write"] }), db: tx, }; const viaKey = await create(anonKey, "key"); expect(viaKey.createdBy).toBeNull(); expect(viaKey.updatedBy).toBeNull();
const system = { ...makeSystemCtx(teamCtx.workspace, { job: "test" }), db: tx, }; const viaSystem = await create(system, "system"); expect(viaSystem.createdBy).toBeNull();
const full = await getMaintenance({ ctx: anonKey, input: { id: viaKey.id }, }); expect(full.createdByUser).toBeNull(); }); });
test("update moves updated_by and keeps created_by", async () => { await withTestTransaction(async (tx) => { const editor = await createUser({}, tx); const record = await create({ ...teamCtx, db: tx }, "edit"); await updateMaintenance({ ctx: { ...makeUserCtx(teamCtx.workspace, { userId: editor.id }), db: tx, }, input: { id: record.id, title: `${TEST_PREFIX}-renamed` }, }); const row = await tx .select() .from(maintenance) .where(eq(maintenance.id, record.id)) .get(); expect(row?.createdBy).toBe(ownerId); expect(row?.updatedBy).toBe(editor.id); }); });});