const record = await db.transaction(async (tx) => {
// First try to find the existing record
const existingRecord = await tx.query.records.findFirst({
where: eq(records.phoneNumber, '+15555555555'),
orderBy: asc(records.createdAt)
});
if (existingRecord) {
return existingRecord;
}
// If no record exists, create a new one
const [newRecord] = await tx.insert(records)
.values({
phoneNumber: '+15555555555'
})
.returning();
return newRecord;
});
const record = await db.transaction(async (tx) => {
// First try to find the existing record
const existingRecord = await tx.query.records.findFirst({
where: eq(records.phoneNumber, '+15555555555'),
orderBy: asc(records.createdAt)
});
if (existingRecord) {
return existingRecord;
}
// If no record exists, create a new one
const [newRecord] = await tx.insert(records)
.values({
phoneNumber: '+15555555555'
})
.returning();
return newRecord;
});