aboutsummaryrefslogtreecommitdiffstats
path: root/whisper/whisper.go
diff options
context:
space:
mode:
Diffstat (limited to 'whisper/whisper.go')
-rw-r--r--whisper/whisper.go13
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