Function createOrGetOrganization

packages/trpc/src/routers/onboarding.ts:13–59

(
  input: z.infer<typeof zOnboardingProject>,
  user: IServiceUser,
)

import { createTRPCRouter, protectedProcedure, publicProcedure } from '../trpc';

async function createOrGetOrganization(
  input: z.infer<typeof zOnboardingProject>,
  user: IServiceUser,
) {
  if (input.organizationId) {
    return await getOrganizationById(input.organizationId);
  }

  const TRIAL_DURATION_IN_DAYS = 30;
  // Generous trial allowance so trialing orgs never get flagged as
  // "limit exceeded" (the limit defaults to 0, which trips on the first event).
  const TRIAL_EVENTS_LIMIT = 10_000_000;

  if (input.organization) {
    const organizationId = await getId('organization', input.organization);

    // Create the organization and its owner (org:admin member) atomically. The
    // `delete` cron treats an organization with no org:admin member as ownerless
    // and removes it, so an organization must never exist without one.
    const [organization] = await db.$transaction([
      db.organization.create({
        data: {
          id: organizationId,
          name: input.organization,
          createdByUserId: user.id,
          subscriptionEndsAt: addDays(new Date(), TRIAL_DURATION_IN_DAYS),
          subscriptionStatus: 'trialing',
          subscriptionPeriodEventsLimit: TRIAL_EVENTS_LIMIT,
          timezone: input.timezone,
          onboarding: '',
        },
      }),
      db.member.create({
        data: {
          email: user.email,
          organizationId,
          role: 'org:admin',
          userId: user.id,
        },
      }),
    ]);

    return organization;
  }

  return null;
}

export const onboardingRouter = createTRPCRouter({
  skipOnboardingCheck: publicProcedure.query(async ({ ctx }) => {