logos-messaging/lab.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/lab.waku.org.git synced 2026-02-06 23:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

update to latest

Browse Source
This commit is contained in:
Sasha 2025-07-17 17:04:38 +02:00
parent a1b991b1ed
commit c66508f74f
No known key found for this signature in database
3 changed files with 944 additions and 522 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

File diff suppressed because it is too large Load Diff

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

@ -156,8 +156,15 @@ async function initializeApp() {
const subscribeToMessages = async () => {
const decoder = createWakuDecoder();
(window as any)["storeQuery"] = () => {
node.store.queryWithOrderedCallback([decoder], (msg) => {
console.log("DEBUG", msg);
});
};
console.log("Subscribing to messages...");
await node.nextFilter.subscribe(decoder, (wakuMessage: DecodedMessage) => {
await node.filter.subscribe(decoder, (wakuMessage: DecodedMessage) => {
console.log("Raw Waku message received, payload length:", wakuMessage.payload.length);
const chatMessage = decodeMessage(wakuMessage.payload);

35
examples/dogfooding/src/waku-service.ts
View File

@ -21,32 +21,33 @@ export async function getWakuNode(): Promise<LightNode> {
const privateKey = await generateKeyPairFromSeed("Ed25519", fromString(seed));
const node = await createLightNode({
defaultBootstrap: false,
networkConfig: {
clusterId: 42,
shards: [0]
},
defaultBootstrap: true,
// networkConfig: {
// clusterId: 42,
// shards: [0]
// },
discovery: {
dns: false,
dns: true,
peerExchange: true,
localPeerCache: false,
},
numPeersToUse: 2,
libp2p: {
privateKey,
},
}
});
await Promise.allSettled([
node.dial("/dns4/waku-test.bloxy.one/tcp/8095/wss/p2p/16Uiu2HAmSZbDB7CusdRhgkD81VssRjQV5ZH13FbzCGcdnbbh6VwZ"),
node.dial("/dns4/vps-aaa00d52.vps.ovh.ca/tcp/8000/wss/p2p/16Uiu2HAm9PftGgHZwWE3wzdMde4m3kT2eYJFXLZfGoSED3gysofk")
]);
(window as any).waku = node;
// await Promise.allSettled([
// node.dial("/dns4/waku-test.bloxy.one/tcp/8095/wss/p2p/16Uiu2HAmSZbDB7CusdRhgkD81VssRjQV5ZH13FbzCGcdnbbh6VwZ"),
// node.dial("/dns4/vps-aaa00d52.vps.ovh.ca/tcp/8000/wss/p2p/16Uiu2HAm9PftGgHZwWE3wzdMde4m3kT2eYJFXLZfGoSED3gysofk")
// ]);
await node.start();
await node.waitForPeers();
wakuNodeInstance = node;
(window as any).waku = node;
return node;
}
@ -57,13 +58,13 @@ export function getPeerId(): string | undefined {
export function createWakuEncoder() {
return createEncoder({
contentTopic: DEFAULT_CONTENT_TOPIC,
pubsubTopicShardInfo: {
clusterId: 42,
shard: 0,
}
// pubsubTopicShardInfo: {
// clusterId: 42,
// shard: 0,
// }
});
}
export function createWakuDecoder() {
return createDecoder(DEFAULT_CONTENT_TOPIC, { clusterId: 42, shard: 0 });
return createDecoder(DEFAULT_CONTENT_TOPIC/*, { clusterId: 42, shard: 0 }*/);
}