Function insertOrganization

apps/cloud/src/auth/user-store.ts:67–94

(
  db: DrizzleDb,
  row: Pick<Organization, "id" | "name" | "workosUpdatedAt" | "deletedAt">,
)

 *   surfacing loudly beats a silently unslugged organization.
 */
export const insertOrganization = async (
  db: DrizzleDb,
  row: Pick<Organization, "id" | "name" | "workosUpdatedAt" | "deletedAt">,
): Promise<Organization> => {
  const slugTaken = async (slug: string) => {
    const rows = await db
      .select({ id: organizations.id })
      .from(organizations)
      .where(eq(organizations.slug, slug));
    return rows.length > 0;
  };
  for (let attempt = 0; attempt < 4; attempt++) {
    const slug = await generateOrgSlug(row.name, slugTaken);
    const [inserted] = await db
      .insert(organizations)
      .values({ ...row, slug })
      .onConflictDoNothing()
      .returning();
    if (inserted) return inserted;
    // The insert was swallowed by a conflict. If the id now exists, a
    // concurrent writer mirrored it — return that row. Otherwise the slug
    // candidate collided; loop and mint a fresh one.
    const held = await readOrganization(db, row.id);
    if (held) return held;
  }
  // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: slug minting exhausted retries; surfacing loudly beats a silently unslugged org
  throw new Error(`unable to mint a slug for organization ${row.id}`);
};

export const makeUserStore = (db: DrizzleDb) => {
  const getOrganization = (id: string) => readOrganization(db, id);