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.
3.0 kB · 104 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105import type { ExternalServiceRow } from "@openstatus/services/external-service";import type { DetectionResult, FetchError, StatusPageProvider,} from "@openstatus/status-fetcher";
export const PROBE_TTL_MS = 24 * 60 * 60 * 1000;
const lastProbeAt = new Map<string, number>();
// check-and-set: stamps on `true` so a no-result probe still waits out the TTLexport function shouldProbe( slug: string, now: number, map: Map<string, number> = lastProbeAt,): boolean { const last = map.get(slug); if (last !== undefined && now - last < PROBE_TTL_MS) return false; map.set(slug, now); return true;}
// refunds the TTL after a failed write so the next tick retriesexport function clearProbeStamp( slug: string, map: Map<string, number> = lastProbeAt,): void { map.delete(slug);}
const BLOCKED_STATUSES = new Set([401, 403, 429]);
// Bot challenges and rate limits say nothing about the provider; probing them// daily only adds noise.export function isBlocked(err: FetchError): boolean { return ( err.kind === "http" && err.httpStatus !== undefined && BLOCKED_STATUSES.has(err.httpStatus) );}
export function isSuspicious(err: FetchError): boolean { if (err.kind === "parse" || err.kind === "schema") return true; return ( err.kind === "http" && err.httpStatus !== undefined && err.httpStatus < 500 && !isBlocked(err) );}
export type DetectionAction = | { kind: "apply"; provider: StatusPageProvider; evidence: string[] } | { kind: "clear-config"; evidence: string[] } | { kind: "suggest"; suggestion: string; evidence: string[] } | { kind: "noop"; reason: "transient" | "no-evidence"; evidence: string[] };
export function decideDetectionAction( result: DetectionResult, row: Pick<ExternalServiceRow, "provider" | "apiConfig">,): DetectionAction { const { evidence } = result; if (result.currentProviderValidated) { return row.apiConfig?.endpoint ? { kind: "clear-config", evidence } : { kind: "noop", reason: "transient", evidence }; } const single = result.matches.length === 1 ? result.matches[0] : undefined; if (single) { return { kind: "apply", provider: single.provider, evidence }; } if (result.matches.length >= 2) { return { kind: "suggest", suggestion: result.matches .map((m) => m.provider) .sort() .join("|"), evidence, }; } // A move needs a status_page_url edit, which stays manual. if (result.movedTo) { const providers = result.movedTo.matches .map((m) => m.provider) .sort() .join("|"); return { kind: "suggest", suggestion: `${providers} at ${result.movedTo.base}`, evidence, }; } if (result.hostnameSuggestions.length > 0) { return { kind: "suggest", suggestion: [...result.hostnameSuggestions].sort().join("|"), evidence, }; } return { kind: "noop", reason: "no-evidence", evidence };}