From db3403d88fc095182594a24b08e99814b61b8d7c Mon Sep 17 00:00:00 2001 From: Franck Royer Date: Thu, 15 Jul 2021 15:02:16 +1000 Subject: [PATCH] Update Waku Message examples --- README.md | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/README.md b/README.md index 466776c045..f3410585c7 100644 --- a/README.md +++ b/README.md @@ -67,7 +67,7 @@ Send a message on the waku relay network: ```javascript import { WakuMessage } from 'js-waku'; -const msg = WakuMessage.fromUtf8String("Here is a message!", "/my-cool-app/1/my-use-case/proto") +const msg = await WakuMessage.fromUtf8String("Here is a message!", { contentTopic: "/my-cool-app/1/my-use-case/proto" }) await waku.relay.send(msg); ``` @@ -79,17 +79,19 @@ Query a waku store peer to check historical messages: ```javascript // Process messages once they are all retrieved: -const messages = await waku.store.queryHistory(storePeerId, ["my-cool-app"]); +const messages = await waku.store.queryHistory({ contentTopics: ["my-cool-app"] }); messages.forEach((msg) => { console.log("Message retrieved:", msg.payloadAsUtf8) }) // Or, pass a callback function to be executed as pages are received: -waku.store.queryHistory(storePeerId, ["my-cool-app"], - (messages) => { - messages.forEach((msg) => { - console.log("Message retrieved:", msg.payloadAsUtf8) - }) +waku.store.queryHistory({ + contentTopics: ["my-cool-app"], + callback: (messages) => { + messages.forEach((msg) => { + console.log("Message retrieved:", msg.payloadAsUtf8); + }); + } }); ```