Function createStreamingHost

packages/player/src/services/streamingHost.ts:52–139

()

};

export const createStreamingHost = (): StreamingHost => ({
  resolveCandidatesForTrack: async (track: Track) => {
    const provider = getActiveStreamingProvider();

    if (!provider) {
      Logger.streaming.warn('No streaming provider available');
      return {
        success: false,
        error: 'No streaming provider available',
      };
    }

    try {
      // Temporarily provide both methods to avoid breaking existing providers until we have autoupdate for plugins
      const candidates = provider.searchForTrackV2
        ? await provider.searchForTrackV2(track)
        : await provider.searchForTrack(
            track.artists[0]?.name ?? 'Unknown Artist',
            track.title,
            track.album?.title,
          );

      return {
        success: true,
        candidates,
      };
    } catch (error) {
      Logger.streaming.error(
        `resolveCandidatesForTrack error: ${resolveErrorMessage(error)}`,
      );
      const message = error instanceof Error ? error.message : 'Unknown error';
      return {
        success: false,
        error: `Failed to resolve candidates: ${message}`,
      };
    }
  },

  resolveStreamForCandidate: async (candidate: StreamCandidate) => {
    const provider = getActiveStreamingProvider();

    if (!provider) {
      Logger.streaming.warn('No provider for stream resolution');
      return undefined;
    }

    if (candidate.failed) {
      Logger.streaming.warn('Candidate already marked as failed');
      return candidate;
    }

    if (candidate.stream && !isStreamExpired(candidate)) {
      return candidate;
    }

    const retries =
      (useSettingsStore
        .getState()