add support for openStream data (#158)

jakolehm · web-flow · commit 6be661905f64 · 2022-01-05T15:08:28.000+02:00
Signed-off-by: Jari Kolehmainen &lt;jari.kolehmainen@gmail.com&gt;
diff --git a/package.json b/package.json
@@ -27,7 +27,7 @@
   },
   "dependencies": {
     "@sentry/node": "^6.15.0",
-    "bored-mplex": "^0.0.17",
+    "bored-mplex": "^0.0.20",
     "jsonwebtoken": "^8.5.1",
     "ws": "^7.4.6"
   }
diff --git a/src/agent.ts b/src/agent.ts
@@ -63,8 +63,8 @@ export class Agent {
   addClient(socket: WebSocket, userId: string) {
     this.clients.push({ socket, userId });
 
-    const mplex = new BoredMplex((stream) => {
-      const agentStream = this.openStream();
+    const mplex = new BoredMplex((stream, data) => {
+      const agentStream = this.openStream(data);
 
       stream.pipe(agentStream);
       agentStream.pipe(stream);
@@ -113,7 +113,7 @@ export class Agent {
     console.log("SERVER: client disconnected");
   }
 
-  openStream() {
-    return this.mplex.openStream();
+  openStream(data?: Buffer) {
+    return this.mplex.openStream(data);
   }
 }
diff --git a/yarn.lock b/yarn.lock
@@ -979,9 +979,10 @@ binary-extensions@^2.0.0:
   version "2.2.0"
   resolved "https://registry.npmjs.org/binary-extensions/-/binary-extensions-2.2.0.tgz"
 
-bored-mplex@^0.0.17:
-  version "0.0.17"
-  resolved "https://registry.npmjs.org/bored-mplex/-/bored-mplex-0.0.17.tgz"
+bored-mplex@^0.0.20:
+  version "0.0.20"
+  resolved "https://registry.yarnpkg.com/bored-mplex/-/bored-mplex-0.0.20.tgz#8f64ad23d605751a1ca2ff3e07d5e808c27962ef"
+  integrity sha512-1kzzE6qe8ugO8RVswgzZue28YtZBMlpY/J0XICQmYr/h0RxIn76ZtMVWDF0drVfdISyw49nFqphQ2v5DagpKIA==
   dependencies:
     msgpackr "1.2.9"
 

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@`
`27`	`27`	`},`
`28`	`28`	`"dependencies": {`
`29`	`29`	`"@sentry/node": "^6.15.0",`
`30`		`- "bored-mplex": "^0.0.17",`
	`30`	`+ "bored-mplex": "^0.0.20",`
`31`	`31`	`"jsonwebtoken": "^8.5.1",`
`32`	`32`	`"ws": "^7.4.6"`
`33`	`33`	`}`
Original file line number	Diff line number	Diff line change
`@@ -63,8 +63,8 @@ export class Agent {`
`63`	`63`	`addClient(socket: WebSocket, userId: string) {`
`64`	`64`	`this.clients.push({ socket, userId });`
`65`	`65`
`66`		`- const mplex = new BoredMplex((stream) => {`
`67`		`- const agentStream = this.openStream();`
	`66`	`+ const mplex = new BoredMplex((stream, data) => {`
	`67`	`+ const agentStream = this.openStream(data);`
`68`	`68`
`69`	`69`	`stream.pipe(agentStream);`
`70`	`70`	`agentStream.pipe(stream);`
`@@ -113,7 +113,7 @@ export class Agent {`
`113`	`113`	`console.log("SERVER: client disconnected");`
`114`	`114`	`}`
`115`	`115`
`116`		`- openStream() {`
`117`		`- return this.mplex.openStream();`
	`116`	`+ openStream(data?: Buffer) {`
	`117`	`+ return this.mplex.openStream(data);`
`118`	`118`	`}`
`119`	`119`	`}`