waku-org
/
js-waku
mirror of https://github.com/waku-org/js-waku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: filter for wss in libp2p websocket transport

This commit is contained in:
Arseniy Klempner 2024-04-26 17:55:04 -07:00
parent 3d92f194a7
commit 682cc66232
No known key found for this signature in database
GPG Key ID: 51653F18863BD24B
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/sdk/src/utils/libp2p.ts
View File

@ -5,7 +5,7 @@ import { identify } from "@libp2p/identify";
import { mplex } from "@libp2p/mplex"; import { mplex } from "@libp2p/mplex";
import { ping } from "@libp2p/ping"; import { ping } from "@libp2p/ping";
import { webSockets } from "@libp2p/websockets"; import { webSockets } from "@libp2p/websockets";
import { all as filterAll } from "@libp2p/websockets/filters"; import { all as filterAll, wss } from "@libp2p/websockets/filters";
import { wakuMetadata } from "@waku/core"; import { wakuMetadata } from "@waku/core";
import { import {
type CreateLibp2pOptions, type CreateLibp2pOptions,
@ -64,11 +64,13 @@ export async function defaultLibp2p(
? { metadata: wakuMetadata(shardInfo) } ? { metadata: wakuMetadata(shardInfo) }
: {}; : {};
const filter = process?.env?.NODE_ENV === "test" ? filterAll : wss;
return createLibp2p({ return createLibp2p({
connectionManager: { connectionManager: {
minConnections: 1 minConnections: 1
}, },
transports: [webSockets({ filter: filterAll })], transports: [webSockets({ filter })],
streamMuxers: [mplex()], streamMuxers: [mplex()],
connectionEncryption: [noise()], connectionEncryption: [noise()],
...options, ...options,