@workkit/testing

In-memory mocks for all Cloudflare Workers bindings

Install

bun add -D @workkit/testing

Usage

Before (testing with Miniflare or mocking manually)

// Either spin up Miniflare (slow) or hand-roll mocks for every binding
const mockKV = {
  get: vi.fn(),
  put: vi.fn(),
  delete: vi.fn(),
  list: vi.fn(),
  getWithMetadata: vi.fn(),
}
// Repeat for D1, R2, Queue, DO... hundreds of lines of boilerplate

After (workkit testing)

import {
  createMockKV,
  createMockD1,
  createMockR2,
  createMockQueue,
  createMockDO,
  createTestEnv,
  createRequest,
  createExecutionContext,
} from "@workkit/testing"

// One-liner mocks with real behavior (Map-backed, with expiration support)
const kv = createMockKV()
await kv.put("key", "value", { expirationTtl: 60 })
const val = await kv.get("key") // "value"

// Full test env
const env = createTestEnv({
  MY_KV: createMockKV(),
  DB: createMockD1(),
  BUCKET: createMockR2(),
  QUEUE: createMockQueue(),
})

// Test helpers for requests and execution context
const request = createRequest("https://example.com/api/users", {
  method: "POST",
  body: { name: "Alice" },
})
const ctx = createExecutionContext()

const response = await worker.fetch(request, env, ctx)

API

createMockKV() — In-memory KVNamespace with expiration support
createMockD1() — In-memory D1Database mock
createFailingD1() — D1 mock that throws on every query (for error path testing)
createMockR2() — In-memory R2Bucket mock
createMockQueue() — In-memory Queue mock (stores sent messages)
createMockDO() — In-memory DurableObjectStorage mock
createTestEnv(bindings) — Compose bindings into a typed env object
createRequest(url, options?) — Create a Request with JSON body support
createExecutionContext() — Create an ExecutionContext with waitUntil and passThroughOnException

Observable Mocks

All mocks automatically track operations. Every createMock* return value includes operation tracking methods:

const kv = createMockKV()
await kv.put("key", "value")
await kv.get("key")

kv.operations   // [{ type: "write", key: "key", ... }, { type: "read", key: "key", ... }]
kv.reads()      // only read operations
kv.writes()     // only write operations
kv.deletes()    // only delete operations
kv.reset()      // clear tracked operations

Seed Builders

Pass initial data to createMockKV and createMockD1 for one-call fixture setup:

const kv = createMockKV({ "user:1": { name: "Alice" }, "user:2": { name: "Bob" } })
const db = createMockD1({ users: [{ id: 1, name: "Alice" }, { id: 2, name: "Bob" }] })

Error Injection

All mocks support error injection for testing failure paths:

const kv = createMockKV()
kv.failAfter(3)                         // fail after 3 successful operations
kv.failOn(/^admin:/)                    // fail on keys matching a pattern
kv.withLatency(50, 200)                 // add 50-200ms random latency
kv.clearInjections()                    // remove all injections

Environment Snapshots

Capture a summary of all bindings in a test env with snapshotEnv:

import { snapshotEnv } from "@workkit/testing"

const snap = snapshotEnv(env)
snap.summary   // { kv: 2, d1: 1, r2: 0, queue: 1, do: 0, var: 3 }
snap.bindings  // { MY_KV: { type: "kv", count: 5 }, DB: { type: "d1" }, ... }

License

MIT