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.6 kB · 99 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100import { Events } from "@openstatus/analytics";import { CreateInvitationInput, acceptInvitation, createInvitation, deleteInvitation, getInvitationByToken, listInvitations,} from "@openstatus/services/invitation";import { TRPCError } from "@trpc/server";import { z } from "zod";
import { toServiceCtx, toTRPCError } from "../service-adapter";import { createTRPCRouter, protectedProcedure } from "../trpc";
export const invitationRouter = createTRPCRouter({ create: protectedProcedure .meta({ track: Events.InviteUser, trackProps: ["email"] }) .input(CreateInvitationInput) .mutation(async ({ ctx, input }) => { try { return await createInvitation({ ctx: toServiceCtx(ctx), input, }); } catch (err) { toTRPCError(err); } }),
delete: protectedProcedure .input(z.object({ id: z.number() })) .meta({ track: Events.DeleteInvite }) .mutation(async ({ ctx, input }) => { try { await deleteInvitation({ ctx: toServiceCtx(ctx), input: { id: input.id }, }); } catch (err) { toTRPCError(err); } }),
list: protectedProcedure.query(async ({ ctx }) => { try { return await listInvitations({ ctx: toServiceCtx(ctx) }); } catch (err) { toTRPCError(err); } }),
get: protectedProcedure .input(z.object({ token: z.string().nullable() })) .query(async ({ ctx, input }) => { if (!input.token) { throw new TRPCError({ code: "BAD_REQUEST", message: "Token is required.", }); } if (!ctx.user.email) { throw new TRPCError({ code: "UNAUTHORIZED", message: "You are not authorized to access this resource.", }); } try { return await getInvitationByToken({ ctx: toServiceCtx(ctx), input: { token: input.token, email: ctx.user.email }, }); } catch (err) { toTRPCError(err); } }),
accept: protectedProcedure .input(z.object({ id: z.number() })) .mutation(async ({ ctx, input }) => { if (!ctx.user.email) { throw new TRPCError({ code: "UNAUTHORIZED", message: "You are not authorized to access this resource.", }); } try { return await acceptInvitation({ ctx: toServiceCtx(ctx), input: { id: input.id, email: ctx.user.email, }, }); } catch (err) { toTRPCError(err); } }),});