SubMiner/src/main/runtime/jellyfin-command-dispatch.ts

import type { CliArgs } from '../../cli/args';

type JellyfinConfigBase = {
  serverUrl?: string;
  accessToken?: string;
  userId?: string;
  username?: string;
};

type JellyfinSession = {
  serverUrl: string;
  accessToken: string;
  userId: string;
  username: string;
};

export function createRunJellyfinCommandHandler<
  TClientInfo,
  TConfig extends JellyfinConfigBase,
>(deps: {
  getJellyfinConfig: () => TConfig;
  defaultServerUrl: string;
  getJellyfinClientInfo: (config: TConfig) => TClientInfo;
  handleAuthCommands: (params: {
    args: CliArgs;
    jellyfinConfig: TConfig;
    serverUrl: string;
    clientInfo: TClientInfo;
  }) => Promise<boolean>;
  handleRemoteAnnounceCommand: (args: CliArgs) => Promise<boolean>;
  handleListCommands: (params: {
    args: CliArgs;
    session: JellyfinSession;
    clientInfo: TClientInfo;
    jellyfinConfig: TConfig;
  }) => Promise<boolean>;
  handlePlayCommand: (params: {
    args: CliArgs;
    session: JellyfinSession;
    clientInfo: TClientInfo;
    jellyfinConfig: TConfig;
  }) => Promise<boolean>;
}) {
  return async (args: CliArgs): Promise<void> => {
    const jellyfinConfig = deps.getJellyfinConfig();
    const serverUrl =
      args.jellyfinServer?.trim() || jellyfinConfig.serverUrl || deps.defaultServerUrl;
    const clientInfo = deps.getJellyfinClientInfo(jellyfinConfig);

    if (
      await deps.handleAuthCommands({
        args,
        jellyfinConfig,
        serverUrl,
        clientInfo,
      })
    ) {
      return;
    }

    const accessToken = jellyfinConfig.accessToken;
    const userId = jellyfinConfig.userId;
    if (!serverUrl || !accessToken || !userId) {
      throw new Error('Missing Jellyfin session. Run --jellyfin-login first.');
    }

    const session: JellyfinSession = {
      serverUrl,
      accessToken,
      userId,
      username: jellyfinConfig.username || '',
    };

    if (await deps.handleRemoteAnnounceCommand(args)) {
      return;
    }

    if (
      await deps.handleListCommands({
        args,
        session,
        clientInfo,
        jellyfinConfig,
      })
    ) {
      return;
    }

    if (
      await deps.handlePlayCommand({
        args,
        session,
        clientInfo,
        jellyfinConfig,
      })
    ) {
      return;
    }
  };
}