status-im
/
js-waku-examples
mirror of https://github.com/status-im/js-waku-examples.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #201 from waku-org/chore/update-web-chat 

chore(web-chat): bump @waku/core to 0.0.10
This commit is contained in:
Danish Arora 2023-02-02 07:59:46 +05:30 committed by GitHub
parent 2ef8f92036 35ff489247
commit 7a4d9767af
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 1222 additions and 887 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2087
examples/web-chat/package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

2
examples/web-chat/package.json
View File

@ -8,7 +8,7 @@
"@livechat/ui-kit": "^0.5.0-24", "@livechat/ui-kit": "^0.5.0-24",
"@multiformats/multiaddr": "11.0.7", "@multiformats/multiaddr": "11.0.7",
"@waku/byte-utils": "^0.0.2", "@waku/byte-utils": "^0.0.2",
"@waku/core": "^0.0.6", "@waku/core": "^0.0.10",
"@waku/create": "^0.0.4", "@waku/create": "^0.0.4",
"@waku/dns-discovery": "0.0.5", "@waku/dns-discovery": "0.0.5",
"@waku/interfaces": "^0.0.5", "@waku/interfaces": "^0.0.5",

12
examples/web-chat/src/App.tsx
View File

@ -8,10 +8,10 @@ import { generate } from "server-name-generator";
import { Message } from "./Message"; import { Message } from "./Message";
import { wakuDnsDiscovery } from "@waku/dns-discovery"; import { wakuDnsDiscovery } from "@waku/dns-discovery";
import { wakuPeerExchangeDiscovery } from "@waku/peer-exchange"; import { wakuPeerExchangeDiscovery } from "@waku/peer-exchange";
import { waitForRemotePeer } from "@waku/core/lib/wait_for_remote_peer"; import { waitForRemotePeer } from "@waku/core";
import { Protocols, WakuLight } from "@waku/interfaces"; import { Protocols, WakuLight } from "@waku/interfaces";
import { createLightNode } from "@waku/create"; import { createLightNode } from "@waku/create";
import { DecoderV0, MessageV0 } from "@waku/core/lib/waku_message/version_0"; import { DecodedMessage, Decoder } from "@waku/core/lib/message/version_0";
import { PageDirection } from "@waku/interfaces"; import { PageDirection } from "@waku/interfaces";
const themes = { const themes = {
@ -44,7 +44,7 @@ const themes = {
}; };
export const ChatContentTopic = "/toy-chat/2/huilong/proto"; export const ChatContentTopic = "/toy-chat/2/huilong/proto";
const ChatDecoder = new DecoderV0(ChatContentTopic); const ChatDecoder = new Decoder(ChatContentTopic);
async function retrieveStoreMessages( async function retrieveStoreMessages(
waku: WakuLight, waku: WakuLight,
@ -111,7 +111,7 @@ export default function App() {
// Let's retrieve previous messages before listening to new messages // Let's retrieve previous messages before listening to new messages
if (!historicalMessagesRetrieved) return; if (!historicalMessagesRetrieved) return;
const handleIncomingMessage = (wakuMsg: MessageV0) => { const handleIncomingMessage = (wakuMsg: DecodedMessage) => {
console.log("Message received: ", wakuMsg); console.log("Message received: ", wakuMsg);
const msg = Message.fromWakuMessage(wakuMsg); const msg = Message.fromWakuMessage(wakuMsg);
if (msg) { if (msg) {
@ -223,6 +223,8 @@ function reduceMessages(state: Message[], newMessages: Message[]) {
return state.concat(newMessages); return state.concat(newMessages);
} }
const isMessageDefined = (msg: MessageV0 | undefined): msg is MessageV0 => { const isMessageDefined = (
msg: DecodedMessage | undefined
): msg is DecodedMessage => {
return !!msg; return !!msg;
}; };

4
examples/web-chat/src/Message.ts
View File

@ -1,4 +1,4 @@
import { MessageV0 } from "@waku/core/lib/waku_message/version_0"; import { DecodedMessage } from "@waku/core/lib/message/version_0";
import { ChatMessage } from "./chat_message"; import { ChatMessage } from "./chat_message";
export class Message { export class Message {
@ -11,7 +11,7 @@ export class Message {
this.sentTimestamp = sentTimestamp; this.sentTimestamp = sentTimestamp;
} }
static fromWakuMessage(wakuMsg: MessageV0): Message | undefined { static fromWakuMessage(wakuMsg: DecodedMessage): Message | undefined {
if (wakuMsg.payload) { if (wakuMsg.payload) {
try { try {
const chatMsg = ChatMessage.decode(wakuMsg.payload); const chatMsg = ChatMessage.decode(wakuMsg.payload);

4
examples/web-chat/src/Room.tsx
View File

@ -7,7 +7,7 @@ import { TitleBar } from "@livechat/ui-kit";
import { Message } from "./Message"; import { Message } from "./Message";
import { ChatMessage } from "./chat_message"; import { ChatMessage } from "./chat_message";
import { useEffect, useState } from "react"; import { useEffect, useState } from "react";
import { EncoderV0 } from "@waku/core/lib/waku_message/version_0"; import { Encoder } from "@waku/core/lib/message/version_0";
interface Props { interface Props {
messages: Message[]; messages: Message[];
@ -25,7 +25,7 @@ export default function Room(props: Props) {
const [bootstrapPeers, setBootstrapPeers] = useState(new Set<string>()); const [bootstrapPeers, setBootstrapPeers] = useState(new Set<string>());
const [peerExchangePeers, setPeerExchangePeers] = useState(new Set<string>()); const [peerExchangePeers, setPeerExchangePeers] = useState(new Set<string>());
const ChatEncoder = new EncoderV0(ChatContentTopic); const ChatEncoder = new Encoder(ChatContentTopic);
useEffect(() => { useEffect(() => {
if (!waku) return; if (!waku) return;