Function makeSource

apps/sim/lib/data-drains/service.test.ts:23–33

(pages: Row[][])

type Row = { id: string; ts: string }

function makeSource(pages: Row[][]) {
  return {
    type: 'workflow_logs' as const,
    displayName: 'Test',
    pages: vi.fn(async function* () {
      for (const page of pages) yield page
    }),
    serialize: vi.fn((row: Row) => row),
    cursorAfter: vi.fn((row: Row) => JSON.stringify({ ts: row.ts, id: row.id })),
  }
}

function makeDestination(
  opts: { deliver?: ReturnType<typeof vi.fn>; close?: ReturnType<typeof vi.fn> } = {}