peter/doneit-web
1
0
Fork 0
mirror of https://code.equilibrium.co.ao/ITO/doneit-web.git synced 2026-04-18 20:47:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

change upload to paralel

Browse Source
This commit is contained in:
Peter Maquiran
2024-02-23 13:17:45 +01:00
parent 44dfcf7e79
commit 7d31198348
1 changed files with 32 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/app/shared/publication/upload/upload-streaming.service.ts
+32 -29
View File
@@ -76,34 +76,34 @@ class UploadFileUseCase {
if(needUpload) {
// upload every chunk at onces
// const request = readAndUploadChunk(index).then(async(uploadRequest) => {
const request = readAndUploadChunk(index).then(async(uploadRequest) => {
// if(uploadRequest.isErr()) {
// connection = false
// const pingRequest = await this.CMAPIService.ping()
// if( pingRequest.isErr()) {
// errorMessage = UploadError.noConnection
// } else {
// errorMessage = UploadError.slow
// }
// }
if(uploadRequest.isErr()) {
connection = false
const pingRequest = await this.CMAPIService.ping()
if( pingRequest.isErr()) {
errorMessage = UploadError.noConnection
} else {
errorMessage = UploadError.slow
}
}
// })
// allRequest.push(request)
})
allRequest.push(request)
// one by one chunk upload
const request = readAndUploadChunk(index)
allRequest.push(request)
const uploadRequest = await request
// const request = readAndUploadChunk(index)
// allRequest.push(request)
// const uploadRequest = await request
if(uploadRequest.isErr()) {
const pingRequest = await this.CMAPIService.ping()
if( pingRequest.isErr()) {
return resolve(err(UploadError.noConnection))
} else {
return resolve(err(UploadError.slow))
}
}
// if(uploadRequest.isErr()) {
// const pingRequest = await this.CMAPIService.ping()
// if( pingRequest.isErr()) {
// return resolve(err(UploadError.noConnection))
// } else {
// return resolve(err(UploadError.slow))
// }
// }
}
}
@@ -269,14 +269,17 @@ export class PublicationFormMV {
PublicationAttachmentEntity.chucksManager.setManualRetry()
resolve(false)
} else {
const guid = PublicationAttachmentEntity.chucksManager.path
this.ObjectMergeNotification.subscribe(guid, (data) => {
PublicationAttachmentEntity.chucksManager.doneChunkUpload()
const mergeRequest = await this.ObjectMergeNotification.socket.commit(PublicationAttachmentEntity.chucksManager.path)
if(mergeRequest.isOk()) {
PublicationAttachmentEntity.chucksManager.contentSetReady()
resolve(true)
})
PublicationAttachmentEntity.chucksManager.doneChunkUpload()
this.ObjectMergeNotification.socket.commit(PublicationAttachmentEntity.chucksManager.path)
resolve(true)
} else {
resolve(false)
}
}
} else {