Function scheduleRetry

apps/sim/lib/core/outbox/service.ts:438–498

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

}

async function scheduleRetry(
  event: typeof outboxEvent.$inferSelect,
  errMsg: string,
  minimumBackoffMs = 0
): Promise<'pending' | '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) {
      logger.warn('Outbox event dead-letter skipped — lease lost', {
        eventId: event.id,
        eventType: event.eventType,
      })
      return 'lease_lost'
    }
    logger.error('Outbox event dead-lettered after max attempts', {
      eventId: event.id,
      eventType: event.eventType,
      attempts: nextAttempts,
      error: errMsg,
    })
    return 'dead_letter'
  }

  const backoffMs = Math.max(
    minimumBackoffMs,
    Math.min(MAX_BACKOFF_MS, BASE_BACKOFF_MS * 2 ** nextAttempts)
  )
  const nextAvailableAt = new Date(Date.now() + backoffMs)
  const updated = await updateIfLeaseHeld(event, {
    attempts: nextAttempts,
    status: 'pending',
    lastError: errMsg,
    availableAt: nextAvailableAt,
    lockedAt: null,
  })
  if (!updated) {
    logger.warn('Outbox event retry-schedule skipped — lease lost', {
      eventId: event.id,
      eventType: event.eventType,
    })
    return 'lease_lost'
  }
  logger.warn('Outbox event failed, scheduled retry', {
    eventId: event.id,
    eventType: event.eventType,
    attempts: nextAttempts,
    backoffMs,
    nextAvailableAt: nextAvailableAt.toISOString(),
    error: errMsg,