DevComp/fxtwitter-docker
1
0
Fork 0
mirror of https://github.com/CompeyDev/fxtwitter-docker.git synced 2025-04-05 18:40:56 +01:00
Code Issues Projects Releases Packages Wiki Activity

Handle caching unavailable (for bun and other envs)

Browse source
This commit is contained in:
dangered wolf 2024-01-31 17:19:21 -05:00
parent 722d6663ea
commit e4fbe63250
No known key found for this signature in database
GPG key ID: 41E4D37680ED8B58
2 changed files with 16 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/caches.ts
View file

@ -22,6 +22,12 @@ export const cacheMiddleware = (): MiddlewareHandler => async (c, next) => {
let cacheKey: Request;
const returnAsJson = Constants.API_HOST_LIST.includes(cacheUrl.hostname);
/* If caching unavailable, ignore the rest of the cache middleware */
if (typeof caches === 'undefined') {
await next();
return c.res.clone();
}
try {
cacheKey = new Request(cacheUrl.toString(), request);
} catch (e) {

13
src/fetch.ts
View file

@ -59,7 +59,7 @@ export const twitterFetch = async (
}
);
const cache = caches.default;
const cache = typeof caches !== 'undefined' ? caches.default : null;
while (apiAttempts < API_ATTEMPTS) {
/* Generate a random CSRF token, Twitter just cares that header and cookie match,
@ -75,7 +75,12 @@ export const twitterFetch = async (
let activate: Response | null = null;
if (!newTokenGenerated && !useElongator) {
if (cache === null) {
console.log('Caching unavailable, requesting new token');
newTokenGenerated = true;
}
if (!newTokenGenerated && !useElongator && cache) {
const timeBefore = performance.now();
const cachedResponse = await cache.match(guestTokenRequestCacheDummy.clone());
const timeAfter = performance.now();
@ -172,6 +177,7 @@ export const twitterFetch = async (
}
try {
!useElongator &&
cache &&
c.executionCtx &&
c.executionCtx.waitUntil(
cache.delete(guestTokenRequestCacheDummy.clone(), { ignoreMethod: true })
@ -207,6 +213,7 @@ export const twitterFetch = async (
console.log(`Purging token on this edge due to low rate limit remaining`);
try {
c.executionCtx &&
cache &&
c.executionCtx.waitUntil(
cache.delete(guestTokenRequestCacheDummy.clone(), { ignoreMethod: true })
);
@ -231,7 +238,7 @@ export const twitterFetch = async (
}
try {
/* If we've generated a new token, we'll cache it */
if (c.executionCtx && newTokenGenerated && activate) {
if (c.executionCtx && newTokenGenerated && activate && cache) {
const cachingResponse = new Response(await activate.clone().text(), {
headers: {
...tokenHeaders,