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

Start of query RPC

This commit is contained in:
Oskar Thoren 2021-06-10 15:28:49 +08:00
parent cb3fa8a0b1
commit 7098d3da51
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
1 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
nwaku/jsonrpc.go
View File

@ -10,10 +10,19 @@ import (
// NOTE Can be generalized with different transports (HTTP, IPC, WS etc)
// https://github.com/ethereum/go-ethereum/blob/master/rpc/client.go#L169
// TODO Move to types
type WakuInfo struct {
ListenStr string `json:"listenStr"`
}
type HistoricalMessageResponse struct {
Messages string `json:"messages"`
}
type ContentFilter struct {
ContentTopic string `json:"contentTopic"`
}
func main() {
fmt.Println("JSON RPC request...")
@ -28,4 +37,23 @@ func main() {
panic(err)
}
fmt.Println("WakuInfo ListenStr", wakuInfo.ListenStr)
// TODO Lets do query of messages
//
//curl -d '{"jsonrpc":"2.0","id":"id","method":"get_waku_v2_store_v1_messages", "params":["", [{"contentTopic":"/waku/2/default-content/proto"}]]}' --header "Content-Type: application/json" http://localhost:8545
var messageResponse HistoricalMessageResponse
var contentFilter = ContentFilter{"/toy-chat/2/huilong/proto"}
var contentFilters []ContentFilter
contentFilters = append(contentFilters, contentFilter)
var arg1 = ""
var arg2 = contentFilters
if err := client.Call(&messageResponse, "get_waku_v2_store_v1_messages", arg1, arg2); err != nil {
panic(err)
}
fmt.Println("Resp", messageResponse)
}
// ./bin/wakunode2 --storenode=/ip4/188.166.135.145/tcp/30303/p2p/16Uiu2HAmL5okWopX7NqZWBUKVqW8iUxCEmd5GMHLVPwCgzYzQv3e
// curl -d '{"jsonrpc":"2.0","id":"id","method":"get_waku_v2_store_v1_messages", "params":["", [{"contentTopic":"/toy-chat/2/huilong/proto"}]]}' --header "Content-Type: application/json" http://localhost:8545
// Later: Generalize with CallContext (not prio)