Updated QWhisper
* changed api * general whisper debug interface
This commit is contained in:
23
ui/qt/qwhisper/message.go
Normal file
23
ui/qt/qwhisper/message.go
Normal file
@ -0,0 +1,23 @@
|
||||
package qwhisper
|
||||
|
||||
import (
|
||||
"github.com/ethereum/go-ethereum/crypto"
|
||||
"github.com/ethereum/go-ethereum/ethutil"
|
||||
"github.com/ethereum/go-ethereum/whisper"
|
||||
)
|
||||
|
||||
type Message struct {
|
||||
ref *whisper.Message
|
||||
Flags byte
|
||||
Payload string
|
||||
From string
|
||||
}
|
||||
|
||||
func ToQMessage(msg *whisper.Message) *Message {
|
||||
return &Message{
|
||||
ref: msg,
|
||||
Flags: msg.Flags,
|
||||
Payload: ethutil.Bytes2Hex(msg.Payload),
|
||||
From: ethutil.Bytes2Hex(crypto.FromECDSAPub(msg.Recover())),
|
||||
}
|
||||
}
|
13
ui/qt/qwhisper/watch.go
Normal file
13
ui/qt/qwhisper/watch.go
Normal file
@ -0,0 +1,13 @@
|
||||
package qwhisper
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"unsafe"
|
||||
)
|
||||
|
||||
type Watch struct {
|
||||
}
|
||||
|
||||
func (self *Watch) Arrived(v unsafe.Pointer) {
|
||||
fmt.Println(v)
|
||||
}
|
@ -3,7 +3,6 @@ package qwhisper
|
||||
import (
|
||||
"fmt"
|
||||
"time"
|
||||
"unsafe"
|
||||
|
||||
"github.com/ethereum/go-ethereum/crypto"
|
||||
"github.com/ethereum/go-ethereum/ethutil"
|
||||
@ -19,13 +18,6 @@ func fromHex(s string) []byte {
|
||||
}
|
||||
func toHex(b []byte) string { return "0x" + ethutil.Bytes2Hex(b) }
|
||||
|
||||
type Watch struct {
|
||||
}
|
||||
|
||||
func (self *Watch) Arrived(v unsafe.Pointer) {
|
||||
fmt.Println(v)
|
||||
}
|
||||
|
||||
type Whisper struct {
|
||||
*whisper.Whisper
|
||||
view qml.Object
|
||||
@ -70,15 +62,18 @@ func (self *Whisper) HasIdentity(key string) bool {
|
||||
return self.Whisper.HasIdentity(crypto.ToECDSA(fromHex(key)))
|
||||
}
|
||||
|
||||
func (self *Whisper) Watch(opts map[string]interface{}) *Watch {
|
||||
func (self *Whisper) Watch(opts map[string]interface{}, view *qml.Common) int {
|
||||
filter := filterFromMap(opts)
|
||||
filter.Fn = func(msg *whisper.Message) {
|
||||
fmt.Println(msg)
|
||||
if view != nil {
|
||||
view.Call("onMessage", ToQMessage(msg))
|
||||
}
|
||||
}
|
||||
|
||||
i := self.Whisper.Watch(filter)
|
||||
self.watches[i] = &Watch{}
|
||||
|
||||
return self.watches[i]
|
||||
return i
|
||||
}
|
||||
|
||||
func filterFromMap(opts map[string]interface{}) (f whisper.Filter) {
|
||||
|
Reference in New Issue
Block a user