Allow web workers to stream fetching in several formats (#26)

* Allow web workers to stream fetching in several formats * Fix package-lock.json
DevoInc · Oct 10, 2022 · ee6a2d3 · ee6a2d3
1 parent cd40882
commit ee6a2d3
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,11 @@
 
 Change log.
 
+## 3.0.5
+
+Make streamFetch available to web workers (since they are not considered as a browser, they have no window object)
+Allowed to set output format in stream calls.
+
 ## 3.0.4
 
 Fix(node-fetch): wd 11834 fix node fetch vulnerability

diff --git a/lib/client.js b/lib/client.js
@@ -53,9 +53,11 @@ class Client {
    *  - abort: Function to call when query is aborted
    */
   streamFetch(options, callbacks) {
-    const opc = this._config.parseQuery(options, 'json/simple/compact');
+    const opc = this._config.parseQuery(options,
+      options.format || 'json/simple/compact');
     const validOpc = validateOpc(opc, callbacks);
-    return validOpc === true ? streamFetch.create(options).stream(opc, callbacks) : validOpc;
+    return validOpc === true ?
+      streamFetch.create(options).stream(opc, callbacks) : validOpc;
   }
 
   /**
@@ -170,4 +172,4 @@ const validateOpc = (opc, callbacks) => {
     }
   }
   return true;
-};
+};
diff --git a/lib/fetchStreamReadable/polyfills/fetchPolyfill.js b/lib/fetchStreamReadable/polyfills/fetchPolyfill.js
@@ -12,6 +12,9 @@ function getFetchMethod() {
     }
     return window.fetch.bind(window);
   }
+  if (typeof fetch === 'function') {
+    return fetch;
+  }
 }
 
 function isNativeStreamFetchSupported() {

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@devoinc/browser-sdk",
-  "version": "3.0.4",
+  "version": "3.0.5",
   "description": "Devo browser SDK",
   "author": "Devo Dev Team",
   "eslintConfig": {