bagas/filekeeper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #71 from fossyy/staging

Browse Source 
fix: resolve file upload resume issue
This commit is contained in:
Bagas Aulia Rezki
2024-09-17 14:19:26 +07:00
committed by GitHub
parent be352279ee 54fcc9d549
commit 8982ec217b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
handler/user/user.go
View File

@ -254,18 +254,16 @@ func handlerWS(conn *websocket.Conn, userSession types.User) {
app.Server.Logger.Error(err.Error()) app.Server.Logger.Error(err.Error())
fileData.Done = false fileData.Done = false
} else { } else {
for i := 0; i <= int(file.TotalChunk); i++ { for i := 0; i < int(file.TotalChunk); i++ {
fileData.Chunk[fmt.Sprintf("chunk_%d", i)] = false fileData.Chunk[fmt.Sprintf("chunk_%d", i)] = false
} }
for _, chunkFile := range chunkFiles { for _, chunkFile := range chunkFiles {
var chunkIndex int var chunkIndex int
fmt.Sscanf(filepath.Base(chunkFile), "chunk_%d", &chunkIndex) fmt.Sscanf(filepath.Base(chunkFile), "chunk_%d", &chunkIndex)
fileData.Chunk[fmt.Sprintf("chunk_%d", chunkIndex)] = true fileData.Chunk[fmt.Sprintf("chunk_%d", chunkIndex)] = true
} }
for i := 0; i <= int(file.TotalChunk); i++ { for i := 0; i < int(file.TotalChunk); i++ {
if !fileData.Chunk[fmt.Sprintf("chunk_%d", i)] { if !fileData.Chunk[fmt.Sprintf("chunk_%d", i)] {
fileData.Done = false fileData.Done = false
break break