Adding server side worker support & a blob placeholder (not utilized …

…beyond an existence check)

.eslintrc

@@ -98,7 +98,7 @@
 		"no-negated-in-lhs": [2],
 		"no-nested-ternary": [0],
 		"no-new": [2],
-		"no-new-func": [2],
+		"no-new-func": [0],
 		"no-new-object": [2],
 		"no-new-require": [0],
 		"no-new-wrappers": [2],

lib/haro.es6.js

@@ -5,7 +5,7 @@
  * @copyright 2015
  * @license BSD-3-Clause
  * @link http://haro.rocks
- * @version 1.7.1
+ * @version 1.7.2
  */
 "use strict";
 
@@ -17,6 +17,8 @@ const Set = !server ? global.Set : require("es6-set");
 const fetch = !server ? global.fetch : require("node-fetch");
 const deferred = !server ? global.deferred : require("tiny-defer");
 const tuple = !server ? global.tuple : require("tiny-tuple");
+const Blob = !server ? global.Blob : require("Blob");
+const Worker = !server ? global.Worker : require("webworker-threads").Worker;
 const r = [8, 9, "a", "b"];
 const regex = {
 	querystring: /\?.*/,
@@ -185,6 +187,10 @@ function onmessage (ev) {
 	}
 
 	postMessage(JSON.stringify(result));
+
+	if (server && typeof self !== "undefined") {
+		self.close();
+	}
 }
 
 function patch (ogdata = {}, data = {}, key = "", overwrite = false) {
@@ -1073,11 +1079,11 @@ function factory (data = null, config = {}, indexes = []) {
 			setIndexValue.toString(),
 			setIndex.toString(),
 			cast.toString(),
-			"onmessage = " + onmessage.toString() + ";"
+			(!server ? "" : "this.") + "onmessage = " + onmessage.toString() + ";"
 		];
 
 		try {
-			obj.worker = global.URL.createObjectURL(blob(functions.join("\n")));
+			obj.worker = !server ? global.URL.createObjectURL(blob(functions.join("\n"))) : new Function(functions.join("\n"));
 		} catch (e) {
 			obj.worker = null;
 		}
@@ -1087,7 +1093,7 @@ function factory (data = null, config = {}, indexes = []) {
 }
 
 factory.transform = cast;
-factory.version = "1.7.1";
+factory.version = "1.7.2";
 
 // Node, AMD & window supported
 if (typeof exports !== "undefined") {

lib/haro.js

@@ -5,7 +5,7 @@
  * @copyright 2015
  * @license BSD-3-Clause
  * @link http://haro.rocks
- * @version 1.7.1
+ * @version 1.7.2
  */
 "use strict";
 
@@ -21,6 +21,8 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Cons
 	var fetch = !server ? global.fetch : require("node-fetch");
 	var deferred = !server ? global.deferred : require("tiny-defer");
 	var tuple = !server ? global.tuple : require("tiny-tuple");
+	var Blob = !server ? global.Blob : require("Blob");
+	var Worker = !server ? global.Worker : require("webworker-threads").Worker;
 	var r = [8, 9, "a", "b"];
 	var regex = {
 		querystring: /\?.*/,
@@ -189,6 +191,10 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Cons
 		}
 
 		postMessage(JSON.stringify(result));
+
+		if (server && typeof self !== "undefined") {
+			self.close();
+		}
 	}
 
 	function patch() {
@@ -1206,10 +1212,10 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Cons
 		    functions = undefined;
 
 		if (webWorker) {
-			functions = [createIndexes.toString(), keyIndex.toString(), setIndexValue.toString(), setIndex.toString(), cast.toString(), "onmessage = " + onmessage.toString() + ";"];
+			functions = [createIndexes.toString(), keyIndex.toString(), setIndexValue.toString(), setIndex.toString(), cast.toString(), (!server ? "" : "this.") + "onmessage = " + onmessage.toString() + ";"];
 
 			try {
-				obj.worker = global.URL.createObjectURL(blob(functions.join("\n")));
+				obj.worker = !server ? global.URL.createObjectURL(blob(functions.join("\n"))) : new Function(functions.join("\n"));
 			} catch (e) {
 				obj.worker = null;
 			}
@@ -1219,7 +1225,7 @@ function _classCallCheck(instance, Constructor) { if (!(instance instanceof Cons
 	}
 
 	factory.transform = cast;
-	factory.version = "1.7.1";
+	factory.version = "1.7.2";
 
 	// Node, AMD & window supported
 	if (typeof exports !== "undefined") {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "haro",
-  "version": "1.7.1",
+  "version": "1.7.2",
   "description": "Harō is a modern immutable DataStore using Maps, Sets, Promises, & Tuples",
   "main": "lib/haro.js",
   "scripts": {
@@ -39,11 +39,13 @@
     "tenso": "^1.5.1"
   },
   "dependencies": {
+    "Blob": "^0.10.0",
     "es6-map": "^0.1.1",
     "es6-promise": "^3.0.2",
     "es6-set": "^0.1.1",
     "node-fetch": "^1.2.1",
     "tiny-defer": "^1.0.2",
-    "tiny-tuple": "^1.0.5"
+    "tiny-tuple": "^1.0.5",
+    "webworker-threads": "^0.6.0"
   }
 }

src/factory.js

@@ -9,11 +9,11 @@ function factory (data = null, config = {}, indexes = []) {
 			setIndexValue.toString(),
 			setIndex.toString(),
 			cast.toString(),
-			"onmessage = " + onmessage.toString() + ";"
+			(!server ? "" : "this.") + "onmessage = " + onmessage.toString() + ";"
 		];
 
 		try {
-			obj.worker = global.URL.createObjectURL(blob(functions.join("\n")));
+			obj.worker = !server ? global.URL.createObjectURL(blob(functions.join("\n"))) : new Function(functions.join("\n"));
 		} catch (e) {
 			obj.worker = null;
 		}

src/intro.js

@@ -8,6 +8,8 @@ const Set = !server ? global.Set : require("es6-set");
 const fetch = !server ? global.fetch : require("node-fetch");
 const deferred = !server ? global.deferred : require("tiny-defer");
 const tuple = !server ? global.tuple : require("tiny-tuple");
+const Blob = !server ? global.Blob : require("Blob");
+const Worker = !server ? global.Worker : require("webworker-threads").Worker;
 const r = [8, 9, "a", "b"];
 const regex = {
 	querystring: /\?.*/,

src/utility.js

@@ -157,6 +157,10 @@ function onmessage (ev) {
 	}
 
 	postMessage(JSON.stringify(result));
+
+	if (server && typeof self !== "undefined") {
+		self.close();
+	}
 }
 
 function patch (ogdata = {}, data = {}, key = "", overwrite = false) {