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.
4.3 kB · 140 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141import { customDomainSchema } from "@openstatus/db/src/schema/pages/validation";import { assertCustomDomainInWorkspace } from "@openstatus/services/page";import { z } from "zod";
import { env } from "../env";import { type domainConfigResponseSchema, fetchDomainConfig, getCertificateReadiness, issueCertificateOnVercel, vercelFetch,} from "../lib/vercel";import { toServiceCtx, toTRPCError } from "../service-adapter";import { createTRPCRouter, protectedProcedure } from "../trpc";
export const domainResponseSchema = z.object({ name: z.string().optional(), apexName: z.string().optional(), projectId: z.string().optional(), redirect: z.string().optional().nullable(), redirectStatusCode: z .union([z.literal(307), z.literal(301), z.literal(302), z.literal(308)]) .optional() .nullable(), gitBranch: z.string().optional().nullable(), updatedAt: z.number().optional(), createdAt: z.number().optional(), verified: z.boolean().optional(), verification: z .array( z.object({ type: z.string(), domain: z.string(), value: z.string(), reason: z.string(), }), ) .optional(),});
export type DomainVerificationResponse = z.infer<typeof domainResponseSchema>;export type DomainConfigResponse = z.infer<typeof domainConfigResponseSchema>;export type DomainResponse = z.infer<typeof domainResponseSchema>;export type DomainVerificationStatusProps = | "Valid Configuration" | "Invalid Configuration" | "Pending Verification" | "Generating SSL Certificate" | "Domain Not Found" | "Unknown Error";
async function assertOwned( ctx: Parameters<typeof toServiceCtx>[0], domain: string,) { try { await assertCustomDomainInWorkspace({ ctx: toServiceCtx(ctx), input: { domain }, }); } catch (err) { toTRPCError(err); }}
const domainInput = z.object({ domain: customDomainSchema.optional() });
export const domainRouter = createTRPCRouter({ getDomainResponse: protectedProcedure .input(domainInput) .query(async (opts) => { if (!opts.input.domain) { return null; } await assertOwned(opts.ctx, opts.input.domain); const data = await vercelFetch( `/v9/projects/${env.PROJECT_ID_VERCEL}/domains/${encodeURIComponent(opts.input.domain)}?teamId=${env.TEAM_ID_VERCEL}`, ); const json = await data.json(); const result = domainResponseSchema .extend({ error: z .object({ code: z.string(), message: z.string(), }) .optional(), }) .parse(json); return result; }), getConfigResponse: protectedProcedure .input(domainInput) .query(async (opts) => { if (!opts.input.domain) { return null; } await assertOwned(opts.ctx, opts.input.domain); return fetchDomainConfig(opts.input.domain); }), getCertificateStatus: protectedProcedure .input(domainInput) .query(async (opts) => { if (!opts.input.domain) { return null; } await assertOwned(opts.ctx, opts.input.domain); const { ready } = await getCertificateReadiness(opts.input.domain); return { ready }; }), issueCertificate: protectedProcedure .input(domainInput) .mutation(async (opts) => { if (!opts.input.domain) { return { issued: false }; } await assertOwned(opts.ctx, opts.input.domain); const { configured, ready } = await getCertificateReadiness( opts.input.domain, ); if (!configured || ready) { return { issued: false }; } await issueCertificateOnVercel(opts.input.domain); return { issued: true }; }), verifyDomain: protectedProcedure.input(domainInput).query(async (opts) => { if (!opts.input.domain) { return null; } await assertOwned(opts.ctx, opts.input.domain); const data = await vercelFetch( `/v9/projects/${env.PROJECT_ID_VERCEL}/domains/${encodeURIComponent(opts.input.domain)}/verify?teamId=${env.TEAM_ID_VERCEL}`, { method: "POST" }, ); const json = await data.json(); const result = domainResponseSchema.parse(json); return result; }),});