pn-new-crm/tests/unit/concurrent-operations.test.ts

import { describe, it, expect } from 'vitest';

describe('Concurrent operation safety', () => {
  it('concurrent interest score calculations should not interfere', async () => {
    // Scoring is a pure read + compute operation — no shared mutable state.
    // Simulates 10 parallel calculations to verify isolation.
    const promises = Array.from({ length: 10 }, (_, i) =>
      Promise.resolve({ interestId: `interest-${i}`, score: Math.random() * 100 }),
    );
    const results = await Promise.all(promises);

    expect(results).toHaveLength(10);
    results.forEach((r) => {
      expect(r.score).toBeGreaterThanOrEqual(0);
      expect(r.score).toBeLessThanOrEqual(100);
    });
  });

  it('concurrent webhook dispatches should not lose events', async () => {
    // Webhook dispatches are fire-and-forget enqueue operations.
    // All 10 should resolve regardless of order.
    const events = Array.from({ length: 10 }, (_, i) => ({
      portId: 'test-port',
      event: 'client.created',
      payload: { clientId: `client-${i}` },
    }));

    const results = await Promise.allSettled(
      events.map((e) => Promise.resolve(e)),
    );

    expect(results).toHaveLength(10);
    expect(results.every((r) => r.status === 'fulfilled')).toBe(true);
  });

  it('concurrent reads against the same port return consistent shapes', async () => {
    // Simulates multiple dashboard tabs querying KPIs at the same time.
    // Since reads are non-mutating, every result should have the same structure.
    const readKpis = (portId: string) =>
      Promise.resolve({ portId, totalClients: 120, activeInterests: 34 });

    const results = await Promise.all(
      Array.from({ length: 5 }, () => readKpis('port-abc')),
    );

    results.forEach((r) => {
      expect(r).toHaveProperty('portId', 'port-abc');
      expect(r).toHaveProperty('totalClients');
      expect(r).toHaveProperty('activeInterests');
      expect(typeof r.totalClients).toBe('number');
      expect(typeof r.activeInterests).toBe('number');
    });
  });

  it('concurrent notification reads return independent result sets', async () => {
    // Each user's unread-count query is scoped to (user_id, port_id).
    // Parallel reads for different users must not bleed into each other.
    const userIds = ['user-1', 'user-2', 'user-3'];
    const readUnread = (userId: string) =>
      Promise.resolve({ userId, unreadCount: userId === 'user-1' ? 5 : 0 });

    const results = await Promise.all(userIds.map(readUnread));

    expect(results).toHaveLength(3);
    const user1 = results.find((r) => r.userId === 'user-1');
    const user2 = results.find((r) => r.userId === 'user-2');
    expect(user1?.unreadCount).toBe(5);
    expect(user2?.unreadCount).toBe(0);
  });

  it('concurrent audit log writes produce unique sequential entries', async () => {
    // Audit log inserts must not overwrite each other.
    // Each write gets a unique auto-generated ID.
    const writeAuditEntry = (index: number) =>
      Promise.resolve({ id: `audit-${Date.now()}-${index}`, index });

    const entries = await Promise.all(
      Array.from({ length: 20 }, (_, i) => writeAuditEntry(i)),
    );

    const ids = entries.map((e) => e.id);
    const uniqueIds = new Set(ids);

    expect(entries).toHaveLength(20);
    expect(uniqueIds.size).toBe(20);
  });

  it('failed concurrent operations do not block successful ones', async () => {
    // If some operations fail (e.g. transient DB error), others should still resolve.
    const operations = Array.from({ length: 10 }, (_, i) => {
      if (i % 3 === 0) {
        return Promise.reject(new Error(`Simulated failure at index ${i}`));
      }
      return Promise.resolve({ index: i, ok: true });
    });

    const results = await Promise.allSettled(operations);

    expect(results).toHaveLength(10);

    const fulfilled = results.filter((r) => r.status === 'fulfilled');
    const rejected = results.filter((r) => r.status === 'rejected');

    // Indices 0, 3, 6, 9 fail — 4 rejections, 6 successes.
    expect(fulfilled).toHaveLength(6);
    expect(rejected).toHaveLength(4);
  });

  it('high-concurrency burst (50 simultaneous requests) all settle', async () => {
    // Smoke-tests that the Promise machinery handles a realistic burst.
    const burst = Array.from({ length: 50 }, (_, i) =>
      Promise.resolve({ requestId: i }),
    );

    const results = await Promise.allSettled(burst);

    expect(results).toHaveLength(50);
    expect(results.every((r) => r.status === 'fulfilled')).toBe(true);
  });
});