YouTube.js/lib/parser/contents/classes/NavigationEndpoint.js

'use strict';

const Parser = require('..');

class NavigationEndpoint {
  type = 'navigationEndpoint';

  constructor(data) {
    data?.serviceEndpoint &&
      (data = data.serviceEndpoint);

    this.metadata = {
      url: data?.commandMetadata?.webCommandMetadata.url || null,
      page_type: data?.commandMetadata?.webCommandMetadata.webPageType || 'N/A',
      api_url: data?.commandMetadata?.webCommandMetadata.apiUrl || null,
      send_post: data?.commandMetadata?.webCommandMetadata.sendPost || null
    }
    
    if (data?.browseEndpoint) {
      this.browse = {
        id: data?.browseEndpoint?.browseId || null,
        params: data?.browseEndpoint.params || null,
        base_url: data?.browseEndpoint?.canonicalBaseUrl || null
      };
    }
    
    if (data?.watchEndpoint) {
      this.watch = {
        video_id: data?.watchEndpoint?.videoId,
        playlist_id: data?.watchEndpoint.playlistId || null,
        params: data?.watchEndpoint.params || null,
        index: data?.watchEndpoint.index || null, 
        supported_onesie_config: data?.watchEndpoint?.watchEndpointSupportedOnesieConfig
      };
    }
    
    if (data?.subscribeEndpoint) {
      this.subscribe = {
        channel_ids: data.subscribeEndpoint.channelIds,
        params: data.subscribeEndpoint.params
      }
    }
    
    if (data?.unsubscribeEndpoint) {
      this.unsubscribe = {
        channel_ids: data.unsubscribeEndpoint.channelIds,
        params: data.unsubscribeEndpoint.params
      }
    }
    
    if (data?.likeEndpoint) {
      this.like = {
        status: data.likeEndpoint.status,
        target: { video_id: data.likeEndpoint.target.videoId },
        remove_like_params: data.likeEndpoint?.removeLikeParams
      }
    }
    
    if (data?.offlineVideoEndpoint) {
      this.offline_video = {
        video_id: data.offlineVideoEndpoint.videoId,
        on_add_command: {
          get_download_action: {
            video_id: data.offlineVideoEndpoint.videoId,
            params: data.offlineVideoEndpoint.onAddCommand.getDownloadActionCommand.params,
          }
        }
      }
    }
    
    if (data?.continuationCommand) {
      this.continuation = {
        request: data?.continuationCommand?.request || null,
        token: data?.continuationCommand?.token || null
      };
    }
    
    if (data?.feedbackEndpoint) {
      this.feedback = {
        token: data.feedbackEndpoint.feedbackToken
      }
    }
    
    if (data?.watchPlaylistEndpoint) {
      this.watch_playlist = {
        playlist_id: data.watchPlaylistEndpoint?.playlistId
      }
    }
    
    if (data?.playlistEditEndpoint) {
      this.playlist_edit = {
        playlist_id: data.playlistEditEndpoint.playlistId,
        actions: data.playlistEditEndpoint.actions.map((item) => ({
          action: item.action,
          removed_video_id: item.removedVideoId 
        }))
      }
    }
    
    if (data?.addToPlaylistServiceEndpoint) {
      this.add_to_playlist = {
        video_id: data.addToPlaylistServiceEndpoint.videoId
      }
    }
    
    if (data?.getReportFormEndpoint) {
      this.get_report_form = {
        params: data.getReportFormEndpoint.params
      }
    }
  }
  
  async call(actions) {
    if (this.continuation) {
      switch (this.continuation.request) {
        case 'CONTINUATION_REQUEST_TYPE_BROWSE': {
          const response = await actions.browse(this.continuation.token, { is_ctoken: true });
          return Parser.parseResponse(response.data);
        }
        case 'CONTINUATION_REQUEST_TYPE_SEARCH': {
          const response = await actions.search({ ctoken: this.continuation.token });
          return Parser.parseResponse(response.data);
        }
        default:
          throw new Error(this.continuation.request + ' not implemented');
      }
    }
    
    if (this.browse) {
      const args = {};
      
      this.browse.params && 
        (args.params = this.browse.params);
      
      const response = await actions.browse(this.browse.id, args);
      return Parser.parseResponse(response.data);
    }
  }
}

module.exports = NavigationEndpoint;