From 889ddcef7e49d9961977ee3d29c0dd2df1e280c2 Mon Sep 17 00:00:00 2001 From: Noah Hsu Date: Sun, 11 Sep 2022 17:09:48 +0800 Subject: [PATCH] feat(baidu): update upload progress --- drivers/baidu_netdisk/driver.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/drivers/baidu_netdisk/driver.go b/drivers/baidu_netdisk/driver.go index 8d9c13c8..310090c4 100644 --- a/drivers/baidu_netdisk/driver.go +++ b/drivers/baidu_netdisk/driver.go @@ -202,7 +202,7 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F "uploadid": precreateResp.Uploadid, } left = stream.GetSize() - for _, partseq := range precreateResp.BlockList { + for i, partseq := range precreateResp.BlockList { byteSize := Default var byteData []byte if left < Default { @@ -223,6 +223,9 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F return err } log.Debugln(res.String()) + if len(precreateResp.BlockList) > 0 { + up(i * 100 / len(precreateResp.BlockList)) + } } _, err = d.create(path, stream.GetSize(), 0, precreateResp.Uploadid, block_list_str) return err