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
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369import { eq } from "@openstatus/db";import { selectWorkspaceSchema, workspace } from "@openstatus/db/src/schema";import { getLimits } from "@openstatus/db/src/schema/plan/utils";import { addUserToWorkspace, createTestWorkspace, createUser,} from "@openstatus/db/src/test/factories";import { expect } from "@std/expect";import { describe, test } from "@std/testing/bdd";import { ZodError } from "zod";
import { expectAuditRow, makeApiKeyCtx, makeUserCtx, readAuditLog, withTestTransaction,} from "../../../test/helpers";import { ConflictError, ForbiddenError } from "../../errors";import { getWorkspaceForMember, listWorkspaceOwners, updateWorkspaceLimits, updateWorkspaceStripeId,} from "../index.ts";
describe("getWorkspaceForMember", () => { test("resolves the workspace by slug for a member, with their email", async () => { const { workspace: ws, user } = await createTestWorkspace({ plan: "free" });
const found = await getWorkspaceForMember({ input: { slug: ws.slug, userId: user.id }, });
expect(found?.workspace.id).toBe(ws.id); expect(found?.email).toBe(user.email); expect(typeof found?.workspace.limits).toBe("object"); });
test("returns null for a user who is not a member", async () => { const { workspace: ws } = await createTestWorkspace({ plan: "free" }); const stranger = await createUser();
const found = await getWorkspaceForMember({ input: { slug: ws.slug, userId: stranger.id }, });
expect(found).toBeNull(); });
test("returns null for an unknown slug", async () => { const { user } = await createTestWorkspace({ plan: "free" }); const found = await getWorkspaceForMember({ input: { slug: `missing-${crypto.randomUUID()}`, userId: user.id }, }); expect(found).toBeNull(); });});
describe("listWorkspaceOwners", () => { test("lists owners only", async () => { const { workspace: ws, user: owner } = await createTestWorkspace({ plan: "free", }); const member = await createUser(); await addUserToWorkspace(member.id, ws.id, "member");
const owners = await listWorkspaceOwners({ input: { workspaceId: ws.id }, });
expect(owners).toEqual([{ id: owner.id, email: owner.email }]); });
test("skips owners whose account was deleted", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user: owner } = await createTestWorkspace( { plan: "free" }, tx, ); const gone = await createUser({ deletedAt: new Date() }, tx); await addUserToWorkspace(gone.id, ws.id, "owner", tx);
const owners = await listWorkspaceOwners({ input: { workspaceId: ws.id }, db: tx, });
expect(owners).toEqual([{ id: owner.id, email: owner.email }]); }); });});
describe("updateWorkspaceStripeId", () => { test("links the customer and audits the change", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user } = await createTestWorkspace( { plan: "free", stripeId: null }, tx, ); const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await updateWorkspaceStripeId({ ctx, input: { stripeId: "cus_linked" } });
const after = await tx .select() .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(after?.stripeId).toBe("cus_linked");
await expectAuditRow({ workspaceId: ws.id, action: "workspace.update", entityType: "workspace", entityId: ws.id, actorType: "user", db: tx, }); const [audit] = await readAuditLog({ workspaceId: ws.id, entityType: "workspace", entityId: ws.id, db: tx, }); expect(audit?.changedFields).toContain("stripeId"); }); });
test("refuses to replace a customer linked by a concurrent request", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user } = await createTestWorkspace( { plan: "free", stripeId: "cus_first" }, tx, ); // Snapshot from before the other request linked its customer. const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse({ ...ws, stripeId: null }), { userId: user.id, }), db: tx, };
await expect( updateWorkspaceStripeId({ ctx, input: { stripeId: "cus_second" } }), ).rejects.toBeInstanceOf(ConflictError);
const after = await tx .select({ stripeId: workspace.stripeId }) .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(after?.stripeId).toBe("cus_first"); }); });
test("re-linking the same customer is a no-op", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user } = await createTestWorkspace( { plan: "free", stripeId: "cus_same" }, tx, ); const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await updateWorkspaceStripeId({ ctx, input: { stripeId: "cus_same" } });
const audits = await readAuditLog({ workspaceId: ws.id, entityType: "workspace", entityId: ws.id, db: tx, }); expect(audits).toHaveLength(0); }); });
test("rejects a read-only api key actor", async () => { await withTestTransaction(async (tx) => { const { workspace: ws } = await createTestWorkspace({ plan: "free" }, tx); const ctx = { ...makeApiKeyCtx(selectWorkspaceSchema.parse(ws), { keyId: "k-read", userId: 1, scopes: ["read"], }), db: tx, }; await expect( updateWorkspaceStripeId({ ctx, input: { stripeId: "cus_x" } }), ).rejects.toBeInstanceOf(ForbiddenError); }); });});
describe("updateWorkspaceLimits", () => { test("applies the addon, clears the trial when told, and stamps the reason", async () => { await withTestTransaction(async (tx) => { const trialEndsAt = new Date("2027-01-15T00:00:00Z"); const { workspace: ws, user } = await createTestWorkspace( { plan: "starter", trialEndsAt, limits: JSON.stringify(getLimits("starter")), }, tx, ); const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await updateWorkspaceLimits({ ctx, input: { addon: "monitors", value: 99, trialEndsAt: null, reason: "trial_converted", }, });
const after = await tx .select() .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(JSON.parse(after?.limits ?? "{}")).toEqual({ ...getLimits("starter"), monitors: 99, }); expect(after?.trialEndsAt).toBeNull();
const [audit] = await readAuditLog({ workspaceId: ws.id, entityType: "workspace", entityId: ws.id, db: tx, }); expect(audit?.changedFields).toContain("limits"); expect(audit?.changedFields).toContain("trialEndsAt"); expect(audit?.metadata).toMatchObject({ reason: "trial_converted" }); }); });
test("merges into the current limits, not the caller's snapshot", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user } = await createTestWorkspace( { plan: "starter", limits: JSON.stringify(getLimits("starter")) }, tx, ); // Both calls carry the same pre-change workspace snapshot. const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await updateWorkspaceLimits({ ctx, input: { addon: "white-label", value: true }, }); await updateWorkspaceLimits({ ctx, input: { addon: "monitors", value: 42 }, });
const after = await tx .select() .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(JSON.parse(after?.limits ?? "{}")).toEqual({ ...getLimits("starter"), "white-label": true, monitors: 42, }); }); });
test("leaves trialEndsAt alone when not given", async () => { await withTestTransaction(async (tx) => { const trialEndsAt = new Date("2027-01-15T00:00:00Z"); const { workspace: ws, user } = await createTestWorkspace( { plan: "starter", trialEndsAt, limits: JSON.stringify(getLimits("starter")), }, tx, ); const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await updateWorkspaceLimits({ ctx, input: { addon: "monitors", value: 5 }, });
const after = await tx .select() .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(after?.trialEndsAt).toEqual(trialEndsAt); }); });
test("rejects a value of the wrong kind instead of persisting unchanged limits", async () => { await withTestTransaction(async (tx) => { const { workspace: ws, user } = await createTestWorkspace( { plan: "starter", limits: JSON.stringify(getLimits("starter")) }, tx, ); const ctx = { ...makeUserCtx(selectWorkspaceSchema.parse(ws), { userId: user.id }), db: tx, };
await expect( updateWorkspaceLimits({ ctx, input: { addon: "monitors", value: false }, }), ).rejects.toBeInstanceOf(ZodError); await expect( updateWorkspaceLimits({ ctx, input: { addon: "white-label", value: 3 }, }), ).rejects.toBeInstanceOf(ZodError);
const after = await tx .select() .from(workspace) .where(eq(workspace.id, ws.id)) .get(); expect(JSON.parse(after?.limits ?? "{}")).toEqual(getLimits("starter")); }); });
test("rejects a read-only api key actor", async () => { await withTestTransaction(async (tx) => { const { workspace: ws } = await createTestWorkspace({ plan: "free" }, tx); const ctx = { ...makeApiKeyCtx(selectWorkspaceSchema.parse(ws), { keyId: "k-read", userId: 1, scopes: ["read"], }), db: tx, }; await expect( updateWorkspaceLimits({ ctx, input: { addon: "white-label", value: true }, }), ).rejects.toBeInstanceOf(ForbiddenError); }); });});