Function runHandlerWithTimeout

apps/sim/lib/core/outbox/service.ts:522–548

(
  handler: OutboxHandler,
  event: typeof outboxEvent.$inferSelect,
  timeoutMs: number = DEFAULT_HANDLER_TIMEOUT_MS
)

}

function runHandlerWithTimeout(
  handler: OutboxHandler,
  event: typeof outboxEvent.$inferSelect,
  timeoutMs: number = DEFAULT_HANDLER_TIMEOUT_MS
): Promise<void> {
  const context: OutboxEventContext = {
    eventId: event.id,
    eventType: event.eventType,
    attempts: event.attempts,
  }

  return new Promise((resolve, reject) => {
    const timeout = setTimeout(() => {
      reject(new OutboxHandlerTimeoutError(timeoutMs))
    }, timeoutMs)

    handler(event.payload, context)
      .then((value) => {
        clearTimeout(timeout)
        resolve(value)
      })
      .catch((err) => {
        clearTimeout(timeout)
        reject(err)
      })
  })
}

/**
 * Conditional terminal update scoped to the lease acquired at claim