Function create

apps/app-server/src/trpc/api/pages/create.ts:26–141

({
  ctx,
  input,
}: InferProcedureOpts<typeof baseProcedure>)

export const createProcedure = once(() => baseProcedure.mutation(create));

export async function create({
  ctx,
  input,
}: InferProcedureOpts<typeof baseProcedure>) {
  return await ctx.usingLocks(
    [[`user-lock:${ctx.userId}`], [`group-lock:${input.groupId}`]],
    async (signals) => {
      return await ctx.dataAbstraction.transaction(async (dtrx) => {
        // Check sufficient permissions

        if (input.groupCreation == null) {
          await ctx.assertSufficientGroupPermissions({
            userId: ctx.userId,
            groupId: input.groupId,
            permission: 'editGroupPages',
          });
        }

        // Get some necessary user data

        const [userPlan, personalGroupId] = await ctx.dataAbstraction.hmget(
          'user',
          ctx.userId,
          ['plan', 'personal-group-id'],
        );

        // Assert agent is subscribed

        if (input.groupId !== personalGroupId || input.groupCreation != null) {
          await ctx.assertUserSubscribed({ userId: ctx.userId });
        }

        // Check if can create page

        let numFreePages;

        if (userPlan !== 'pro') {
          numFreePages =
            (await ctx.dataAbstraction.hget(
              'user',
              ctx.userId,
              'num-free-pages',
            )) + 1;

          if (numFreePages > 50) {
            throw new TRPCError({
              code: 'FORBIDDEN',
              message: 'You have reached your limit of 50 free pages.',
            });
          }

          await ctx.dataAbstraction.patch(
            'user',
            ctx.userId,
            { num_free_pages: numFreePages },
            { dtrx },
          );
        }