fixed tests

This commit is contained in:
obscuren 2014-12-12 22:38:54 +01:00
parent 4c84db85c5
commit f8061fcba8
2 changed files with 10 additions and 10 deletions

View File

@ -11,7 +11,7 @@ import (
func TestBox(t *testing.T) { func TestBox(t *testing.T) {
prv1 := ToECDSA(ethutil.Hex2Bytes("4b50fa71f5c3eeb8fdc452224b2395af2fcc3d125e06c32c82e048c0559db03f")) prv1 := ToECDSA(ethutil.Hex2Bytes("4b50fa71f5c3eeb8fdc452224b2395af2fcc3d125e06c32c82e048c0559db03f"))
prv2 := ToECDSA(ethutil.Hex2Bytes("d0b043b4c5d657670778242d82d68a29d25d7d711127d17b8e299f156dad361a")) prv2 := ToECDSA(ethutil.Hex2Bytes("d0b043b4c5d657670778242d82d68a29d25d7d711127d17b8e299f156dad361a"))
pub2 := PubToECDSA(ethutil.Hex2Bytes("04bd27a63c91fe3233c5777e6d3d7b39204d398c8f92655947eb5a373d46e1688f022a1632d264725cbc7dc43ee1cfebde42fa0a86d08b55d2acfbb5e9b3b48dc5")) pub2 := ToECDSAPub(ethutil.Hex2Bytes("04bd27a63c91fe3233c5777e6d3d7b39204d398c8f92655947eb5a373d46e1688f022a1632d264725cbc7dc43ee1cfebde42fa0a86d08b55d2acfbb5e9b3b48dc5"))
message := []byte("Hello, world.") message := []byte("Hello, world.")
ct, err := Encrypt(pub2, message) ct, err := Encrypt(pub2, message)

View File

@ -3,6 +3,7 @@ package qwhisper
import ( import (
"time" "time"
"github.com/ethereum/go-ethereum/crypto"
"github.com/ethereum/go-ethereum/ethutil" "github.com/ethereum/go-ethereum/ethutil"
"github.com/ethereum/go-ethereum/whisper" "github.com/ethereum/go-ethereum/whisper"
) )
@ -27,7 +28,7 @@ func (self *Whisper) Post(data string, pow, ttl uint32, to, from string) {
msg := whisper.NewMessage(fromHex(data)) msg := whisper.NewMessage(fromHex(data))
envelope, err := msg.Seal(time.Duration(pow), whisper.Opts{ envelope, err := msg.Seal(time.Duration(pow), whisper.Opts{
Ttl: time.Duration(ttl), Ttl: time.Duration(ttl),
To: crypto.PubTECDSA(fromHex(to)), To: crypto.ToECDSAPub(fromHex(to)),
From: crypto.ToECDSA(fromHex(from)), From: crypto.ToECDSA(fromHex(from)),
}) })
if err != nil { if err != nil {
@ -35,7 +36,7 @@ func (self *Whisper) Post(data string, pow, ttl uint32, to, from string) {
return return
} }
if err := self.Whisper.Send(envolpe); err != nil { if err := self.Whisper.Send(envelope); err != nil {
// handle error // handle error
return return
} }
@ -51,20 +52,19 @@ func (self *Whisper) HasIdentify(key string) bool {
func (self *Whisper) Watch(opts map[string]interface{}) { func (self *Whisper) Watch(opts map[string]interface{}) {
filter := filterFromMap(opts) filter := filterFromMap(opts)
filter.Fn = func(msg *Message) { filter.Fn = func(msg *whisper.Message) {
// TODO POST TO QT WINDOW // TODO POST TO QT WINDOW
} }
self.Watch(filter) self.Whisper.Watch(filter)
} }
func filterFromMap(opts map[string]interface{}) whisper.Filter { func filterFromMap(opts map[string]interface{}) (f whisper.Filter) {
var f Filter
if to, ok := opts["to"].(string); ok { if to, ok := opts["to"].(string); ok {
f.To = ToECDSA(fromHex(to)) f.To = crypto.ToECDSA(fromHex(to))
} }
if from, ok := opts["from"].(string); ok { if from, ok := opts["from"].(string); ok {
f.From = ToECDSAPub(fromHex(from)) f.From = crypto.ToECDSAPub(fromHex(from))
} }
return f return
} }