Initial coomit for AAI-UI(sparky-fe)

[aai/sparky-fe.git] / src / app / vnfSearch / VnfSearchActions.js

diff --git a/src/app/vnfSearch/VnfSearchActions.js b/src/app/vnfSearch/VnfSearchActions.js
new file mode 100644 (file)
index 0000000..0f31e09
--- /dev/null
+++ b/src/app/vnfSearch/VnfSearchActions.js
@@ -0,0 +1,215 @@
+/*
+ * ============LICENSE_START===================================================
+ * SPARKY (AAI UI service)
+ * ============================================================================
+ * Copyright © 2017 AT&T Intellectual Property.
+ * Copyright © 2017 Amdocs
+ * 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=====================================================
+ *
+ * ECOMP and OpenECOMP are trademarks
+ * and service marks of AT&T Intellectual Property.
+ */
+
+import {
+  vnfActionTypes,
+  VNF_RESULT_URL
+} from 'app/vnfSearch/VnfSearchConstants.js';
+
+import {
+  getVnfProvStatusQueryString,
+  getVnfOrchStatusQueryString,
+  getVnfCountQueryString
+} from 'app/networking/NetworkUtil.js';
+import {
+  POST,
+  POST_HEADER,
+  ERROR_RETRIEVING_DATA
+} from 'app/networking/NetworkConstants.js';
+import {
+  getSetGlobalMessageEvent,
+  getClearGlobalMessageEvent
+} from 'app/GlobalInlineMessageBar/GlobalInlineMessageBarActions.js';
+
+let fetch = require('node-fetch');
+fetch.Promise = require('es6-promise').Promise;
+
+const itemKeyWord = 'key';
+const countKeyWord = 'doc_count';
+
+function getInvalidQueryEvent() {
+  return {
+    type: vnfActionTypes.VNF_NETWORK_ERROR,
+    data: {errorMsg: ERROR_RETRIEVING_DATA}
+  };
+}
+/*it is a vertical bar chart then y and x are switched */
+function getProvStatusEvent(responseJson) {
+  if (responseJson && responseJson.groupby_aggregation &&
+    responseJson.groupby_aggregation.buckets &&
+    responseJson.groupby_aggregation.buckets.length > 0) {
+    let groupByProvStatusBucket;
+    let dataPoints = [];
+    for (groupByProvStatusBucket of
+      responseJson.groupby_aggregation.buckets) {
+      dataPoints.push({
+        'x': groupByProvStatusBucket[itemKeyWord].split('=', 1)[0],
+        'y': groupByProvStatusBucket[countKeyWord]
+      });
+    }
+
+    let newProvStatusChartData = [
+      {
+        'values': dataPoints
+      }
+    ];
+
+    let provStatusCountChartData = {
+      chartData: newProvStatusChartData
+    };
+    return {
+      type: vnfActionTypes.COUNT_BY_PROV_STATUS_RECEIVED,
+      data: {provStatusCountChartData}
+    };
+  }
+  else {
+    return {
+      type: vnfActionTypes.ERROR_NO_DATA_FOR_PROV_STATUS_IN_SEARCH_RANGE_RECEIVED
+    };
+  }
+}
+
+function getOrchStatusEvent(responseJson) {
+  if (responseJson && responseJson.groupby_aggregation &&
+    responseJson.groupby_aggregation.buckets &&
+    responseJson.groupby_aggregation.buckets.length > 0) {
+    let groupByOrchStatusBucket;
+    let dataPoints = [];
+    for (groupByOrchStatusBucket of
+      responseJson.groupby_aggregation.buckets) {
+      dataPoints.push({
+        'x': groupByOrchStatusBucket[itemKeyWord].split('=', 1)[0],
+        'y': groupByOrchStatusBucket[countKeyWord]
+      });
+    }
+
+    let newOrchStatusChartData = [
+      {
+        'values': dataPoints
+      }
+    ];
+
+    let orchStatusCountChartData = {
+      chartData: newOrchStatusChartData
+    };
+    return {
+      type: vnfActionTypes.COUNT_BY_ORCH_STATUS_RECEIVED,
+      data: {orchStatusCountChartData}
+    };
+  }
+  else {
+    return {
+      type: vnfActionTypes.ERROR_NO_DATA_FOR_ORCH_STATUS_IN_SEARCH_RANGE_RECEIVED
+    };
+  }
+}
+
+function getTotalVnfEvent(responseJson) {
+  if (responseJson && responseJson.count && responseJson.count > 0) {
+    return {
+      type: vnfActionTypes.TOTAL_VNF_COUNT_RECEIVED,
+      data: {count: responseJson.count}
+    };
+  }
+  else {
+    return {
+      type: vnfActionTypes.ERROR_NO_COUNT_RECEIVED
+    };
+  }
+}
+
+export function processProvStatusVisualizationOnSearchChange(requestObject) {
+  return dispatch => {
+    return fetch(VNF_RESULT_URL, {
+      method: POST,
+      headers: POST_HEADER,
+      body: JSON.stringify(getVnfProvStatusQueryString(requestObject))
+    }).then(
+      (response) => response.json()
+    ).then(
+      (responseJson) => {
+        dispatch(getProvStatusEvent(responseJson));
+      }
+    ).catch(
+      () => {
+        dispatch(getInvalidQueryEvent());
+      }
+    );
+  };
+}
+
+export function processOrchStatusVisualizationOnSearchChange(requestObject) {
+  return dispatch => {
+    return fetch(VNF_RESULT_URL, {
+      method: POST,
+      headers: POST_HEADER,
+      body: JSON.stringify(getVnfOrchStatusQueryString(requestObject))
+    }).then(
+      (response) => response.json()
+    ).then(
+      (responseJson) => {
+        dispatch(getOrchStatusEvent(responseJson));
+      }
+    ).catch(
+      () => {
+        dispatch(getInvalidQueryEvent());
+      }
+    );
+  };
+}
+
+export function processTotalVnfVisualizationOnSearchChange(requestObject) {
+  return dispatch => {
+    return fetch(VNF_RESULT_URL + '/count', {
+      method: POST,
+      headers: POST_HEADER,
+      body: JSON.stringify(
+        getVnfCountQueryString(requestObject))
+    }).then(
+      (response) => response.json()
+    ).then(
+      (responseJson) => {
+        dispatch(getTotalVnfEvent(responseJson));
+      }
+    ).catch(
+      () => {
+        dispatch(getInvalidQueryEvent());
+      }
+    );
+  };
+}
+
+export function setNotificationText(msgText, msgSeverity) {
+  if (msgText.length > 0) {
+    return dispatch => {
+      dispatch(
+        getSetGlobalMessageEvent(msgText, msgSeverity));
+    };
+  } else {
+    return dispatch => {
+      dispatch(getClearGlobalMessageEvent());
+    };
+  }
+}