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.4 kB · 90 lines
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091import { asc, db as defaultDb, eq, or, sql } from "@openstatus/db";import { type ExternalService, apiConfigSchema, externalService, selectExternalServiceSchema,} from "@openstatus/db/src/schema";
import { retryRead } from "../retry";import { type GlobalReadContext, liveOnlyClause } from "./internal";
export type ListExternalServicesInput = { includeDeleted?: boolean;};
export type ExternalServiceRow = ExternalService;
function parseRow(raw: ExternalService): ExternalService | null { if (raw.apiConfig != null) { const parsed = apiConfigSchema.safeParse(raw.apiConfig); if (!parsed.success) { console.warn( `[external-service] dropping row id=${raw.id} slug=${raw.slug}: invalid apiConfig`, parsed.error.issues, ); return null; } } return raw;}
function validateRows(rows: ReadonlyArray<unknown>): ExternalServiceRow[] { const out: ExternalServiceRow[] = []; for (const row of rows) { const select = selectExternalServiceSchema.safeParse(row); if (!select.success) { console.warn( "[external-service] dropping row: failed select schema", select.error.issues, ); continue; } const validated = parseRow(select.data); if (validated) out.push(validated); } return out;}
export async function listExternalServices(args: { ctx?: GlobalReadContext; input?: ListExternalServicesInput;}): Promise<ExternalServiceRow[]> { const { ctx, input } = args ?? {}; const db = ctx?.db ?? defaultDb;
const query = db .select() .from(externalService) .orderBy(asc(sql`lower(${externalService.name})`));
const rows = await retryRead(() => input?.includeDeleted ? query.all() : query.where(liveOnlyClause()).all(), );
return validateRows(rows);}
export async function getExternalServiceBySlug(args: { ctx?: GlobalReadContext; slug: string;}): Promise<ExternalServiceRow | null> { const { ctx, slug } = args; const db = ctx?.db ?? defaultDb;
const rows = await retryRead(() => db .select() .from(externalService) .where( or( eq(externalService.slug, slug), sql`EXISTS (SELECT 1 FROM json_each(${externalService.aliases}) WHERE value = ${slug})`, ), ) .all(), );
const validated = validateRows(rows); return validated[0] ?? null;}