summaryrefslogtreecommitdiffstats
path: root/openecomp-ui/src/sdc-app/flows/FlowsActions.js
diff options
context:
space:
mode:
authorMichael Lando <ml636r@att.com>2017-02-19 12:57:33 +0200
committerMichael Lando <ml636r@att.com>2017-02-19 13:47:13 +0200
commitefa037d34be7b1570efdc767c79fad8d4005f10e (patch)
treecf1036ba2728dea8a61492b678fa91954e629403 /openecomp-ui/src/sdc-app/flows/FlowsActions.js
parentf5f13c4f6b6fe3b4d98e349dfd7db59339803436 (diff)
Add new code new version
Change-Id: Ic02a76313503b526f17c3df29eb387a29fe6a42a Signed-off-by: Michael Lando <ml636r@att.com>
Diffstat (limited to 'openecomp-ui/src/sdc-app/flows/FlowsActions.js')
-rw-r--r--openecomp-ui/src/sdc-app/flows/FlowsActions.js191
1 files changed, 191 insertions, 0 deletions
diff --git a/openecomp-ui/src/sdc-app/flows/FlowsActions.js b/openecomp-ui/src/sdc-app/flows/FlowsActions.js
new file mode 100644
index 0000000000..b8772edb08
--- /dev/null
+++ b/openecomp-ui/src/sdc-app/flows/FlowsActions.js
@@ -0,0 +1,191 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * SDC
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+import RestAPIUtil from 'nfvo-utils/RestAPIUtil.js';
+import Configuration from 'sdc-app/config/Configuration.js';
+import {actionTypes, enums} from './FlowsConstants.js';
+import SequenceDiagramModelHelper from './SequenceDiagramModelHelper.js';
+
+
+function baseUrl(serviceId, artifactId = '') {
+ const restATTPrefix = Configuration.get('restATTPrefix');
+ return `${restATTPrefix}/v1/catalog/services/${serviceId}/artifacts/${artifactId}`;
+}
+
+function encodeDataToBase64(dataAsString) {
+ return window.btoa(dataAsString);
+}
+
+function decodeDataToBase64(encodedData) {
+ return window.atob(encodedData);
+}
+
+function encodeContent(flowData) {
+ let data = {
+ VERSION: {
+ major: 1,
+ minor: 0
+ },
+ description: flowData.description,
+ sequenceDiagramModel: flowData.sequenceDiagramModel
+ };
+
+ return encodeDataToBase64(JSON.stringify(data));
+}
+
+function decodeContent(base64Contents) {
+ let description, sequenceDiagramModel;
+ let payload = JSON.parse(decodeDataToBase64(base64Contents));
+
+ if (payload.VERSION === undefined) {
+ description = payload.description || 'Please, provide description...';
+ sequenceDiagramModel = payload.data || payload;
+ sequenceDiagramModel = sequenceDiagramModel.model || sequenceDiagramModel;
+
+ } else if (payload.VERSION.major === 1) {
+ description = payload.description;
+ sequenceDiagramModel = payload.sequenceDiagramModel;
+ }
+
+ return {
+ description,
+ sequenceDiagramModel
+ };
+}
+
+function createOrUpdate(flowData) {
+ let createOrUpdateRequest = {
+ payloadData: encodeContent(flowData),
+ artifactLabel: flowData.artifactLabel || flowData.artifactName,
+ artifactName: flowData.artifactName,
+ artifactType: flowData.artifactType,
+ artifactGroupType: enums.INFORMATIONAL,
+ description: flowData.description
+ };
+
+ return RestAPIUtil.create(
+ baseUrl(flowData.serviceID, flowData.uniqueId),
+ createOrUpdateRequest,
+ {md5: true}
+ );
+}
+
+const FlowsActions = Object.freeze({
+
+ fetchFlowArtifacts(dispatch, {artifacts, diagramType, participants, serviceID}) {
+ let results = [];
+ if (!Object.keys(artifacts).length) {
+ dispatch({type: actionTypes.FLOW_LIST_LOADED, results, participants, serviceID, diagramType});
+ FlowsActions.openFlowDetailsEditor(dispatch);
+ }
+ else {
+ Object.keys(artifacts).forEach(artifact => results.push({
+ artifactType: diagramType,
+ participants,
+ serviceID,
+ ...artifacts[artifact]
+ }));
+ dispatch({type: actionTypes.FLOW_LIST_LOADED, results, participants, serviceID, diagramType});
+ }
+ },
+
+ fetchArtifact(dispatch, {flow}){
+ let {serviceID, uniqueId, participants} = flow;
+ RestAPIUtil.fetch(baseUrl(serviceID, uniqueId)).then(response => {
+
+ let {artifactName, base64Contents} = response;
+ let {sequenceDiagramModel, ...other} = decodeContent(base64Contents);
+
+ if (!sequenceDiagramModel) {
+ sequenceDiagramModel = SequenceDiagramModelHelper.createModel({
+ id: uniqueId,
+ name: artifactName,
+ lifelines: participants
+ });
+ }
+ else {
+ sequenceDiagramModel = SequenceDiagramModelHelper.updateModel(sequenceDiagramModel, {
+ name: artifactName,
+ lifelines: participants
+ });
+ }
+
+ flow = {
+ ...flow,
+ ...other,
+ uniqueId,
+ artifactName,
+ sequenceDiagramModel
+ };
+
+ dispatch({type: actionTypes.ARTIFACT_LOADED, flow});
+ FlowsActions.openFlowDiagramEditor(dispatch, {flow});
+ });
+ },
+
+ createOrUpdateFlow(dispatch, {flow}, isNew) {
+ if (!isNew && flow.sequenceDiagramModel) {
+ flow.sequenceDiagramModel = SequenceDiagramModelHelper.updateModel(flow.sequenceDiagramModel, {
+ name: flow.artifactName
+ });
+ }
+ createOrUpdate(flow).then(response => {
+ let {uniqueId, artifactLabel} = response;
+ flow = {...flow, uniqueId, artifactLabel};
+ if (isNew) {
+ flow.sequenceDiagramModel = SequenceDiagramModelHelper.createModel({id: uniqueId, name: flow.artifactName});
+ }
+ dispatch({type: actionTypes.ADD_OR_UPDATE_FLOW, flow});
+ });
+ },
+
+ deleteFlow(dispatch, {flow}) {
+ RestAPIUtil.destroy(baseUrl(flow.serviceID, flow.uniqueId)).then(() => dispatch({
+ type: actionTypes.DELETE_FLOW,
+ flow
+ }));
+ },
+
+ openFlowDetailsEditor(dispatch, flow) {
+ dispatch({type: actionTypes.OPEN_FLOW_DETAILS_EDITOR, flow});
+ },
+
+ closeFlowDetailsEditor(dispatch) {
+ dispatch({type: actionTypes.CLOSE_FLOW_DETAILS_EDITOR});
+ },
+
+ openFlowDiagramEditor(dispatch, {flow}) {
+ dispatch({type: actionTypes.OPEN_FLOW_DIAGRAM_EDITOR, flow});
+ },
+
+ closeFlowDiagramEditor(dispatch) {
+ dispatch({type: actionTypes.CLOSE_FLOW_DIAGRAM_EDITOR});
+ },
+
+ flowDetailsDataChanged(dispatch, {deltaData}) {
+ dispatch({type: actionTypes.CURRENT_FLOW_DATA_CHANGED, deltaData});
+ },
+
+ reset(dispatch) {
+ dispatch({type: actionTypes.RESET});
+ }
+});
+
+export default FlowsActions;