Function recordTimedOutAttempt

apps/sim/lib/core/outbox/service.ts:396–436

(
  event: typeof outboxEvent.$inferSelect,
  errMsg: string
)

}

async function recordTimedOutAttempt(
  event: typeof outboxEvent.$inferSelect,
  errMsg: string
): Promise<'dead_letter' | 'lease_lost'> {
  const nextAttempts = event.attempts + 1
  const isDead = nextAttempts >= event.maxAttempts

  if (isDead) {
    const updated = await updateIfLeaseHeld(event, {
      attempts: nextAttempts,
      status: 'dead_letter',
      lastError: errMsg,
      processedAt: new Date(),
      lockedAt: null,
    })
    if (!updated) return 'lease_lost'
    logger.error('Outbox event dead-lettered after handler timeout max attempts', {
      eventId: event.id,
      eventType: event.eventType,
      attempts: nextAttempts,
      error: errMsg,
    })
    return 'dead_letter'
  }

  const updated = await updateProcessingIfLeaseHeld(event, {
    attempts: nextAttempts,
    lastError: errMsg,
    lockedAt: new Date(),
  })
  if (!updated) return 'lease_lost'

  logger.warn('Outbox event handler timed out; leaving lease for stuck-row reaper', {
    eventId: event.id,
    eventType: event.eventType,
    attempts: nextAttempts,
    reaperThresholdMs: STUCK_PROCESSING_THRESHOLD_MS,
    error: errMsg,
  })
  return 'lease_lost'
}

async function scheduleRetry(
  event: typeof outboxEvent.$inferSelect,