GitNexus/gitnexus/test/unit/status-content-drift.test.ts

/**
 * Unit Tests: `status` freshness verdict from per-file drift (#3077)
 *
 * The reported defect was a verdict nobody could clear: any modified or
 * untracked file in the working tree — including files the index never reads —
 * made `status` print "stale (re-run gitnexus analyze)", and running `analyze`
 * left it unchanged. These tests pin the new decision order: the per-file
 * comparison decides when it can run, and the repo-wide dirty flag survives
 * only as the fallback for metadata written before `fileHashes` existed.
 */
import { describe, it, expect, vi, beforeEach, afterEach } from 'vitest';

const { runnerIdentity } = vi.hoisted(() => ({
  runnerIdentity: {
    schemaVersion: 4 as const,
    runtime: {
      executablePath: '/usr/bin/node',
      version: 'v22.0.0',
      platform: 'linux',
      architecture: 'x64',
      modulesAbi: '127',
      libc: 'glibc:2.39',
    },
    cliVersion: '1.6.10',
    invokedArtifact: { path: '/opt/gitnexus/dist/cli/index.js', digest: 'sha256:entry' },
    build: {
      kind: 'distribution' as const,
      rootPath: '/opt/gitnexus/dist',
      canonicalization: 'gitnexus-analyzer-build-v2' as const,
      digest: 'sha256:build',
    },
    dependencyRuntime: {
      manifestPath: '/opt/gitnexus/package.json',
      lockfilePath: '/opt/package-lock.json',
      canonicalization: 'gitnexus-analyzer-dependency-runtime-v4' as const,
      packageCount: 42,
      artifactCount: 12,
      digest: 'sha256:dependencies',
    },
  },
}));

vi.mock('../../src/storage/repo-manager.js', () => ({
  listRegisteredRepos: vi.fn(),
  getStoragePaths: vi.fn((repoPath: string) => ({
    storagePath: `${repoPath}/.gitnexus`,
    lbugPath: `${repoPath}/.gitnexus/lbug`,
    metaPath: `${repoPath}/.gitnexus/meta.json`,
  })),
  loadMeta: vi.fn(),
  hasKuzuIndex: vi.fn().mockResolvedValue(false),
}));

vi.mock('../../src/core/analyzer-identity.js', () => ({
  resolveAnalyzerRunnerIdentity: vi.fn(() => runnerIdentity),
  analyzerRunnerIdentitiesEqual: vi.fn((indexed: unknown, current: unknown) => indexed === current),
}));

vi.mock('../../src/storage/git.js', () => ({
  isGitRepo: vi.fn().mockReturnValue(true),
  getCurrentCommit: vi.fn().mockReturnValue('headsha0'),
  getCurrentBranch: vi.fn().mockReturnValue('main'),
  getGitRoot: vi.fn().mockReturnValue('/repo'),
  isWorkingTreeDirty: vi.fn().mockReturnValue(false),
  listWorkingTreeDirtyPaths: vi.fn().mockReturnValue([]),
}));

vi.mock('../../src/core/index-content-drift.js', () => ({
  detectIndexContentDrift: vi.fn(),
}));

vi.mock('../../src/storage/storage-resolver.js', () => ({
  requireStoragePath: vi.fn().mockResolvedValue('/repo/.gitnexus'),
  requireRegisteredStoragePath: vi.fn().mockResolvedValue('/repo/.gitnexus'),
  STATUS_STORAGE_REQUIREMENTS: { allowedStates: ['owned'], requireCodeIndexDB: true },
  StorageRequirementError: class StorageRequirementError extends Error {},
}));

import { statusCommand } from '../../src/cli/status.js';
import { setCliLanguage } from '../../src/cli/i18n/index.js';
import { loadMeta } from '../../src/storage/repo-manager.js';
import { getCurrentCommit, isWorkingTreeDirty } from '../../src/storage/git.js';
import { detectIndexContentDrift } from '../../src/core/index-content-drift.js';

let logSpy: ReturnType<typeof vi.spyOn>;
const output = () => logSpy.mock.calls.map((c) => c.join(' ')).join('\n');

const repoWithCoverage = {
  repoPath: '/repo',
  storagePath: '/repo/.gitnexus',
  lbugPath: '/repo/.gitnexus/lbug',
  metaPath: '/repo/.gitnexus/meta.json',
  meta: {
    repoPath: '/repo',
    lastCommit: 'headsha0',
    indexedAt: '2026-08-28T12:00:00.000Z',
    branch: 'main',
    runnerIdentity,
    fileHashes: { 'a.js': 'sha-a' },
    scopeExtractionReceipt: 1 as const,
  },
};

beforeEach(() => {
  vi.clearAllMocks();
  logSpy = vi.spyOn(console, 'log').mockImplementation(() => {});
  (loadMeta as any).mockResolvedValue(repoWithCoverage.meta);
  (getCurrentCommit as any).mockReturnValue('headsha0');
  (isWorkingTreeDirty as any).mockReturnValue(false);
});

afterEach(() => {
  setCliLanguage(null);
  logSpy.mockRestore();
});

describe('status freshness from per-file drift (#3077)', () => {
  it('is up-to-date when every covered file matches, despite a dirty working tree', async () => {
    // The reported case: one modified file outside the index's coverage. The
    // old repo-wide check called this stale and `analyze` could not clear it.
    (isWorkingTreeDirty as any).mockReturnValue(true);
    (detectIndexContentDrift as any).mockResolvedValue({ kind: 'current', coveredFileCount: 210 });

    await statusCommand({ json: true });

    expect(JSON.parse(output())).toMatchObject({
      status: 'up-to-date',
      contentDrift: { status: 'current', coveredFiles: 210 },
    });
  });

  it('reports covered-file drift as stale and names the files', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'drifted',
      changed: ['src/app.ts'],
      added: [],
      deleted: [],
    });

    await statusCommand();

    const out = output();
    expect(out).not.toContain('up-to-date');
    expect(out).toContain('1 changed, 0 added, 0 deleted');
    expect(out).toContain('changed: src/app.ts');
  });

  it('escapes control characters in drifted path names', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'drifted',
      changed: ['src/\u001b[31mevil.ts'],
      added: [],
      deleted: [],
    });

    await statusCommand();

    const out = output();
    expect(out).toContain(JSON.stringify('src/\u001b[31mevil.ts'));
    expect(out).not.toContain('\u001b[31m');
  });

  it('localizes overflow category labels in zh-CN', async () => {
    setCliLanguage('zh-CN');
    const changed = Array.from({ length: 12 }, (_, i) => `src/file-${i}.ts`);
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'drifted',
      changed,
      added: [],
      deleted: [],
    });

    await statusCommand();

    const out = output();
    expect(out).toContain('已修改: src/file-0.ts');
    expect(out).toContain('另有 2 个 已修改');
    expect(out).not.toMatch(/\bchanged\b/);
  });

  it('names a failed coverage scan in human output instead of falling back', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'unmeasurable',
      reason: 'scan-failed',
    });

    await statusCommand();

    const out = output();
    expect(out).toContain('coverage scan failed');
    expect(out).toContain('stale');
    expect(out).not.toContain('fell back to the working-tree check');
  });

  it('exposes drift counts and a capped sample in --json', async () => {
    const changed = Array.from({ length: 25 }, (_, i) => `src/file-${i}.ts`);
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'drifted',
      changed,
      added: [],
      deleted: [],
    });

    await statusCommand({ json: true });

    const parsed = JSON.parse(output());
    expect(parsed.status).toBe('stale');
    expect(parsed.contentDrift.counts).toEqual({ changed: 25, added: 0, deleted: 0 });
    expect(parsed.contentDrift.changed).toHaveLength(10);
    expect(parsed.contentDrift.truncated).toEqual({
      changed: true,
      added: false,
      deleted: false,
    });
  });

  it('falls back to the working-tree check when coverage cannot be compared', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'unmeasurable',
      reason: 'no-file-hashes',
    });
    (isWorkingTreeDirty as any).mockReturnValue(true);

    await statusCommand({ json: true });

    expect(JSON.parse(output())).toMatchObject({
      status: 'stale',
      contentDrift: { status: 'unmeasurable', reason: 'no-file-hashes' },
    });
  });

  it('is stale when coverage cannot be compared because the scan failed', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'unmeasurable',
      reason: 'scan-failed',
    });

    await statusCommand({ json: true });

    expect(JSON.parse(output())).toMatchObject({
      status: 'stale',
      contentDrift: { status: 'unmeasurable', reason: 'scan-failed' },
    });
  });

  it('is up-to-date on a clean tree when hashes are missing (legacy metadata)', async () => {
    (detectIndexContentDrift as any).mockResolvedValue({
      kind: 'unmeasurable',
      reason: 'no-file-hashes',
    });

    await statusCommand({ json: true });

    expect(JSON.parse(output())).toMatchObject({
      status: 'up-to-date',
      contentDrift: { status: 'unmeasurable', reason: 'no-file-hashes' },
    });
  });

  it('skips the scan when the index is already stale on metadata alone', async () => {
    // A moved HEAD is decided without paying for a repository-wide hash pass.
    (getCurrentCommit as any).mockReturnValue('othersha');

    await statusCommand({ json: true });

    expect(detectIndexContentDrift).not.toHaveBeenCalled();
    expect(JSON.parse(output())).toMatchObject({
      status: 'stale',
      contentDrift: { status: 'not-checked' },
    });
  });

  it('replays persisted indexCoverage into the drift check', async () => {
    const coverage = { maxFileSizeBytes: 1024 * 1024, dirtyPaths: ['a.js'] };
    (loadMeta as any).mockResolvedValue({ ...repoWithCoverage.meta, indexCoverage: coverage });
    (detectIndexContentDrift as any).mockResolvedValue({ kind: 'current', coveredFileCount: 1 });

    await statusCommand({ json: true });

    expect(detectIndexContentDrift).toHaveBeenCalledWith('/repo', { 'a.js': 'sha-a' }, coverage);
  });
});