p2p: Fix "Unknown Channel" bug on CustomReactors (#6297)

Finschia · Dec 23, 2021 · 4f22ffe · 4f22ffe
1 parent b59f44d
commit 4f22ffe
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/p2p/peer.go b/p2p/peer.go
@@ -135,10 +135,15 @@ func newPeer(
 	onPeerError func(Peer, interface{}),
 	options ...PeerOption,
 ) *peer {
+	var channs = make([]byte, 0, len(chDescs))
+	for _, desc := range chDescs {
+		channs = append(channs, desc.ID)
+	}
+
 	p := &peer{
 		peerConn:      pc,
 		nodeInfo:      nodeInfo,
-		channels:      nodeInfo.(DefaultNodeInfo).Channels, // TODO
+		channels:      channs,
 		Data:          cmap.NewCMap(),
 		metricsTicker: time.NewTicker(metricsTickerDuration),
 		metrics:       NopMetrics(),