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
 110   return dispatch => {
 111     dispatch(fetchSubscriptionPayload(externalfetchRequest));
 112   };
 113 }
 114
 115 function validateExternalParams(externalURLParams) {
 116   if(externalURLParams.view && externalURLParams.entityId && externalURLParams.entityType) {
 117     return true;
 118   }
 119   return false;
 120
 121 }
 122
 123 function createSuggestionFoundEvent(suggestion) {
 124   return {
 125     type: contextHandlerActionTypes.SINGLE_SUGGESTION_FOUND,
 126     data: suggestion
 127   };
 128 }
 129
 130
 131 function fetchDataForExternalRequest(fetchRequestCallback) {
 132   return dispatch => {
 133     return fetchRequestCallback().then(
 134       (response) => {
 135         if (response.status === STATUS_CODE_204_NO_CONTENT || response.status >= STATUS_CODE_3XX_REDIRECTION) {
 136           return Promise.reject(new Error(response.status));
 137         } else {
 138           // assume 200 status
 139           return response.json();
 140         }
 141       }
 142     ).then(
 143       (results)=> {
 144         if (results.suggestions !== undefined) {
 145           if( results.suggestions.length === 1) {
 146             dispatch(getClearGlobalMessageEvent());
 147             dispatch(createSuggestionFoundEvent({suggestion: results.suggestions[0]}));
 148           } else if(results.totalFound === 0 ) {
 149             dispatch(getSetGlobalMessageEvent(ZERO_RESULT, MESSAGE_LEVEL_DANGER));
 150           } else {
 151             dispatch(getSetGlobalMessageEvent(MULTIPLE_RESULT, MESSAGE_LEVEL_DANGER));          }
 152         } else {
 153           dispatch(getSetGlobalMessageEvent(WRONG_RESULT, MESSAGE_LEVEL_DANGER));
 154         }
 155       }
 156     ).catch(
 157       () => {
 158         dispatch(getSetGlobalMessageEvent(FAILED_REQUEST , MESSAGE_LEVEL_DANGER));
 159       }
 160     );
 161   };
 162 }
 163
 164 function validateAndFetchExternalParams(externalParams) {
 165   if(!validateExternalParams(externalParams)) {
 166     return dispatch => {
 167       dispatch(
 168         getSetGlobalMessageEvent(WRONG_EXTERNAL_REQUEST_MESSAGE, MESSAGE_LEVEL_DANGER));
 169     };
 170   } else {
 171     let postBody = JSON.stringify(externalParams);
 172     let externalfetchRequest =
 173       () => networkCall.fetchRequestObj(EXTERNAL_REQ_ENTITY_SEARCH_URL, POST,
 174         POST_HEADER, postBody);
 175     return dispatch => {
 176       dispatch(fetchDataForExternalRequest(externalfetchRequest));
 177     };
 178   }
 179 }
 180 export function externalUrlRequest(urlParams) {
 181   let externalURLParams = getExternalParamValues(urlParams);
 182   return dispatch => {
 183     dispatch(
 184       validateAndFetchExternalParams(externalURLParams));
 185   };
 186 }
 187 export function externalMessageRequest(jsonParams) {
 188   return dispatch => {
 189     dispatch(
 190       validateAndFetchExternalParams(jsonParams));
 191   };
 192
 193 }
 194