actually tell swarm compression strategy

hivenapp · Jul 9, 2020 · 8a880bf · 8a880bf
1 parent b5c499c
commit 8a880bf
Show file tree

Hide file tree

Showing 7 changed files with 229 additions and 4 deletions.
diff --git a/node_modules/.yarn-integrity b/node_modules/.yarn-integrity
diff --git a/node_modules/@types/pako/LICENSE b/node_modules/@types/pako/LICENSE
diff --git a/node_modules/@types/pako/README.md b/node_modules/@types/pako/README.md
diff --git a/node_modules/@types/pako/index.d.ts b/node_modules/@types/pako/index.d.ts
diff --git a/node_modules/@types/pako/package.json b/node_modules/@types/pako/package.json
diff --git a/swarm.ts b/swarm.ts
@@ -1,7 +1,7 @@
 import { EventEmitter } from 'events';
-import pako from 'pako';
+import {inflate} from 'pako';
 
-enum DecompressionStrategy {
+export enum DecompressionStrategy {
   ZlibJson = 'zlib_json',
   TextJson = 'text_json'
 }
@@ -32,7 +32,7 @@ export class SwarmClient extends EventEmitter {
   }
 
   connect() {
-    const socket = new WebSocket(`${this.swarmHost}/socket?encoding=${this.encoding}`);
+    const socket = new WebSocket(`${this.swarmHost}/socket?encoding=${this.encoding}&compression=${this.compression}`);
 
     this.socket = socket;
     this.state = "connecting";
@@ -85,7 +85,7 @@ export class SwarmClient extends EventEmitter {
   private decompress(data: any): any {
     switch (this.compression) {
       case DecompressionStrategy.ZlibJson: {
-        return JSON.parse(pako.inflate(data, {to: 'string'}));
+        return JSON.parse(inflate(data, {to: 'string'}));
       }
 
       default: {

diff --git a/yarn.lock b/yarn.lock
@@ -6,6 +6,10 @@
   version "3.0.0"
   resolved "https://registry.yarnpkg.com/@types/events/-/events-3.0.0.tgz#2862f3f58a9a7f7c3e78d79f130dd4d71c25c2a7"
 
+"@types/pako@^1.0.1":
+  version "1.0.1"
+  resolved "https://registry.yarnpkg.com/@types/pako/-/pako-1.0.1.tgz#33b237f3c9aff44d0f82fe63acffa4a365ef4a61"
+
 events@^3.0.0:
   version "3.0.0"
   resolved "https://registry.yarnpkg.com/events/-/events-3.0.0.tgz#9a0a0dfaf62893d92b875b8f2698ca4114973e88"