From aaf4847fc2d026cbff20e161e10ea330c8ee05af Mon Sep 17 00:00:00 2001 From: Matt Ciaccio Date: Thu, 23 Apr 2026 23:47:12 +0200 Subject: [PATCH] refactor(yachts): use withTransaction helper per project convention --- src/lib/services/yachts.service.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/lib/services/yachts.service.ts b/src/lib/services/yachts.service.ts index 802a2af..af2c603 100644 --- a/src/lib/services/yachts.service.ts +++ b/src/lib/services/yachts.service.ts @@ -5,6 +5,7 @@ import { companies } from '@/lib/db/schema/companies'; import { createAuditLog } from '@/lib/audit'; import { NotFoundError, ValidationError } from '@/lib/errors'; import { emitToRoom } from '@/lib/socket/server'; +import { withTransaction } from '@/lib/db/utils'; import type { z } from 'zod'; import type { createYachtSchema } from '@/lib/validators/yachts'; @@ -36,8 +37,8 @@ async function assertOwnerExists( } export async function createYacht(portId: string, data: CreateYachtInput, meta: AuditMeta) { - return await db.transaction(async (tx) => { - await assertOwnerExists(portId, data.owner, tx as unknown as typeof db); + return await withTransaction(async (tx) => { + await assertOwnerExists(portId, data.owner, tx); const [yacht] = await tx .insert(yachts)