Vitest

// test/setup.ts
import { varianzVitest } from '@varianz/vitest';

export const { test } = varianzVitest({
  // endpoint omitted: falls back to VARIANZ_REGISTRY_ADDR / VARIANZ_ENDPOINT,
  // then http://127.0.0.1:50051
  applicationName: 'my-service-tests',
});
export { describe, expect, beforeAll } from 'vitest';
export { cel } from '@varianz/vitest';

// vitest.config.ts
import { defineConfig } from 'vitest/config';

export default defineConfig({
  test: {
    setupFiles: ['@varianz/vitest/setup'],  // installs the custom matchers
    fileParallelism: false,                 // initRegistry is process-global
  },
});

import { test, expect, cel, describe } from './setup.js';
import { PricingService } from '../src/service.js';

describe('pricing', () => {
  test('bulk discount applies at 10+', async ({ varianz }) => {
    await varianz.insert(cel(
      'pricing/calculate',
      'args.input.quantity >= 10 ' +
        '? PricingResult { totalPrice: args.input.basePrice * args.input.quantity * 0.9, discountApplied: true } ' +
        ': invoke()',
    ));

    await varianz.awaitSyncOrFail(5_000);

    // The fixture has already entered the session scope for the test body —
    // in-process calls match session stages without extra wiring.
    const out = new PricingService().calculate(input);

    expect(out.totalPrice).toBeCloseTo(108);
    await expect(varianz).toEventuallyHaveSample('price-result', { within: 5_000 });
  });
});

await expect(varianz).toEventuallyHaveSample('price-result', { within: 5_000 });
await expect(varianz).toHaveSampleValue('price-result', 108, { path: 'totalPrice', within: 10_000 });

await varianz.run(() => service.calculate(input));