logos-messaging/js-waku
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-waku.git synced 2026-01-05 23:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Upgrade to latest nim-waku commit

Browse Source
This commit is contained in:
Franck Royer 2021-04-13 10:36:22 +10:00
parent e534e0a4c8
commit ef409bd89b
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
3 changed files with 9 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nim-waku

@ -1 +1 @@
Subproject commit 5747ff5be00b7b99e61021c17a975761fbe151f3 Subproject commit 286482ea32401952ff01b80ad7cc183cb9336c06

20
proto/waku/v2/store.proto
View File

@ -9,33 +9,27 @@ message Index {
double received_time = 2; double received_time = 2;
} }
message PagingInfoQuery {
uint32 page_size = 1; // TODO: See https://github.com/vacp2p/rfc/issues/326
Index cursor = 2;
Direction direction = 3;
}
enum Direction { enum Direction {
DIRECTION_BACKWARD_UNSPECIFIED = 0; DIRECTION_BACKWARD_UNSPECIFIED = 0;
DIRECTION_FORWARD = 1; DIRECTION_FORWARD = 1;
} }
message PagingInfoResponse { message PagingInfo {
uint64 page_size = 1; // TODO: See https://github.com/vacp2p/rfc/issues/326 uint64 page_size = 1;
Index cursor = 2; Index cursor = 2;
Direction direction = 3; Direction direction = 3;
} }
message HistoryQuery { message HistoryQuery {
repeated string topics = 1; repeated string topics = 2;
optional PagingInfoQuery paging_info = 2; optional PagingInfo paging_info = 3;
optional double start_time = 3; optional double start_time = 4;
optional double end_time = 4; optional double end_time = 5;
} }
message HistoryResponse { message HistoryResponse {
repeated WakuMessageProto messages = 1; repeated WakuMessageProto messages = 1;
PagingInfoResponse paging_info = 2; PagingInfo paging_info = 2;
} }
message HistoryRPC { message HistoryRPC {

3
src/lib/waku_store/index.spec.ts
View File

@ -59,8 +59,7 @@ describe('Waku Store', () => {
const response = await waku.store.queryHistory(nimPeerId); const response = await waku.store.queryHistory(nimPeerId);
const messages = response?.messages; const messages = response?.messages;
// TODO: Should be fixed with https://github.com/status-im/nim-waku/issues/471 expect(messages?.length).eq(2);
// expect(messages?.length).eq(2);
const result = messages const result = messages
?.map((protoMsg) => { ?.map((protoMsg) => {
return WakuMessage.fromProto(protoMsg); return WakuMessage.fromProto(protoMsg);