waku-org
/
js-waku-examples
mirror of https://github.com/waku-org/js-waku-examples.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore(light-chat): bump @waku/core to 0.0.16 and other @waku/* pkgs (#222)

This commit is contained in:
fryorcraken.eth 2023-04-03 21:51:55 +10:00 committed by GitHub
parent 2820bd2579
commit 6506aa286a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/light-chat/index.html
View File

@ -26,9 +26,6 @@
<h4>Remote Peer Id</h4>
<p id="remotePeerId"></p>
<h4>Remote peer's multiaddr</h4>
<p id="remoteMultiAddr"></p>
</details>
</div>

30
examples/light-chat/index.js
View File

@ -1,15 +1,12 @@
import * as utils from "https://unpkg.com/@waku/byte-utils@0.0.2/bundle/index.js";
import * as wakuCreate from "https://unpkg.com/@waku/create@0.0.6/bundle/index.js";
import * as utils from "https://unpkg.com/@waku/utils@0.0.4/bundle/bytes.js";
import * as wakuCreate from "https://unpkg.com/@waku/create@0.0.12/bundle/index.js";
import {
waitForRemotePeer,
createDecoder,
createEncoder,
} from "https://unpkg.com/@waku/core@0.0.10/bundle/index.js";
} from "https://unpkg.com/@waku/core@0.0.16/bundle/index.js";
const MULTI_ADDR =
"/dns4/node-01.ac-cn-hongkong-c.wakuv2.test.statusim.net/tcp/443/wss/p2p/16Uiu2HAkvWiyFsgRhuJEb9JfjYxEkoHLgnUQmr1N5mKWnYjxYRVm";
const CONTENT_TOPIC = "/toy-chat/2/huilong/proto";
const PROTOCOLS = ["filter", "lightpush"];
const ui = initUI();
runApp(ui).catch((err) => {
@ -21,8 +18,6 @@ async function runApp(ui) {
ui.setStatus("connecting...", "progress");
const { info, sendMessage, unsubscribeFromMessages } = await initWakuContext({
protocols: PROTOCOLS,
multiAddr: MULTI_ADDR,
contentTopic: CONTENT_TOPIC,
onMessageReceived: ui.renderMessage,
});
@ -31,7 +26,6 @@ async function runApp(ui) {
ui.setLocalPeer(info.localPeerId);
ui.setRemotePeer(info.remotePeerIds);
ui.setRemoteMultiAddr(info.multiAddr);
ui.setContentTopic(info.contentTopic);
ui.onSendMessage(sendMessage);
@ -44,14 +38,9 @@ async function runApp(ui) {
});
}
async function initWakuContext({
multiAddr,
protocols,
contentTopic,
onMessageReceived,
}) {
async function initWakuContext({ contentTopic, onMessageReceived }) {
const Decoder = createDecoder(contentTopic);
const Encoder = createEncoder(contentTopic);
const Encoder = createEncoder({ contentTopic });
const ChatMessage = new protobuf.Type("ChatMessage")
.add(new protobuf.Field("timestamp", 1, "uint64"))
@ -61,7 +50,7 @@ async function initWakuContext({
const node = await wakuCreate.createLightNode({ defaultBootstrap: true });
await node.start();
await waitForRemotePeer(node, protocols);
await waitForRemotePeer(node);
// Set a filter by using Decoder for a given ContentTopic
const unsubscribeFromMessages = await node.filter.subscribe(
@ -83,7 +72,6 @@ async function initWakuContext({
return {
unsubscribeFromMessages,
info: {
multiAddr,
contentTopic,
localPeerId,
remotePeerIds,
@ -99,7 +87,7 @@ async function initWakuContext({
text: utils.utf8ToBytes(text),
});
await node.lightPush.push(Encoder, {
await node.lightPush.send(Encoder, {
payload: ChatMessage.encode(protoMessage).finish(),
});
},
@ -114,7 +102,6 @@ function initUI() {
const statusBlock = document.getElementById("status");
const localPeerBlock = document.getElementById("localPeerId");
const remotePeerId = document.getElementById("remotePeerId");
const remoteMultiAddr = document.getElementById("remoteMultiAddr");
const contentTopicBlock = document.getElementById("contentTopic");
const messagesBlock = document.getElementById("messages");
@ -146,9 +133,6 @@ function initUI() {
setRemotePeer: (ids) => {
remotePeerId.innerText = ids.join("\n");
},
setRemoteMultiAddr: (multiAddr) => {
remoteMultiAddr.innerText = multiAddr.toString();
},
setContentTopic: (topic) => {
contentTopicBlock.innerText = topic.toString();
},