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 => fetchRequestCallback().then(
  85       (response) => {
  86         if (response.status >= STATUS_CODE_3XX_REDIRECTION) {
  87           return Promise.reject(new Error(response.status));
  88         } else {
  89           // assume 200 status
  90           return response.json();
  91         }
  92       }
  93     ).then(
  94       (results)=> {
  95         dispatch(createSubscriptionPayloadEvent(results));
  96       }
  97     ).catch(
  98       () => {
  99         dispatch(getSetGlobalMessageEvent(SUBSCRIPTION_FAILED_MESSAGE , MESSAGE_LEVEL_WARNING));
 100       }
 101     );
 102 }
 103
 104 export function getSubscriptionPayload() {
 105   let externalfetchRequest =
 106   () => networkCall.getRequest(SUBSCRIPTION_PAYLOAD_URL, GET);
 107
 108   return dispatch => dispatch(fetchSubscriptionPayload(externalfetchRequest));
 109 }
 110
 111 function validateExternalParams(externalURLParams) {
 112   if(externalURLParams.view && externalURLParams.entityId && externalURLParams.entityType) {
 113     return true;
 114   }
 115   return false;
 116
 117 }
 118
 119 function createSuggestionFoundEvent(suggestion) {
 120   return {
 121     type: contextHandlerActionTypes.SINGLE_SUGGESTION_FOUND,
 122     data: suggestion
 123   };
 124 }
 125
 126
 127 function fetchDataForExternalRequest(fetchRequestCallback) {
 128   return dispatch =>
 129     fetchRequestCallback().then(
 130       (response) => {
 131         if (response.status === STATUS_CODE_204_NO_CONTENT || response.status >= STATUS_CODE_3XX_REDIRECTION) {
 132           return Promise.reject(new Error(response.status));
 133         } else {
 134           // assume 200 status
 135           return response.json();
 136         }
 137       }
 138     ).then(
 139       (results)=> {
 140         if (results.suggestions !== undefined) {
 141           if( results.suggestions.length === 1) {
 142             dispatch(getClearGlobalMessageEvent());
 143             dispatch(createSuggestionFoundEvent({suggestion: results.suggestions[0]}));
 144           } else if(results.totalFound === 0 ) {
 145             dispatch(getSetGlobalMessageEvent(ZERO_RESULT, MESSAGE_LEVEL_DANGER));
 146           } else {
 147             dispatch(getSetGlobalMessageEvent(MULTIPLE_RESULT, MESSAGE_LEVEL_DANGER));          }
 148         } else {
 149           dispatch(getSetGlobalMessageEvent(WRONG_RESULT, MESSAGE_LEVEL_DANGER));
 150         }
 151       }
 152     ).catch(
 153       () => {
 154         dispatch(getSetGlobalMessageEvent(FAILED_REQUEST , MESSAGE_LEVEL_DANGER));
 155       }
 156     );
 157 }
 158
 159 function validateAndFetchExternalParams(externalParams) {
 160   if(!validateExternalParams(externalParams)) {
 161     return dispatch => {
 162       dispatch(
 163         getSetGlobalMessageEvent(WRONG_EXTERNAL_REQUEST_MESSAGE, MESSAGE_LEVEL_DANGER));
 164     };
 165   } else {
 166     let postBody = JSON.stringify(externalParams);
 167     let externalfetchRequest =
 168       () => networkCall.fetchRequestObj(EXTERNAL_REQ_ENTITY_SEARCH_URL, POST,
 169         POST_HEADER, postBody);
 170     return dispatch => dispatch(fetchDataForExternalRequest(externalfetchRequest));
 171   }
 172 }
 173 export function externalUrlRequest(urlParams) {
 174   let externalURLParams = getExternalParamValues(urlParams);
 175   return dispatch => dispatch(validateAndFetchExternalParams(externalURLParams));
 176 }
 177 export function externalMessageRequest(jsonParams) {
 178   return dispatch => {
 179     dispatch(
 180       validateAndFetchExternalParams(jsonParams));
 181   };
 182
 183 }
 184