@kiwa-test/data

Data pipeline / queue / cron / batch test adapter for kiwa.

Overview

@kiwa-test/data provides deterministic primitives for testing message queues, cron-scheduled jobs, and batch pipelines without booting external infrastructure:

• setupQueueEnv({ mode }) — in-memory queue with FIFO ordering, dedupKey-based idempotency, at-least-once consume semantics, and DLQ.
• createFakeClock({ startMs }) — drive time forward in a single line; cron-style schedule(intervalMs, fn) fires deterministically.
• expectIdempotent / expectAtLeastOnce — assertion helpers for delivery semantics.

Install

pnpm add -D @kiwa-test/data @kiwa-test/core vitest

Queue env

import { setupQueueEnv } from "@kiwa-test/data";

const env = await setupQueueEnv<Order>({ mode: "mock", maxReceiveCount: 3 });
const unsubscribe = env.client.consume(async (msg, ack) => {
  if (canProcess(msg.body)) ack.ack();
  else ack.nack();
});
env.client.send({ orderId: "1", amount: 100 });
// later
unsubscribe();
expect(env.client.dlqSize()).toBe(0);
await env.stop();

Fake clock

import { createFakeClock } from "@kiwa-test/data";

const clock = createFakeClock();
const id = clock.schedule(100, () => doWork());
await clock.advanceMs(350); // doWork() fires 3 times deterministically
clock.unschedule(id);

Assertion helpers

import { expectIdempotent, expectAtLeastOnce } from "@kiwa-test/data";

await expectIdempotent(env.client, body, { dedupKey: "task-1" }, expect);
await expectAtLeastOnce(env.client, body, 3, expect);

Example: queue + cron PoC

See examples/queue-poc/ for the end-to-end PoC.

License

MIT