Update Waku Message examples

This commit is contained in:
Franck Royer 2021-07-15 15:02:16 +10:00
parent 5c790a41c9
commit db3403d88f
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 9 additions and 7 deletions

View File

@ -67,7 +67,7 @@ Send a message on the waku relay network:
```javascript ```javascript
import { WakuMessage } from 'js-waku'; 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); await waku.relay.send(msg);
``` ```
@ -79,17 +79,19 @@ Query a waku store peer to check historical messages:
```javascript ```javascript
// Process messages once they are all retrieved: // 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) => { messages.forEach((msg) => {
console.log("Message retrieved:", msg.payloadAsUtf8) console.log("Message retrieved:", msg.payloadAsUtf8)
}) })
// Or, pass a callback function to be executed as pages are received: // Or, pass a callback function to be executed as pages are received:
waku.store.queryHistory(storePeerId, ["my-cool-app"], waku.store.queryHistory({
(messages) => { contentTopics: ["my-cool-app"],
messages.forEach((msg) => { callback: (messages) => {
console.log("Message retrieved:", msg.payloadAsUtf8) messages.forEach((msg) => {
}) console.log("Message retrieved:", msg.payloadAsUtf8);
});
}
}); });
``` ```