aboutsummaryrefslogtreecommitdiffstats
path: root/whisper/whisper.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-12-08 21:25:52 +0800
committerobscuren <geffobscura@gmail.com>2014-12-08 21:25:52 +0800
commit76842b0df8b5605682362bd57fbd6eb315bcaf1f (patch)
tree8671edce47cfc7212de29eaa200c96bd2c6e47ec /whisper/whisper.go
parente3a8412df3fe75fe498a3fce64fd2fd691a18183 (diff)
downloadgo-tangerine-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.gz
go-tangerine-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.zst
go-tangerine-76842b0df8b5605682362bd57fbd6eb315bcaf1f.zip
Additional checks and debug output
Diffstat (limited to 'whisper/whisper.go')
-rw-r--r--whisper/whisper.go7
1 files changed, 7 insertions, 0 deletions
diff --git a/whisper/whisper.go b/whisper/whisper.go
index 255bd2152..78e4d4848 100644
--- a/whisper/whisper.go
+++ b/whisper/whisper.go
@@ -2,6 +2,7 @@ package whisper
import (
"bytes"
+ "fmt"
"sync"
"time"
@@ -34,6 +35,8 @@ const (
envelopesMsg = 0x01
)
+const defaultTtl = 50 * time.Second
+
type Whisper struct {
pub, sec []byte
protocol p2p.Protocol
@@ -55,6 +58,8 @@ func New(pub, sec []byte) *Whisper {
}
go whisper.update()
+ whisper.Send(defaultTtl, nil, NewMessage([]byte("Hello world. This is whisper-go")))
+
// p2p whisper sub protocol handler
whisper.protocol = p2p.Protocol{
Name: "shh",
@@ -102,6 +107,7 @@ func (self *Whisper) msgHandler(peer *p2p.Peer, ws p2p.MsgReadWriter) error {
}
self.add(envelope)
+ wpeer.addKnown(envelope)
}
}
@@ -110,6 +116,7 @@ func (self *Whisper) add(envelope *Envelope) {
self.mmu.Lock()
defer self.mmu.Unlock()
+ fmt.Println("add", envelope)
self.messages[envelope.Hash()] = envelope
if self.expiry[envelope.Expiry] == nil {
self.expiry[envelope.Expiry] = set.NewNonTS()