logos-messaging/lab.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/lab.waku.org.git synced 2026-01-03 22:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: latest master

Browse Source
This commit is contained in:
Sasha 2025-04-17 12:17:38 +02:00
parent 57d8c27b25
commit a7e96385c2
No known key found for this signature in database
3 changed files with 432 additions and 353 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

760
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-0e49a1e.0",
"@waku/sdk": "0.0.31-3038c48.0",
"libp2p": "^2.1.10",
"protobufjs": "^7.3.0",
"uint8arrays": "^5.1.0"

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

@ -1,7 +1,5 @@
import {
createLightNode,
createEncoder,
createDecoder,
DecodedMessage,
LightNode,
utils,
@ -19,7 +17,6 @@ import {
generateRandomNumber,
sha256,
buildExtraData,
DEFAULT_EXTRA_DATA_STR,
} from "./util";
const DEFAULT_CONTENT_TOPIC = "/js-waku-examples/1/message-ratio/utf8";
@ -50,21 +47,13 @@ async function wakuNode(): Promise<LightNode> {
const privateKey = await generateKeyPairFromSeed("Ed25519", fromString(seed));
const node = await createLightNode({
defaultBootstrap: false,
networkConfig: {
clusterId: 42,
shards: [0]
},
defaultBootstrap: true,
numPeersToUse: 2,
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;
}
@ -78,12 +67,8 @@ export async function app(telemetryClient: TelemetryClient) {
await node.waitForPeers();
const peerId = node.libp2p.peerId.toString();
const encoder = createEncoder({
contentTopic: DEFAULT_CONTENT_TOPIC,
pubsubTopicShardInfo: {
clusterId: 42,
shard: 0,
}
const encoder = node.createEncoder({
contentTopic: DEFAULT_CONTENT_TOPIC
});
node.libp2p.addEventListener("peer:discovery", async (event) => {
@ -166,7 +151,7 @@ export async function app(telemetryClient: TelemetryClient) {
};
const startFilterSubscription = async () => {
const decoder = createDecoder(DEFAULT_CONTENT_TOPIC, { clusterId: 42, shard: 0 });
const decoder = node.createDecoder({ contentTopic: DEFAULT_CONTENT_TOPIC });
const subscriptionCallback = async (message: DecodedMessage) => {
const decodedMessage: any = ProtoSequencedMessage.decode(