Я создал загрузку файла, используя angular и antivescript. Когда я загружаю один файл, currentBytes и totalBytes работают нормально - это означает, что totalBytes не изменяется, а currentBytes увеличивается. С мультизагрузкой ситуация другая. При выборе нескольких файлов выглядит, как он начинает загружать чанки, а totalBytes и currentBytes различаются при каждом обратном вызове. Так сделать индикатор прогресса невозможно. Любые идеи, как получить totalBytes из currentBytes, консистентного для мультизагрузки?
Также 'complete' вызывается несколько раз - есть ли другой способ, а не увеличивать локальную переменную, и когда ее значение равно количеству файлов, затем вызывать полный обратный вызов?
Буду признателен за любую помощь.
Вот моя функция:
uploadFiles(images: ImageAsset[]): Observable<ImageUploadResponse> {
this.componentService.loadingIndicator.showMessage({ message: 'Uploading Images', showProgressIndicator: true });
return new Observable<ImageUploadResponse>(observer => {
const session = backgroundHttp.session('image-upload');
const uploadParams = [];
if (images.length === 0) {
observer.next({ imageIds: [] });
observer.complete();
return;
}
let imagesUploadCompleted = 0;
images.forEach(async image => {
// const imageSource = await ImageSource.fromAsset(image);
let localPath: any;
if (platformModule.isAndroid) {
localPath = image.android;
} /* else {
// selected_item.ios for iOS is PHAsset and not path - so we are creating own path
const folder = fileSystemModule.knownFolders.documents();
const path = fileSystemModule.path.join(folder.path, uuid.v1() + '.jpeg');
imageSource.saveToFile(path, 'jpeg');
localPath = path;
} */
uploadParams.push({ name: 'files', filename: localPath, mimeType: 'image/jpeg' });
const request = {
url: `${environment.apiUrl}/upload`,
method: 'POST',
headers: { 'Content-Type': 'application/octet-stream' },
description: 'Uploading images'
};
const task = session.multipartUpload(uploadParams, request);
task.on('progress', (e) => {
if (e.currentBytes) {
// console.log('progress ->', e.currentBytes);
this.ngZone.run(() => {
this.componentService.loadingIndicator.showProgress({ maxValue: e.totalBytes, value: e.currentBytes });
});
}
});
task.on('error', (e) => {
this.ngZone.run(() => {
observer.error(e.error);
observer.complete();
});
});
task.on('complete', (e: any) => {
imagesUploadCompleted++;
if (imagesUploadCompleted === images.length) {
this.ngZone.run(() => {
observer.next(JSON.parse(e.response.getBodyAsString()));
observer.complete();
});
}
});
// const file = fileSystemModule.File.fromPath(image['_android']);
// paths.push(imageSource.toBase64String('jpeg', 60));*/
});
});
}