Function createOrganization

apps/web/src/lib/organizations/organizations.ts:188–250

(
  name: string,
  // this is only used in tests
  // TODO(bmc): remove this from tests in the future. nbd rn.
  userId?: User['id'] | null,
  addUserAsOwner: boolean = true,
  company_domain?: string,
  plan?: 'teams' | 'enterprise'
)

export async function getProfileOrganizations(
  userId: User['id'],
  options: GetProfileOrganizationsOptions = {}
): Promise<ProfileOrganization[]> {
  const { excludeAccessBlocked = false } = options;

  // Only pull in each org's current subscription status when the caller needs
  // to hide "Access Blocked" orgs. organization_seats_purchases is append-only,
  // so the most recently created row reflects the current state. This keeps
  // getProfileOrganizations a single query and adds no seat-purchase lookup for
  // callers that don't opt in.
  const latestSeatPurchaseStatus = excludeAccessBlocked
    ? sql<OrganizationSeatsPurchase['subscription_status'] | null>`(
        SELECT ${organization_seats_purchases.subscription_status}
        FROM ${organization_seats_purchases}
        WHERE ${organization_seats_purchases.organization_id} = ${organizations.id}
        ORDER BY ${organization_seats_purchases.created_at} DESC
        LIMIT 1
      )`
    : sql<OrganizationSeatsPurchase['subscription_status'] | null>`NULL`;

  const results = await db
    .select({
      organization: organizations,
      membership: organization_memberships,
      latestSeatPurchaseStatus,
    })
    .from(organizations)
    .innerJoin(
      organization_memberships,
      eq(organization_memberships.organization_id, organizations.id)
    )
    .where(and(eq(organization_memberships.kilo_user_id, userId), isNull(organizations.deleted_at)))
    // Deterministic order so callers can treat the first element as a stable
    // default selection (e.g. profile `selectedOrganizationId`). Old form was
    // created_at, id; sales-demo orgs win so profile selectedOrganizationId is
    // the demo org.
    .orderBy(
      desc(sql`COALESCE((${organizations.settings}->>'is_sales_demo')::boolean, false)`),
      asc(organizations.created_at),
      asc(organizations.id)
    );

  const parentOrganizationIdsWithMembershipInAChild = new Set(
    results.flatMap(result =>
      result.organization.parent_organization_id ? [result.organization.parent_organization_id] : []
    )
  );

  const now = new Date();
  return results
    .filter(result => !parentOrganizationIdsWithMembershipInAChild.has(result.organization.id))
    .filter(result => {
      if (!excludeAccessBlocked) return true;
      const classification = classifyOrganizationEntitlement({
        organization: result.organization,
        latestSeatPurchaseStatus: result.latestSeatPurchaseStatus,
        now,
      });
      return !classification.isTrialExpiredForEnforcement;