From 482f4f8846938aff5dfa322e716a2da69766a5e9 Mon Sep 17 00:00:00 2001 From: rairyx Date: Fri, 19 Jul 2019 22:55:35 -0700 Subject: [PATCH] Test gossipsub --- pubsub/raven.go | 17 +++++------------ 1 file changed, 5 insertions(+), 12 deletions(-) diff --git a/pubsub/raven.go b/pubsub/raven.go index 9a45e6b..e20017a 100644 --- a/pubsub/raven.go +++ b/pubsub/raven.go @@ -17,7 +17,7 @@ import ( "github.com/libp2p/go-libp2p-crypto" logging "github.com/whyrusleeping/go-logging" - floodsub "github.com/libp2p/go-libp2p-pubsub" + gossipsub "github.com/libp2p/go-libp2p-pubsub" ma "github.com/multiformats/go-multiaddr" ) @@ -45,13 +45,6 @@ func parseArgs() (bool, string, int) { return bBootstrap, privKeyFilePath, listenPort } -func handleConn(conn inet.Conn) { - ctx := context.Background() - h := ho - fmt.Printf(" New peer joined: %v\n", conn.RemoteMultiaddr().String()) - _ = h - _ = ctx -} func main() { log.SetAllLoggers(logging.DEBUG) @@ -118,8 +111,8 @@ func main() { if err = kademliaDHT.Bootstrap(ctx); err != nil { panic(err) } - // Construct a floodsub instance for this host - fsub, err := floodsub.NewFloodSub(ctx, host, floodsub.WithMessageSigning(false)) + // 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) panic(err) @@ -154,7 +147,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) @@ -190,7 +183,7 @@ func main() { // 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) } }