From 636fb81243aec7afa32b1f1c3dbd42402b159b9f Mon Sep 17 00:00:00 2001 From: Dirk McCormick Date: Mon, 8 Feb 2021 16:31:06 +0100 Subject: [PATCH] feat: deals - show data transfer % --- api/api_full.go | 7 ++++--- cli/client.go | 25 +++++++++++++------------ cli/test/client.go | 1 - go.mod | 2 +- go.sum | 4 ++-- node/impl/client/client.go | 15 +++++++++++++-- 6 files changed, 33 insertions(+), 21 deletions(-) diff --git a/api/api_full.go b/api/api_full.go index 7aea4c4433b..4c0003a168b 100644 --- a/api/api_full.go +++ b/api/api_full.go @@ -937,9 +937,10 @@ type DataSize struct { } type DataCIDSize struct { - PayloadSize int64 - PieceSize abi.PaddedPieceSize - PieceCID cid.Cid + RawBlockSize uint64 + PayloadSize int64 + PieceSize abi.PaddedPieceSize + PieceCID cid.Cid } type CommPRet struct { diff --git a/cli/client.go b/cli/client.go index 60729f2e5a4..10ea092a859 100644 --- a/cli/client.go +++ b/cli/client.go @@ -850,8 +850,9 @@ uiLoop: TransferType: storagemarket.TTGraphsync, Root: data, - PieceCid: &ds.PieceCID, - PieceSize: ds.PieceSize.Unpadded(), + PieceCid: &ds.PieceCID, + PieceSize: ds.PieceSize.Unpadded(), + RawBlockSize: ds.RawBlockSize, }, Wallet: a, Miner: maddr, @@ -1567,7 +1568,7 @@ func outputStorageDeals(ctx context.Context, out io.Writer, full lapi.FullNode, if verbose { w := tabwriter.NewWriter(out, 2, 4, 2, ' ', 0) - fmt.Fprintf(w, "Created\tDealCid\tDealId\tProvider\tState\tOn Chain?\tSlashed?\tPieceCID\tSize\tPrice\tDuration\tTransferChannelID\tTransferStatus\tVerified\tMessage\n") + fmt.Fprintf(w, "Created\tDealCid\tDealId\tProvider\tState\tOn Chain?\tSlashed?\tPieceCID\tSize\tPrice\tDuration\tTransferChannelID\tTransferStatus\tTransfer %%\tVerified\tMessage\n") for _, d := range deals { onChain := "N" if d.OnChainDealState.SectorStartEpoch != -1 { @@ -1585,17 +1586,16 @@ func outputStorageDeals(ctx context.Context, out io.Writer, full lapi.FullNode, transferChannelID = d.LocalDeal.TransferChannelID.String() } transferStatus := "" + transferPct := "" if d.LocalDeal.DataTransfer != nil { transferStatus = datatransfer.Statuses[d.LocalDeal.DataTransfer.Status] - // TODO: Include the transferred percentage once this bug is fixed: - // https://github.com/ipfs/go-graphsync/issues/126 - //fmt.Printf("transferred: %d / size: %d\n", d.LocalDeal.DataTransfer.Transferred, d.LocalDeal.Size) - //if d.LocalDeal.Size > 0 { - // pct := (100 * d.LocalDeal.DataTransfer.Transferred) / d.LocalDeal.Size - // transferPct = fmt.Sprintf("%d%%", pct) - //} - } - fmt.Fprintf(w, "%s\t%s\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%s\t%s\t%v\t%s\n", + // Calculate transfer % + if d.LocalDeal.DataRef.RawBlockSize > 0 { + pct := (100 * d.LocalDeal.DataTransfer.Transferred) / d.LocalDeal.DataRef.RawBlockSize + transferPct = fmt.Sprintf("%d%%", pct) + } + } + fmt.Fprintf(w, "%s\t%s\t%d\t%s\t%s\t%s\t%s\t%s\t%s\t%s\t%d\t%s\t%s\t%s\t%v\t%s\n", d.LocalDeal.CreationTime.Format(time.Stamp), d.LocalDeal.ProposalCid, d.LocalDeal.DealID, @@ -1609,6 +1609,7 @@ func outputStorageDeals(ctx context.Context, out io.Writer, full lapi.FullNode, d.LocalDeal.Duration, transferChannelID, transferStatus, + transferPct, d.LocalDeal.Verified, d.LocalDeal.Message) } diff --git a/cli/test/client.go b/cli/test/client.go index 4a49f732a45..4cb1300a19f 100644 --- a/cli/test/client.go +++ b/cli/test/client.go @@ -69,7 +69,6 @@ func RunClientTest(t *testing.T, cmds []*lcli.Command, clientNode test.TestNode) dataCid2.String(), duration, minerAddr.String(), - "no", "yes", } out = clientCLI.RunInteractiveCmd(cmd, interactiveCmds) diff --git a/go.mod b/go.mod index b3a144ed69d..19fbcb96d95 100644 --- a/go.mod +++ b/go.mod @@ -33,7 +33,7 @@ require ( github.com/filecoin-project/go-crypto v0.0.0-20191218222705-effae4ea9f03 github.com/filecoin-project/go-data-transfer v1.2.7 github.com/filecoin-project/go-fil-commcid v0.0.0-20201016201715-d41df56b4f6a - github.com/filecoin-project/go-fil-markets v1.1.7 + github.com/filecoin-project/go-fil-markets v1.0.8-0.20210208151159-6cbbb53c4e61 github.com/filecoin-project/go-jsonrpc v0.1.2 github.com/filecoin-project/go-multistore v0.0.3 github.com/filecoin-project/go-padreader v0.0.0-20200903213702-ed5fae088b20 diff --git a/go.sum b/go.sum index b40b7000c5d..d34f82ae3ab 100644 --- a/go.sum +++ b/go.sum @@ -269,8 +269,8 @@ github.com/filecoin-project/go-fil-commcid v0.0.0-20200716160307-8f644712406f/go github.com/filecoin-project/go-fil-commcid v0.0.0-20201016201715-d41df56b4f6a h1:hyJ+pUm/4U4RdEZBlg6k8Ma4rDiuvqyGpoICXAxwsTg= github.com/filecoin-project/go-fil-commcid v0.0.0-20201016201715-d41df56b4f6a/go.mod h1:Eaox7Hvus1JgPrL5+M3+h7aSPHc0cVqpSxA+TxIEpZQ= github.com/filecoin-project/go-fil-markets v1.0.5-0.20201113164554-c5eba40d5335/go.mod h1:AJySOJC00JRWEZzRG2KsfUnqEf5ITXxeX09BE9N4f9c= -github.com/filecoin-project/go-fil-markets v1.1.7 h1:7yy7alIDWzUxljxZhGmG3+wvaU4Ty5QDMbPmdZeaIJ8= -github.com/filecoin-project/go-fil-markets v1.1.7/go.mod h1:6oTRaAsHnCqhi3mpZqdvnWIzH6QzHQc4dbhJrI9/BfQ= +github.com/filecoin-project/go-fil-markets v1.0.8-0.20210208151159-6cbbb53c4e61 h1:HZC4V3/YzJz0shB3f02sf1gcC7aROmWKHcVQRm+a5SQ= +github.com/filecoin-project/go-fil-markets v1.0.8-0.20210208151159-6cbbb53c4e61/go.mod h1:6oTRaAsHnCqhi3mpZqdvnWIzH6QzHQc4dbhJrI9/BfQ= github.com/filecoin-project/go-hamt-ipld v0.1.5 h1:uoXrKbCQZ49OHpsTCkrThPNelC4W3LPEk0OrS/ytIBM= github.com/filecoin-project/go-hamt-ipld v0.1.5/go.mod h1:6Is+ONR5Cd5R6XZoCse1CWaXZc0Hdb/JeX+EQCQzX24= github.com/filecoin-project/go-hamt-ipld/v2 v2.0.0 h1:b3UDemBYN2HNfk3KOXNuxgTTxlWi3xVvbQP0IT38fvM= diff --git a/node/impl/client/client.go b/node/impl/client/client.go index 00c840b6360..2a60da9bf52 100644 --- a/node/impl/client/client.go +++ b/node/impl/client/client.go @@ -755,7 +755,13 @@ func (a *API) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCID w := &writer.Writer{} bw := bufio.NewWriterSize(w, int(writer.CommPBuf)) - err := car.WriteCar(ctx, dag, []cid.Cid{root}, w) + // Calculate the raw block size so we can figure out the transfer percentage + // (the raw block size is the denominator) + var rawBlockSize uint64 + err := car.WriteCarWithWalker(ctx, dag, []cid.Cid{root}, w, func(nd ipld.Node) ([]*ipld.Link, error) { + rawBlockSize += uint64(len(nd.RawData())) + return nd.Links(), nil + }) if err != nil { return api.DataCIDSize{}, err } @@ -765,7 +771,12 @@ func (a *API) ClientDealPieceCID(ctx context.Context, root cid.Cid) (api.DataCID } dataCIDSize, err := w.Sum() - return api.DataCIDSize(dataCIDSize), err + return api.DataCIDSize{ + RawBlockSize: rawBlockSize, + PayloadSize: dataCIDSize.PayloadSize, + PieceSize: dataCIDSize.PieceSize, + PieceCID: dataCIDSize.PieceCID, + }, err } func (a *API) ClientGenCar(ctx context.Context, ref api.FileRef, outputPath string) error {