From 389b0f362fc1b0247ff3e86eef7973f32cac19b2 Mon Sep 17 00:00:00 2001 From: LuanRT Date: Mon, 25 Oct 2021 02:25:52 -0300 Subject: [PATCH] chore: format code --- lib/Actions.js | 6 +++--- lib/Innertube.js | 46 +++++++++++++++++++++++----------------------- lib/SigDecipher.js | 2 +- 3 files changed, 27 insertions(+), 27 deletions(-) diff --git a/lib/Actions.js b/lib/Actions.js index f4fd8f8f6..2e5a69f47 100644 --- a/lib/Actions.js +++ b/lib/Actions.js @@ -56,7 +56,7 @@ async function browse(session, action_type) { break; default: } - + const response = await Axios.post(`${Constants.urls.YT_BASE_URL}/youtubei/v1/browse${session.logged_in && session.cookie.length < 1 ? '' : `?key=${session.key}`}`, JSON.stringify(data), Constants.innertube_request_opts({ session })).catch((error) => error); if (response instanceof Error) return { success: false, status_code: response.response.status, message: response.message }; return { @@ -104,7 +104,7 @@ async function notifications(session, action_type, args = {}) { async function livechat(session, action_type, args = {}) { let data; switch (action_type) { - case 'live_chat/send_message': + case 'live_chat/send_message': data = { context: session.context, params: Utils.generateMessageParams(args.channel_id, args.video_id), @@ -127,7 +127,7 @@ async function livechat(session, action_type, args = {}) { break; default: } - + const response = await Axios.post(`${Constants.urls.YT_BASE_URL}/youtubei/v1/${action_type}${session.logged_in && session.cookie.length < 1 ? '' : `?key=${session.key}`}`, JSON.stringify(data), Constants.innertube_request_opts({ session, params: args.params })).catch((error) => error); if (response instanceof Error) return { success: false, status_code: response.response.status, message: response.message }; return { diff --git a/lib/Innertube.js b/lib/Innertube.js index a66cca697..e1a6443e6 100644 --- a/lib/Innertube.js +++ b/lib/Innertube.js @@ -149,7 +149,7 @@ class Innertube extends EventEmitter { } else { video_data.getLivechat = () => {}; } - + video_data.like = () => Actions.engage(this, 'like/like', { video_id: id }); video_data.dislike = () => Actions.engage(this, 'like/dislike', { video_id: id }); video_data.removeLike = () => Actions.engage(this, 'like/removelike', { video_id: id }); @@ -161,32 +161,32 @@ class Innertube extends EventEmitter { return video_data; } - + async getComments(video_id, token) { let comment_section_token; - + if (!token) { const data_continuation = await Actions.getContinuation(this, { video_id }); const item_section_renderer = data_continuation.data.contents.twoColumnWatchNextResults.results.results.contents.find((item) => item.itemSectionRenderer); comment_section_token = item_section_renderer.itemSectionRenderer.contents[0].continuationItemRenderer.continuationEndpoint.continuationCommand.token; } - + const response = await Actions.getContinuation(this, { continuation_token: comment_section_token || token }); if (!response.success) throw new Error('Could not fetch comment section'); - + const comments_section = { comments: [] }; !token && (comments_section.comment_count = response.data.onResponseReceivedEndpoints[0].reloadContinuationItemsCommand.continuationItems && response.data.onResponseReceivedEndpoints[0].reloadContinuationItemsCommand.continuationItems[0].commentsHeaderRenderer.countText.runs[0].text || 'N/A'); - + let continuation_token; - !token && (continuation_token = response.data.onResponseReceivedEndpoints[1].reloadContinuationItemsCommand.continuationItems.find((item) => item.continuationItemRenderer).continuationItemRenderer.continuationEndpoint.continuationCommand.token) - || (continuation_token = response.data.onResponseReceivedEndpoints[0].appendContinuationItemsAction.continuationItems.find((item) => item.continuationItemRenderer).continuationItemRenderer.continuationEndpoint.continuationCommand.token); - + !token && (continuation_token = response.data.onResponseReceivedEndpoints[1].reloadContinuationItemsCommand.continuationItems.find((item) => item.continuationItemRenderer).continuationItemRenderer.continuationEndpoint.continuationCommand.token) || + (continuation_token = response.data.onResponseReceivedEndpoints[0].appendContinuationItemsAction.continuationItems.find((item) => item.continuationItemRenderer).continuationItemRenderer.continuationEndpoint.continuationCommand.token); + comments_section.getContinuation = () => this.getComments(video_id, continuation_token); - + let contents; - !token && (contents = response.data.onResponseReceivedEndpoints[1].reloadContinuationItemsCommand.continuationItems) - || (contents = response.data.onResponseReceivedEndpoints[0].appendContinuationItemsAction.continuationItems); - + !token && (contents = response.data.onResponseReceivedEndpoints[1].reloadContinuationItemsCommand.continuationItems) || + (contents = response.data.onResponseReceivedEndpoints[0].appendContinuationItemsAction.continuationItems); + contents.forEach((thread) => { if (!thread.commentThreadRenderer) return; const comment = { @@ -207,26 +207,26 @@ class Innertube extends EventEmitter { }; comments_section.comments.push(comment); }); - + return comments_section; } - + async getSubscriptionsFeed() { const response = await Actions.browse(this, 'subscriptions_feed'); if (!response.success) throw new Error('Could not fetch subscriptions feed'); - + const contents = response.data.contents.twoColumnBrowseResultsRenderer.tabs[0].tabRenderer.content.sectionListRenderer.contents; const subscriptions_feed = {}; - + contents.forEach((section) => { if (!section.itemSectionRenderer) return; - + const section_contents = section.itemSectionRenderer.contents[0]; const section_items = section_contents.shelfRenderer.content.gridRenderer.items; - + const key = section_contents.shelfRenderer.title.runs[0].text; subscriptions_feed[key.toLowerCase().replace(/ +/g, '_')] = []; - + section_items.forEach((item) => { const content = { title: item.gridVideoRenderer.title.runs.map((run) => run.text).join(' '), @@ -240,18 +240,18 @@ class Innertube extends EventEmitter { owner_badges: item.gridVideoRenderer.ownerBadges && item.gridVideoRenderer.ownerBadges.map((badge) => badge.metadataBadgeRenderer.tooltip) || 'N/A' } }; - + subscriptions_feed[key.toLowerCase().replace(/ +/g, '_')].push(content); }); }); - + return subscriptions_feed; } async getNotifications() { const response = await Actions.notifications(this, 'get_notification_menu'); if (!response.success) throw new Error('Could not fetch notifications'); - + const contents = response.data.actions[0].openPopupAction.popup.multiPageMenuRenderer.sections[0]; if (!contents.multiPageMenuNotificationSectionRenderer) return { error: 'You don\'t have any notification.' }; return contents.multiPageMenuNotificationSectionRenderer.items.map((notification) => { diff --git a/lib/SigDecipher.js b/lib/SigDecipher.js index 6cbfc32ab..751a5a8d9 100644 --- a/lib/SigDecipher.js +++ b/lib/SigDecipher.js @@ -49,7 +49,7 @@ class SigDecipher { } const url_components = new URL(args.url); - + args.sp !== undefined ? url_components.searchParams.set(args.sp, signature.join('')) : url_components.searchParams.set('signature', signature.join('')); url_components.searchParams.set('cver', this.cver); url_components.searchParams.set('ratebypass', 'yes');