utils: fix pipeRequest callback

This commit is contained in:
undefined committed 2025-01-23 04:23:33 +08:00
1 parent 7dee035a89
commit 5b5dd148ee
3 files changed
+6 -3

No files matched your search

+1 -1
View File
@@ -1,7 +1,7 @@
{ {
"name": "@hydrooj/hydrojudge", "name": "@hydrooj/hydrojudge",
"bin": "bin/hydrojudge.js", "bin": "bin/hydrojudge.js",
"version": "3.4.0", "version": "3.4.1",
"main": "./src/index.ts", "main": "./src/index.ts",
"author": "undefined <i@undefined.moe>", "author": "undefined <i@undefined.moe>",
"repository": "https://github.com/hydro-dev/Hydro.git", "repository": "https://github.com/hydro-dev/Hydro.git",
+4 -1
View File
@@ -327,6 +327,9 @@ export async function extractZip(zip: AdmZip, dest: string, overwrite = false, s
export async function pipeRequest(req: superagent.Request, w: fs.WriteStream, timeout?: number, name?: string) { export async function pipeRequest(req: superagent.Request, w: fs.WriteStream, timeout?: number, name?: string) {
try { try {
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
w.on('finish', () => {
resolve(null);
});
req.buffer(false).timeout({ req.buffer(false).timeout({
response: Math.min(10000, timeout), response: Math.min(10000, timeout),
deadline: timeout, deadline: timeout,
@@ -336,10 +339,10 @@ export async function pipeRequest(req: superagent.Request, w: fs.WriteStream, ti
resp.pipe(w); resp.pipe(w);
resp.on('end', () => { resp.on('end', () => {
cb(null, undefined); cb(null, undefined);
resolve(null);
}); });
resp.on('error', (err) => { resp.on('error', (err) => {
cb(err, undefined); cb(err, undefined);
reject(err);
}); });
} }
}).catch(reject); }).catch(reject);
+1 -1
View File
@@ -1,6 +1,6 @@
{ {
"name": "@hydrooj/utils", "name": "@hydrooj/utils",
"version": "1.4.32", "version": "1.4.33",
"description": "hydrooj utils", "description": "hydrooj utils",
"main": "lib/utils.ts", "main": "lib/utils.ts",
"repository": "https://github.com/hydro-dev/Hydro.git", "repository": "https://github.com/hydro-dev/Hydro.git",