// Session 52 — GET /api/internal/snapshot/status (verification probe).

const express = require('express');
const request = require('supertest');

const mockCacheGet = jest.fn();
jest.mock('../../src/utils/redis', () => ({
  cacheGet: (...a) => mockCacheGet(...a),
  cacheSet: jest.fn(),
}));

beforeEach(() => {
  jest.resetAllMocks();
  process.env.VYNDR_INTERNAL_KEY = 'test-internal-key-9999';
});

function mountApp() {
  delete require.cache[require.resolve('../../src/routes/internal')];
  const internalRoutes = require('../../src/routes/internal');
  const app = express();
  app.use(express.json());
  app.use('/api/internal', internalRoutes);
  return app;
}

describe('GET /api/internal/snapshot/status', () => {
  it('requires the internal key', async () => {
    const res = await request(mountApp()).get('/api/internal/snapshot/status');
    expect(res.status).toBe(401);
  });

  it('reports cron state, last snapshot, redis keys, ticker count', async () => {
    process.env.SNAPSHOT_CRON = '1';
    mockCacheGet.mockImplementation(async (key) => {
      if (key === 'snapshot:mlb:latest') return { updated_at: '2026-06-19T18:00:00Z', grades: [{}, {}, {}], deltas: [{}] };
      if (key === 'grades:mlb') return { grades: [{}, {}, {}] };
      if (key === 'ticker:items') return [{ type: 'READ' }, { type: 'ALERT' }];
      return null;
    });

    const res = await request(mountApp())
      .get('/api/internal/snapshot/status')
      .set('x-internal-key', 'test-internal-key-9999');

    expect(res.status).toBe(200);
    expect(res.body.cron_armed).toBe(true);
    expect(res.body.last_snapshot.mlb.gradeCount).toBe(3);
    expect(res.body.last_snapshot.mlb.deltaCount).toBe(1);
    expect(res.body.redis_keys['snapshot:mlb:latest']).toBe(true);
    expect(res.body.redis_keys['snapshot:mlb:previous']).toBe(false);
    expect(res.body.ticker_count).toBe(2);
    delete process.env.SNAPSHOT_CRON;
  });
});