import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
import { newFixture, type Fixture } from '../helpers/fixture.js';

let fixture: Fixture;

beforeEach(async () => {
    vi.resetModules();
    fixture = await newFixture({ 'hud.gsc': 'v1' }, ['t5_kino_1', 't5_ascension_1']);
    // No integrations → sweep marks rows manual, exercising that branch.
    delete process.env.KOMODO_ADDRESS;
    delete process.env.IW4M_ADDRESS;
});

afterEach(async () => {
    await fixture.cleanup();
});

describe('sweep', () => {
    it('marks all pending rows manual when integrations are unset', async () => {
        const { doPush } = await import('../../src/lib/server/fleet/push.js');
        const { sweep } = await import('../../src/lib/server/pipeline/sweep.js');
        const { seedServerRegistry } = await import('../../src/lib/server/fleet/servers.js');
        const { setAuthState } = await import('../../src/lib/server/integrations/auth-state.js');
        const { db } = await import('../../src/lib/server/db/index.js');
        await seedServerRegistry();

        // Force ready so pipelineReady() lets sweep run (even though
        // integrations are off — that's the branch we want to test).
        setAuthState({ kind: 'ready', token: 'abcd', cookie: 'x=y', expiresAt: Date.now() + 100_000 });

        const push = await doPush({ patterns: ['*'] });
        expect(push.deploymentId).not.toBeNull();

        const result = await sweep();
        expect(result.frozen).toBe(false);

        const rows = db()
            .prepare("SELECT restart_state FROM deployment_servers WHERE deployment_id = ?")
            .all(push.deploymentId!) as Array<{ restart_state: string }>;
        for (const r of rows) expect(r.restart_state).toBe('manual');
    });

    it('freezes when auth is not ready', async () => {
        const { doPush } = await import('../../src/lib/server/fleet/push.js');
        const { sweep } = await import('../../src/lib/server/pipeline/sweep.js');
        const { seedServerRegistry } = await import('../../src/lib/server/fleet/servers.js');
        await seedServerRegistry();

        await doPush({ patterns: ['*'] });
        const result = await sweep();
        expect(result.frozen).toBe(true);
    });
});