diff options
Diffstat (limited to 'whisper/whisper.go')
| -rw-r--r-- | whisper/whisper.go | 13 |
1 files changed, 3 insertions, 10 deletions
diff --git a/whisper/whisper.go b/whisper/whisper.go index 1b3f54b67..f91b61d9a 100644 --- a/whisper/whisper.go +++ b/whisper/whisper.go @@ -4,6 +4,7 @@ import ( "bytes" "crypto/ecdsa" "errors" + "fmt" "sync" "time" @@ -71,16 +72,6 @@ func New() *Whisper { } whisper.filters.Start() - // XXX TODO REMOVE TESTING CODE - //msg := NewMessage([]byte(fmt.Sprintf("Hello world. This is whisper-go. Incase you're wondering; the time is %v", time.Now()))) - //envelope, _ := msg.Seal(DefaultPow, Opts{ - // Ttl: DefaultTtl, - //}) - //if err := whisper.Send(envelope); err != nil { - // fmt.Println(err) - //} - // XXX TODO REMOVE TESTING CODE - // p2p whisper sub protocol handler whisper.protocol = p2p.Protocol{ Name: "shh", @@ -158,6 +149,7 @@ func (self *Whisper) msgHandler(peer *p2p.Peer, ws p2p.MsgReadWriter) error { continue } + fmt.Println("recv") if err := self.add(envelope); err != nil { // TODO Punish peer here. Invalid envelope. peer.Infoln(err) @@ -184,6 +176,7 @@ func (self *Whisper) add(envelope *Envelope) error { if !self.expiry[envelope.Expiry].Has(hash) { self.expiry[envelope.Expiry].Add(hash) self.postEvent(envelope) + fmt.Println("envelope added", envelope) } return nil |