0fe43ff6027c3b482883478328abcddaf4131ac9
[aai/sparky-fe.git] / src / app / contextHandler / ContextHandlerActions.js
1 /*
2  * ============LICENSE_START=======================================================
3  * org.onap.aai
4  * ================================================================================
5  * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
6  * Copyright © 2017 Amdocs
7  * ================================================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *       http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=========================================================
20  *
21  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
22  */
23
24 import {
25   POST,
26   POST_HEADER,
27   GET
28 } from 'app/networking/NetworkConstants.js';
29 import networkCall from 'app/networking/NetworkCalls.js';
30 import {EXTERNAL_REQ_ENTITY_SEARCH_URL,
31 WRONG_EXTERNAL_REQUEST_MESSAGE,
32   WRONG_RESULT,
33   ZERO_RESULT,
34   MULTIPLE_RESULT,
35   FAILED_REQUEST,
36   SUBSCRIPTION_FAILED_MESSAGE,
37   SUBSCRIPTION_PAYLOAD_URL
38 } from 'app/contextHandler/ContextHandlerConstants';
39 import {
40   getSetGlobalMessageEvent,
41   getClearGlobalMessageEvent
42 } from 'app/globalInlineMessageBar/GlobalInlineMessageBarActions.js';
43
44 import {  STATUS_CODE_204_NO_CONTENT,
45   STATUS_CODE_3XX_REDIRECTION,
46   MESSAGE_LEVEL_DANGER,
47   MESSAGE_LEVEL_WARNING
48 } from 'utils/GlobalConstants.js';
49
50
51 import {
52   contextHandlerActionTypes
53 } from 'app/contextHandler/ContextHandlerConstants.js';
54
55 function getExternalParamValues(urlParams) {
56   var pairs = decodeURIComponent(urlParams).replace('?','').replace(/\r\n|\n/,'').split('&');
57
58   var externalparamObject = {};
59   pairs.forEach(function(pair) {
60     pair = pair.split('=');
61     externalparamObject[pair[0]] = pair[1] || '';
62   });
63   return externalparamObject;
64
65 }
66
67 function createSubscriptionPayloadEvent(payload) {
68
69   let event = undefined;
70
71   if (payload.subscriptionEnabled) {
72     event = {
73       type: contextHandlerActionTypes.SUBSCRIPTION_PAYLOAD_FOUND,
74       data: payload
75     };
76   } else {
77     event = {
78       type: contextHandlerActionTypes.SUBSCRIPTION_PAYLOAD_EMPTY,
79       data: {}
80     };
81   }
82
83   return event;
84 }
85
86 function fetchSubscriptionPayload(fetchRequestCallback) {
87   return dispatch => {
88     return fetchRequestCallback().then(
89       (response) => {
90         if (response.status >= STATUS_CODE_3XX_REDIRECTION) {
91           return Promise.reject(new Error(response.status));
92         } else {
93           // assume 200 status
94           return response.json();
95         }
96       }
97     ).then(
98       (results)=> {
99         dispatch(createSubscriptionPayloadEvent(results));
100       }
101     ).catch(
102       () => {
103         dispatch(getSetGlobalMessageEvent(SUBSCRIPTION_FAILED_MESSAGE , MESSAGE_LEVEL_WARNING));
104       }
105     );
106   };
107 }
108
109 export function getSubscriptionPayload() {
110   let externalfetchRequest =
111     () => networkCall.getRequest(SUBSCRIPTION_PAYLOAD_URL, GET);
112   return dispatch => {
113     dispatch(fetchSubscriptionPayload(externalfetchRequest));
114   };
115 }
116
117 function validateExternalParams(externalURLParams) {
118   if(externalURLParams.view && externalURLParams.entityId && externalURLParams.entityType) {
119     return true;
120   }
121   return false;
122
123 }
124
125 function createSuggestionFoundEvent(suggestion) {
126   return {
127     type: contextHandlerActionTypes.SINGLE_SUGGESTION_FOUND,
128     data: suggestion
129   };
130 }
131
132
133 function fetchDataForExternalRequest(fetchRequestCallback) {
134   return dispatch => {
135     return fetchRequestCallback().then(
136       (response) => {
137         if (response.status === STATUS_CODE_204_NO_CONTENT || response.status >= STATUS_CODE_3XX_REDIRECTION) {
138           return Promise.reject(new Error(response.status));
139         } else {
140           // assume 200 status
141           return response.json();
142         }
143       }
144     ).then(
145       (results)=> {
146         if (results.suggestions !== undefined) {
147           if( results.suggestions.length === 1) {
148             dispatch(getClearGlobalMessageEvent());
149             dispatch(createSuggestionFoundEvent({suggestion: results.suggestions[0]}));
150           } else if(results.totalFound === 0 ) {
151             dispatch(getSetGlobalMessageEvent(ZERO_RESULT, MESSAGE_LEVEL_DANGER));
152           } else {
153             dispatch(getSetGlobalMessageEvent(MULTIPLE_RESULT, MESSAGE_LEVEL_DANGER));          }
154         } else {
155           dispatch(getSetGlobalMessageEvent(WRONG_RESULT, MESSAGE_LEVEL_DANGER));
156         }
157       }
158     ).catch(
159       () => {
160         dispatch(getSetGlobalMessageEvent(FAILED_REQUEST , MESSAGE_LEVEL_DANGER));
161       }
162     );
163   };
164 }
165
166 function validateAndFetchExternalParams(externalParams) {
167   if(!validateExternalParams(externalParams)) {
168     return dispatch => {
169       dispatch(
170         getSetGlobalMessageEvent(WRONG_EXTERNAL_REQUEST_MESSAGE, MESSAGE_LEVEL_DANGER));
171     };
172   } else {
173     let postBody = JSON.stringify(externalParams);
174     let externalfetchRequest =
175       () => networkCall.fetchRequestObj(EXTERNAL_REQ_ENTITY_SEARCH_URL, POST,
176         POST_HEADER, postBody);
177     return dispatch => {
178       dispatch(fetchDataForExternalRequest(externalfetchRequest));
179     };
180   }
181 }
182 export function externalUrlRequest(urlParams) {
183   let externalURLParams = getExternalParamValues(urlParams);
184   return dispatch => {
185     dispatch(
186       validateAndFetchExternalParams(externalURLParams));
187   };
188 }
189 export function externalMessageRequest(jsonParams) {
190   return dispatch => {
191     dispatch(
192       validateAndFetchExternalParams(jsonParams));
193   };
194
195 }
196