waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-02-27 03:20:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use callback option in store guide

Browse Source
This commit is contained in:
Franck Royer 2021-10-05 13:35:29 +11:00
parent 6f4d765e30
commit d6f180cf36
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
guides/store-retrieve-messages.md
View File

@ -140,23 +140,26 @@ const decodeWakuMessage = (wakuMessage) => {
You now have all the building blocks to retrieve and decode messages for a store node. You now have all the building blocks to retrieve and decode messages for a store node.
Retrieve messages from a store node: Store node responses are paginated.
The `WakuStore.queryHistory` API automatically query all the pages in a sequential manner.
To process messages as soon as they received (page by page), use the `callback` option:
```js ```js
const ContentTopic = '/store-guide/1/news/proto'; const ContentTopic = '/store-guide/1/news/proto';
waku.store waku.store
.queryHistory([ContentTopic]) .queryHistory([ContentTopic], {
callback: (retrievedMessages) => {
const articles = retrievedMessages
.map(decodeWakuMessage) // Decode messages
.filter(Boolean); // Filter out undefined values
console.log(`${articles.length} articles have been retrieved`);
}
})
.catch((e) => { .catch((e) => {
// Be sure to catch any potential error // Be sure to catch any potential error
console.log('Failed to retrieve messages', e); console.log('Failed to retrieve messages', e);
})
.then((retrievedMessages) => {
const articles = retrievedMessages
.map(decodeWakuMessage) // Decode messages
.filter(Boolean); // Filter out undefined values
console.log(`${articles.length} articles have been retrieved`);
}); });
``` ```