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.
2.7 kB · 85 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586import { db, eq } from "@openstatus/db";import { page, pageSubscriber } from "@openstatus/db/src/schema";import { createPage, createTestWorkspace,} from "@openstatus/db/src/test/factories";import { NextRequest } from "next/server.js";import { afterAll, beforeAll, describe, expect, test } from "vitest";
import { appRouter } from "../root";import { createInnerTRPCContext } from "../trpc";
let workspaceId: number;let pageId: number;let slug: string;
// No external email I/O in tests: capture outgoing requests instead.const realFetch = globalThis.fetch;const sent: { url: string; body: string }[] = [];
function caller() { return appRouter.createCaller( createInnerTRPCContext({ req: new NextRequest("http://rsc.internal"), session: null, }), );}
beforeAll(async () => { globalThis.fetch = (input, init) => { const url = input instanceof Request ? input.url : String(input); sent.push({ url, body: String(init?.body ?? "") }); return Promise.resolve( new Response(JSON.stringify({ id: "email_test" }), { status: 200, headers: { "content-type": "application/json" }, }), ); }; const fixture = await createTestWorkspace(); workspaceId = fixture.workspace.id; const _page = await createPage(workspaceId); pageId = _page.id; slug = _page.slug;});
afterAll(async () => { globalThis.fetch = realFetch; await db.delete(pageSubscriber).where(eq(pageSubscriber.pageId, pageId)); await db.delete(page).where(eq(page.workspaceId, workspaceId));});
describe("statusPage.subscribe", () => { test("never returns the verification token to the caller", async () => { const result = await caller().statusPage.subscribe({ slug, email: "someone-else@example.com", subscribeComponents: false, pageComponents: [], });
expect(result?.id).toBeDefined(); expect(result).not.toHaveProperty("token");
const row = await db.query.pageSubscriber.findFirst({ where: eq(pageSubscriber.id, result?.id ?? -1), }); expect(row?.token).toBeTruthy(); expect(row?.acceptedAt).toBeNull(); expect(JSON.stringify(result)).not.toContain(row?.token ?? "");
// The verification link went to the subscriber's mailbox instead. const email = sent.find((r) => r.body.includes("someone-else@example.com")); expect(email?.body).toContain(`/verify/${row?.token}`); });
test("the public token-based verification email endpoint is gone", () => { expect( Object.keys(appRouter._def.procedures).filter((p) => p.startsWith("emailRouter."), ), ).not.toContain("emailRouter.sendPageSubscriptionVerification"); });});