daenamnu/discordeno
1
0
Fork 0
mirror of https://github.com/discordeno/discordeno.git synced 2026-06-03 09:20:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: if undefined

Browse Source
This commit is contained in:
H01001000
2022-12-22 02:18:23 +08:00
parent e7e63da614
commit ce8e17f3e0
4 changed files with 1 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/rest/src/createInvalidRequestBucket.ts
View File

@@ -83,7 +83,7 @@ export function createInvalidRequestBucket (
// Mark a request has been invalid
bucket.current++
// If a timeout was not started, start a timeout to reset this bucket
if (bucket.timeoutId !== undefined) {
if (bucket.timeoutId === undefined) {
bucket.timeoutId = setTimeout(() => {
bucket.frozenAt = 0
bucket.current = 0

1
packages/rest/src/index.ts
View File

@@ -4,7 +4,6 @@ export * from './convertRestError.js'
export * from './createRequestBody.js'
export * from './helpers/index.js'
export * from './processGlobalQueue.js'
export * from './processQueue.js'
export * from './processRateLimitedPaths.js'
export * from './processRequest.js'
export * from './processRequestHeaders.js'

56
packages/rest/src/processQueue.ts
View File

@@ -1,56 +0,0 @@
import type { RestManager } from './restManager.js'
/** Processes the queue by looping over each path separately until the queues are empty. */
export function processQueue (rest: RestManager, id: string): void {
// const queue = rest.pathQueues.get(id);
// if (!queue) return;
// while (queue.requests.length) {
// rest.debug(`[REST - processQueue] Running while loop.`);
// if (rest.globallyRateLimited) {
// rest.debug(`[REST - processQueue] Globally rate limited.`);
// continue;
// }
// // SELECT THE FIRST ITEM FROM THIS QUEUE
// const queuedRequest = queue.requests[0];
// // IF THIS DOESN'T HAVE ANY ITEMS JUST CANCEL, THE CLEANER WILL REMOVE IT.
// if (!queuedRequest) break;
// const basicURL = rest.simplifyUrl(queuedRequest.request.url, queuedRequest.request.method);
// // IF THIS URL IS STILL RATE LIMITED, TRY AGAIN
// const urlResetIn = rest.checkRateLimits(rest, basicURL);
// if (urlResetIn) {
// // ONLY ADD TIMEOUT IF ANOTHER QUEUE IS NOT PENDING
// if (!queue.isWaiting) {
// queue.isWaiting = true;
// setTimeout(() => {
// queue.isWaiting = false;
// rest.debug(`[REST - processQueue] rate limited, running setTimeout.`);
// rest.processQueue(rest, id);
// }, urlResetIn);
// }
// // BREAK WHILE LOOP
// break;
// }
// // IF A BUCKET EXISTS, CHECK THE BUCKET'S RATE LIMITS
// const bucketResetIn = queuedRequest.payload.bucketId
// ? rest.checkRateLimits(rest, queuedRequest.payload.bucketId)
// : false;
// // THIS BUCKET IS STILL RATE LIMITED, RE-ADD TO QUEUE
// if (bucketResetIn) continue;
// // EXECUTE THE REQUEST
// // CUSTOM HANDLER FOR USER TO LOG OR WHATEVER WHENEVER A FETCH IS MADE
// rest.debug(`[REST - Add To Global Queue] ${JSON.stringify(queuedRequest.payload)}`);
// // rest.globalQueue.push({
// // ...queuedRequest,
// // urlToUse: queuedRequest.request.url,
// // basicURL,
// // });
// rest.processGlobalQueue(rest, {
// ...queuedRequest,
// urlToUse: queuedRequest.request.url,
// basicURL,
// });
// queue.requests.shift();
// }
// // ONCE QUEUE IS DONE, WE CAN TRY CLEANING UP
// rest.cleanupQueues(rest);
}

4
packages/rest/src/restManager.ts
View File

@@ -13,7 +13,6 @@ import type { QueueBucket } from './createQueueBucket.js'
import { createRequestBody } from './createRequestBody.js'
import * as helpers from './helpers/index.js'
import { processGlobalQueue } from './processGlobalQueue.js'
import { processQueue } from './processQueue.js'
import { processRateLimitedPaths } from './processRateLimitedPaths.js'
import { processRequest } from './processRequest.js'
import { processRequestHeaders } from './processRequestHeaders.js'
@@ -60,7 +59,6 @@ export function createRestManager (
debug: options.debug ?? function (_text: string) {},
checkRateLimits: options.checkRateLimits ?? checkRateLimits,
cleanupQueues: options.cleanupQueues ?? cleanupQueues,
processQueue: options.processQueue ?? processQueue,
processRateLimitedPaths:
options.processRateLimitedPaths ?? processRateLimitedPaths,
processRequestHeaders:
@@ -126,7 +124,6 @@ export interface CreateRestManagerOptions {
debug?: (text: string) => unknown
checkRateLimits?: typeof checkRateLimits
cleanupQueues?: typeof cleanupQueues
processQueue?: typeof processQueue
processRateLimitedPaths?: typeof processRateLimitedPaths
processRequestHeaders?: typeof processRequestHeaders
processRequest?: typeof processRequest
@@ -165,7 +162,6 @@ export interface RestManager extends FinalHelpers {
debug: (text: string) => unknown
checkRateLimits: typeof checkRateLimits
cleanupQueues: typeof cleanupQueues
processQueue: typeof processQueue
processRateLimitedPaths: typeof processRateLimitedPaths
processRequestHeaders: typeof processRequestHeaders
processRequest: typeof processRequest