process.test.ts

import { afterEach, beforeEach, describe, expect, it } from 'vitest';
import { getEventsForOffer } from '../events/log';
import { __resetActivityStore, getOfferSnapshot } from '../routers/deals';
import { __resetIdempotencyStore } from './idempotency';
import { processPartnerWebhook } from './process';

const NEEDS_ATTENTION_OFFER = 'a7b3c1d4-2e5f-4a68-9d70-5c2e8f1b4a09';
const TRACKING_OFFER = 'c4e9f2a1-8b5d-4f7a-9c2e-1d3b6a8e0f42';

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

afterEach(() => {
  __resetActivityStore();
  __resetIdempotencyStore();
});

describe('processPartnerWebhook', () => {
  it('returns offer_not_found when offer_id is unknown', () => {
    const result = processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: 'does-not-exist',
      idempotency_key: 'k1',
    });
    expect(result).toEqual({ kind: 'offer_not_found' });
  });

  it('appends audit + effects and reprojects on attribution_verified', () => {
    const before = getOfferSnapshot(NEEDS_ATTENTION_OFFER);
    expect(before?.user_offer_activity.status).toBe('RETRY');
    expect(before?._bucket).toBe('pending');

    const result = processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'evt_verify_1',
    });
    expect(result.kind).toBe('ok');

    const after = getOfferSnapshot(NEEDS_ATTENTION_OFFER);
    expect(after?.user_offer_activity.status).toBe('IN_PROGRESS');
    expect(after?._bucket).toBe('in_progress');

    const events = getEventsForOffer(NEEDS_ATTENTION_OFFER);
    const kinds = events.map((e) => e.kind);
    expect(kinds).toContain('partner_webhook_received');
    expect(kinds).toContain('offer_updated');
    expect(kinds).toContain('activity_status_changed');
  });

  it('returns duplicate and appends no new events for a repeated idempotency key', () => {
    const first = processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'evt_dup',
    });
    expect(first.kind).toBe('ok');
    const firstCount = getEventsForOffer(NEEDS_ATTENTION_OFFER).length;

    const second = processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'evt_dup',
    });
    expect(second.kind).toBe('duplicate');
    if (first.kind === 'ok' && second.kind === 'duplicate') {
      expect(second.event_seq).toBe(first.event_seq);
    }
    expect(getEventsForOffer(NEEDS_ATTENTION_OFFER).length).toBe(firstCount);
  });

  it('scopes idempotency per partner_slug', () => {
    processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'shared',
    });
    const between = getEventsForOffer(NEEDS_ATTENTION_OFFER).length;

    const result = processPartnerWebhook({
      partner_slug: 'gokart',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'shared',
    });
    expect(result.kind).toBe('ok');
    expect(getEventsForOffer(NEEDS_ATTENTION_OFFER).length).toBeGreaterThan(between);
  });

  it('returns invalid for milestone_completed without an event_id', () => {
    const result = processPartnerWebhook({
      partner_slug: 'gokart',
      event_name: 'milestone_completed',
      offer_id: TRACKING_OFFER,
      idempotency_key: 'k1',
    });
    expect(result.kind).toBe('invalid');
    if (result.kind === 'invalid') {
      expect(result.reason).toMatch(/event_id/i);
    }
  });

  it('moves the offer to completed bucket on reward_paid', () => {
    processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'reward_paid',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'k1',
    });
    const after = getOfferSnapshot(NEEDS_ATTENTION_OFFER);
    expect(after?._bucket).toBe('completed');
    expect(after?.user_offer_activity.status).toBe('COMPLETED');
  });

  it('moves the offer back to RETRY on attribution_failed', () => {
    processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_verified',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'a',
    });
    expect(getOfferSnapshot(NEEDS_ATTENTION_OFFER)?.user_offer_activity.status).toBe(
      'IN_PROGRESS',
    );

    processPartnerWebhook({
      partner_slug: 'adjoe',
      event_name: 'attribution_failed',
      offer_id: NEEDS_ATTENTION_OFFER,
      idempotency_key: 'b',
    });
    expect(getOfferSnapshot(NEEDS_ATTENTION_OFFER)?.user_offer_activity.status).toBe('RETRY');
  });
});