gob: type not registered for interface: network.Direction

waku/v2/peerstore/waku_peer_store.go

@@ -158,7 +158,7 @@ func (ps *WakuPeerstoreImpl) ConnFailures(pID peer.ID) int {
 
 // SetDirection sets connection direction for a specific peer.
 func (ps *WakuPeerstoreImpl) SetDirection(p peer.ID, direction network.Direction) error {
-	return ps.peerStore.Put(p, peerDirection, direction)
+	return ps.peerStore.Put(p, peerDirection, int(direction))
 }
 
 // Direction fetches the connection direction (Inbound or outBound) for a specific peer
@@ -168,7 +168,7 @@ func (ps *WakuPeerstoreImpl) Direction(p peer.ID) (network.Direction, error) {
 		return network.DirUnknown, err
 	}
 
-	return result.(network.Direction), nil
+	return network.Direction(result.(int)), nil
 }
 
 // AddPubSubTopic adds a new pubSubTopic for a peer

waku/v2/protocol/metadata/waku_metadata.go

@@ -125,7 +125,7 @@ func (wakuM *WakuMetadata) Request(ctx context.Context, peerID peer.ID) (*pb.Wak
 
 	writer := pbio.NewDelimitedWriter(stream)
 	reader := pbio.NewDelimitedReader(stream, math.MaxInt32)
-	logger.Debug("sending metadata request")
+	logger.Info("sending metadata request", zap.Uint32("clusterId", *clusterID), zap.Uint32s("shards", shards))
 
 	err = writer.WriteMsg(request)
 	if err != nil {
@@ -148,7 +148,7 @@ func (wakuM *WakuMetadata) Request(ctx context.Context, peerID peer.ID) (*pb.Wak
 	}
 
 	stream.Close()
-	logger.Debug("received metadata response")
+	logger.Info("received metadata response", zap.Uint32("clusterId", *response.ClusterId), zap.Uint32s("shards", request.Shards))
 	return response, nil
 }
 
@@ -186,7 +186,7 @@ func (wakuM *WakuMetadata) onRequest(ctx context.Context) func(network.Stream) {
 			}
 			return
 		}
-		logger.Debug("sent metadata response to peer")
+		logger.Info("sent metadata response to peer", zap.Uint32("clusterId", *clusterID), zap.Uint32s("shards", shards))
 
 		stream.Close()
 	}