Merge branch 'gossipsub'

README.md

@@ -4,9 +4,9 @@
 
 Blockchain has enabled decentralized value transfer. A bigger future is decentralized communication. One step forward is anonymous decentralized communication which provides a censorship resistence privacy preserved communication network that anyone can send/receive, broadcast messages anonymously without revealing message metadata(sender, receiver, who send to whom, etc). It will find broad use cases, e.g., whistleblowing, anonymous group chat, anonymous survey, privacy preserved messaging in Dapps etc.
 
-Anonymity is achieved by implementing Dandelion protocol on top of libp2p's pub/sub module, dandelion is a privacy preserving protocol to make message sender anonymous, it has 2 phases, the first phase is stem phase, where messages go through a psuedo-random path, the second phase is fluffing, at a random time of the stem phase, the message is diffused to its surrounding peers, so the third party observer cannot track back the node original node who send the message, because the message is relayed through an anonymous graph. Message broadcasting is implemented by libp2p floodsub. 
+Anonymity is achieved by implementing Dandelion++ protocol on top of libp2p's pub/sub module, Dandelion is a privacy preserving protocol to make message sender anonymous, it has 2 phases, the first phase is stem phase, where messages go through a psuedo-random path, the second phase is fluffing, at a random time of the stem phase, the message is diffused to its surrounding peers, so the third party observer cannot track back the node original node who send the message, because the message is relayed through an anonymous graph. Message broadcasting is implemented by libp2p floodsub. Dandelion++ is an improved version of Dandelion.
 
-**Dandelion implementation on libp2p-pubsub**: https://github.com/rairyx/go-libp2p-pubsub/tree/dandelion
+**Dandelion++ implementation on libp2p-pubsub**: https://github.com/rairyx/go-libp2p-pubsub/tree/dandelion++
 
 
 ## Demo
@@ -42,23 +42,19 @@ This peer, which is not in bootstrapper mode, creates a node, subscribes to the
 
 ```
 cd pubsub
-./raven ../util/private_key.bin.peer.W6 6001
+./raven ../util/private_key.bin.peer.w6 6001
 ```
 
 
 
-**Fourth terminal**:  Create a JS peer to connect to bootstrap and publish on topic
+**Fourth terminal**:  Create a third go peer to connect to bootstrap and publish on topic
 
 ```
-cd pubsub/js
-npm install  # first time only
-node index.js /ip4/127.0.0.1/tcp/5555/ipfs/QmehVYruznbyDZuHBV4vEHESpDevMoAovET6aJ9oRuEzWa
+cd pubsub
+./raven ../util/private_key.bin.peer.d9 6002
+
 ```
 
-This JS peer will accept lines of text typed on stdin, and publish them on the PubSub topic.
-
-(Note that the JS peer generates a new identity (public/private keypair) each time, and prints its public key to stdout.  This is a deficiency in the demo; to be consistent with the Go code it should accept a private key on the CLI.)
-
 
 If you return to the second, third or fourth terminals and type a message, the bootstrapper and the other 2 peers will all print your message.
 

pubsub/raven.go

@@ -7,26 +7,31 @@ import (
 	"io/ioutil"
 	"os"
 	_ "time"
-
-	libp2p "github.com/libp2p/go-libp2p"
-	host "github.com/libp2p/go-libp2p-host"
+        "strconv"
+	"github.com/ipfs/go-log"
+	"github.com/libp2p/go-libp2p"
+        host "github.com/libp2p/go-libp2p-core/host"
 	inet "github.com/libp2p/go-libp2p-net"
 	peerstore "github.com/libp2p/go-libp2p-peerstore"
 
 	"github.com/libp2p/go-libp2p-crypto"
-
-	floodsub "github.com/libp2p/go-floodsub"
+	logging "github.com/whyrusleeping/go-logging"
+	gossipsub "github.com/libp2p/go-libp2p-pubsub"
 	ma "github.com/multiformats/go-multiaddr"
 )
 
 var ho host.Host
 
-//var TopicName string = "libp2p-demo-chat"
-//h("libp2p-demo-chat") = "RDEpsjSPrAZF9JCK5REt3tao" - rust uses the hash unlike js/go ()
 var TopicName string = "RDEpsjSPrAZF9JCK5REt3tao"
 
-func parseArgs() (bool, string) {
-	usage := fmt.Sprintf("Usage: %s PRIVATE_KEY [--bootstrapper]\n\nPRIVATE_KEY is the path to a private key like '../util/private_key.bin'\n--bootstrapper to run in bootstrap mode (creates a DHT and listens for peers)\n", os.Args[0])
+
+
+func init() {
+	         os.Setenv("GODEBUG", os.Getenv("GODEBUG")+",tls13=1")
+}
+
+func parseArgs() (bool, string, int) {
+	usage := fmt.Sprintf("Usage: %s PRIVATE_KEY  PORT [--bootstrapper] \n\nPRIVATE_KEY is the path to a private key like '../util/private_key.bin'\n PORT is port to listen on, default is 6000\n--bootstrapper to run in bootstrap mode (creates a DHT and listens for peers)\n", os.Args[0])
 	var bBootstrap bool = false
 	var privKeyFilePath string
 	var args []string = os.Args[1:]
@@ -41,15 +46,9 @@ func parseArgs() (bool, string) {
 	return bBootstrap, privKeyFilePath
 }
 
-func handleConn(conn inet.Conn) {
-	ctx := context.Background()
-	h := ho
-	fmt.Printf("<NOTICE> New peer joined: %v\n", conn.RemoteMultiaddr().String())
-	_ = h
-	_ = ctx
-}
-
 func main() {
+	log.SetAllLoggers(logging.DEBUG)
+	log.SetLogLevel("raven", "debug")
 	ctx := context.Background()
 
 	bBootstrap, privKeyFilePath := parseArgs()
@@ -98,12 +97,16 @@ func main() {
 		panic(err)
 	}
 
-	//
-	// Construct a floodsub instance for this host
-	//
-	fsub, err := floodsub.NewFloodSub(ctx, host, floodsub.WithMessageSigning(false))
+	// Bootstrap the DHT. In the default configuration, this spawns a Background
+	// thread that will refresh the peer table every five minutes.
+	logger.Debug("Bootstrapping the DHT")
+	if err = kademliaDHT.Bootstrap(ctx); err != nil {
+			panic(err)
+	}
+	// Construct a gossipsub instance for this host
+	gsub, err := gossipsub.NewGossipSub(ctx, host, gossipsub.WithMessageSigning(false))
 	if err != nil {
-		fmt.Println("Error (floodsub.NewFloodSub): %v", err)
+		fmt.Println("Error (gossipsub.NewGossipSub): %v", err)
 		panic(err)
 	}
 
@@ -137,7 +140,7 @@ func main() {
 	//
 	// Subscribe to the topic and wait for messages published on that topic
 	//
-	sub, err := fsub.Subscribe(TopicName)
+	sub, err := gsub.Subscribe(TopicName)
 	if err != nil {
 		fmt.Println("Error (fsub.Subscribe): %v", err)
 		panic(err)
@@ -166,14 +169,13 @@ func main() {
 		},
 	})
 	if bBootstrap {
-		fmt.Println("Bootstrapper running.\nPubSub object instantiated using FloodSubRouter.\nCtrl+C to exit.")
-		for true {
-		}
+		fmt.Println("Bootstrapper running.\nPubSub object instantiated using GossipSubRouter.\nCtrl+C to exit.")
+		select {}
 	} else {
 		// Now, wait for input from the user, and send that out!
 		scan := bufio.NewScanner(os.Stdin)
 		for scan.Scan() {
-			if err := fsub.Publish(TopicName, scan.Bytes()); err != nil {
+			if err := gsub.Publish(TopicName, scan.Bytes()); err != nil {
 				panic(err)
 			}
 		}