Remove unzip/unrar/untar worker dependency on archive.js so that we can turn it into an ES module for Issue #16

archive/archive.js

@@ -231,21 +231,53 @@ bitjs.archive.Unarchiver = class {
     }
   }
 
+  /**
+   * Create an UnarchiveEvent out of the object sent back from the Worker.
+   * @param {Object} obj
+   * @return {bitjs.archive.UnarchiveEvent}
+   * @private
+   */
+  createUnarchiveEvent_(obj) {
+    switch (obj.type) {
+      case bitjs.archive.UnarchiveEvent.Type.START:
+        return new bitjs.archive.UnarchiveStartEvent();
+      case bitjs.archive.UnarchiveEvent.Type.PROGRESS:
+        return new bitjs.archive.UnarchiveProgressEvent(
+          obj.currentFilename,
+          obj.currentFileNumber,
+          obj.currentBytesUnarchivedInFile,
+          obj.currentBytesUnarchived,
+          obj.totalUncompressedBytesInArchive,
+          obj.totalFilesInArchive,
+          obj.totalCompressedBytesRead);
+      case bitjs.archive.UnarchiveEvent.Type.EXTRACT:
+        return new bitjs.archive.UnarchiveExtractEvent(obj.unarchivedFile);
+      case bitjs.archive.UnarchiveEvent.Type.FINISH:
+        return new bitjs.archive.UnarchiveFinishEvent(obj.metadata);
+      case bitjs.archive.UnarchiveEvent.Type.INFO:
+        return new bitjs.archive.UnarchiveInfoEvent(obj.msg);
+      case bitjs.archive.UnarchiveEvent.Type.ERROR:
+        return new bitjs.archive.UnarchiveErrorEvent(obj.msg);
+    }
+  }
+
   /**
    * Receive an event and pass it to the listener functions.
    *
    * @param {bitjs.archive.UnarchiveEvent} e
    * @private
    */
-  handleWorkerEvent_(e) {
+  handleWorkerEvent_(obj) {
-    if ((e instanceof bitjs.archive.UnarchiveEvent || e.type) &&
+    const type = obj.type;
-        this.listeners_[e.type] instanceof Array) {
+    if (type && Object.values(bitjs.archive.UnarchiveEvent.Type).includes(type) &&
-      this.listeners_[e.type].forEach(function (listener) { listener(e) });
+      this.listeners_[obj.type] instanceof Array) {
-      if (e.type == bitjs.archive.UnarchiveEvent.Type.FINISH) {
+      const evt = this.createUnarchiveEvent_(obj);
+      this.listeners_[evt.type].forEach(function (listener) { listener(evt) });
+      if (evt.type == bitjs.archive.UnarchiveEvent.Type.FINISH) {
         this.worker_.terminate();
       }
     } else {
-      console.log(e);
+      console.log(`Unknown object received from worker: ${obj}`);
     }
   }
 
@@ -268,8 +300,6 @@ bitjs.archive.Unarchiver = class {
           // Just log any strings the workers pump our way.
           console.log(e.data);
         } else {
-          // Assume that it is an UnarchiveEvent.  Some browsers preserve the 'type'
-          // so that instanceof UnarchiveEvent returns true, but others do not.
           me.handleWorkerEvent_(e.data);
         }
       };

archive/unrar.js

@@ -15,7 +15,6 @@
 importScripts('../io/bitstream-worker.js');
 importScripts('../io/bytestream-worker.js');
 importScripts('../io/bytebuffer-worker.js');
-importScripts('archive.js');
 importScripts('rarvm.js');
 
 const UnarchiveState = {
@@ -41,21 +40,22 @@ let totalFilesInArchive = 0;
 
 // Helper functions.
 const info = function (str) {
-  postMessage(new bitjs.archive.UnarchiveInfoEvent(str));
+  postMessage({ type: 'info', msg: str });
 };
 const err = function (str) {
-  postMessage(new bitjs.archive.UnarchiveErrorEvent(str));
+  postMessage({ type: 'error', msg: str });
 };
 const postProgress = function () {
-  postMessage(new bitjs.archive.UnarchiveProgressEvent(
+  postMessage({
+    type: 'progress',
     currentFilename,
     currentFileNumber,
     currentBytesUnarchivedInFile,
     currentBytesUnarchived,
     totalUncompressedBytesInArchive,
     totalFilesInArchive,
-    parseInt(bytestream.getNumBytesRead(), 10),
+    totalCompressedBytesRead: bytestream.getNumBytesRead(),
-  ));
+  });
 };
 
 // shows a byte value as its hex representation
@@ -1377,7 +1377,7 @@ function unrar() {
       localFile.unrar();
 
       if (localFile.isValid) {
-        postMessage(new bitjs.archive.UnarchiveExtractEvent(localFile));
+        postMessage({ type: 'extract', unarchivedFile: localFile });
         postProgress();
       }
     } else if (localFile.header.packSize == 0 && localFile.header.unpackedSize == 0) {
@@ -1410,7 +1410,7 @@ onmessage = function (event) {
     totalUncompressedBytesInArchive = 0;
     totalFilesInArchive = 0;
     allLocalFiles = [];
-    postMessage(new bitjs.archive.UnarchiveStartEvent());
+    postMessage({ type: 'start' });
   } else {
     bytestream.push(bytes);
   }
@@ -1440,7 +1440,7 @@ onmessage = function (event) {
     try {
       unrar();
       unarchiveState = UnarchiveState.FINISHED;
-      postMessage(new bitjs.archive.UnarchiveFinishEvent());
+      postMessage({ type: 'finish', metadata: {} });
     } catch (e) {
       if (typeof e === 'string' && e.startsWith('Error!  Overflowed')) {
         if (logToConsole) {

archive/untar.js

@@ -12,7 +12,6 @@
 
 // This file expects to be invoked as a Worker (see onmessage below).
 importScripts('../io/bytestream-worker.js');
-importScripts('archive.js');
 
 const UnarchiveState = {
   NOT_STARTED: 0,
@@ -37,21 +36,22 @@ let totalFilesInArchive = 0;
 
 // Helper functions.
 const info = function (str) {
-  postMessage(new bitjs.archive.UnarchiveInfoEvent(str));
+  postMessage({ type: 'info', msg: str });
 };
 const err = function (str) {
-  postMessage(new bitjs.archive.UnarchiveErrorEvent(str));
+  postMessage({ type: 'error', msg: str });
 };
 const postProgress = function () {
-  postMessage(new bitjs.archive.UnarchiveProgressEvent(
+  postMessage({
+    type: 'progress',
     currentFilename,
     currentFileNumber,
     currentBytesUnarchivedInFile,
     currentBytesUnarchived,
     totalUncompressedBytesInArchive,
     totalFilesInArchive,
-    bytestream.getNumBytesRead(),
+    totalCompressedBytesRead: bytestream.getNumBytesRead(),
-  ));
+  });
 };
 
 // Removes all characters from the first zero-byte in the string onwards.
@@ -146,7 +146,7 @@ const untar = function () {
       currentFileNumber = totalFilesInArchive++;
       currentBytesUnarchivedInFile = oneLocalFile.size;
       currentBytesUnarchived += oneLocalFile.size;
-      postMessage(new bitjs.archive.UnarchiveExtractEvent(oneLocalFile));
+      postMessage({ type: 'extract', unarchivedFile: oneLocalFile });
       postProgress();
     }
   }
@@ -179,7 +179,7 @@ onmessage = function (event) {
     totalFilesInArchive = 0;
     allLocalFiles = [];
 
-    postMessage(new bitjs.archive.UnarchiveStartEvent());
+    postMessage({ type: 'start' });
 
     unarchiveState = UnarchiveState.UNARCHIVING;
 
@@ -191,7 +191,7 @@ onmessage = function (event) {
     try {
       untar();
       unarchiveState = UnarchiveState.FINISHED;
-      postMessage(new bitjs.archive.UnarchiveFinishEvent());
+      postMessage({ type: 'finish', metadata: {} });
     } catch (e) {
       if (typeof e === 'string' && e.startsWith('Error!  Overflowed')) {
         // Overrun the buffer.

archive/unzip.js

@@ -16,7 +16,6 @@
 importScripts('../io/bitstream-worker.js');
 importScripts('../io/bytebuffer-worker.js');
 importScripts('../io/bytestream-worker.js');
-//importScripts('archive.js');
 
 const UnarchiveState = {
   NOT_STARTED: 0,
@@ -41,21 +40,22 @@ let totalFilesInArchive = 0;
 
 // Helper functions.
 const info = function (str) {
-  postMessage(new bitjs.archive.UnarchiveInfoEvent(str));
+  postMessage({ type: 'info', msg: str });
 };
 const err = function (str) {
-  postMessage(new bitjs.archive.UnarchiveErrorEvent(str));
+  postMessage({ type: 'error', msg: str });
 };
 const postProgress = function () {
-  postMessage(new bitjs.archive.UnarchiveProgressEvent(
+  postMessage({
+    type: 'progress',
     currentFilename,
     currentFileNumber,
     currentBytesUnarchivedInFile,
     currentBytesUnarchived,
     totalUncompressedBytesInArchive,
     totalFilesInArchive,
-    bytestream.getNumBytesRead(),
+    totalCompressedBytesRead: bytestream.getNumBytesRead(),
-  ));
+  });
 };
 
 const zLocalFileHeaderSignature = 0x04034b50;
@@ -547,7 +547,7 @@ function unzip() {
       oneLocalFile.unzip();
 
       if (oneLocalFile.fileData != null) {
-        postMessage(new bitjs.archive.UnarchiveExtractEvent(oneLocalFile));
+        postMessage({ type: 'extract', unarchivedFile: oneLocalFile });
         postProgress();
       }
     }
@@ -644,7 +644,7 @@ function unzip() {
   bytestream = bstream.tee();
 
   unarchiveState = UnarchiveState.FINISHED;
-  postMessage(new bitjs.archive.UnarchiveFinishEvent(metadata));
+  postMessage({ type: 'finish', metadata });
 }
 
 // event.data.file has the first ArrayBuffer.
@@ -670,7 +670,7 @@ onmessage = function (event) {
     currentBytesUnarchived = 0;
     allLocalFiles = [];
 
-    postMessage(new bitjs.archive.UnarchiveStartEvent());
+    postMessage({ type: 'start' });
 
     unarchiveState = UnarchiveState.UNARCHIVING;