claude-bot/EJClaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: apply prettier formatting

Browse Source
This commit is contained in:
ejclaw
2026-04-09 16:31:19 +09:00
parent 1e46b05b03
commit 0461e401e8
2 changed files with 21 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/db/paired-state.ts
View File

@@ -559,11 +559,7 @@ export function claimPairedTurnReservationInDatabase(
AND status = ? AND status = ?
`, `,
) )
.run( .run(args.taskId, args.taskUpdatedAt, args.taskStatus);
args.taskId,
args.taskUpdatedAt,
args.taskStatus,
);
if (claimedTask.changes === 0) { if (claimedTask.changes === 0) {
throw new PairedTurnReservationClaimError(); throw new PairedTurnReservationClaimError();

23
src/db/schema.ts
View File

@@ -75,8 +75,9 @@ function inferLegacyExecutionLeaseServiceId(
case 'owner': { case 'owner': {
const ownerAgentType = normalizePairedAgentType(row.owner_agent_type); const ownerAgentType = normalizePairedAgentType(row.owner_agent_type);
return ( return (
(row.owner_service_id ? normalizeServiceId(row.owner_service_id) : null) ?? (row.owner_service_id
resolveRoleServiceShadow('owner', ownerAgentType) ? normalizeServiceId(row.owner_service_id)
: null) ?? resolveRoleServiceShadow('owner', ownerAgentType)
); );
} }
case 'reviewer': { case 'reviewer': {
@@ -86,8 +87,7 @@ function inferLegacyExecutionLeaseServiceId(
return ( return (
(row.reviewer_service_id (row.reviewer_service_id
? normalizeServiceId(row.reviewer_service_id) ? normalizeServiceId(row.reviewer_service_id)
: null) ?? : null) ?? resolveRoleServiceShadow('reviewer', reviewerAgentType)
resolveRoleServiceShadow('reviewer', reviewerAgentType)
); );
} }
case 'arbiter': { case 'arbiter': {
@@ -95,8 +95,7 @@ function inferLegacyExecutionLeaseServiceId(
return ( return (
(row.arbiter_service_id (row.arbiter_service_id
? normalizeServiceId(row.arbiter_service_id) ? normalizeServiceId(row.arbiter_service_id)
: null) ?? : null) ?? resolveRoleServiceShadow('arbiter', arbiterAgentType)
resolveRoleServiceShadow('arbiter', arbiterAgentType)
); );
} }
default: default:
@@ -106,7 +105,11 @@ function inferLegacyExecutionLeaseServiceId(
function backfillLegacyExecutionLeaseServiceShadows(database: Database): void { function backfillLegacyExecutionLeaseServiceShadows(database: Database): void {
if ( if (
!tableHasColumn(database, 'paired_task_execution_leases', 'claimed_service_id') !tableHasColumn(
database,
'paired_task_execution_leases',
'claimed_service_id',
)
) { ) {
return; return;
} }
@@ -163,7 +166,8 @@ function backfillLegacyExecutionLeaseServiceShadows(database: Database): void {
AND claimed_service_id IS NULL AND claimed_service_id IS NULL
`, `,
); );
const tx = database.transaction((leaseRows: LegacyExecutionLeaseServiceRow[]) => { const tx = database.transaction(
(leaseRows: LegacyExecutionLeaseServiceRow[]) => {
for (const row of leaseRows) { for (const row of leaseRows) {
const claimedServiceId = inferLegacyExecutionLeaseServiceId(row); const claimedServiceId = inferLegacyExecutionLeaseServiceId(row);
if (!claimedServiceId) { if (!claimedServiceId) {
@@ -171,7 +175,8 @@ function backfillLegacyExecutionLeaseServiceShadows(database: Database): void {
} }
update.run(claimedServiceId, row.rowid); update.run(claimedServiceId, row.rowid);
} }
}); },
);
tx(rows); tx(rows);
} }