Function updateProcessingIfLeaseHeld

apps/sim/lib/core/outbox/service.ts:500–520

(
  event: typeof outboxEvent.$inferSelect,
  patch: {
    attempts: number
    lastError: string
    lockedAt: Date
  }
)

}

async function updateProcessingIfLeaseHeld(
  event: typeof outboxEvent.$inferSelect,
  patch: {
    attempts: number
    lastError: string
    lockedAt: Date
  }
): 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
}

function runHandlerWithTimeout(
  handler: OutboxHandler,