fix: subscribe to topic

network/frost/frost_stream.go

@@ -33,7 +33,6 @@ func (s *FrostStream) Client(stream network.Stream) *network.Stream {
 }
 
 func (s *FrostStream) Handler() func(network.Stream) {
-	fmt.Println(">>>>>>>>>>>>>>>  FROST Handler called:")
 
 	return func(stream network.Stream) {
 		go func() {

network/frost/proto/frost.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+
+package v1;
+
+option go_package = "/frost/proto";
+
+// Block contains a block data
+message FrostMessage {
+  string message = 1;
+  string number = 2;
+}
+

network/server.go

@@ -10,6 +10,7 @@ import (
 	"github.com/0xPolygon/polygon-edge/network/common"
 	"github.com/0xPolygon/polygon-edge/network/dial"
 	"github.com/0xPolygon/polygon-edge/network/discovery"
+	"github.com/0xPolygon/polygon-edge/network/frost/proto"
 	"github.com/armon/go-metrics"
 	"github.com/libp2p/go-libp2p"
 	"github.com/libp2p/go-libp2p/p2p/security/noise"
@@ -92,6 +93,7 @@ type Server struct {
 	frostPeersLock              sync.Mutex                     // lock for the peer map of topos nodes
 	frostPendingPeerConnections sync.Map                       // Map that keeps track of the frost pending status
 	frostConnectionCounts       *ConnectionInfo
+	frostTopic                  *Topic
 }
 
 // NewServer returns a new instance of the networking server
@@ -285,6 +287,17 @@ func (s *Server) Start() error {
 		return fmt.Errorf("unable to setup frost, %w", setupErr)
 	}
 
+	topic, err := s.NewTopic("/frost", &proto.FrostMessage{})
+	if err != nil {
+		return err
+	}
+
+	if err := topic.Subscribe(s.handleFrostStatusUpdate); err != nil {
+		return fmt.Errorf("unable to subscribe to gossip topic, %w", err)
+	}
+
+	s.frostTopic = topic
+
 	// Set up the peer discovery mechanism if needed
 	if !s.config.NoDiscover {
 		// Parse the bootnode data

network/server_frost.go

@@ -6,6 +6,7 @@ import (
 	"github.com/0xPolygon/polygon-edge/network/common"
 	peerEvent "github.com/0xPolygon/polygon-edge/network/event"
 	"github.com/0xPolygon/polygon-edge/network/frost"
+	"github.com/0xPolygon/polygon-edge/network/frost/proto"
 	"github.com/armon/go-metrics"
 	"github.com/libp2p/go-libp2p/core/network"
 	"github.com/libp2p/go-libp2p/core/peer"
@@ -137,3 +138,21 @@ func (s *Server) registerFrostService(frostService *frost.FrostService) {
 	frostStream := frost.NewFrostStream()
 	s.RegisterRawProtocol(common.Frost, frostStream)
 }
+
+// handleFrostStatusUpdate is a handler of gossip
+func (s *Server) handleFrostStatusUpdate(obj interface{}, from peer.ID) {
+	frostMessage, ok := obj.(*proto.FrostMessage)
+	fmt.Println(">>>>>>>>>>>>>>>>>> Received frost message:", frostMessage)
+	if !ok {
+		s.logger.Error("failed to cast gossiped frost message")
+		return
+	}
+
+	// if !s.host.Network().IsConnected(from) {
+	// 	if m.id != from.String() {
+	// 		m.logger.Debug("received status from non-connected peer, ignore", "id", from)
+	// 	}
+
+	// 	return
+	// }
+}