Fix race condition in mod asset extraction

Author: rubensworks

lib/modloader/ModLoader.ts

@@ -333,42 +333,45 @@ export class ModLoader {
       openZip(modFile, { lazyEntries: true, autoClose: true }, (e, f) => {
         if (e) {
           reject(e);
+        } else {
+          resolve(f);
         }
-        resolve(f);
       });
     });
 
-    zipFile.readEntry();
-    zipFile.on('error', e => process.stdout.write(String(e)));
-    zipFile.on('entry', (entry: Entry) => {
-      if (entry.fileName.endsWith('/')) {
-        // Directory
-        zipFile.readEntry();
-      } else if (entry.fileName.startsWith('assets/') || entry.fileName.startsWith('data/')) {
-        // File
-        const prefix = entry.fileName.startsWith('assets/') ? 7 : 5;
-        const targetFile = join(
-          this.path,
-          'mod_assets',
-          entry.fileName.slice(prefix, entry.fileName.length),
-        );
-        const targetDir = dirname(targetFile);
-        void this.ensureDirExists(targetDir).then(() => {
-          zipFile.openReadStream(entry, (e, readStream) => {
-            if (e) {
-              throw e;
-            }
-            readStream.pipe(createWriteStream(targetFile));
-            readStream.on('end', () => zipFile.readEntry());
-          });
-        }).catch((e: unknown) => {
-          throw e;
-        });
-      } else {
-        zipFile.readEntry();
-      }
+    await new Promise<void>((resolve, reject) => {
+      zipFile.on('error', reject);
+      zipFile.on('end', resolve);
+      zipFile.on('entry', (entry: Entry) => {
+        if (entry.fileName.endsWith('/')) {
+          // Directory
+          zipFile.readEntry();
+        } else if (entry.fileName.startsWith('assets/') || entry.fileName.startsWith('data/')) {
+          // File
+          const prefix = entry.fileName.startsWith('assets/') ? 7 : 5;
+          const targetFile = join(
+            this.path,
+            'mod_assets',
+            entry.fileName.slice(prefix, entry.fileName.length),
+          );
+          const targetDir = dirname(targetFile);
+          this.ensureDirExists(targetDir).then(() => {
+            zipFile.openReadStream(entry, (e, readStream) => {
+              if (e) {
+                reject(e);
+                return;
+              }
+              readStream.on('error', reject);
+              readStream.pipe(createWriteStream(targetFile));
+              readStream.on('end', () => zipFile.readEntry());
+            });
+          }).catch(reject);
+        } else {
+          zipFile.readEntry();
+        }
+      });
+      zipFile.readEntry();
     });
-    await new Promise(resolve => zipFile.on('end', resolve));
   }
 
   /**