opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-06 16:33:40 +08:00
Code Issues Projects Releases Wiki Activity

core/commands/pin: refactor 'pin ls'

Browse Source 
License: MIT
Signed-off-by: Christian Couder <chriscool@tuxfamily.org>
This commit is contained in:
Christian Couder
2016-01-12 21:54:37 +01:00
parent b770c881a7
commit c89e3c22eb
1 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
core/commands/pin.go
View File

@ -212,13 +212,18 @@ Example:
} }
keys := make(map[string]RefKeyObject) keys := make(map[string]RefKeyObject)
if typeStr == "direct" || typeStr == "all" {
for _, k := range n.Pinning.DirectKeys() { AddToResultKeys := func(keyList []key.Key, typeStr string) {
for _, k := range keyList {
keys[k.B58String()] = RefKeyObject{ keys[k.B58String()] = RefKeyObject{
Type: "direct", Type: typeStr,
} }
} }
} }
if typeStr == "direct" || typeStr == "all" {
AddToResultKeys(n.Pinning.DirectKeys(), "direct")
}
if typeStr == "indirect" || typeStr == "all" { if typeStr == "indirect" || typeStr == "all" {
ks := key.NewKeySet() ks := key.NewKeySet()
for _, k := range n.Pinning.RecursiveKeys() { for _, k := range n.Pinning.RecursiveKeys() {
@ -232,20 +237,11 @@ Example:
res.SetError(err, cmds.ErrNormal) res.SetError(err, cmds.ErrNormal)
return return
} }
}
for _, k := range ks.Keys() {
keys[k.B58String()] = RefKeyObject{
Type: "indirect",
}
} }
AddToResultKeys(ks.Keys(), "indirect")
} }
if typeStr == "recursive" || typeStr == "all" { if typeStr == "recursive" || typeStr == "all" {
for _, k := range n.Pinning.RecursiveKeys() { AddToResultKeys(n.Pinning.RecursiveKeys(), "recursive")
keys[k.B58String()] = RefKeyObject{
Type: "recursive",
}
}
} }
res.SetOutput(&RefKeyList{Keys: keys}) res.SetOutput(&RefKeyList{Keys: keys})