logos-messaging/lab.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/lab.waku.org.git synced 2026-01-04 14:53:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: use dns discovery lib for dogfooding

Browse Source
This commit is contained in:
Sasha 2025-03-27 12:01:03 +01:00
parent 4f9fcad915
commit 79d44fa5ee
No known key found for this signature in database
3 changed files with 869 additions and 819 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1667
examples/dogfooding/package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

2
examples/dogfooding/package.json
View File

@ -9,7 +9,7 @@
"dependencies": {
"@libp2p/crypto": "^5.0.5",
"@multiformats/multiaddr": "^12.3.1",
"@waku/sdk": "0.0.30-c43cec2.0",
"@waku/sdk": "0.0.30-0e49a1e.0",
"libp2p": "^2.1.10",
"protobufjs": "^7.3.0",
"uint8arrays": "^5.1.0"

19
examples/dogfooding/src/index.ts
View File

@ -49,16 +49,23 @@ async function wakuNode(): Promise<LightNode> {
const privateKey = await generateKeyPairFromSeed("Ed25519", fromString(seed));
return createLightNode({
const node = await createLightNode({
defaultBootstrap: false,
networkConfig: {
contentTopics: [DEFAULT_CONTENT_TOPIC],
clusterId: 42,
shards: [0]
},
numPeersToUse: 2,
defaultBootstrap: true,
libp2p: {
privateKey,
},
});
await node.dial("/dns4/waku-test.bloxy.one/tcp/8095/wss/p2p/16Uiu2HAmSZbDB7CusdRhgkD81VssRjQV5ZH13FbzCGcdnbbh6VwZ");
await node.dial("/dns4/vps-aaa00d52.vps.ovh.ca/tcp/8000/wss/p2p/16Uiu2HAm9PftGgHZwWE3wzdMde4m3kT2eYJFXLZfGoSED3gysofk");
await node.dial("/dns4/waku.fryorcraken.xyz/tcp/8000/wss/p2p/16Uiu2HAmMRvhDHrtiHft1FTUYnn6cVA8AWVrTyLUayJJ3MWpUZDB");
return node;
}
export async function app(telemetryClient: TelemetryClient) {
@ -73,6 +80,10 @@ export async function app(telemetryClient: TelemetryClient) {
const peerId = node.libp2p.peerId.toString();
const encoder = createEncoder({
contentTopic: DEFAULT_CONTENT_TOPIC,
pubsubTopicShardInfo: {
clusterId: 42,
shard: 0,
}
});
node.libp2p.addEventListener("peer:discovery", async (event) => {
@ -155,7 +166,7 @@ export async function app(telemetryClient: TelemetryClient) {
};
const startFilterSubscription = async () => {
const decoder = createDecoder(DEFAULT_CONTENT_TOPIC);
const decoder = createDecoder(DEFAULT_CONTENT_TOPIC, { clusterId: 42, shard: 0 });
const subscriptionCallback = async (message: DecodedMessage) => {
const decodedMessage: any = ProtoSequencedMessage.decode(