dkg/sync: move connected logs to server (#771)

Moves connected logs to server and removes inbound and outbound logs from client and server.

category: bug
ticket: #762

dkg/sync/client.go

@@ -72,7 +72,6 @@ func (c *Client) Run(ctx context.Context) error {
 			return err
 		}
 
-		log.Info(ctx, "Connected to peer (outbound)")
 		c.setConnected()
 
 		reconnect, err := c.sendMsgs(ctx, stream)

dkg/sync/server.go

@@ -20,6 +20,7 @@ package sync
 import (
 	"context"
 	"encoding/binary"
+	"fmt"
 	"io"
 	"sync"
 	"time"
@@ -122,11 +123,13 @@ func (s *Server) isConnected(pID peer.ID) bool {
 }
 
 // setConnected sets the shared connected state for the peer.
-func (s *Server) setConnected(pID peer.ID) {
+func (s *Server) setConnected(pID peer.ID) int {
 	s.mu.Lock()
 	defer s.mu.Unlock()
 
 	s.connected[pID] = struct{}{}
+
+	return len(s.connected)
 }
 
 // clearConnected clears the shared connected state for the peer.
@@ -202,8 +205,8 @@ func (s *Server) handleStream(ctx context.Context, stream network.Stream) error
 
 			log.Error(ctx, "Received mismatching cluster definition hash from peer", nil)
 		} else if ok && !s.isConnected(pID) {
-			log.Info(ctx, "Connected to peer (inbound)")
-			s.setConnected(pID)
+			count := s.setConnected(pID)
+			log.Info(ctx, fmt.Sprintf("Connected to peer %d of %d", count, s.allCount))
 		}
 
 		// Write response message