From 0461e401e823c199b4352c3603fc0049bde258dd Mon Sep 17 00:00:00 2001 From: ejclaw Date: Thu, 9 Apr 2026 16:31:19 +0900 Subject: [PATCH] style: apply prettier formatting --- src/db/paired-state.ts | 6 +----- src/db/schema.ts | 35 ++++++++++++++++++++--------------- 2 files changed, 21 insertions(+), 20 deletions(-) diff --git a/src/db/paired-state.ts b/src/db/paired-state.ts index 5cf742b..194b907 100644 --- a/src/db/paired-state.ts +++ b/src/db/paired-state.ts @@ -559,11 +559,7 @@ export function claimPairedTurnReservationInDatabase( AND status = ? `, ) - .run( - args.taskId, - args.taskUpdatedAt, - args.taskStatus, - ); + .run(args.taskId, args.taskUpdatedAt, args.taskStatus); if (claimedTask.changes === 0) { throw new PairedTurnReservationClaimError(); diff --git a/src/db/schema.ts b/src/db/schema.ts index bace81a..ca7dc79 100644 --- a/src/db/schema.ts +++ b/src/db/schema.ts @@ -75,8 +75,9 @@ function inferLegacyExecutionLeaseServiceId( case 'owner': { const ownerAgentType = normalizePairedAgentType(row.owner_agent_type); return ( - (row.owner_service_id ? normalizeServiceId(row.owner_service_id) : null) ?? - resolveRoleServiceShadow('owner', ownerAgentType) + (row.owner_service_id + ? normalizeServiceId(row.owner_service_id) + : null) ?? resolveRoleServiceShadow('owner', ownerAgentType) ); } case 'reviewer': { @@ -86,8 +87,7 @@ function inferLegacyExecutionLeaseServiceId( return ( (row.reviewer_service_id ? normalizeServiceId(row.reviewer_service_id) - : null) ?? - resolveRoleServiceShadow('reviewer', reviewerAgentType) + : null) ?? resolveRoleServiceShadow('reviewer', reviewerAgentType) ); } case 'arbiter': { @@ -95,8 +95,7 @@ function inferLegacyExecutionLeaseServiceId( return ( (row.arbiter_service_id ? normalizeServiceId(row.arbiter_service_id) - : null) ?? - resolveRoleServiceShadow('arbiter', arbiterAgentType) + : null) ?? resolveRoleServiceShadow('arbiter', arbiterAgentType) ); } default: @@ -106,7 +105,11 @@ function inferLegacyExecutionLeaseServiceId( function backfillLegacyExecutionLeaseServiceShadows(database: Database): void { if ( - !tableHasColumn(database, 'paired_task_execution_leases', 'claimed_service_id') + !tableHasColumn( + database, + 'paired_task_execution_leases', + 'claimed_service_id', + ) ) { return; } @@ -163,15 +166,17 @@ function backfillLegacyExecutionLeaseServiceShadows(database: Database): void { AND claimed_service_id IS NULL `, ); - const tx = database.transaction((leaseRows: LegacyExecutionLeaseServiceRow[]) => { - for (const row of leaseRows) { - const claimedServiceId = inferLegacyExecutionLeaseServiceId(row); - if (!claimedServiceId) { - continue; + const tx = database.transaction( + (leaseRows: LegacyExecutionLeaseServiceRow[]) => { + for (const row of leaseRows) { + const claimedServiceId = inferLegacyExecutionLeaseServiceId(row); + if (!claimedServiceId) { + continue; + } + update.run(claimedServiceId, row.rowid); } - update.run(claimedServiceId, row.rowid); - } - }); + }, + ); tx(rows); }