X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FUI.git;a=blobdiff_plain;f=skyquake%2Fplugins%2Fcomposer%2Fsrc%2Fsrc%2Fstores%2FCatalogPackageManagerStore.js;h=5ffe83f9001502f809817098fdaed2fe3ea86a3d;hp=3a82114a085ab811bad8a2e4d3518447e6055d5d;hb=2140fb647aae159dc38bd0893a94133220369de5;hpb=6cbc0bd30ecad2fb08d3b220904889d439579f70 diff --git a/skyquake/plugins/composer/src/src/stores/CatalogPackageManagerStore.js b/skyquake/plugins/composer/src/src/stores/CatalogPackageManagerStore.js index 3a82114a0..5ffe83f90 100644 --- a/skyquake/plugins/composer/src/src/stores/CatalogPackageManagerStore.js +++ b/skyquake/plugins/composer/src/src/stores/CatalogPackageManagerStore.js @@ -18,7 +18,8 @@ */ 'use strict'; -import _ from 'lodash' +import _delay from 'lodash/delay' +import _pick from 'lodash/pick' import alt from '../alt' import guid from '../libraries/guid' import numeral from 'numeral' @@ -65,7 +66,7 @@ function delayStatusCheck(statusCheckFunction, catalogPackage) { delete catalogPackage.checkStatusTimeoutId; statusCheckFunction(catalogPackage).catch(exception); }; - catalogPackage.checkStatusTimeoutId = _.delay(delayCallback, defaults.checkStatusDelayInSeconds * 1000); + catalogPackage.checkStatusTimeoutId = _delay(delayCallback, defaults.checkStatusDelayInSeconds * 1000); } } @@ -109,7 +110,7 @@ class CatalogPackageManagerStore { uploadCatalogPackage(file) { file.id = file.id || guid(); - const catalogPackage = _.pick(file, packagePropertyNames); + const catalogPackage = _pick(file, packagePropertyNames); catalogPackage.icon = file.riftAction === 'onboard' ? imgOnboard : imgUpdate; catalogPackage.type = 'upload'; this.addPackage(catalogPackage); @@ -195,51 +196,57 @@ function updateStatusInfo(response) { }; const responseData = (response.data.output) ? response.data.output : response.data; const catalogPackage = response.state; - switch(response.data.status) { - case 'upload-progress': - statusInfo.pending = true; - statusInfo.progress = parseFloat(responseData.progress) || 0; - statusInfo.message = calculateUploadProgressMessage(catalogPackage.size, responseData.progress, responseData.bytesSent); - break; - case 'upload-success': - statusInfo.pending = true; - statusInfo.progress = 100; - statusInfo.message = 'Upload completed.'; - statusInfo.transactionId = responseData['transaction_id'] || responseData['transaction-id'] || catalogPackage.transactionId; - break; - case 'upload-error': - statusInfo.error = true; - statusInfo.message = responseData.message; - break; - case 'download-requested': - statusInfo.pending = true; - statusInfo.progress = 25; - statusInfo.transactionId = responseData['transaction_id'] || responseData['transaction-id'] || catalogPackage.transactionId; - break; - case 'pending': - statusInfo.pending = true; - statusInfo.progress = 50; - statusInfo.message = responseData.events[responseData.events.length - 1].text; - break; - case 'success': - statusInfo.success = true; - statusInfo.progress = 100; - statusInfo.message = responseData.events[responseData.events.length - 1].text; - if (catalogPackage.type === 'download') { - statusInfo.urlValidUntil = moment().add(defaults.downloadUrlTimeToLiveInMinutes, 'minutes').toISOString(); - if (responseData.filename) { - statusInfo.url = getCatalogPackageManagerServerOrigin() + '/api/export/' + responseData.filename; - } else { - statusInfo.url = getCatalogPackageManagerServerOrigin() + '/api/export/' + catalogPackage.transactionId + '.tar.gz'; + if ( typeof response.data.status !== "number" ) { + switch(response.data.status) { + case 'upload-progress': + statusInfo.pending = true; + statusInfo.progress = parseFloat(responseData.progress) || 0; + statusInfo.message = calculateUploadProgressMessage(catalogPackage.size, responseData.progress, responseData.bytesSent); + break; + case 'upload-success': + statusInfo.pending = true; + statusInfo.progress = 100; + statusInfo.message = 'Upload completed.'; + statusInfo.transactionId = responseData['transaction_id'] || responseData['transaction-id'] || catalogPackage.transactionId; + break; + case 'upload-error': + statusInfo.error = true; + statusInfo.message = responseData.message; + break; + case 'download-requested': + statusInfo.pending = true; + statusInfo.progress = 25; + statusInfo.transactionId = responseData['transaction_id'] || responseData['transaction-id'] || catalogPackage.transactionId; + break; + case 'pending': + statusInfo.pending = true; + statusInfo.progress = 50; + statusInfo.message = responseData.events[responseData.events.length - 1].text; + break; + case 'success': + statusInfo.success = true; + statusInfo.progress = 100; + statusInfo.message = responseData.events[responseData.events.length - 1].text; + if (catalogPackage.type === 'download') { + statusInfo.urlValidUntil = moment().add(defaults.downloadUrlTimeToLiveInMinutes, 'minutes').toISOString(); + if (responseData.filename) { + statusInfo.url = getCatalogPackageManagerServerOrigin() + '/api/export/' + responseData.filename; + } else { + statusInfo.url = getCatalogPackageManagerServerOrigin() + '/api/export/' + catalogPackage.transactionId + '.tar.gz'; + } } + break; + case 'failure': + statusInfo.error = true; + statusInfo.message = responseData.errors[0].value; + break; + default: + throw new ReferenceError('a status of "request", "success", "failure", "pending", "upload-completed", "upload-error", "download-requested", "upload-progress", "upload-action" is required'); } - break; - case 'failure': + } else { + // typically get here due to unexpected development errors (backend exceptions, down/up load server access issues) statusInfo.error = true; - statusInfo.message = responseData.errors[0].value; - break; - default: - throw new ReferenceError('a status of "request", "success", "failure", "pending", "upload-completed", "upload-error", "download-requested", "upload-progress", "upload-action" is required'); + statusInfo.message = responseData.statusText || 'Error'; } return Object.assign({}, catalogPackage, statusInfo); }