Function makePendingRow

apps/sim/lib/core/outbox/service.test.ts:136–151

(overrides: Partial<OutboxRow> = {})

import { enqueueOutboxEvent, processOutboxEvents } from './service'

function makePendingRow(overrides: Partial<OutboxRow> = {}): OutboxRow {
  return {
    id: 'evt-1',
    eventType: 'test.event',
    payload: { foo: 'bar' },
    status: 'pending',
    attempts: 0,
    maxAttempts: 10,
    availableAt: new Date(Date.now() - 1000),
    lockedAt: null,
    lastError: null,
    createdAt: new Date(Date.now() - 5000),
    processedAt: null,
    ...overrides,
  }
}

function resetState() {
  state.claimedRows = []