Function updateIfLeaseHeld

apps/sim/lib/core/outbox/service.ts:557–580

* Conditional terminal update scoped to the lease acquired at claim * time. Returns true if the UPDATE affected a row, false if the row's * lease was revoked (reaped, reclaimed by another worker). Callers * treat `false` as a "lease lost" signal and skip without retrying — * the newer owner is r

(
  event: typeof outboxEvent.$inferSelect,
  patch: {
    status: 'completed' | 'pending' | 'dead_letter'
    attempts?: number
    lastError?: string | null
    availableAt?: Date
    lockedAt: Date | null
    processedAt?: Date | null
  }
)

 * the newer owner is responsible for the row now.
 */
async function updateIfLeaseHeld(
  event: typeof outboxEvent.$inferSelect,
  patch: {
    status: 'completed' | 'pending' | 'dead_letter'
    attempts?: number
    lastError?: string | null
    availableAt?: Date
    lockedAt: Date | null
    processedAt?: Date | null
  }
): Promise<boolean> {
  const whereClauses = [eq(outboxEvent.id, event.id), eq(outboxEvent.status, 'processing')]
  if (event.lockedAt) {
    whereClauses.push(eq(outboxEvent.lockedAt, event.lockedAt))
  }

  const result = await db
    .update(outboxEvent)
    .set(patch)
    .where(and(...whereClauses))
    .returning({ id: outboxEvent.id })

  return result.length > 0
}