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.
7.3 kB · 269 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270import { expect } from "@std/expect";import { describe, test } from "@std/testing/bdd";import { z } from "zod";
import { isValidTimeZone, noopFlagSchema, OSTinybird, status15mParameters, status15mShape,} from "./client";
describe("noopFlagSchema", () => { test("treats the string 'false' as disabled, not as a truthy string", () => { expect(noopFlagSchema.parse("false")).toBe(false); expect(noopFlagSchema.parse("0")).toBe(false); expect(noopFlagSchema.parse("")).toBe(false); });
test("enables on the documented truthy spellings", () => { expect(noopFlagSchema.parse("true")).toBe(true); expect(noopFlagSchema.parse("1")).toBe(true); });
test("passes booleans through for schemas that already coerced", () => { expect(noopFlagSchema.parse(true)).toBe(true); expect(noopFlagSchema.parse(false)).toBe(false); });
test("defaults to disabled when unset or unrecognised", () => { expect(noopFlagSchema.parse(undefined)).toBe(false); expect(noopFlagSchema.parse("nope")).toBe(false); });});
describe("OSTinybird", () => { test("no-ops under NODE_ENV=test even when the call site asks for a real client", async () => { const tb = new OSTinybird({ token: "a-token", // Unroutable on purpose: a real client would reject instead of resolving. baseUrl: "http://127.0.0.1:1", noop: false, });
expect(await tb.homeStats({})).toEqual({ meta: [], data: [] }); });});
const listV2Getters = [ "httpListV2Daily", "httpListV2Weekly", "httpListV2Biweekly", "tcpListV2Daily", "tcpListV2Weekly", "tcpListV2Biweekly", "icmpListV2Daily", "icmpListV2Weekly", "icmpListV2Biweekly", "dnsListV2Biweekly", "grpcListV2Biweekly",] as const;
const facetGetters = [ "httpListFacets", "tcpListFacets", "icmpListFacets", "dnsListFacets", "grpcListFacets",] as const;
describe("v2 response-log list pipes", () => { const tb = new OSTinybird({ token: "a-token" });
for (const name of listV2Getters) { test(`${name} rejects a limit outside the pipe ceiling`, async () => { await expect(tb[name]({ monitorId: "1", limit: 1001 })).rejects.toThrow(); await expect(tb[name]({ monitorId: "1", limit: 0 })).rejects.toThrow(); });
test(`${name} rejects an unknown direction`, async () => { await expect( tb[name]({ monitorId: "1", limit: 50, direction: "sideways" as unknown as "next", }), ).rejects.toThrow(); });
test(`${name} accepts a filtered cursor page`, async () => { expect( await tb[name]({ monitorId: "1", limit: 50, cursor: 1_700_000_000_000, direction: "prev", fromDate: 1_699_000_000_000, toDate: 1_700_000_000_000, regions: ["ams"], status: ["error"], trigger: ["cron"], latencyMin: 0, latencyMax: 1000, }), ).toEqual({ meta: [], data: [] }); }); }
test("httpListV2Biweekly accepts a status-code filter", async () => { expect( await tb.httpListV2Biweekly({ monitorId: "1", limit: 50, statusCodes: [200, 500], }), ).toEqual({ meta: [], data: [] }); });
test("httpListV2Biweekly rejects oversized filter arrays", async () => { await expect( tb.httpListV2Biweekly({ monitorId: "1", limit: 50, regions: Array.from({ length: 129 }, (_, i) => `r${i}`), }), ).rejects.toThrow(); await expect( tb.httpListV2Biweekly({ monitorId: "1", limit: 50, statusCodes: Array.from({ length: 101 }, (_, i) => i), }), ).rejects.toThrow(); });});
describe("response-log facet pipes", () => { const tb = new OSTinybird({ token: "a-token" });
for (const name of facetGetters) { test(`${name} rejects a non-array region filter`, async () => { await expect( tb[name]({ monitorId: "1", regions: "ams" as unknown as string[], }), ).rejects.toThrow(); });
test(`${name} accepts the filter set without a cursor`, async () => { expect( await tb[name]({ monitorId: "1", fromDate: 1_699_000_000_000, toDate: 1_700_000_000_000, regions: ["ams"], status: ["error"], trigger: ["cron"], latencyMin: 0, latencyMax: 1000, }), ).toEqual({ meta: [], data: [] }); }); }});
const status15mGetters = [ "httpStatus15m", "tcpStatus15m", "dnsStatus15m", "icmpStatus15m", "grpcStatus15m",] as const;
describe("status15mParameters", () => { test("defaults timezone to UTC", () => { expect(status15mParameters.parse({ monitorIds: ["1"] })).toEqual({ monitorIds: ["1"], timezone: "UTC", }); });
test("forwards any zone untouched, fractional offsets included", () => { for (const timezone of [ "Europe/Berlin", "Asia/Kolkata", "Asia/Kathmandu", ]) { expect( status15mParameters.parse({ monitorIds: ["1", "2"], timezone }) .timezone, ).toBe(timezone); } });
test("rejects zone names ClickHouse would 400 on, before the request", () => { for (const timezone of ["Mars/Olympus", "", "GMT+1", "+05:30", "-03:00"]) { const result = status15mParameters.safeParse({ monitorIds: ["1"], timezone, }); expect(result.success).toBe(false); } expect(isValidTimeZone("Etc/GMT+1")).toBe(true); });});
describe("status15mShape", () => { const shape = status15mShape(z.coerce.string());
test("re-keys the local calendar date as UTC midnight, like the 45d pipes", () => { const row = shape.parse({ day: "2026-10-14", count: 10, ok: 9, degraded: 0, error: 1, monitorId: 1, }); expect(row.day).toBe("2026-10-14T00:00:00.000Z"); // the key every day-indexed consumer derives must be the local date itself expect(new Date(row.day).toISOString().split("T")[0]).toBe("2026-10-14"); expect(row.monitorId).toBe("1"); });
test("rejects a datetime or epoch `day`, which would re-introduce the UTC shift", () => { for (const day of [ "2026-10-13 22:00:00", "2026-10-13T22:00:00.000Z", 1760392800000, ]) { expect( shape.safeParse({ day, count: 0, ok: 0, degraded: 0, error: 0, monitorId: "1", }).success, ).toBe(false); } });
test("defaults missing counters to 0", () => { expect(shape.parse({ day: "2026-01-01", monitorId: "1" })).toMatchObject({ count: 0, ok: 0, degraded: 0, error: 0, }); });});
describe("15m status pipes", () => { const tb = new OSTinybird({ token: "a-token" });
for (const name of status15mGetters) { test(`${name} resolves for any zone and when timezone is omitted`, async () => { expect( await tb[name]({ monitorIds: ["1"], timezone: "Asia/Kolkata" }), ).toEqual({ meta: [], data: [] }); expect(await tb[name]({ monitorIds: ["1"] })).toEqual({ meta: [], data: [], }); }); }});