Getting messages from #test
This commit is contained in:
parent
8a464eb0d8
commit
a5d2f25b01
|
@ -1,11 +1,16 @@
|
||||||
import NimQml
|
import NimQml
|
||||||
import status
|
import status
|
||||||
import libstatus
|
import libstatus
|
||||||
|
import json
|
||||||
|
|
||||||
|
|
||||||
var signalHandler: SignalCallback = proc(p0: cstring): void =
|
var signalHandler: SignalCallback = proc(p0: cstring): void =
|
||||||
setupForeignThreadGc()
|
setupForeignThreadGc()
|
||||||
echo $p0
|
|
||||||
|
var jsonSignal = ($p0).parseJson
|
||||||
|
if $jsonSignal["type"].getStr == "messages.new":
|
||||||
|
echo $p0
|
||||||
|
|
||||||
tearDownForeignThreadGc()
|
tearDownForeignThreadGc()
|
||||||
|
|
||||||
QtObject:
|
QtObject:
|
||||||
|
|
|
@ -15,37 +15,9 @@ proc setSignalHandler*(something: SignalCallback) =
|
||||||
libstatus.setSignalEventCallback(something)
|
libstatus.setSignalEventCallback(something)
|
||||||
|
|
||||||
proc subscribeToTest*() =
|
proc subscribeToTest*() =
|
||||||
|
var result = ""
|
||||||
|
|
||||||
var payload = %* {
|
var payload = %* {
|
||||||
"jasonrpc": "2.0",
|
|
||||||
"id": 2,
|
|
||||||
"method": "waku_generateSymKeyFromPassword",
|
|
||||||
"params": ["test"]
|
|
||||||
}
|
|
||||||
var result = $libstatus.callPrivateRPC($payload)
|
|
||||||
let keyId = $result.parseJson()["result"]
|
|
||||||
|
|
||||||
var topic = "0x9c22ff5f"; #sha3 of test
|
|
||||||
|
|
||||||
payload = %* {
|
|
||||||
"jsonrpc": "2.0",
|
|
||||||
"id": 3,
|
|
||||||
"method": "wakuext_loadFilters",
|
|
||||||
"params": [
|
|
||||||
[{
|
|
||||||
"chatId": "test",
|
|
||||||
"symKeyId": keyId,
|
|
||||||
"topic": topic,
|
|
||||||
"discovery": false,
|
|
||||||
"negotiated": false,
|
|
||||||
"listen": true
|
|
||||||
}]
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|
||||||
result = $libstatus.callPrivateRPC($payload)
|
|
||||||
echo result;
|
|
||||||
|
|
||||||
payload = %* {
|
|
||||||
"jsonrpc": "2.0",
|
"jsonrpc": "2.0",
|
||||||
"id": 3,
|
"id": 3,
|
||||||
"method": "wakuext_startMessenger",
|
"method": "wakuext_startMessenger",
|
||||||
|
@ -53,8 +25,53 @@ proc subscribeToTest*() =
|
||||||
}
|
}
|
||||||
result = $libstatus.callPrivateRPC($payload)
|
result = $libstatus.callPrivateRPC($payload)
|
||||||
|
|
||||||
|
payload = %* {
|
||||||
|
"jsonrpc": "2.0",
|
||||||
|
"id": 3,
|
||||||
|
"method": "wakuext_loadFilters",
|
||||||
|
"params": [
|
||||||
|
[{
|
||||||
|
"ChatID":"test",
|
||||||
|
"OneToOne":false
|
||||||
|
}]
|
||||||
|
]
|
||||||
|
}
|
||||||
|
result = $libstatus.callPrivateRPC($payload)
|
||||||
|
|
||||||
|
|
||||||
|
payload = %* {
|
||||||
|
"jsonrpc": "2.0",
|
||||||
|
"id": 4,
|
||||||
|
"method": "wakuext_saveChat",
|
||||||
|
"params": [
|
||||||
|
{
|
||||||
|
"lastClockValue":0,
|
||||||
|
"color":"#51d0f0",
|
||||||
|
"name":"test",
|
||||||
|
"lastMessage":nil,
|
||||||
|
"active":true,
|
||||||
|
"id":"test",
|
||||||
|
"unviewedMessagesCount":0,
|
||||||
|
"chatType":2,
|
||||||
|
"timestamp":1588940692659
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
result = $libstatus.callPrivateRPC($payload)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
payload = %* {
|
||||||
|
"jsonrpc": "2.0",
|
||||||
|
"id": 3,
|
||||||
|
"method": "wakuext_chatMessages",
|
||||||
|
"params": [
|
||||||
|
"test", nil, 20
|
||||||
|
]
|
||||||
|
}
|
||||||
|
result = $libstatus.callPrivateRPC($payload)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue