diff --git a/src/app/shared/publication/upload/upload-streaming.service.ts b/src/app/shared/publication/upload/upload-streaming.service.ts index 99698bb29..555741778 100644 --- a/src/app/shared/publication/upload/upload-streaming.service.ts +++ b/src/app/shared/publication/upload/upload-streaming.service.ts @@ -75,20 +75,36 @@ class UploadFileUseCase { if(needUpload) { - const request = readAndUploadChunk(index).then(async(uploadRequest) => { + // upload every chunk at onces + // 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) + + // one by one chunk upload + 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)) + } + } + } }