idempotency.test.ts

import { beforeEach, describe, expect, it } from 'vitest';
import {
  __resetIdempotencyStore,
  checkIdempotency,
  compositeKey,
  markIdempotent,
} from './idempotency';

beforeEach(() => {
  __resetIdempotencyStore();
});

describe('idempotency store', () => {
  it('builds composite keys scoped by partner', () => {
    expect(compositeKey('adjoe', 'evt_1')).toBe('adjoe:evt_1');
    expect(compositeKey('gokart', 'evt_1')).toBe('gokart:evt_1');
    expect(compositeKey('adjoe', 'evt_1')).not.toBe(compositeKey('gokart', 'evt_1'));
  });

  it('returns null for an unseen key', () => {
    expect(checkIdempotency('adjoe:unseen')).toBeNull();
  });

  it('returns the stored record for a seen key', () => {
    markIdempotent('adjoe:k', { seq: 42, at: '2026-04-22T12:00:00.000Z' });
    expect(checkIdempotency('adjoe:k')).toEqual({
      seq: 42,
      at: '2026-04-22T12:00:00.000Z',
    });
  });

  it('reset clears all records', () => {
    markIdempotent('adjoe:k', { seq: 1, at: 'now' });
    __resetIdempotencyStore();
    expect(checkIdempotency('adjoe:k')).toBeNull();
  });
});