diff --git a/package.json b/package.json index aee27df..f42d054 100644 --- 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 index 910641c..08cab19 100644 --- 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 index d8a02bc..7feed29 100644 --- 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"