refactor: use original peerids

ipfs · Oct 12, 2021 · 7ddcab4 · 7ddcab4
1 parent fc2d7fb
commit 7ddcab4
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/pubsub.go b/pubsub.go
@@ -47,11 +47,7 @@ func (s *PubSubSubscription) Next() (*Message, error) {
 
 	// fields are wrapped in multibase when sent over HTTP RPC
 	// and need to be decoded (https://github.com/ipfs/go-ipfs/pull/8183)
-	_, bfrom, err := mbase.Decode(r.From)
-	if err != nil {
-		return nil, err
-	}
-	from, err := peer.IDFromBytes(bfrom)
+	from, err := peer.Decode(r.From)
 	if err != nil {
 		return nil, err
 	}