From 0a01ffb87fa7a142e577cf795e2976d679ec2fac Mon Sep 17 00:00:00 2001 From: "Tom O'Donnell (te0d)" Date: Wed, 19 Jul 2017 17:32:11 -0400 Subject: [PATCH] ipfs add: added size to response of `ipfs add` command 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 --- core/coreunix/add.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/core/coreunix/add.go b/core/coreunix/add.go index 8539bf108..a765f4ebd 100644 --- a/core/coreunix/add.go +++ b/core/coreunix/add.go @@ -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())), }