refactor: extract mpv runtime command and osd helpers

src/core/services/mpv-runtime-service.test.ts

@@ -0,0 +1,69 @@
+import test from "node:test";
+import assert from "node:assert/strict";
+import {
+  playNextSubtitleRuntimeService,
+  replayCurrentSubtitleRuntimeService,
+  sendMpvCommandRuntimeService,
+  setMpvSubVisibilityRuntimeService,
+  showMpvOsdRuntimeService,
+} from "./mpv-runtime-service";
+
+test("showMpvOsdRuntimeService sends show-text when connected", () => {
+  const commands: (string | number)[][] = [];
+  showMpvOsdRuntimeService(
+    {
+      connected: true,
+      send: ({ command }) => {
+        commands.push(command);
+      },
+    },
+    "hello",
+  );
+  assert.deepEqual(commands, [["show-text", "hello", "3000"]]);
+});
+
+test("showMpvOsdRuntimeService logs fallback when disconnected", () => {
+  const logs: string[] = [];
+  showMpvOsdRuntimeService(
+    {
+      connected: false,
+      send: () => {},
+    },
+    "hello",
+    (line) => {
+      logs.push(line);
+    },
+  );
+  assert.deepEqual(logs, ["OSD (MPV not connected): hello"]);
+});
+
+test("mpv runtime command wrappers call expected client methods", () => {
+  const calls: string[] = [];
+  const client = {
+    connected: true,
+    send: ({ command }: { command: (string | number)[] }) => {
+      calls.push(`send:${command.join(",")}`);
+    },
+    replayCurrentSubtitle: () => {
+      calls.push("replay");
+    },
+    playNextSubtitle: () => {
+      calls.push("next");
+    },
+    setSubVisibility: (visible: boolean) => {
+      calls.push(`subVisible:${visible}`);
+    },
+  };
+
+  replayCurrentSubtitleRuntimeService(client);
+  playNextSubtitleRuntimeService(client);
+  sendMpvCommandRuntimeService(client, ["script-message", "x"]);
+  setMpvSubVisibilityRuntimeService(client, false);
+
+  assert.deepEqual(calls, [
+    "replay",
+    "next",
+    "send:script-message,x",
+    "subVisible:false",
+  ]);
+});

src/core/services/mpv-runtime-service.ts

@@ -0,0 +1,49 @@
+export interface MpvRuntimeClientLike {
+  connected: boolean;
+  send: (payload: { command: (string | number)[] }) => void;
+  replayCurrentSubtitle?: () => void;
+  playNextSubtitle?: () => void;
+  setSubVisibility?: (visible: boolean) => void;
+}
+
+export function showMpvOsdRuntimeService(
+  mpvClient: MpvRuntimeClientLike | null,
+  text: string,
+  fallbackLog: (text: string) => void = console.log,
+): void {
+  if (mpvClient && mpvClient.connected) {
+    mpvClient.send({ command: ["show-text", text, "3000"] });
+    return;
+  }
+  fallbackLog(`OSD (MPV not connected): ${text}`);
+}
+
+export function replayCurrentSubtitleRuntimeService(
+  mpvClient: MpvRuntimeClientLike | null,
+): void {
+  if (!mpvClient?.replayCurrentSubtitle) return;
+  mpvClient.replayCurrentSubtitle();
+}
+
+export function playNextSubtitleRuntimeService(
+  mpvClient: MpvRuntimeClientLike | null,
+): void {
+  if (!mpvClient?.playNextSubtitle) return;
+  mpvClient.playNextSubtitle();
+}
+
+export function sendMpvCommandRuntimeService(
+  mpvClient: MpvRuntimeClientLike | null,
+  command: (string | number)[],
+): void {
+  if (!mpvClient) return;
+  mpvClient.send({ command });
+}
+
+export function setMpvSubVisibilityRuntimeService(
+  mpvClient: MpvRuntimeClientLike | null,
+  visible: boolean,
+): void {
+  if (!mpvClient?.setSubVisibility) return;
+  mpvClient.setSubVisibility(visible);
+}