coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-02-23 03:17:43 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

ipfs add: added size to response of ipfs add command

Browse Source 
The `ipfs add` command was modified to include the added
node's size as a string. The size is included in the
dagnode info sent over the output channel.

License: MIT
Signed-off-by: Tom O'Donnell <todonnel91@gmail.com>
This commit is contained in:
Tom O'Donnell (te0d) 2017-07-19 17:32:11 -04:00
parent 4c3487017c
commit 0a01ffb87f
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
core/coreunix/add.go
View File

@ -7,6 +7,7 @@ import (
"io/ioutil"
"os"
gopath "path"
"strconv"
bs "github.com/ipfs/go-ipfs/blocks/blockstore"
bstore "github.com/ipfs/go-ipfs/blocks/blockstore"
@ -46,6 +47,7 @@ type Link struct {
type Object struct {
Hash string
Links []Link
Size string
}
type hiddenFileError struct {
@ -68,6 +70,7 @@ type AddedObject struct {
Name string
Hash string `json:",omitempty"`
Bytes int64 `json:",omitempty"`
Size string `json:",omitempty"`
}
func NewAdder(ctx context.Context, p pin.Pinner, bs bstore.GCBlockstore, ds dag.DAGService) (*Adder, error) {
@ -543,6 +546,7 @@ func outputDagnode(out chan interface{}, name string, dn node.Node) error {
out <- &AddedObject{
Hash: o.Hash,
Name: name,
Size: o.Size,
}
return nil
@ -558,9 +562,14 @@ func NewMemoryDagService() dag.DAGService {
// from core/commands/object.go
func getOutput(dagnode node.Node) (*Object, error) {
c := dagnode.Cid()
s, err := dagnode.Size()
if err != nil {
return nil, err
}
output := &Object{
Hash: c.String(),
Size: strconv.FormatUint(s, 10),
Links: make([]Link, len(dagnode.Links())),
}