fix resume download

zboxcore/sdk/allocation.go

@@ -1134,6 +1134,7 @@ func (a *Allocation) addAndGenerateDownloadRequest(
 		opt(downloadReq)
 	}
 	downloadReq.workdir = filepath.Join(downloadReq.workdir, ".zcn")
+	fmt.Println("downloadReq: ", downloadReq.downloadStorer != nil, " workDir:", downloadReq.workdir, "opts: ", len(downloadReqOpts))
 	a.downloadProgressMap[remotePath] = downloadReq
 	a.downloadRequests = append(a.downloadRequests, downloadReq)
 	if isFinal {

zboxcore/sdk/download_progress_storer.go

@@ -10,7 +10,6 @@ import (
 
 	"github.com/0chain/errors"
 	"github.com/0chain/gosdk/core/sys"
-	"github.com/hitenjain14/fasthttp"
 )
 
 type DownloadProgressStorer interface {
@@ -43,32 +42,34 @@ func CreateFsDownloadProgress() *FsDownloadProgressStorer {
 }
 
 func (ds *FsDownloadProgressStorer) Start(ctx context.Context) {
+	tc := time.NewTicker(2 * time.Second)
 	ds.next += ds.dp.numBlocks
-	tc := fasthttp.AcquireTimer(2 * time.Second)
-	defer fasthttp.ReleaseTimer(tc)
-	for {
-		select {
-		case <-ctx.Done():
-			return
-		case <-tc.C:
-			ds.Lock()
-			if ds.isRemoved {
-				ds.Unlock()
+	go func() {
+		defer tc.Stop()
+		for {
+			select {
+			case <-ctx.Done():
 				return
-			}
-			if len(ds.queue) > 0 && ds.queue[0] == ds.next {
-				for len(ds.queue) > 0 && ds.queue[0] == ds.next {
-					ds.dp.LastWrittenBlock = ds.next
-					heap.Pop(&ds.queue)
-					ds.next += ds.dp.numBlocks
+			case <-tc.C:
+				ds.Lock()
+				if ds.isRemoved {
+					ds.Unlock()
+					return
+				}
+				if len(ds.queue) > 0 && ds.queue[0] == ds.next {
+					for len(ds.queue) > 0 && ds.queue[0] == ds.next {
+						ds.dp.LastWrittenBlock = ds.next
+						heap.Pop(&ds.queue)
+						ds.next += ds.dp.numBlocks
+					}
+					ds.Unlock()
+					ds.saveToDisk()
+				} else {
+					ds.Unlock()
 				}
-				ds.Unlock()
-				ds.saveToDisk()
-			} else {
-				ds.Unlock()
 			}
 		}
-	}
+	}()
 }
 
 func (ds *FsDownloadProgressStorer) Load(progressID string) *DownloadProgress {

zboxcore/sdk/downloadworker.go

@@ -649,7 +649,7 @@ func (req *DownloadRequest) processDownload(ctx context.Context) {
 			if !writerAt {
 				blocks <- blockData{blockNum: j, data: data}
 			} else {
-				offset := int64(j) * numBlocks * int64(req.effectiveBlockSize) * int64(req.datashards)
+				offset := (startBlock + int64(j)*numBlocks) * int64(req.effectiveBlockSize) * int64(req.datashards)
 				var total int
 				if j == n-1 {
 					total, err = writeAtData(writeAtHandler, data, req.datashards, offset, int(lastBlockSize))
@@ -956,6 +956,10 @@ func (req *DownloadRequest) calculateShardsParams(
 	// Can be nil when using file writer in wasm
 	if info != nil {
 		if req.downloadStorer != nil {
+			err = sys.Files.MkdirAll(filepath.Join(req.workdir, "download"), 0766)
+			if err != nil {
+				return 0, err
+			}
 			progressID := req.progressID()
 			var dp *DownloadProgress
 			if info.Size() > 0 {