Function enqueueOutboxEvent

apps/sim/lib/core/outbox/service.ts:98–114

(
  executor: Pick<typeof db, 'insert'>,
  eventType: string,
  payload: T,
  options: EnqueueOptions = {}
)

 * a transaction some other way (or none at all).
 */
export async function enqueueOutboxEvent<T>(
  executor: Pick<typeof db, 'insert'>,
  eventType: string,
  payload: T,
  options: EnqueueOptions = {}
): Promise<string> {
  const id = generateId()
  await executor.insert(outboxEvent).values({
    id,
    eventType,
    payload: payload as never,
    maxAttempts: options.maxAttempts ?? DEFAULT_MAX_ATTEMPTS,
    availableAt: options.availableAt ?? new Date(),
  })
  logger.info('Enqueued outbox event', { id, eventType })
  return id
}

/** Cap on how many dead-lettered rows a single reconciler scan materializes. */
const DEAD_LETTER_SCAN_LIMIT = 100