cal.pub0.org/packages/app-store/ee/routing_forms/trpc-router.ts

import { Prisma } from "@prisma/client";
import { z } from "zod";

import { createProtectedRouter } from "@server/createRouter";
import { TRPCError } from "@trpc/server";

import { zodFields, zodRoutes } from "./zod";

const app_RoutingForms = createProtectedRouter()
  .query("forms", {
    async resolve({ ctx: { user, prisma } }) {
      return await prisma.app_RoutingForms_Form.findMany({
        where: {
          userId: user.id,
        },
        orderBy: {
          createdAt: "asc",
        },
      });
    },
  })
  .query("form", {
    input: z.object({
      id: z.string(),
    }),
    async resolve({ ctx: { prisma }, input }) {
      const form = await prisma.app_RoutingForms_Form.findFirst({
        where: {
          id: input.id,
        },
      });

      return form;
    },
  })
  .mutation("form", {
    input: z.object({
      id: z.string(),
      name: z.string(),
      description: z.string().nullable().optional(),
      disabled: z.boolean().optional(),
      fields: zodFields,
      routes: zodRoutes,
    }),
    async resolve({ ctx: { user, prisma }, input }) {
      const { name, id, routes, description, disabled } = input;
      let { fields } = input;
      fields = fields || [];
      return await prisma.app_RoutingForms_Form.upsert({
        where: {
          id: id,
        },
        create: {
          user: {
            connect: {
              id: user.id,
            },
          },
          fields: fields,
          name: name,
          description,
          // Prisma doesn't allow setting null value directly for JSON. It recommends using JsonNull for that case.
          routes: routes === null ? Prisma.JsonNull : routes,
          id: id,
        },
        update: {
          disabled: disabled,
          fields: fields,
          name: name,
          description,
          routes: routes === null ? Prisma.JsonNull : routes,
        },
      });
    },
  })
  // TODO: Can't se use DELETE method on form?
  .mutation("deleteForm", {
    input: z.object({
      id: z.string(),
    }),
    async resolve({ ctx, input }) {
      return await ctx.prisma.app_RoutingForms_Form.delete({
        where: {
          id: input.id,
        },
      });
    },
  })
  .mutation("response", {
    input: z.object({
      formId: z.string(),
      formFillerId: z.string(),
      response: z.record(
        z.object({
          label: z.string(),
          value: z.union([z.string(), z.array(z.string())]),
        })
      ),
    }),
    async resolve({ ctx: { prisma }, input }) {
      try {
        const { response, formId } = input;
        const form = await prisma.app_RoutingForms_Form.findFirst({
          where: {
            id: formId,
          },
        });
        if (!form) {
          throw new TRPCError({
            code: "NOT_FOUND",
          });
        }
        const fieldsParsed = zodFields.safeParse(form.fields);
        if (!fieldsParsed.success) {
          // This should not be possible normally as before saving the form it is verified by zod
          throw new TRPCError({
            code: "INTERNAL_SERVER_ERROR",
          });
        }

        const fields = fieldsParsed.data;

        if (!fields) {
          // There is no point in submitting a form that doesn't have fields defined
          throw new TRPCError({
            code: "BAD_REQUEST",
          });
        }

        const missingFields = fields
          .filter((field) => !(field.required ? response[field.id]?.value : true))
          .map((f) => f.label);

        if (missingFields.length) {
          throw new TRPCError({
            code: "BAD_REQUEST",
            message: `Missing required fields ${missingFields.join(", ")}`,
          });
        }
        const invalidFields = fields
          .filter((field) => {
            const fieldValue = response[field.id]?.value;
            // The field isn't required at this point. Validate only if it's set
            if (!fieldValue) {
              return false;
            }
            let schema;
            if (field.type === "email") {
              schema = z.string().email();
            } else if (field.type === "phone") {
              schema = z.any();
            } else {
              schema = z.any();
            }
            return !schema.safeParse(fieldValue).success;
          })
          .map((f) => ({ label: f.label, type: f.type }));

        if (invalidFields.length) {
          throw new TRPCError({
            code: "BAD_REQUEST",
            message: `Invalid fields ${invalidFields.map((f) => `${f.label}: ${f.type}`)}`,
          });
        }

        return await prisma.app_RoutingForms_FormResponse.create({
          data: input,
        });
      } catch (e) {
        if (e instanceof Prisma.PrismaClientKnownRequestError) {
          if (e.code === "P2002") {
            throw new TRPCError({
              code: "CONFLICT",
            });
          }
        }
        throw e;
      }
    },
  });

export default app_RoutingForms;