src/app/contextHandler/ContextHandlerActions.js

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * org.onap.aai
   4  * ================================================================================
   5  * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * Copyright © 2017-2018 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 import {
  22   POST,
  23   POST_HEADER,
  24   GET
  25 } from 'app/networking/NetworkConstants.js';
  26 import networkCall from 'app/networking/NetworkCalls.js';
  27 import {EXTERNAL_REQ_ENTITY_SEARCH_URL,
  28 WRONG_EXTERNAL_REQUEST_MESSAGE,
  29   WRONG_RESULT,
  30   ZERO_RESULT,
  31   MULTIPLE_RESULT,
  32   FAILED_REQUEST,
  33   SUBSCRIPTION_FAILED_MESSAGE,
  34   SUBSCRIPTION_PAYLOAD_URL
  35 } from 'app/contextHandler/ContextHandlerConstants';
  36 import {
  37   getSetGlobalMessageEvent,
  38   getClearGlobalMessageEvent
  39 } from 'app/globalInlineMessageBar/GlobalInlineMessageBarActions.js';
  40
  41 import {  STATUS_CODE_204_NO_CONTENT,
  42   STATUS_CODE_3XX_REDIRECTION,
  43   MESSAGE_LEVEL_DANGER,
  44   MESSAGE_LEVEL_WARNING
  45 } from 'utils/GlobalConstants.js';
  46
  47
  48 import {
  49   contextHandlerActionTypes
  50 } from 'app/contextHandler/ContextHandlerConstants.js';
  51
  52 function getExternalParamValues(urlParams) {
  53   var pairs = decodeURIComponent(urlParams).replace('?','').replace(/\r\n|\n/,'').split('&');
  54
  55   var externalparamObject = {};
  56   pairs.forEach(function(pair) {
  57     pair = pair.split('=');
  58     externalparamObject[pair[0]] = pair[1] || '';
  59   });
  60   return externalparamObject;
  61
  62 }
  63
  64 function createSubscriptionPayloadEvent(payload) {
  65
  66   let event = undefined;
  67
  68   if (payload.subscriptionEnabled) {
  69     event = {
  70       type: contextHandlerActionTypes.SUBSCRIPTION_PAYLOAD_FOUND,
  71       data: payload
  72     };
  73   } else {
  74     event = {
  75       type: contextHandlerActionTypes.SUBSCRIPTION_PAYLOAD_EMPTY,
  76       data: {}
  77     };
  78   }
  79
  80   return event;
  81 }
  82
  83 function fetchSubscriptionPayload(fetchRequestCallback) {
  84   return dispatch => {
  85     return fetchRequestCallback().then(
  86       (response) => {
  87         if (response.status >= STATUS_CODE_3XX_REDIRECTION) {
  88           return Promise.reject(new Error(response.status));
  89         } else {
  90           // assume 200 status
  91           return response.json();
  92         }
  93       }
  94     ).then(
  95       (results)=> {
  96         dispatch(createSubscriptionPayloadEvent(results));
  97       }
  98     ).catch(
  99       () => {
 100         dispatch(getSetGlobalMessageEvent(SUBSCRIPTION_FAILED_MESSAGE , MESSAGE_LEVEL_WARNING));
 101       }
 102     );
 103   };
 104 }
 105
 106 export function getSubscriptionPayload() {
 107   let externalfetchRequest =
 108     () => networkCall.getRequest(SUBSCRIPTION_PAYLOAD_URL, GET);
 109   return dispatch => {
 110     dispatch(fetchSubscriptionPayload(externalfetchRequest));
 111   };
 112 }
 113
 114 function validateExternalParams(externalURLParams) {
 115   if(externalURLParams.view && externalURLParams.entityId && externalURLParams.entityType) {
 116     return true;
 117   }
 118   return false;
 119
 120 }
 121
 122 function createSuggestionFoundEvent(suggestion) {
 123   return {
 124     type: contextHandlerActionTypes.SINGLE_SUGGESTION_FOUND,
 125     data: suggestion
 126   };
 127 }
 128
 129
 130 function fetchDataForExternalRequest(fetchRequestCallback) {
 131   return dispatch => {
 132     return fetchRequestCallback().then(
 133       (response) => {
 134         if (response.status === STATUS_CODE_204_NO_CONTENT || response.status >= STATUS_CODE_3XX_REDIRECTION) {
 135           return Promise.reject(new Error(response.status));
 136         } else {
 137           // assume 200 status
 138           return response.json();
 139         }
 140       }
 141     ).then(
 142       (results)=> {
 143         if (results.suggestions !== undefined) {
 144           if( results.suggestions.length === 1) {
 145             dispatch(getClearGlobalMessageEvent());
 146             dispatch(createSuggestionFoundEvent({suggestion: results.suggestions[0]}));
 147           } else if(results.totalFound === 0 ) {
 148             dispatch(getSetGlobalMessageEvent(ZERO_RESULT, MESSAGE_LEVEL_DANGER));
 149           } else {
 150             dispatch(getSetGlobalMessageEvent(MULTIPLE_RESULT, MESSAGE_LEVEL_DANGER));          }
 151         } else {
 152           dispatch(getSetGlobalMessageEvent(WRONG_RESULT, MESSAGE_LEVEL_DANGER));
 153         }
 154       }
 155     ).catch(
 156       () => {
 157         dispatch(getSetGlobalMessageEvent(FAILED_REQUEST , MESSAGE_LEVEL_DANGER));
 158       }
 159     );
 160   };
 161 }
 162
 163 function validateAndFetchExternalParams(externalParams) {
 164   if(!validateExternalParams(externalParams)) {
 165     return dispatch => {
 166       dispatch(
 167         getSetGlobalMessageEvent(WRONG_EXTERNAL_REQUEST_MESSAGE, MESSAGE_LEVEL_DANGER));
 168     };
 169   } else {
 170     let postBody = JSON.stringify(externalParams);
 171     let externalfetchRequest =
 172       () => networkCall.fetchRequestObj(EXTERNAL_REQ_ENTITY_SEARCH_URL, POST,
 173         POST_HEADER, postBody);
 174     return dispatch => {
 175       dispatch(fetchDataForExternalRequest(externalfetchRequest));
 176     };
 177   }
 178 }
 179 export function externalUrlRequest(urlParams) {
 180   let externalURLParams = getExternalParamValues(urlParams);
 181   return dispatch => {
 182     dispatch(
 183       validateAndFetchExternalParams(externalURLParams));
 184   };
 185 }
 186 export function externalMessageRequest(jsonParams) {
 187   return dispatch => {
 188     dispatch(
 189       validateAndFetchExternalParams(jsonParams));
 190   };
 191
 192 }
 193