chore(release): 0.2.0-develop.17 [skip ci]

# [0.2.0-develop.17](https://git.lumeweb.com/LumeWeb/libportal/compare/v0.2.0-develop.16...v0.2.0-develop.17) (2023-08-10)

### Bug Fixes

* refactor how we process a nodejs stream, as the current approach is extremely slow and wasteful. We need to do a bit of macgyvering and convert it via pipe to a passthrough so it passes a typeof check for Stream, then import it to form-data Response, and request a blob ([ae35797](ae35797a25))

.github/workflows/ci.yml

@@ -6,6 +6,11 @@ on:
             - master
             - develop
             - develop-*
+    workflow_dispatch:
+        inputs:
+            debug_enabled:
+                description: debug_enabled
+                type: boolean
 jobs:
     build:
         runs-on: ubuntu-latest
@@ -16,24 +21,18 @@ jobs:
                 with:
                     node-version: 18.x
                     cache: 'npm'
+            -  name: Setup Golang
+               uses: actions/setup-go@v4
+               with:
+                 go-version: 1.19
             -   name: Setup Golang
                 run: |
-                    sudo apt-get update;
-                    bash < <(curl -s -S -L https://raw.githubusercontent.com/moovweb/gvm/master/binscripts/gvm-installer);
-                    source ~/.gvm/scripts/gvm;
-                    gvm install go1.4 -B;
-                    gvm use go1.4 --default;
-                    gvm install go1.19 -B;
                     VERSION=0.28.1;
                     TINYGO="tinygo_${VERSION}_amd64.deb";
                     wget -q https://github.com/tinygo-org/tinygo/releases/download/v$VERSION/$TINYGO;
                     sudo dpkg -i $TINYGO && rm $TINYGO;
             -   name: Fetch Wasm Deps
-                run: |
+                run: cd src/golang && go get
-                    source ~/.gvm/scripts/gvm;
-                    gvm use go1.19 --default;
-                    cd src/golang;
-                    go get;
             -   run: npm ci
             -   run: npm run build --if-present
             -   name: Install SSH key

CHANGELOG.md

@@ -1,3 +1,10 @@
+# [0.2.0-develop.17](https://git.lumeweb.com/LumeWeb/libportal/compare/v0.2.0-develop.16...v0.2.0-develop.17) (2023-08-10)
+
+
+### Bug Fixes
+
+* refactor how we process a nodejs stream, as the current approach is extremely slow and wasteful. We need to do a bit of macgyvering and convert it via pipe to a passthrough so it passes a typeof check for Stream, then import it to form-data Response, and request a blob ([ae35797](https://git.lumeweb.com/LumeWeb/libportal/commit/ae35797a2525d23ac9a552d076a9904e68a7a142))
+
 # [0.2.0-develop.16](https://git.lumeweb.com/LumeWeb/libportal/compare/v0.2.0-develop.15...v0.2.0-develop.16) (2023-07-18)
 
 

npm-shrinkwrap.json

@@ -1,12 +1,12 @@
 {
     "name": "@lumeweb/libportal",
-    "version": "0.2.0-develop.16",
+    "version": "0.2.0-develop.17",
     "lockfileVersion": 3,
     "requires": true,
     "packages": {
         "": {
             "name": "@lumeweb/libportal",
-            "version": "0.2.0-develop.16",
+            "version": "0.2.0-develop.17",
             "dependencies": {
                 "@lumeweb/node-library-preset": "git+https://git.lumeweb.com/LumeWeb/node-library-preset.git",
                 "@noble/curves": "^1.1.0",

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@lumeweb/libportal",
-    "version": "0.2.0-develop.16",
+    "version": "0.2.0-develop.17",
     "main": "lib/index.js",
     "module": "lib/index.mjs",
     "types": "lib/index.d.ts",

src/client.ts

@@ -29,6 +29,7 @@ import isNode from "detect-node";
 import { utf8ToBytes } from "@noble/curves/abstract/utils";
 
 type NodeReadableStreamType = typeof import("stream").Readable;
+type NodePassThroughStreamType = typeof import("stream").PassThrough;
 
 export interface ClientOptions {
   portalUrl: string;
@@ -340,13 +341,14 @@ export class Client {
     let NodeReadableStream =
       (await this.getNodeReadableObject()) as NodeReadableStreamType;
 
-    if (NodeReadableStream && stream instanceof NodeReadableStream) {
+    let NodePassThroughStream =
-      let data = new Uint8Array();
+      (await this.getNodePassThroughObject()) as NodePassThroughStreamType;
-      for await (const chunk of stream) {
-        data = Uint8Array.from([...data, ...chunk]);
-      }
 
-      stream = data;
+    if (NodeReadableStream && stream instanceof NodeReadableStream) {
+      const Response = await this.getFetchResponseObject();
+      stream = await new Response(
+        stream.pipe(new NodePassThroughStream()) as any,
+      ).blob();
     }
 
     if (stream instanceof Uint8Array) {
@@ -541,6 +543,7 @@ export class Client {
 
     return FormData;
   }
+
   private async getBlobObject() {
     if (isNode) {
       return (await import("node-fetch")).Blob;
@@ -556,6 +559,15 @@ export class Client {
 
     return undefined;
   }
+
+  private async getNodePassThroughObject() {
+    if (isNode) {
+      return (await import("stream")).PassThrough;
+    }
+
+    return undefined;
+  }
+
   private async getFetchObject() {
     if (isNode) {
       return (await import("node-fetch")).default;
@@ -563,6 +575,7 @@ export class Client {
 
     return fetch;
   }
+
   private async getFetchResponseObject() {
     if (isNode) {
       return (await import("node-fetch")).Response;