import { Kysely, type DatabaseConnection } from 'kysely';

import { makeMockWarehouseDialect } from '../../test/stubs/makeMockWarehouseKyselyDialect.js';
import {
  makeMockPgDialect,
  type MockPgExecute,
} from '../../test/stubs/KyselyPg.js';
import { type UserStatisticsServiceWarehouse } from './dbTypes.js';
import { type makeFetchUserActionStatistics } from './fetchUserActionStatistics.js';
import { type makeFetchUserSubmissionStatistics } from './fetchUserSubmissionStatistics.js';
import { internalMakeUserStatisticsService } from './userStatisticsService.js';

describe('UserStatisticsService', () => {
  describe('refreshUserScoresCache', () => {
    test.todo('should fetch stats w/ batching and update accordingly');

    test('is a no-op without warehouse change streams', async () => {
      const warehouseMock = jest
        .fn<DatabaseConnection['executeQuery']>()
        .mockImplementation(async (_query) => {
          return { rows: [] };
        });

      const pgReadMock = jest
        .fn<MockPgExecute>()
        .mockResolvedValue({ rows: [], command: 'SELECT', rowCount: 0 });

      const pgWriteMock = jest
        .fn<MockPgExecute>()
        .mockResolvedValue({ rows: [], command: 'SELECT', rowCount: 0 });

      const fetchUserActionStatisticsMock = jest
        .fn<ReturnType<typeof makeFetchUserActionStatistics>>()
        .mockResolvedValue([]);

      const fetchUserSubmissionStatisticsMock = jest
        .fn<ReturnType<typeof makeFetchUserSubmissionStatistics>>()
        .mockResolvedValue([]);

      const warehouseKysely = new Kysely<UserStatisticsServiceWarehouse>({
        dialect: makeMockWarehouseDialect(warehouseMock),
      });

      const sut = internalMakeUserStatisticsService(
        new Kysely({ dialect: makeMockPgDialect(pgWriteMock) }),
        new Kysely({ dialect: makeMockPgDialect(pgReadMock) }),
        warehouseKysely,
        fetchUserActionStatisticsMock,
        fetchUserSubmissionStatisticsMock,
      );

      await sut.refreshUserScoresCache(async () => []);

      expect(pgWriteMock).not.toHaveBeenCalled();
      expect(warehouseMock).not.toHaveBeenCalled();
      expect(fetchUserActionStatisticsMock).not.toHaveBeenCalled();
      expect(fetchUserSubmissionStatisticsMock).not.toHaveBeenCalled();
    });
  });
});