X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=skyquake%2Fplugins%2Fcomposer%2Fsrc%2Fsrc%2Fsources%2FCatalogPackageManagerSource.js;fp=skyquake%2Fplugins%2Fcomposer%2Fsrc%2Fsrc%2Fsources%2FCatalogPackageManagerSource.js;h=be11dfcf1ad44ca7d534001f62b3d6a36568df96;hb=e29efc315df33d546237e270470916e26df391d6;hp=0000000000000000000000000000000000000000;hpb=9c5e457509ba5a1822c316635c6308874e61b4b9;p=osm%2FUI.git

diff --git a/skyquake/plugins/composer/src/src/sources/CatalogPackageManagerSource.js b/skyquake/plugins/composer/src/src/sources/CatalogPackageManagerSource.js
new file mode 100644
index 000000000..be11dfcf1
--- /dev/null
+++ b/skyquake/plugins/composer/src/src/sources/CatalogPackageManagerSource.js
@@ -0,0 +1,117 @@
+
+/*
+ * 
+ *   Copyright 2016 RIFT.IO Inc
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *   See the License for the specific language governing permissions and
+ *   limitations under the License.
+ *
+ */
+'use strict';
+
+import $ from 'jquery'
+import alt from '../alt'
+import utils from '../libraries/utils'
+import CatalogPackageManagerActions from '../actions/CatalogPackageManagerActions'
+let Utils = require('utils/utils.js');
+function getApiServerOrigin() {
+	return utils.getSearchParams(window.location).upload_server + ':4567';
+}
+
+function ajaxRequest(path, catalogPackage, resolve, reject, method = 'GET') {
+	$.ajax({
+		url: getApiServerOrigin() + path,
+		type: method,
+		beforeSend: Utils.addAuthorizationStub,
+		dataType: 'json',
+		success: function(data) {
+			if (typeof data == 'string') {
+				data = JSON.parse(data);
+			}
+			resolve({
+				data: data,
+				state: catalogPackage
+			});
+		},
+		error: function(error) {
+			if (typeof error == 'string') {
+				error = JSON.parse(error);
+			}
+			reject({
+				data: error,
+				state: catalogPackage
+			});
+		}
+	}).fail(function(xhr){
+			            //Authentication and the handling of fail states should be wrapped up into a connection class.
+			            Utils.checkAuthentication(xhr.status);
+		          	});
+}
+
+const CatalogPackageManagerSource = {
+
+	requestCatalogPackageDownload: function () {
+		return {
+			remote: function (state, download, format, grammar) {
+				return new Promise((resolve, reject) => {
+					// the server does not add a status in the payload
+					// so we add one so that the success handler will
+					// be able to follow the flow of this download
+					const setStatusBeforeResolve = (response = {}) => {
+						response.data.status = 'download-requested';
+						resolve(response);
+					};
+					// RIFT-13485 requires to send type (nsd/vnfd) as a path element.
+					// Backend no longer supports mixed multi-package download.
+					// Probably does not even support multi-package download of same type.
+					// Hence, pick the type from the first element.
+					const path = '/api/export/' + download['catalogItems'][0]['uiState']['type'] + '?schema=' + format + '&grammar=' + grammar + '&format=yaml&ids=' + download.ids;
+					ajaxRequest(path, download, setStatusBeforeResolve, reject);
+				});
+			},
+			success: CatalogPackageManagerActions.downloadCatalogPackageStatusUpdated,
+			error: CatalogPackageManagerActions.downloadCatalogPackageError
+		};
+	},
+
+	requestCatalogPackageDownloadStatus: function() {
+		return {
+			remote: function(state, download) {
+				const transactionId = download.transactionId;
+				return new Promise(function(resolve, reject) {
+					const path = '/api/export/' + transactionId + '/state';
+					ajaxRequest(path, download, resolve, reject);
+				});
+			},
+			success: CatalogPackageManagerActions.downloadCatalogPackageStatusUpdated,
+			error: CatalogPackageManagerActions.downloadCatalogPackageError
+		}
+	},
+
+	requestCatalogPackageUploadStatus: function () {
+		return {
+			remote: function (state, upload) {
+				const transactionId = upload.transactionId;
+				return new Promise(function (resolve, reject) {
+					const action = upload.riftAction === 'onboard' ? 'upload' : 'update';
+					const path = '/api/' + action + '/' + transactionId + '/state';
+					ajaxRequest(path, upload, resolve, reject);
+				});
+			},
+			success: CatalogPackageManagerActions.uploadCatalogPackageStatusUpdated,
+			error: CatalogPackageManagerActions.uploadCatalogPackageError
+		};
+	}
+
+};
+
+export default CatalogPackageManagerSource;