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

migrate relay-react-chat

Browse Source
This commit is contained in:
Sasha 2023-06-22 01:21:21 +02:00
parent dd6cc060d7
commit 954416f245
No known key found for this signature in database
3 changed files with 3453 additions and 1307 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4740
examples/relay-reactjs-chat/package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

3
examples/relay-reactjs-chat/package.json
View File

@ -7,8 +7,7 @@
"@testing-library/jest-dom": "^5.16.5",
"@testing-library/react": "^13.4.0",
"@testing-library/user-event": "^13.5.0",
"@waku/core": "^0.0.10",
"@waku/create": "^0.0.6",
"@waku/sdk": "^0.0.16",
"protobufjs": "^7.1.2",
"react": "^18.2.0",
"react-dom": "^18.2.0",

17
examples/relay-reactjs-chat/src/App.js
View File

@ -1,10 +1,14 @@
import * as React from "react";
import protobuf from "protobufjs";
import { createRelayNode } from "@waku/create";
import { createDecoder, createEncoder, waitForRemotePeer } from "@waku/core";
import {
createRelayNode,
createDecoder,
createEncoder,
waitForRemotePeer,
} from "@waku/sdk";
const ContentTopic = `/js-waku-examples/1/chat/proto`;
const Encoder = createEncoder(ContentTopic);
const Encoder = createEncoder({ contentTopic: ContentTopic });
const Decoder = createDecoder(ContentTopic);
const SimpleChatMessage = new protobuf.Type("SimpleChatMessage")
@ -29,7 +33,10 @@ function App() {
setWaku(waku);
await waku.start();
setWakuStatus("Connecting");
await waitForRemotePeer(waku, ["relay"]);
await waku.dial(
"/ip4/0.0.0.0/tcp/8000/ws/p2p/16Uiu2HAmSC4xN3R831RmRiHfWFnyQi4A8kzQEoYS36YLWtSLsL4x"
);
// await waitForRemotePeer(waku, ["relay"]);
setWakuStatus("Ready");
})();
}, [waku, wakuStatus]);
@ -54,7 +61,7 @@ function App() {
if (!waku) return;
// Pass the content topic to only process messages related to your dApp
const deleteObserver = waku.relay.addObserver(
const deleteObserver = waku.relay.subscribe(
Decoder,
processIncomingMessage
);