await ctx.db.transaction(async (tx) => {
await tx.insert(businessTable).values({
businessName: input.businessName,
description: input.description,
email: input.email,
hasAgreedTerms: input.hasAgreedTerms,
userId: ctx.userId
});
const business = await tx.select({ businessId: businessTable.businessId }).from(businessTable).where(eq(businessTable.userId, ctx.userId));
const businessId = business[0]?.businessId;
await tx.insert(businessAddressTable).values({
addressOne: input.addressOne,
addressTwo: input.addressTwo,
city: input.city,
postCode: input.postCode,
countryId: input.countryId,
businessId: businessId
});
});
await ctx.db.transaction(async (tx) => {
await tx.insert(businessTable).values({
businessName: input.businessName,
description: input.description,
email: input.email,
hasAgreedTerms: input.hasAgreedTerms,
userId: ctx.userId
});
const business = await tx.select({ businessId: businessTable.businessId }).from(businessTable).where(eq(businessTable.userId, ctx.userId));
const businessId = business[0]?.businessId;
await tx.insert(businessAddressTable).values({
addressOne: input.addressOne,
addressTwo: input.addressTwo,
city: input.city,
postCode: input.postCode,
countryId: input.countryId,
businessId: businessId
});
});