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
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197// Import the real module BEFORE mock.module runs so we can spread real// service functions (createSubscription, updateChannel, etc.) into the// replacement while still stubbing the dispatch-side spies.import * as realSubscriptions from "@openstatus/subscriptions";import { mock } from "@openstatus/test-utils";
// Subscription dispatch spies — accessible in tests via globalThis.__subscriptionSpiesconst dispatchStatusReportUpdateSpy = mock((_id: number) => Promise.resolve());const dispatchMaintenanceUpdateSpy = mock((_id: number) => Promise.resolve());
const sendVerificationSpy = mock( (_subscription: realSubscriptions.Subscription, _verifyUrl: string) => Promise.resolve(),);
const getChannelMock = { id: "email", sendVerification: sendVerificationSpy, sendNotifications: mock(() => Promise.resolve()), validateConfig: mock(() => Promise.resolve({ valid: true })),};
(globalThis as Record<string, unknown>).__subscriptionSpies = { dispatchStatusReportUpdate: dispatchStatusReportUpdateSpy, dispatchMaintenanceUpdate: dispatchMaintenanceUpdateSpy, sendVerification: sendVerificationSpy, getChannel: getChannelMock,};
mock.module("@openstatus/subscriptions", () => ({ ...realSubscriptions, dispatchStatusReportUpdate: dispatchStatusReportUpdateSpy, dispatchMaintenanceUpdate: dispatchMaintenanceUpdateSpy, getChannel: () => getChannelMock,}));
const testRedisStore = new Map<string, string>();(globalThis as Record<string, unknown>).__testRedisStore = testRedisStore;
mock.module("@openstatus/upstash", () => ({ Redis: { fromEnv() { return { get: (key: string) => Promise.resolve(testRedisStore.get(key) ?? null), set: (key: string, value: string) => { testRedisStore.set(key, value); return Promise.resolve("OK"); }, del: (key: string) => { const existed = testRedisStore.has(key) ? 1 : 0; testRedisStore.delete(key); return Promise.resolve(existed); }, getdel: (key: string) => { const value = testRedisStore.get(key) ?? null; testRedisStore.delete(key); return Promise.resolve(value); }, expire: (_key: string, _seconds: number) => { return Promise.resolve(1); }, }; }, },}));
const tinybirdMockData = { httpListBiweekly: [] as unknown[], httpGetBiweekly: [] as unknown[],};const tinybirdMockCalls = { httpListBiweekly: [] as unknown[], httpGetBiweekly: [] as unknown[],};
(globalThis as Record<string, unknown>).__tinybirdMockData = tinybirdMockData;(globalThis as Record<string, unknown>).__tinybirdMockCalls = tinybirdMockCalls;
const emptyTinybirdResponse = () => Promise.resolve({ data: [] });
const tbMock = { get legacy_httpStatus45d() { return emptyTinybirdResponse; }, get legacy_tcpStatus45d() { return emptyTinybirdResponse; }, get httpListBiweekly() { return (params: unknown) => { tinybirdMockCalls.httpListBiweekly.push(params); return Promise.resolve({ data: tinybirdMockData.httpListBiweekly }); }; }, get httpGetBiweekly() { return (params: unknown) => { tinybirdMockCalls.httpGetBiweekly.push(params); return Promise.resolve({ data: tinybirdMockData.httpGetBiweekly }); }; }, get httpMetricsDaily() { return emptyTinybirdResponse; }, get httpMetricsWeekly() { return emptyTinybirdResponse; }, get httpMetricsBiweekly() { return emptyTinybirdResponse; }, get tcpMetricsDaily() { return emptyTinybirdResponse; }, get tcpMetricsWeekly() { return emptyTinybirdResponse; }, get tcpMetricsBiweekly() { return emptyTinybirdResponse; }, get dnsMetricsDaily() { return emptyTinybirdResponse; }, get dnsMetricsWeekly() { return emptyTinybirdResponse; }, get dnsMetricsBiweekly() { return emptyTinybirdResponse; },};
mock.module("@/libs/clients", () => ({ tb: tbMock, redis: { get: (key: string) => Promise.resolve(testRedisStore.get(key) ?? null), set: (key: string, value: string) => { testRedisStore.set(key, value); return Promise.resolve("OK"); }, del: (key: string) => { const existed = testRedisStore.has(key) ? 1 : 0; testRedisStore.delete(key); return Promise.resolve(existed); }, getdel: (key: string) => { const value = testRedisStore.get(key) ?? null; testRedisStore.delete(key); return Promise.resolve(value); }, expire: (_key: string, _seconds: number) => Promise.resolve(1), },}));
mock.module("@openstatus/tinybird", () => ({ OSTinybird: class { get legacy_httpStatus45d() { return tbMock.legacy_httpStatus45d; } get legacy_tcpStatus45d() { return tbMock.legacy_tcpStatus45d; } get httpListBiweekly() { return tbMock.httpListBiweekly; } get httpGetBiweekly() { return tbMock.httpGetBiweekly; } // HTTP metrics for GetMonitorSummary get httpMetricsDaily() { return tbMock.httpMetricsDaily; } get httpMetricsWeekly() { return tbMock.httpMetricsWeekly; } get httpMetricsBiweekly() { return tbMock.httpMetricsBiweekly; } // TCP metrics for GetMonitorSummary get tcpMetricsDaily() { return tbMock.tcpMetricsDaily; } get tcpMetricsWeekly() { return tbMock.tcpMetricsWeekly; } get tcpMetricsBiweekly() { return tbMock.tcpMetricsBiweekly; } // DNS metrics for GetMonitorSummary get dnsMetricsDaily() { return tbMock.dnsMetricsDaily; } get dnsMetricsWeekly() { return tbMock.dnsMetricsWeekly; } get dnsMetricsBiweekly() { return tbMock.dnsMetricsBiweekly; } },}));