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

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

Browse Source
This commit is contained in:
fryorcraken.eth 2023-04-03 19:57:04 +10:00
parent 2820bd2579
commit 16225fa4ab
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
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> <h4>Remote Peer Id</h4>
<p id="remotePeerId"></p> <p id="remotePeerId"></p>
<h4>Remote peer's multiaddr</h4>
<p id="remoteMultiAddr"></p>
</details> </details>
</div> </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 utils from "https://unpkg.com/@waku/utils@0.0.4/bundle/bytes.js";
import * as wakuCreate from "https://unpkg.com/@waku/create@0.0.6/bundle/index.js"; import * as wakuCreate from "https://unpkg.com/@waku/create@0.0.12/bundle/index.js";
import { import {
waitForRemotePeer, waitForRemotePeer,
createDecoder, createDecoder,
createEncoder, 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 CONTENT_TOPIC = "/toy-chat/2/huilong/proto";
const PROTOCOLS = ["filter", "lightpush"];
const ui = initUI(); const ui = initUI();
runApp(ui).catch((err) => { runApp(ui).catch((err) => {
@ -21,8 +18,6 @@ async function runApp(ui) {
ui.setStatus("connecting...", "progress"); ui.setStatus("connecting...", "progress");
const { info, sendMessage, unsubscribeFromMessages } = await initWakuContext({ const { info, sendMessage, unsubscribeFromMessages } = await initWakuContext({
protocols: PROTOCOLS,
multiAddr: MULTI_ADDR,
contentTopic: CONTENT_TOPIC, contentTopic: CONTENT_TOPIC,
onMessageReceived: ui.renderMessage, onMessageReceived: ui.renderMessage,
}); });
@ -31,7 +26,6 @@ async function runApp(ui) {
ui.setLocalPeer(info.localPeerId); ui.setLocalPeer(info.localPeerId);
ui.setRemotePeer(info.remotePeerIds); ui.setRemotePeer(info.remotePeerIds);
ui.setRemoteMultiAddr(info.multiAddr);
ui.setContentTopic(info.contentTopic); ui.setContentTopic(info.contentTopic);
ui.onSendMessage(sendMessage); ui.onSendMessage(sendMessage);
@ -44,14 +38,9 @@ async function runApp(ui) {
}); });
} }
async function initWakuContext({ async function initWakuContext({ contentTopic, onMessageReceived }) {
multiAddr,
protocols,
contentTopic,
onMessageReceived,
}) {
const Decoder = createDecoder(contentTopic); const Decoder = createDecoder(contentTopic);
const Encoder = createEncoder(contentTopic); const Encoder = createEncoder({ contentTopic });
const ChatMessage = new protobuf.Type("ChatMessage") const ChatMessage = new protobuf.Type("ChatMessage")
.add(new protobuf.Field("timestamp", 1, "uint64")) .add(new protobuf.Field("timestamp", 1, "uint64"))
@ -61,7 +50,7 @@ async function initWakuContext({
const node = await wakuCreate.createLightNode({ defaultBootstrap: true }); const node = await wakuCreate.createLightNode({ defaultBootstrap: true });
await node.start(); await node.start();
await waitForRemotePeer(node, protocols); await waitForRemotePeer(node);
// Set a filter by using Decoder for a given ContentTopic // Set a filter by using Decoder for a given ContentTopic
const unsubscribeFromMessages = await node.filter.subscribe( const unsubscribeFromMessages = await node.filter.subscribe(
@ -83,7 +72,6 @@ async function initWakuContext({
return { return {
unsubscribeFromMessages, unsubscribeFromMessages,
info: { info: {
multiAddr,
contentTopic, contentTopic,
localPeerId, localPeerId,
remotePeerIds, remotePeerIds,
@ -99,7 +87,7 @@ async function initWakuContext({
text: utils.utf8ToBytes(text), text: utils.utf8ToBytes(text),
}); });
await node.lightPush.push(Encoder, { await node.lightPush.send(Encoder, {
payload: ChatMessage.encode(protoMessage).finish(), payload: ChatMessage.encode(protoMessage).finish(),
}); });
}, },
@ -114,7 +102,6 @@ function initUI() {
const statusBlock = document.getElementById("status"); const statusBlock = document.getElementById("status");
const localPeerBlock = document.getElementById("localPeerId"); const localPeerBlock = document.getElementById("localPeerId");
const remotePeerId = document.getElementById("remotePeerId"); const remotePeerId = document.getElementById("remotePeerId");
const remoteMultiAddr = document.getElementById("remoteMultiAddr");
const contentTopicBlock = document.getElementById("contentTopic"); const contentTopicBlock = document.getElementById("contentTopic");
const messagesBlock = document.getElementById("messages"); const messagesBlock = document.getElementById("messages");
@ -146,9 +133,6 @@ function initUI() {
setRemotePeer: (ids) => { setRemotePeer: (ids) => {
remotePeerId.innerText = ids.join("\n"); remotePeerId.innerText = ids.join("\n");
}, },
setRemoteMultiAddr: (multiAddr) => {
remoteMultiAddr.innerText = multiAddr.toString();
},
setContentTopic: (topic) => { setContentTopic: (topic) => {
contentTopicBlock.innerText = topic.toString(); contentTopicBlock.innerText = topic.toString();
}, },