fix: move away from deprecated peer ID functions

pontiyaraja · Dec 19, 2019 · 4394dca · 4394dca
1 parent 38ba128
commit 4394dca
Show file tree

Hide file tree

Showing 9 changed files with 12 additions and 12 deletions.
diff --git a/core/commands/bitswap.go b/core/commands/bitswap.go
@@ -60,7 +60,7 @@ Print out all blocks currently on the bitswap wantlist for the local peer.`,
 
 		pstr, found := req.Options[peerOptionName].(string)
 		if found {
-			pid, err := peer.IDB58Decode(pstr)
+			pid, err := peer.Decode(pstr)
 			if err != nil {
 				return err
 			}
@@ -195,7 +195,7 @@ prints the ledger associated with a given peer.
 			return e.TypeErr(bs, nd.Exchange)
 		}
 
-		partner, err := peer.IDB58Decode(req.Arguments[0])
+		partner, err := peer.Decode(req.Arguments[0])
 		if err != nil {
 			return err
 		}

diff --git a/core/commands/dht.go b/core/commands/dht.go
@@ -68,7 +68,7 @@ var queryDhtCmd = &cmds.Command{
 			return ErrNotDHT
 		}
 
-		id, err := peer.IDB58Decode(req.Arguments[0])
+		id, err := peer.Decode(req.Arguments[0])
 		if err != nil {
 			return cmds.ClientError("invalid peer ID")
 		}
@@ -370,7 +370,7 @@ var findPeerDhtCmd = &cmds.Command{
 			return ErrNotOnline
 		}
 
-		pid, err := peer.IDB58Decode(req.Arguments[0])
+		pid, err := peer.Decode(req.Arguments[0])
 		if err != nil {
 			return err
 		}

diff --git a/core/commands/id.go b/core/commands/id.go
@@ -75,7 +75,7 @@ EXAMPLE:
 		var id peer.ID
 		if len(req.Arguments) > 0 {
 			var err error
-			id, err = peer.IDB58Decode(req.Arguments[0])
+			id, err = peer.Decode(req.Arguments[0])
 			if err != nil {
 				return fmt.Errorf("invalid peer id")
 			}

diff --git a/core/commands/name/ipnsps.go b/core/commands/name/ipnsps.go
@@ -93,7 +93,7 @@ var ipnspsSubsCmd = &cmds.Command{
 				log.Errorf("ipns key not a valid peer ID: %s", err)
 				continue
 			}
-			paths = append(paths, "/ipns/"+peer.IDB58Encode(pid))
+			paths = append(paths, "/ipns/"+peer.Encode(pid))
 		}
 
 		return cmds.EmitOnce(res, &stringList{paths})
@@ -120,7 +120,7 @@ var ipnspsCancelCmd = &cmds.Command{
 
 		name := req.Arguments[0]
 		name = strings.TrimPrefix(name, "/ipns/")
-		pid, err := peer.IDB58Decode(name)
+		pid, err := peer.Decode(name)
 		if err != nil {
 			return cmds.Errorf(cmds.ErrClient, err.Error())
 		}

diff --git a/core/commands/ping.go b/core/commands/ping.go
@@ -217,6 +217,6 @@ func ParsePeerParam(text string) (ma.Multiaddr, peer.ID, error) {
 		return transport, id, nil
 	}
 	// Raw peer ID
-	p, err := peer.IDB58Decode(text)
+	p, err := peer.Decode(text)
 	return nil, p, err
 }
diff --git a/core/commands/stat.go b/core/commands/stat.go
@@ -109,7 +109,7 @@ Example:
 
 		var pid peer.ID
 		if pfound {
-			checkpid, err := peer.IDB58Decode(pstr)
+			checkpid, err := peer.Decode(pstr)
 			if err != nil {
 				return err
 			}

diff --git a/core/node/groups.go b/core/node/groups.go
@@ -154,7 +154,7 @@ func Identity(cfg *config.Config) fx.Option {
 		return fx.Error(errors.New("no peer ID in config! (was 'ipfs init' run?)"))
 	}
 
-	id, err := peer.IDB58Decode(cid)
+	id, err := peer.Decode(cid)
 	if err != nil {
 		return fx.Error(fmt.Errorf("peer ID invalid: %s", err))
 	}

diff --git a/namesys/namesys.go b/namesys/namesys.go
@@ -189,6 +189,6 @@ func (ns *mpns) PublishWithEOL(ctx context.Context, name ci.PrivKey, value path.
 	if ttEol := time.Until(eol); ttEol < ttl {
 		ttl = ttEol
 	}
-	ns.cacheSet(peer.IDB58Encode(id), value, ttl)
+	ns.cacheSet(peer.Encode(id), value, ttl)
 	return nil
 }
diff --git a/namesys/routing.go b/namesys/routing.go
@@ -59,7 +59,7 @@ func (r *IpnsResolver) resolveOnceAsync(ctx context.Context, name string, option
 	}
 
 	name = strings.TrimPrefix(name, "/ipns/")
-	pid, err := peer.IDB58Decode(name)
+	pid, err := peer.Decode(name)
 	if err != nil {
 		log.Debugf("RoutingResolver: could not convert public key hash %s to peer ID: %s\n", name, err)
 		out <- onceResult{err: err}