DevComp/fxtwitter-docker
1
0
Fork 0
mirror of https://github.com/CompeyDev/fxtwitter-docker.git synced 2025-04-06 19:10:54 +01:00
Code Issues Projects Releases Packages Wiki Activity

switch on guest token cache (borked)

Browse source
This commit is contained in:
dangered wolf 2022-08-18 00:49:57 -04:00
parent 45da5e3ecb
commit 4ae10034db
No known key found for this signature in database
GPG key ID: 41E4D37680ED8B58
4 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/api.ts
View file

@ -138,9 +138,10 @@ const populateTweetProperties = async (
available for free using api.fxtwitter.com. */ available for free using api.fxtwitter.com. */
export const statusAPI = async ( export const statusAPI = async (
status: string, status: string,
language: string | undefined language: string | undefined,
event: FetchEvent
): Promise<APIResponse> => { ): Promise<APIResponse> => {
const conversation = await fetchUsingGuest(status); const conversation = await fetchUsingGuest(status, event);
const tweet = conversation?.globalObjects?.tweets?.[status] || {}; const tweet = conversation?.globalObjects?.tweets?.[status] || {};
/* Fallback for if Tweet did not load */ /* Fallback for if Tweet did not load */

5
src/fetch.ts
View file

@ -1,6 +1,6 @@
import { Constants } from './constants'; import { Constants } from './constants';
export const fetchUsingGuest = async (status: string): Promise<TimelineBlobPartial> => { export const fetchUsingGuest = async (status: string, event: FetchEvent): Promise<TimelineBlobPartial> => {
let apiAttempts = 0; let apiAttempts = 0;
let cachedTokenFailed = false; let cachedTokenFailed = false;
@ -121,9 +121,8 @@ export const fetchUsingGuest = async (status: string): Promise<TimelineBlobParti
cachedTokenFailed = true; cachedTokenFailed = true;
continue; continue;
} }
/* Once we've confirmed we have a working guest token, let's cache it! */ /* Once we've confirmed we have a working guest token, let's cache it! */
// event.waitUntil(cache.put(guestTokenRequest, activate.clone())); event.waitUntil(cache.put(guestTokenRequest, activate.clone()));
conversation.guestToken = guestToken; conversation.guestToken = guestToken;
return conversation; return conversation;
} }

3
src/server.ts
View file

@ -90,7 +90,8 @@ const statusRequest = async (
mediaNumber ? parseInt(mediaNumber) : undefined, mediaNumber ? parseInt(mediaNumber) : undefined,
userAgent, userAgent,
flags, flags,
language language,
event
); );
/* Complete responses are normally sent just by errors. Normal embeds send a `text` value. */ /* Complete responses are normally sent just by errors. Normal embeds send a `text` value. */

5
src/status.ts
View file

@ -24,12 +24,13 @@ export const handleStatus = async (
mediaNumber?: number, mediaNumber?: number,
userAgent?: string, userAgent?: string,
flags?: InputFlags, flags?: InputFlags,
language?: string language?: string,
event?: FetchEvent
// eslint-disable-next-line sonarjs/cognitive-complexity // eslint-disable-next-line sonarjs/cognitive-complexity
): Promise<StatusResponse> => { ): Promise<StatusResponse> => {
console.log('Direct?', flags?.direct); console.log('Direct?', flags?.direct);
const api = await statusAPI(status, language); const api = await statusAPI(status, language, event as FetchEvent);
const tweet = api?.tweet as APITweet; const tweet = api?.tweet as APITweet;
/* Catch this request if it's an API response */ /* Catch this request if it's an API response */