chore(deps): bump js-waku to 0.25.0
This commit is contained in:
parent
5a972024e3
commit
657c1806c9
Binary file not shown.
53
index.js
53
index.js
|
@ -1,9 +1,12 @@
|
|||
import { expect } from "chai";
|
||||
import { describe } from "mocha";
|
||||
import { Multiaddr } from "multiaddr";
|
||||
import { Protocols, Waku, WakuMessage } from "js-waku";
|
||||
import { Protocols, WakuMessage } from "js-waku";
|
||||
import { createWaku } from "js-waku/lib/create_waku";
|
||||
import { v4 as uuidv4 } from "uuid";
|
||||
import delay from "./delay.js";
|
||||
import { PeerDiscoveryStaticPeers } from "js-waku/lib/peer_discovery_static_list";
|
||||
import { waitForRemotePeer } from "js-waku/lib/wait_for_remote_peer";
|
||||
|
||||
export default function runAll(nodes) {
|
||||
describe("Run Waku Test Suite", () => {
|
||||
|
@ -28,17 +31,24 @@ export default function runAll(nodes) {
|
|||
});
|
||||
|
||||
const promises = nodes.map(async (node, i) => {
|
||||
wakus[i] = await Waku.create({
|
||||
bootstrap: { peers: [node] },
|
||||
wakus[i] = await createWaku({
|
||||
libp2p: {
|
||||
peerDiscovery: [new PeerDiscoveryStaticPeers([node])],
|
||||
},
|
||||
});
|
||||
|
||||
await wakus[i].start();
|
||||
|
||||
return new Promise((resolve) => {
|
||||
wakus[i].libp2p.connectionManager.on("peer:connect", (connection) => {
|
||||
resolve(connection.remotePeer);
|
||||
});
|
||||
wakus[i].libp2p.connectionManager.addEventListener(
|
||||
"peer:connect",
|
||||
(evt) => {
|
||||
resolve(evt.detail.remotePeer);
|
||||
}
|
||||
);
|
||||
}).then((peerId) => {
|
||||
console.log("connected", peerId.toB58String());
|
||||
expect(peerId.toB58String()).to.eq(
|
||||
console.log("connected", peerId.toString());
|
||||
expect(peerId.toString()).to.eq(
|
||||
peerIds[i],
|
||||
`Could not connect to ${hostnames[i]}`
|
||||
);
|
||||
|
@ -54,11 +64,14 @@ export default function runAll(nodes) {
|
|||
const id = uuidv4();
|
||||
|
||||
const promises = nodes.map(async (node, i) => {
|
||||
wakus[i] = await Waku.create({
|
||||
bootstrap: { peers: [node] },
|
||||
wakus[i] = await createWaku({
|
||||
libp2p: {
|
||||
peerDiscovery: [new PeerDiscoveryStaticPeers([node])],
|
||||
},
|
||||
});
|
||||
|
||||
await wakus[i].waitForRemotePeer([Protocols.Relay]);
|
||||
await wakus[i].start();
|
||||
await waitForRemotePeer(wakus[i], [Protocols.Relay]);
|
||||
console.log(node + ": ready");
|
||||
});
|
||||
|
||||
|
@ -127,11 +140,14 @@ export default function runAll(nodes) {
|
|||
const id = uuidv4();
|
||||
|
||||
const promises = nodes.map(async (node, i) => {
|
||||
wakus[i] = await Waku.create({
|
||||
bootstrap: { peers: [node] },
|
||||
wakus[i] = await createWaku({
|
||||
libp2p: {
|
||||
peerDiscovery: [new PeerDiscoveryStaticPeers([node])],
|
||||
},
|
||||
});
|
||||
|
||||
await wakus[i].waitForRemotePeer([
|
||||
await wakus[i].start();
|
||||
await waitForRemotePeer(wakus[i], [
|
||||
Protocols.LightPush,
|
||||
Protocols.Relay,
|
||||
]);
|
||||
|
@ -203,11 +219,14 @@ export default function runAll(nodes) {
|
|||
const id = uuidv4();
|
||||
|
||||
const promises = nodes.map(async (node, i) => {
|
||||
wakus[i] = await Waku.create({
|
||||
bootstrap: { peers: [node] },
|
||||
wakus[i] = await createWaku({
|
||||
libp2p: {
|
||||
peerDiscovery: [new PeerDiscoveryStaticPeers([node])],
|
||||
},
|
||||
});
|
||||
|
||||
await wakus[i].waitForRemotePeer([Protocols.Relay, Protocols.Store]);
|
||||
await wakus[i].start();
|
||||
await waitForRemotePeer(wakus[i], [Protocols.Relay, Protocols.Store]);
|
||||
console.log(node + ": ready");
|
||||
});
|
||||
|
||||
|
|
|
@ -49,7 +49,7 @@
|
|||
"prettier": "^2.6.2"
|
||||
},
|
||||
"dependencies": {
|
||||
"js-waku": "^0.20.0",
|
||||
"js-waku": "^0.25.0",
|
||||
"multiaddr": "^10.0.1",
|
||||
"uuid": "^8.3.2"
|
||||
},
|
||||
|
|
|
@ -1,9 +1,8 @@
|
|||
import { describe } from "mocha";
|
||||
import { discovery } from "js-waku";
|
||||
import runAll from "./index.js";
|
||||
import { fleets } from "js-waku/lib/predefined_bootstrap_nodes";
|
||||
|
||||
const prodFleet =
|
||||
discovery.predefined.fleets.fleets["wakuv2.prod"]["waku-websocket"];
|
||||
const prodFleet = fleets.fleets["wakuv2.prod"]["waku-websocket"];
|
||||
const nodes = Object.values(prodFleet);
|
||||
|
||||
describe("Predefined Prod Fleet", () => {
|
||||
|
|
|
@ -1,9 +1,8 @@
|
|||
import { describe } from "mocha";
|
||||
import { discovery } from "js-waku";
|
||||
import { fleets } from "js-waku/lib/predefined_bootstrap_nodes";
|
||||
import runAll from "./index.js";
|
||||
|
||||
const testFleet =
|
||||
discovery.predefined.fleets.fleets["wakuv2.test"]["waku-websocket"];
|
||||
const testFleet = fleets.fleets["wakuv2.test"]["waku-websocket"];
|
||||
const nodes = Object.values(testFleet);
|
||||
|
||||
describe("Predefined Test Fleet", () => {
|
||||
|
|
Loading…
Reference in New Issue