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

safer exit

Browse Source
This commit is contained in:
tresabhi committed 2026-08-08 14:09:48 -05:00
1 parent 6d527a7170
commit 953570461c
1 file changed
+39 -37
Download Patch File Download Diff File Expand all files Collapse all files
packages/scripts/src/discoverIds/index.ts
+39 -37
View File
@@ -2,6 +2,7 @@ import { $ } from "bun";
import { range } from "lodash-es"; import { range } from "lodash-es";
import { compress, decompress } from "lz4js"; import { compress, decompress } from "lz4js";
import { mkdir, rm } from "node:fs/promises"; import { mkdir, rm } from "node:fs/promises";
import { exit } from "node:process";
import { IdArray } from "./idArray"; import { IdArray } from "./idArray";
interface ManifestV1 { interface ManifestV1 {
@@ -42,8 +43,7 @@ console.log(
); );
const t0 = performance.now(); const t0 = performance.now();
// const maxT = 5 * 60 * 60 * 1000; // 5hr const maxT = 5 * 60 * 60 * 1000; // 5hr
const maxT = 60 * 1000;
const t1 = t0 + maxT; const t1 = t0 + maxT;
await mkdir(TEMP, { recursive: true }); await mkdir(TEMP, { recursive: true });
@@ -133,11 +133,47 @@ for (const region of regions) {
console.log(` ${region.domain}: ${region.seed.toLocaleString()}`); console.log(` ${region.domain}: ${region.seed.toLocaleString()}`);
} }
console.log("Starting discovery loop..."); let isSaving = false;
async function save() {
if (isSaving) return;
isSaving = true;
console.log("Saving chunks...");
await rm(`${CHUNKS_DIR}/*`, { force: true });
let totalFound = 0;
for (let i = 0; i < chunks.length; i++) {
const path = `${CHUNKS_DIR}/chunk-${i}.dat.lz4`;
const chunk = chunks[i];
const bytes = chunk.toBytes();
const compressed = compress(bytes);
totalFound += chunk.size();
await Bun.write(path, compressed);
}
const git = $.cwd(WORKING_DIR);
await git`git add .`.quiet();
await git`git commit --amend -m "ids update ${new Date().toISOString()}"`.quiet();
await git`git push --force-with-lease`.quiet();
console.log(
`Committed ${totalFound.toLocaleString()} total ids across ${chunkCount} chunks`,
);
exit(0);
}
process.on("SIGINT", save); process.on("SIGINT", save);
process.on("SIGTERM", save); process.on("SIGTERM", save);
console.log("Starting discovery loop...");
const queue: { region: RegionDescriptor; url: string; size: number }[] = []; const queue: { region: RegionDescriptor; url: string; size: number }[] = [];
const applicationId = import.meta.env.PUBLIC_WARGAMING_APPLICATION_ID; const applicationId = import.meta.env.PUBLIC_WARGAMING_APPLICATION_ID;
const fields = "account_id%2C-account_id"; const fields = "account_id%2C-account_id";
@@ -228,38 +264,4 @@ while (performance.now() < t1 && regions.length > 0) {
} }
} }
let isSaving = false;
async function save() {
if (isSaving) return;
isSaving = true;
console.log("Saving chunks...");
await rm(`${CHUNKS_DIR}/*`, { force: true });
let totalFound = 0;
for (let i = 0; i < chunks.length; i++) {
const path = `${CHUNKS_DIR}/chunk-${i}.dat.lz4`;
const chunk = chunks[i];
const bytes = chunk.toBytes();
const compressed = compress(bytes);
totalFound += chunk.size();
await Bun.write(path, compressed);
}
const git = $.cwd(WORKING_DIR);
await git`git add .`.quiet();
await git`git commit --amend -m "ids update ${new Date().toISOString()}"`.quiet();
await git`git push --force-with-lease`.quiet();
console.log(
`Committed ${totalFound.toLocaleString()} total ids across ${chunkCount} chunks`,
);
}
await save(); await save();