feat: switch dag import command to use default go-ipld-legacy block decoder
Adin Schmahmann committed
May 31, 2023 at 11:22 UTC
4ebde42ec8fce624e510b1763e196805f4b9194b
1 file changed
+4
-2
core/commands/dag/import.go
+4
-2
@@ -27,6 +27,8 @@ func dagImport(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment
27
return err
28
}
29
30
+ blockDecoder := ipldlegacy.NewDecoder()
31
+
32
// on import ensure we do not reach out to the network for any reason
33
// if a pin based on what is imported + what is in the blockstore
34
// isn't possible: tough luck
@@ -94,7 +96,7 @@ func dagImport(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment
96
}
97
98
// the double-decode is suboptimal, but we need it for batching
97
- nd, err := ipldlegacy.DecodeNode(req.Context, block)
99
+ nd, err := blockDecoder.DecodeNode(req.Context, block)
100
if err != nil {
101
return err
102
}
@@ -131,7 +133,7 @@ func dagImport(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment
133
// and ensure the gray bucket is empty at the end (or use the network to download missing blocks).
134
if block, err := node.Blockstore.Get(req.Context, c); err != nil {
135
ret.PinErrorMsg = err.Error()
134
- } else if nd, err := ipldlegacy.DecodeNode(req.Context, block); err != nil {
136
+ } else if nd, err := blockDecoder.DecodeNode(req.Context, block); err != nil {
137
ret.PinErrorMsg = err.Error()
138
} else if err := node.Pinning.Pin(req.Context, nd, true); err != nil {
139
ret.PinErrorMsg = err.Error()