Function createUser

packages/database/auth/drizzle-adapter.ts:73–229

(userData: CreateUserData)

export function DrizzleAdapter(db: MySql2Database): Adapter {
	return {
		async createUser(userData: CreateUserData) {
			const normalizedEmail = userData.email.toLowerCase();
			let userId = User.UserId.make(nanoId());
			await db.transaction(async (tx) => {
				const [existingUser] = await tx
					.select()
					.from(users)
					.where(eq(users.email, normalizedEmail))
					.limit(1);

				if (existingUser) {
					userId = existingUser.id;
					const userUpdate: Partial<typeof users.$inferInsert> = {};

					if (!existingUser.name && userData.name) {
						userUpdate.name = userData.name;
					}
					if (!existingUser.name && !userData.name) {
						userUpdate.name = getProvisionedUserName(normalizedEmail);
					}
					if (!existingUser.emailVerified && userData.emailVerified) {
						userUpdate.emailVerified = userData.emailVerified;
					}
					if (!existingUser.image && userData.image) {
						userUpdate.image = userData.image as ImageUpload.ImageUrlOrKey;
					}

					if (Object.keys(userUpdate).length > 0) {
						await tx.update(users).set(userUpdate).where(eq(users.id, userId));
					}

					return;
				}

				const [pendingInvite] = await tx
					.select({ id: organizationInvites.id })
					.from(organizationInvites)
					.where(
						and(
							eq(organizationInvites.invitedEmail, normalizedEmail),
							eq(organizationInvites.status, "pending"),
						),
					)
					.limit(1);

				await tx.insert(users).values({
					id: userId,
					email: normalizedEmail,
					emailVerified: userData.emailVerified,
					name: userData.name,
					image: userData.image as ImageUpload.ImageUrlOrKey | null,
					activeOrganizationId: Organisation.OrganisationId.make(""),
				});

				if (pendingInvite) {
					return;
				}