TresAbhi/blitzkit
1
0 Fork 0
mirror of https://github.com/blitzkit/blitzkit.git synced 2026-10-23 19:49:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #362 from Hitjack007/discover-ids-await-loop

Browse Source
This commit is contained in:
TrèsAbhi authored and GitHub committed 2026-10-07 16:34:49 -05:00
2 parents f6e5fabb65 3aefe7d985
commit 112472762d
2 files changed
+10 -7
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

packages/scripts/src/discoverIds/index.ts
+6 -5
View File
@@ -135,7 +135,7 @@ let regionI = 0;
console.log("Starting discovery loop..."); console.log("Starting discovery loop...");
atMaxRate(async ({ _break: break1 }) => { await atMaxRate(async ({ _break: break1 }) => {
if (regions.length === 0) { if (regions.length === 0) {
console.log("All regions exhausted, exiting discovery loop..."); console.log("All regions exhausted, exiting discovery loop...");
return break1(); return break1();
@@ -166,7 +166,6 @@ atMaxRate(async ({ _break: break1 }) => {
fields fields
}&account_id=${accountIds}`; }&account_id=${accountIds}`;
atMaxRate(async ({ _break: break2 }) => {
if (idRange.length < MAX_IDS_PER_CALL) { if (idRange.length < MAX_IDS_PER_CALL) {
console.log( console.log(
`Removing region ${region.domain} removed due to ID range exhaustion...`, `Removing region ${region.domain} removed due to ID range exhaustion...`,
@@ -174,10 +173,12 @@ atMaxRate(async ({ _break: break1 }) => {
regions.splice(regionI, 1); regions.splice(regionI, 1);
} }
const response = await fetch(url); await atMaxRate(async ({ _break: break2 }) => {
const data = (await response.json()) as QuickInfo; const data = await fetch(url)
.then((response) => response.json() as Promise<QuickInfo>)
.catch(() => null);
if (data.status !== "ok") { if (data === null || data.status !== "ok") {
console.warn("Failed API call; trying again..."); console.warn("Failed API call; trying again...");
return; return;
} }
packages/scripts/src/discoverIds/time.ts
+4 -2
View File
@@ -20,7 +20,9 @@ interface MethodContext {
let lastT = 0; let lastT = 0;
const maxDelta = 1000 / API_RATE; const maxDelta = 1000 / API_RATE;
const DELTA_BUFFER = 0; const DELTA_BUFFER = 0;
export async function atMaxRate(method: (context: MethodContext) => void) { export async function atMaxRate(
method: (context: MethodContext) => void | Promise<void>,
) {
let isBroken = false; let isBroken = false;
const context: MethodContext = { const context: MethodContext = {
@@ -39,7 +41,7 @@ export async function atMaxRate(method: (context: MethodContext) => void) {
await sleep(maxDelta - delta + DELTA_BUFFER); await sleep(maxDelta - delta + DELTA_BUFFER);
} }
method(context); await method(context);
lastT = t; lastT = t;
} }
} }