import test from 'node:test';
import assert from 'node:assert/strict';
import * as fs from 'fs';
import * as os from 'os';
import * as path from 'path';
import {
  TriggerSubsyncFromConfigDeps,
  runSubsyncManual,
  triggerSubsyncFromConfig,
} from './subsync';
import type { SubsyncManualPayload } from '../../types';

function makeDeps(
  overrides: Partial<TriggerSubsyncFromConfigDeps> = {},
): TriggerSubsyncFromConfigDeps {
  const mpvClient = {
    connected: true,
    currentAudioStreamIndex: null,
    send: () => {},
    requestProperty: async (name: string) => {
      if (name === 'path') return '/tmp/video.mkv';
      if (name === 'sid') return 1;
      if (name === 'secondary-sid') return null;
      if (name === 'track-list') {
        return [
          { id: 1, type: 'sub', selected: true, lang: 'jpn' },
          {
            id: 2,
            type: 'sub',
            selected: false,
            external: true,
            lang: 'eng',
            'external-filename': '/tmp/ref.srt',
          },
          { id: 3, type: 'audio', selected: true, 'ff-index': 1 },
        ];
      }
      return null;
    },
  };

  return {
    getMpvClient: () => mpvClient,
    getResolvedConfig: () => ({
      alassPath: '/usr/bin/alass',
      ffsubsyncPath: '/usr/bin/ffsubsync',
      ffmpegPath: '/usr/bin/ffmpeg',
    }),
    isSubsyncInProgress: () => false,
    setSubsyncInProgress: () => {},
    showMpvOsd: () => {},
    runWithSubsyncSpinner: async <T>(task: () => Promise<T>) => task(),
    openManualPicker: () => {},
    ...overrides,
  };
}

test('triggerSubsyncFromConfig returns early when already in progress', async () => {
  const osd: string[] = [];
  await triggerSubsyncFromConfig(
    makeDeps({
      isSubsyncInProgress: () => true,
      showMpvOsd: (text) => {
        osd.push(text);
      },
    }),
  );
  assert.deepEqual(osd, ['Subsync already running']);
});

test('triggerSubsyncFromConfig opens manual picker', async () => {
  const osd: string[] = [];
  let payloadTrackCount = 0;
  let ffsubsyncAvailable: boolean | null = null;
  let inProgressState: boolean | null = null;

  await triggerSubsyncFromConfig(
    makeDeps({
      openManualPicker: (payload) => {
        payloadTrackCount = payload.subtitleTracks.length;
        ffsubsyncAvailable = payload.ffsubsyncAvailable;
      },
      showMpvOsd: (text) => {
        osd.push(text);
      },
      setSubsyncInProgress: (value) => {
        inProgressState = value;
      },
    }),
  );

  assert.equal(payloadTrackCount, 2);
  assert.equal(ffsubsyncAvailable, true);
  assert.ok(osd.includes('Subsync: choose engine and subtitles'));
  assert.equal(inProgressState, false);
});

test('triggerSubsyncFromConfig marks ffsubsync unavailable for remote media paths', async () => {
  let ffsubsyncAvailable: boolean | null = null;

  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return 'https://jellyfin.example/Videos/movie/stream.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return null;
          if (name === 'track-list') {
            return [
              { id: 1, type: 'sub', selected: true, lang: 'jpn' },
              {
                id: 2,
                type: 'sub',
                selected: false,
                external: true,
                lang: 'eng',
                'external-filename': 'https://jellyfin.example/subs/eng.srt',
              },
            ];
          }
          return null;
        },
      }),
      openManualPicker: (payload) => {
        ffsubsyncAvailable = payload.ffsubsyncAvailable;
      },
    }),
  );

  assert.equal(ffsubsyncAvailable, false);
});

test('triggerSubsyncFromConfig does not run automatic sync', async () => {
  const osd: string[] = [];
  let payloadTrackCount = 0;
  let spinnerRan = false;

  await triggerSubsyncFromConfig(
    makeDeps({
      openManualPicker: (payload) => {
        payloadTrackCount = payload.subtitleTracks.length;
      },
      showMpvOsd: (text) => {
        osd.push(text);
      },
      runWithSubsyncSpinner: async <T>(task: () => Promise<T>) => {
        spinnerRan = true;
        return task();
      },
    }),
  );

  assert.equal(payloadTrackCount, 2);
  assert.equal(spinnerRan, false);
  assert.deepEqual(osd, ['Subsync: choose engine and subtitles']);
});

test('triggerSubsyncFromConfig dedupes repeated subtitle source tracks', async () => {
  let payloadTrackCount = 0;

  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return '/tmp/video.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return 2;
          if (name === 'track-list') {
            return [
              { id: 1, type: 'sub', selected: true, lang: 'jpn' },
              {
                id: 2,
                type: 'sub',
                selected: true,
                external: true,
                lang: 'eng',
                'external-filename': '/tmp/ref.srt',
              },
              {
                id: 3,
                type: 'sub',
                selected: false,
                external: true,
                lang: 'eng',
                'external-filename': '/tmp/ref.srt',
              },
            ];
          }
          return null;
        },
      }),
      openManualPicker: (payload) => {
        payloadTrackCount = payload.subtitleTracks.length;
      },
    }),
  );

  assert.equal(payloadTrackCount, 2);
});

test('triggerSubsyncFromConfig keeps both active tracks when they share a file', async () => {
  let payload: SubsyncManualPayload | null = null;

  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return '/tmp/video.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return 2;
          if (name === 'track-list') {
            // mpv appends a duplicate entry when the same file is re-added, so
            // the primary and secondary slots can point at one path.
            return [
              {
                id: 1,
                type: 'sub',
                selected: true,
                external: true,
                'external-filename': '/tmp/ref.srt',
              },
              {
                id: 2,
                type: 'sub',
                selected: true,
                external: true,
                'external-filename': '/tmp/ref.srt',
              },
              {
                id: 3,
                type: 'sub',
                selected: false,
                external: true,
                'external-filename': '/tmp/ref.srt',
              },
            ];
          }
          return null;
        },
      }),
      openManualPicker: (nextPayload) => {
        payload = nextPayload;
      },
    }),
  );

  assert.ok(payload);
  const resolved = payload as SubsyncManualPayload;
  assert.deepEqual(
    resolved.subtitleTracks.map((track) => track.id),
    [1, 2],
  );
  assert.equal(resolved.defaultReferenceTrackId, 2);
  assert.equal(resolved.defaultTargetTrackId, 1);
});

test('triggerSubsyncFromConfig reports failures to OSD', async () => {
  const osd: string[] = [];
  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => null,
      showMpvOsd: (text) => {
        osd.push(text);
      },
    }),
  );

  assert.ok(osd.some((line) => line.startsWith('Subsync failed: MPV not connected')));
});

test('runSubsyncManual requires a reference track for alass', async () => {
  const result = await runSubsyncManual({ engine: 'alass', referenceTrackId: null }, makeDeps());

  assert.deepEqual(result, {
    ok: false,
    message: 'Select a reference subtitle track for alass',
  });
});

test('runSubsyncManual rejects alass when reference and target are the same track', async () => {
  const result = await runSubsyncManual(
    { engine: 'alass', referenceTrackId: 2, targetTrackId: 2 },
    makeDeps(),
  );

  assert.deepEqual(result, {
    ok: false,
    message: 'Reference and out-of-sync subtitles must be different tracks',
  });
});

test('runSubsyncManual rejects an unknown target track', async () => {
  const result = await runSubsyncManual(
    { engine: 'alass', referenceTrackId: 2, targetTrackId: 99 },
    makeDeps(),
  );

  assert.deepEqual(result, {
    ok: false,
    message: 'Select the out-of-sync subtitle track to retime',
  });
});

test('runSubsyncManual rejects the video reference for remote media', async () => {
  const result = await runSubsyncManual(
    { engine: 'alass', referenceMode: 'video' },
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return 'https://jellyfin.example/Videos/movie/stream.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return null;
          if (name === 'track-list') {
            return [{ id: 1, type: 'sub', selected: true, lang: 'jpn' }];
          }
          return null;
        },
      }),
    }),
  );

  assert.equal(result.ok, false);
  assert.match(result.message, /cannot use a stream URL as reference/);
});

test('openSubsyncManualPicker defaults the reference to the secondary subtitle track', async () => {
  let payload: SubsyncManualPayload | null = null;

  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return '/tmp/video.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return 3;
          if (name === 'track-list') {
            return [
              { id: 1, type: 'sub', selected: true, lang: 'jpn' },
              {
                id: 2,
                type: 'sub',
                selected: false,
                external: true,
                lang: 'eng',
                'external-filename': '/tmp/other.srt',
              },
              {
                id: 3,
                type: 'sub',
                selected: true,
                external: true,
                lang: 'eng',
                'external-filename': '/tmp/secondary.srt',
              },
            ];
          }
          return null;
        },
      }),
      openManualPicker: (nextPayload) => {
        payload = nextPayload;
      },
    }),
  );

  assert.ok(payload);
  const resolved = payload as SubsyncManualPayload;
  assert.deepEqual(
    resolved.subtitleTracks.map((track) => track.id),
    [1, 2, 3],
  );
  assert.equal(resolved.defaultReferenceTrackId, 3);
  assert.equal(resolved.defaultTargetTrackId, 1);
  assert.equal(resolved.videoReferenceAvailable, true);
});

test('openSubsyncManualPicker never defaults to a reference missing from the track list', async () => {
  let payload: SubsyncManualPayload | null = null;

  await triggerSubsyncFromConfig(
    makeDeps({
      getMpvClient: () => ({
        connected: true,
        currentAudioStreamIndex: null,
        send: () => {},
        requestProperty: async (name: string) => {
          if (name === 'path') return '/tmp/video.mkv';
          if (name === 'sid') return 1;
          if (name === 'secondary-sid') return 2;
          if (name === 'track-list') {
            return [
              { id: 1, type: 'sub', selected: true, lang: 'jpn' },
              // Secondary track with no usable file path: filtered out of the picker.
              { id: 2, type: 'sub', selected: true, external: true, 'external-filename': '' },
              { id: 3, type: 'sub', selected: false, lang: 'eng' },
            ];
          }
          return null;
        },
      }),
      openManualPicker: (nextPayload) => {
        payload = nextPayload;
      },
    }),
  );

  assert.ok(payload);
  const resolved = payload as SubsyncManualPayload;
  assert.deepEqual(
    resolved.subtitleTracks.map((track) => track.id),
    [1, 3],
  );
  assert.equal(resolved.defaultReferenceTrackId, 3);
});

test('triggerSubsyncFromConfig does not validate sync tool paths before manual selection', async () => {
  const osd: string[] = [];
  const inProgress: boolean[] = [];
  let payloadTrackCount = 0;

  await triggerSubsyncFromConfig(
    makeDeps({
      getResolvedConfig: () => ({
        alassPath: '/missing/alass',
        ffsubsyncPath: '/missing/ffsubsync',
        ffmpegPath: '/missing/ffmpeg',
      }),
      setSubsyncInProgress: (value) => {
        inProgress.push(value);
      },
      openManualPicker: (payload) => {
        payloadTrackCount = payload.subtitleTracks.length;
      },
      showMpvOsd: (text) => {
        osd.push(text);
      },
    }),
  );

  assert.deepEqual(inProgress, [false]);
  assert.equal(payloadTrackCount, 2);
  assert.deepEqual(osd, ['Subsync: choose engine and subtitles']);
});

function writeExecutableScript(filePath: string, content: string): void {
  fs.writeFileSync(filePath, content, { encoding: 'utf8', mode: 0o755 });
  fs.chmodSync(filePath, 0o755);
}

function toShellPath(filePath: string): string {
  if (process.platform !== 'win32') {
    return filePath;
  }

  return filePath.replace(/\\/g, '/').replace(/^([A-Za-z]):\//, (_, driveLetter: string) => {
    return `/mnt/${driveLetter.toLowerCase()}/`;
  });
}

function fromShellPath(filePath: string): string {
  if (process.platform !== 'win32') {
    return filePath;
  }

  return filePath
    .replace(/^\/mnt\/([a-z])\//, (_, driveLetter: string) => {
      return `${driveLetter.toUpperCase()}:/`;
    })
    .replace(/\//g, '\\');
}

test('runSubsyncManual constructs ffsubsync command and returns success', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-ffsubsync-'));
  const ffsubsyncLogPath = path.join(tmpDir, 'ffsubsync-args.log');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(alassPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    ffsubsyncPath,
    `#!/bin/sh\n: > "${toShellPath(ffsubsyncLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(ffsubsyncLogPath)}"; done\nout=\"\"\nprev=\"\"\nfor arg in \"$@\"; do\n  if [ \"$prev\" = \"-o\" ]; then out=\"$arg\"; fi\n  prev=\"$arg\"\ndone\nif [ -n \"$out\" ]; then : > \"$out\"; fi\nexit 0\n`,
  );

  const sentCommands: Array<Array<string | number>> = [];
  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: 2,
      send: (payload) => {
        sentCommands.push(payload.command);
      },
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'ffsubsync' }, deps);

  assert.equal(result.ok, true);
  assert.equal(result.message, 'Subtitle synchronized with ffsubsync');
  const ffArgs = fs.readFileSync(ffsubsyncLogPath, 'utf8').trim().split('\n');
  assert.equal(ffArgs[0], toShellPath(videoPath));
  assert.ok(ffArgs.includes('-i'));
  assert.ok(ffArgs.includes(toShellPath(primaryPath)));
  assert.ok(ffArgs.includes('--reference-stream'));
  assert.ok(ffArgs.includes('0:2'));
  const ffOutputFlagIndex = ffArgs.indexOf('-o');
  assert.equal(ffOutputFlagIndex >= 0, true);
  assert.equal(ffArgs[ffOutputFlagIndex + 1], toShellPath(primaryPath));
  assert.equal(sentCommands[0]?.[0], 'sub-add');
  assert.deepEqual(sentCommands[1], ['set_property', 'sub-delay', 0]);
});

test('runSubsyncManual writes deterministic _retimed filename when replace is false', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-ffsubsync-no-replace-'));
  const ffsubsyncLogPath = path.join(tmpDir, 'ffsubsync-args.log');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'episode.ja.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(alassPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    ffsubsyncPath,
    `#!/bin/sh\n: > "${toShellPath(ffsubsyncLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(ffsubsyncLogPath)}"; done\nout=\"\"\nprev=\"\"\nfor arg in \"$@\"; do\n  if [ \"$prev\" = \"-o\" ]; then out=\"$arg\"; fi\n  prev=\"$arg\"\ndone\nif [ -n \"$out\" ]; then : > \"$out\"; fi\nexit 0\n`,
  );

  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: () => {},
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
      replace: false,
    }),
  });

  const result = await runSubsyncManual({ engine: 'ffsubsync' }, deps);

  assert.equal(result.ok, true);
  const ffArgs = fs.readFileSync(ffsubsyncLogPath, 'utf8').trim().split('\n');
  const ffOutputFlagIndex = ffArgs.indexOf('-o');
  assert.equal(ffOutputFlagIndex >= 0, true);
  const outputPath = ffArgs[ffOutputFlagIndex + 1];
  assert.equal(outputPath, toShellPath(path.join(tmpDir, 'episode.ja_retimed.srt')));
});

test('runSubsyncManual reports ffsubsync command failures with details', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-ffsubsync-failure-'));
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(alassPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\necho "reference audio missing" >&2\nexit 1\n');

  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: () => {},
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'ffsubsync' }, deps);

  assert.equal(result.ok, false);
  assert.equal(result.message.startsWith('ffsubsync synchronization failed'), true);
  assert.match(result.message, /code=1/);
  assert.match(result.message, /reference audio missing/);
});

test('runSubsyncManual constructs alass command and returns failure on non-zero exit', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-'));
  const alassLogPath = path.join(tmpDir, 'alass-args.log');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');
  const sourcePath = path.join(tmpDir, 'source.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  fs.writeFileSync(sourcePath, 'sub2');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    alassPath,
    `#!/bin/sh\n: > "${toShellPath(alassLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(alassLogPath)}"; done\nexit 1\n`,
  );

  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: () => {},
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
            {
              id: 2,
              type: 'sub',
              selected: false,
              external: true,
              'external-filename': sourcePath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'alass', referenceTrackId: 2 }, deps);

  assert.equal(result.ok, false);
  assert.equal(typeof result.message, 'string');
  assert.equal(result.message.startsWith('alass synchronization failed'), true);
  const alassArgs = fs.readFileSync(alassLogPath, 'utf8').trim().split('\n');
  assert.equal(alassArgs[0], toShellPath(sourcePath));
  assert.equal(alassArgs[1], toShellPath(primaryPath));
});

function makeAlassSelectionDeps(tmpDir: string): {
  deps: TriggerSubsyncFromConfigDeps;
  alassLogPath: string;
  videoPath: string;
  primaryPath: string;
  sourcePath: string;
  sentCommands: Array<Array<string | number>>;
} {
  const alassLogPath = path.join(tmpDir, 'alass-args.log');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');
  const sourcePath = path.join(tmpDir, 'source.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  fs.writeFileSync(sourcePath, 'sub2');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    alassPath,
    `#!/bin/sh\n: > "${toShellPath(alassLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(alassLogPath)}"; done\n: > "$3"\nexit 0\n`,
  );

  const trackList: Array<Record<string, unknown>> = [
    { id: 1, type: 'sub', selected: true, external: true, 'external-filename': primaryPath },
    { id: 2, type: 'sub', selected: true, external: true, 'external-filename': sourcePath },
  ];
  const sentCommands: Array<Array<string | number>> = [];
  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: (payload) => {
        sentCommands.push(payload.command);
        if (payload.command[0] === 'sub-add' || payload.command[0] === 'sub_add') {
          trackList.push({
            id: trackList.length + 1,
            type: 'sub',
            selected: false,
            external: true,
            'external-filename': payload.command[1],
          });
        }
      },
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return 2;
        if (name === 'track-list') return trackList;
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
      replace: false,
    }),
  });

  return { deps, alassLogPath, videoPath, primaryPath, sourcePath, sentCommands };
}

test('runSubsyncManual uses the video file as alass reference when requested', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-video-ref-'));
  const { deps, alassLogPath, videoPath, primaryPath } = makeAlassSelectionDeps(tmpDir);

  const result = await runSubsyncManual({ engine: 'alass', referenceMode: 'video' }, deps);

  assert.equal(result.ok, true);
  const alassArgs = fs.readFileSync(alassLogPath, 'utf8').trim().split('\n');
  assert.equal(alassArgs[0], toShellPath(videoPath));
  assert.equal(alassArgs[1], toShellPath(primaryPath));
});

test('runSubsyncManual retimes the selected target track instead of the primary', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-target-'));
  const { deps, alassLogPath, primaryPath, sourcePath, sentCommands } =
    makeAlassSelectionDeps(tmpDir);

  const result = await runSubsyncManual(
    { engine: 'alass', referenceTrackId: 1, targetTrackId: 2 },
    deps,
  );

  assert.equal(result.ok, true);
  const alassArgs = fs.readFileSync(alassLogPath, 'utf8').trim().split('\n');
  assert.equal(alassArgs[0], toShellPath(primaryPath));
  assert.equal(alassArgs[1], toShellPath(sourcePath));
  assert.equal(sentCommands[0]?.[0], 'sub-add');
  assert.equal(sentCommands[0]?.[2], 'auto');
});

test('runSubsyncManual keeps a retimed secondary track in the secondary slot', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-secondary-slot-'));
  const alassPath = path.join(tmpDir, 'alass.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'ja.srt');
  const secondaryPath = path.join(tmpDir, 'en.srt');
  const retimedPath = path.join(tmpDir, 'en_retimed.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'ja');
  fs.writeFileSync(secondaryPath, 'en');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(alassPath, '#!/bin/sh\n: > "$3"\nexit 0\n');

  const trackList: Array<Record<string, unknown>> = [
    { id: 1, type: 'sub', selected: true, external: true, 'external-filename': primaryPath },
    { id: 2, type: 'sub', selected: true, external: true, 'external-filename': secondaryPath },
  ];
  const sentCommands: Array<Array<string | number>> = [];
  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: (payload) => {
        sentCommands.push(payload.command);
        if (payload.command[0] === 'sub-add') {
          trackList.push({
            id: 3,
            type: 'sub',
            selected: false,
            external: true,
            'external-filename': payload.command[1],
          });
        }
      },
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return 2;
        if (name === 'track-list') return trackList;
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
      replace: false,
    }),
  });

  const result = await runSubsyncManual(
    { engine: 'alass', referenceTrackId: 1, targetTrackId: 2 },
    deps,
  );

  assert.equal(result.ok, true);
  assert.deepEqual(sentCommands[0], ['sub-add', retimedPath, 'auto']);
  assert.deepEqual(sentCommands[1], ['set_property', 'secondary-sub-delay', 0]);
  assert.deepEqual(sentCommands[2], ['set_property', 'secondary-sid', 3]);
  assert.equal(
    sentCommands.some((command) => command[1] === 'sub-delay'),
    false,
  );
  assert.equal(
    sentCommands.some((command) => command[1] === 'sid'),
    false,
  );
  assert.equal(
    sentCommands.some((command) => command[1] === 'sid'),
    false,
  );
});

test('runSubsyncManual converts VTT stream tracks to SRT before running alass', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-vtt-'));
  const alassLogPath = path.join(tmpDir, 'alass-args.log');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const videoPath = 'https://example.com/stream.m3u8';
  const primaryPath = path.join(tmpDir, 'track-1.vtt');
  const sourcePath = path.join(tmpDir, 'track-0.vtt');

  fs.writeFileSync(primaryPath, 'WEBVTT\n\n00:00:05.000 --> 00:00:06.000\nしっかし\n');
  fs.writeFileSync(sourcePath, 'WEBVTT\n\n00:00:01.000 --> 00:00:02.000\nWell then\n');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    alassPath,
    `#!/bin/sh\n: > "${toShellPath(alassLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(alassLogPath)}"; done\ncp "$2" "$3"\nexit 0\n`,
  );

  const sentCommands: Array<Array<string | number>> = [];
  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: (payload) => {
        sentCommands.push(payload.command);
      },
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
            {
              id: 2,
              type: 'sub',
              selected: false,
              external: true,
              'external-filename': sourcePath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'alass', referenceTrackId: 2 }, deps);

  assert.equal(result.ok, true);
  const alassArgs = fs.readFileSync(alassLogPath, 'utf8').trim().split('\n');
  assert.equal(alassArgs.length, 3);
  for (const arg of alassArgs) {
    assert.equal(path.extname(arg), '.srt');
  }
  // The originals stay put; only the alass copies are rewritten.
  assert.equal(fs.existsSync(primaryPath), true);
  assert.equal(fs.existsSync(sourcePath), true);

  const loadedPath = sentCommands[0]?.[1];
  assert.equal(sentCommands[0]?.[0], 'sub-add');
  assert.equal(typeof loadedPath, 'string');
  assert.match(fs.readFileSync(fromShellPath(String(loadedPath)), 'utf8'), /しっかし/);

  fs.rmSync(tmpDir, { recursive: true, force: true });
});

test('runSubsyncManual keeps internal alass source file alive until sync finishes', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-alass-internal-source-'));
  const alassPath = path.join(tmpDir, 'alass.sh');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'sub');
  writeExecutableScript(ffsubsyncPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    ffmpegPath,
    '#!/bin/sh\nout=""\nfor arg in "$@"; do out="$arg"; done\nif [ -n "$out" ]; then : > "$out"; fi\nexit 0\n',
  );
  writeExecutableScript(
    alassPath,
    '#!/bin/sh\nsleep 0.2\nif [ ! -f "$1" ]; then echo "missing reference subtitle" >&2; exit 1; fi\nif [ ! -f "$2" ]; then echo "missing input subtitle" >&2; exit 1; fi\n: > "$3"\nexit 0\n',
  );

  const sentCommands: Array<Array<string | number>> = [];
  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: (payload) => {
        sentCommands.push(payload.command);
      },
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return 1;
        if (name === 'secondary-sid') return null;
        if (name === 'track-list') {
          return [
            {
              id: 1,
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
            {
              id: 2,
              type: 'sub',
              selected: false,
              external: false,
              'ff-index': 2,
              codec: 'ass',
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'alass', referenceTrackId: 2 }, deps);

  assert.equal(result.ok, true);
  assert.equal(result.message, 'Subtitle synchronized with alass');
  assert.equal(sentCommands[0]?.[0], 'sub-add');
  assert.deepEqual(sentCommands[1], ['set_property', 'sub-delay', 0]);
});

test('runSubsyncManual resolves string sid values from mpv stream properties', async () => {
  const tmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'subsync-stream-sid-'));
  const ffsubsyncPath = path.join(tmpDir, 'ffsubsync.sh');
  const ffsubsyncLogPath = path.join(tmpDir, 'ffsubsync-args.log');
  const ffmpegPath = path.join(tmpDir, 'ffmpeg.sh');
  const alassPath = path.join(tmpDir, 'alass.sh');
  const videoPath = path.join(tmpDir, 'video.mkv');
  const primaryPath = path.join(tmpDir, 'primary.srt');

  fs.writeFileSync(videoPath, 'video');
  fs.writeFileSync(primaryPath, 'subtitle');
  writeExecutableScript(ffmpegPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(alassPath, '#!/bin/sh\nexit 0\n');
  writeExecutableScript(
    ffsubsyncPath,
    `#!/bin/sh\nmkdir -p "${toShellPath(tmpDir)}"\n: > "${toShellPath(ffsubsyncLogPath)}"\nfor arg in "$@"; do printf '%s\\n' "$arg" >> "${toShellPath(ffsubsyncLogPath)}"; done\nprev=""\nout=""\nfor arg in "$@"; do\n  if [ "$prev" = "--reference-stream" ]; then :; fi\n  if [ "$prev" = "-o" ]; then out="$arg"; fi\n  prev="$arg"\ndone\nif [ -n "$out" ]; then : > "$out"; fi`,
  );

  const deps = makeDeps({
    getMpvClient: () => ({
      connected: true,
      currentAudioStreamIndex: null,
      send: () => {},
      requestProperty: async (name: string) => {
        if (name === 'path') return videoPath;
        if (name === 'sid') return '1';
        if (name === 'secondary-sid') return '2';
        if (name === 'track-list') {
          return [
            {
              id: '1',
              type: 'sub',
              selected: true,
              external: true,
              'external-filename': primaryPath,
            },
          ];
        }
        return null;
      },
    }),
    getResolvedConfig: () => ({
      alassPath,
      ffsubsyncPath,
      ffmpegPath,
    }),
  });

  const result = await runSubsyncManual({ engine: 'ffsubsync' }, deps);

  assert.equal(result.ok, true);
  assert.equal(result.message, 'Subtitle synchronized with ffsubsync');
  const ffArgs = fs.readFileSync(ffsubsyncLogPath, 'utf8').trim().split('\n');
  const syncOutputIndex = ffArgs.indexOf('-o');
  assert.equal(syncOutputIndex >= 0, true);
  const outputPath = ffArgs[syncOutputIndex + 1];
  assert.equal(typeof outputPath, 'string');
  assert.ok(outputPath!.length > 0);
  assert.equal(fs.readFileSync(fromShellPath(outputPath!), 'utf8'), '');
});