Function register

apps/app-server/src/trpc/api/users/account/register.ts:29–104

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

export const registerProcedure = once(() => baseProcedure.mutation(register));

export async function register({
  ctx,
  input,
}: InferProcedureOpts<typeof baseProcedure>) {
  let emailVerificationCode: string | null;

  await ctx.dataAbstraction.transaction(async (dtrx) => {
    // Get user

    let user = await UserModel.query()
      .where('email_hash', Buffer.from(hashUserEmail(input.email)))
      .where((builder) =>
        builder
          .where('email_verified', true)
          .orWhere('email_verification_expiration_date', '>', new Date()),
      )
      .select('email_verified', 'email_verification_code')
      .first();

    // Check if user already exists

    if (user != null) {
      // User already exists, check if email is verified

      if (user.email_verified) {
        throw new TRPCError({
          message: 'Email already registered.',
          code: 'CONFLICT',
        });
      } else {
        await sendRegistrationEmail({
          email: input.email,
          emailVerificationCode: user.email_verification_code,
        });

        throw new TRPCError({
          message: 'Email awaiting verification. New email sent.',
          code: 'UNAUTHORIZED',
        });
      }
    }

    // Create user

    user = await registerUser({
      ...input,

      ip: ctx.req.ip,
      userAgent: ctx.req.headers['user-agent'] ?? '',

      passwordValues: derivePasswordValues({ password: input.loginHash }),

      dtrx,
    });

    // Send email

    if (process.env.SEND_EMAILS !== 'false') {