fix zip

Author: sunnylqm

src/utils/zip-entries.ts

@@ -1,10 +1,10 @@
+import * as fs from 'fs-extra';
 import os from 'os';
 import path from 'path';
-import * as fs from 'fs-extra';
 import {
   type Entry,
-  type ZipFile as YauzlZipFile,
   open as openZipFile,
+  type ZipFile as YauzlZipFile,
 } from 'yauzl';
 import { t } from './i18n';
 
@@ -56,24 +56,33 @@ export function readEntryPrefix(
       }
 
       let settled = false;
+      let expectedDestroyError: Error | undefined;
       const cleanup = () => {
         stream.off('data', onData);
         stream.off('end', onEnd);
         stream.off('error', onError);
       };
-      const finish = () => {
+      const finish = (destroyStream = false) => {
         if (settled) {
           return;
         }
         settled = true;
-        cleanup();
+        stream.off('data', onData);
+        stream.off('end', onEnd);
+        if (!destroyStream) {
+          stream.off('error', onError);
+        }
         resolve(Buffer.concat(buffers, length));
+
+        if (destroyStream) {
+          expectedDestroyError = new Error('zip entry prefix read complete');
+          stream.destroy(expectedDestroyError);
+        }
       };
       const onData = (chunk: Buffer) => {
         const remaining = maxBytes - length;
         if (remaining <= 0) {
-          finish();
-          stream.destroy();
+          finish(true);
           return;
         }
 
@@ -82,12 +91,15 @@ export function readEntryPrefix(
         buffers.push(slice);
         length += slice.length;
         if (length >= maxBytes) {
-          finish();
-          stream.destroy();
+          finish(true);
         }
       };
       const onEnd = () => finish();
       const onError = (error: Error) => {
+        if (settled && error === expectedDestroyError) {
+          cleanup();
+          return;
+        }
         if (settled) {
           return;
         }

tsconfig.json

@@ -40,7 +40,7 @@
 
     /* Module Resolution Options */
     // "moduleResolution": "node",            /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */
-    "baseUrl": "./src" /* Base directory to resolve non-absolute module names. */,
+    "ignoreDeprecations": "6.0",
     // "paths": {},                           /* A series of entries which re-map imports to lookup locations relative to the 'baseUrl'. */
     // "rootDirs": [
     //   "src",
@@ -52,7 +52,8 @@
     // "types": [],                           /* Type declaration files to be included in compilation. */
     "allowSyntheticDefaultImports": true /* Allow default imports from modules with no default export. This does not affect code emit, just typechecking. */,
     "paths": {
-      "@/*": ["src/*"]
+      "*": ["./src/*"],
+      "@/*": ["./src/*"]
     },
     "resolveJsonModule": true,
     "esModuleInterop": true /* Enables emit interoperability between CommonJS and ES Modules via creation of namespace objects for all imports. Implies 'allowSyntheticDefaultImports'. */,