twitter: clean up
This commit is contained in:
parent
678e00430b
commit
678d6a56ca
1 changed files with 40 additions and 40 deletions
|
@ -1,25 +1,8 @@
|
||||||
import { genericUserAgent } from "../../config.js";
|
import { genericUserAgent } from "../../config.js";
|
||||||
import { createStream } from "../../stream/manage.js";
|
import { createStream } from "../../stream/manage.js";
|
||||||
|
|
||||||
// fix all videos affected by the container bug in twitter muxer (took them over two weeks to fix it????)
|
const graphqlURL = 'https://twitter.com/i/api/graphql/5GOHgZe-8U2j5sVHQzEm9A/TweetResultByRestId';
|
||||||
const TWITTER_EPOCH = 1288834974657n;
|
const tokenURL = 'https://api.twitter.com/1.1/guest/activate.json';
|
||||||
const badContainerStart = new Date(1701446400000);
|
|
||||||
const badContainerEnd = new Date(1702605600000);
|
|
||||||
|
|
||||||
function needsFixing(media) {
|
|
||||||
const representativeId = media.source_status_id_str ?? media.id_str;
|
|
||||||
const mediaTimestamp = new Date(
|
|
||||||
Number((BigInt(representativeId) >> 22n) + TWITTER_EPOCH)
|
|
||||||
)
|
|
||||||
return mediaTimestamp > badContainerStart && mediaTimestamp < badContainerEnd;
|
|
||||||
}
|
|
||||||
|
|
||||||
function bestQuality(arr) {
|
|
||||||
return arr
|
|
||||||
.filter(v => v.content_type === "video/mp4")
|
|
||||||
.reduce((a, b) => Number(a?.bitrate) > Number(b?.bitrate) ? a : b)
|
|
||||||
.url
|
|
||||||
}
|
|
||||||
|
|
||||||
const tweetFeatures = JSON.stringify({ "creator_subscriptions_tweet_preview_api_enabled": true, "c9s_tweet_anatomy_moderator_badge_enabled": true, "tweetypie_unmention_optimization_enabled": true, "responsive_web_edit_tweet_api_enabled": true, "graphql_is_translatable_rweb_tweet_is_translatable_enabled": true, "view_counts_everywhere_api_enabled": true, "longform_notetweets_consumption_enabled": true, "responsive_web_twitter_article_tweet_consumption_enabled": false, "tweet_awards_web_tipping_enabled": false, "responsive_web_home_pinned_timelines_enabled": true, "freedom_of_speech_not_reach_fetch_enabled": true, "standardized_nudges_misinfo": true, "tweet_with_visibility_results_prefer_gql_limited_actions_policy_enabled": true, "longform_notetweets_rich_text_read_enabled": true, "longform_notetweets_inline_media_enabled": true, "responsive_web_graphql_exclude_directive_enabled": true, "verified_phone_label_enabled": false, "responsive_web_media_download_video_enabled": false, "responsive_web_graphql_skip_user_profile_image_extensions_enabled": false, "responsive_web_graphql_timeline_navigation_enabled": true, "responsive_web_enhance_cards_enabled": false });
|
const tweetFeatures = JSON.stringify({ "creator_subscriptions_tweet_preview_api_enabled": true, "c9s_tweet_anatomy_moderator_badge_enabled": true, "tweetypie_unmention_optimization_enabled": true, "responsive_web_edit_tweet_api_enabled": true, "graphql_is_translatable_rweb_tweet_is_translatable_enabled": true, "view_counts_everywhere_api_enabled": true, "longform_notetweets_consumption_enabled": true, "responsive_web_twitter_article_tweet_consumption_enabled": false, "tweet_awards_web_tipping_enabled": false, "responsive_web_home_pinned_timelines_enabled": true, "freedom_of_speech_not_reach_fetch_enabled": true, "standardized_nudges_misinfo": true, "tweet_with_visibility_results_prefer_gql_limited_actions_policy_enabled": true, "longform_notetweets_rich_text_read_enabled": true, "longform_notetweets_inline_media_enabled": true, "responsive_web_graphql_exclude_directive_enabled": true, "verified_phone_label_enabled": false, "responsive_web_media_download_video_enabled": false, "responsive_web_graphql_skip_user_profile_image_extensions_enabled": false, "responsive_web_graphql_timeline_navigation_enabled": true, "responsive_web_enhance_cards_enabled": false });
|
||||||
|
|
||||||
|
@ -31,16 +14,35 @@ const commonHeaders = {
|
||||||
"accept-language": "en"
|
"accept-language": "en"
|
||||||
}
|
}
|
||||||
|
|
||||||
let _cachedToken
|
// fix all videos affected by the container bug in twitter muxer (took them over two weeks to fix it????)
|
||||||
|
const TWITTER_EPOCH = 1288834974657n;
|
||||||
|
const badContainerStart = new Date(1701446400000);
|
||||||
|
const badContainerEnd = new Date(1702605600000);
|
||||||
|
|
||||||
|
function needsFixing(media) {
|
||||||
|
const representativeId = media.source_status_id_str ?? media.id_str;
|
||||||
|
const mediaTimestamp = new Date(
|
||||||
|
Number((BigInt(representativeId) >> 22n) + TWITTER_EPOCH)
|
||||||
|
);
|
||||||
|
return mediaTimestamp > badContainerStart && mediaTimestamp < badContainerEnd
|
||||||
|
}
|
||||||
|
|
||||||
|
function bestQuality(arr) {
|
||||||
|
return arr.filter(v => v.content_type === "video/mp4")
|
||||||
|
.reduce((a, b) => Number(a?.bitrate) > Number(b?.bitrate) ? a : b)
|
||||||
|
.url
|
||||||
|
}
|
||||||
|
|
||||||
|
let _cachedToken;
|
||||||
const getGuestToken = async (forceReload = false) => {
|
const getGuestToken = async (forceReload = false) => {
|
||||||
if (_cachedToken && !forceReload) {
|
if (_cachedToken && !forceReload) {
|
||||||
return _cachedToken;
|
return _cachedToken;
|
||||||
}
|
}
|
||||||
|
|
||||||
const tokenResponse = await fetch(
|
const tokenResponse = await fetch(tokenURL, {
|
||||||
'https://api.twitter.com/1.1/guest/activate.json',
|
method: 'POST',
|
||||||
{ method: 'POST', headers: commonHeaders }
|
headers: commonHeaders
|
||||||
).then(r => r.status === 200 && r.json()).catch(() => {})
|
}).then(r => r.status === 200 && r.json()).catch(() => {})
|
||||||
|
|
||||||
if (tokenResponse?.guest_token) {
|
if (tokenResponse?.guest_token) {
|
||||||
return _cachedToken = tokenResponse.guest_token
|
return _cachedToken = tokenResponse.guest_token
|
||||||
|
@ -48,9 +50,9 @@ const getGuestToken = async (forceReload = false) => {
|
||||||
}
|
}
|
||||||
|
|
||||||
const requestTweet = (tweetId, token) => {
|
const requestTweet = (tweetId, token) => {
|
||||||
const graphqlTweetURL = new URL('https://twitter.com/i/api/graphql/5GOHgZe-8U2j5sVHQzEm9A/TweetResultByRestId');
|
const graphqlTweetURL = new URL(graphqlURL);
|
||||||
graphqlTweetURL.searchParams.set(
|
|
||||||
'variables',
|
graphqlTweetURL.searchParams.set('variables',
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
tweetId,
|
tweetId,
|
||||||
withCommunity: false,
|
withCommunity: false,
|
||||||
|
@ -58,7 +60,6 @@ const requestTweet = (tweetId, token) => {
|
||||||
withVoice: false
|
withVoice: false
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
|
||||||
graphqlTweetURL.searchParams.set('features', tweetFeatures);
|
graphqlTweetURL.searchParams.set('features', tweetFeatures);
|
||||||
|
|
||||||
return fetch(graphqlTweetURL, {
|
return fetch(graphqlTweetURL, {
|
||||||
|
@ -68,7 +69,7 @@ const requestTweet = (tweetId, token) => {
|
||||||
'x-guest-token': token,
|
'x-guest-token': token,
|
||||||
cookie: `guest_id=${encodeURIComponent(`v1:${token}`)}`
|
cookie: `guest_id=${encodeURIComponent(`v1:${token}`)}`
|
||||||
}
|
}
|
||||||
});
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
export default async function({ id, index }) {
|
export default async function({ id, index }) {
|
||||||
|
@ -79,7 +80,7 @@ export default async function({ id, index }) {
|
||||||
|
|
||||||
if ([403, 429].includes(tweet.status)) { // get new token & retry
|
if ([403, 429].includes(tweet.status)) { // get new token & retry
|
||||||
guestToken = await getGuestToken(true);
|
guestToken = await getGuestToken(true);
|
||||||
tweet = await requestTweet(id, guestToken);
|
tweet = await requestTweet(id, guestToken)
|
||||||
}
|
}
|
||||||
|
|
||||||
tweet = await tweet.json();
|
tweet = await tweet.json();
|
||||||
|
@ -92,14 +93,12 @@ export default async function({ id, index }) {
|
||||||
const baseTweet = tweet.data.tweetResult.result.legacy,
|
const baseTweet = tweet.data.tweetResult.result.legacy,
|
||||||
repostedTweet = baseTweet.retweeted_status_result?.result.legacy.extended_entities;
|
repostedTweet = baseTweet.retweeted_status_result?.result.legacy.extended_entities;
|
||||||
|
|
||||||
let media = (
|
let media = (repostedTweet?.media || baseTweet.extended_entities.media);
|
||||||
repostedTweet?.media || baseTweet.extended_entities.media
|
media = media?.filter(m => m.video_info?.variants?.length);
|
||||||
)?.filter(m => ['video', 'animated_gif'].includes(m.type));
|
|
||||||
|
|
||||||
if (index < media?.length) {
|
if (index < media?.length) {
|
||||||
media = [ media[index] ];
|
media = [media[index]]
|
||||||
}
|
}
|
||||||
|
|
||||||
switch (media?.length) {
|
switch (media?.length) {
|
||||||
case undefined:
|
case undefined:
|
||||||
case 0:
|
case 0:
|
||||||
|
@ -116,17 +115,18 @@ export default async function({ id, index }) {
|
||||||
let url = bestQuality(video.video_info.variants);
|
let url = bestQuality(video.video_info.variants);
|
||||||
if (needsFixing(video)) {
|
if (needsFixing(video)) {
|
||||||
url = createStream({
|
url = createStream({
|
||||||
service: 'twitter', type: 'remux',
|
service: 'twitter',
|
||||||
u: url, filename: `twitter_${id}_${i + 1}.mp4`
|
type: 'remux',
|
||||||
|
u: url,
|
||||||
|
filename: `twitter_${id}_${i + 1}.mp4`
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
type: 'video', url,
|
type: 'video',
|
||||||
|
url,
|
||||||
thumb: video.media_url_https,
|
thumb: video.media_url_https,
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
return { picker }
|
return { picker }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue