gerrit.onap Code Review - appc.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Copyright (C) 2017 Amdocs
   8  * =============================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  22  * ============LICENSE_END=========================================================
  23  */
  24
  25 package org.onap.appc.adapter.rest.impl;
  26
  27 import com.att.eelf.configuration.EELFLogger;
  28 import com.att.eelf.configuration.EELFManager;
  29 import org.apache.http.HttpEntity;
  30 import org.apache.http.HttpResponse;
  31 import org.apache.http.client.HttpClient;
  32 import org.apache.http.client.methods.HttpDelete;
  33 import org.apache.http.client.methods.HttpGet;
  34 import org.apache.http.client.methods.HttpPost;
  35 import org.apache.http.client.methods.HttpPut;
  36 import org.apache.http.client.methods.HttpRequestBase;
  37 import org.apache.http.entity.StringEntity;
  38 import org.apache.http.impl.client.CloseableHttpClient;
  39 import org.apache.http.impl.client.HttpClients;
  40 import org.apache.http.util.EntityUtils;
  41 import org.glassfish.grizzly.http.util.HttpStatus;
  42 import org.json.JSONObject;
  43 import org.onap.appc.Constants;
  44 import org.onap.appc.adapter.rest.RestAdapter;
  45 import org.onap.appc.adapter.rest.RequestFactory;
  46 import org.onap.appc.configuration.Configuration;
  47 import org.onap.appc.configuration.ConfigurationFactory;
  48 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  49
  50 import java.util.Iterator;
  51 import java.util.Map;
  52 import java.util.function.Supplier;
  53
  54 /**
  55  * This class implements the {@link RestAdapter} interface. This interface
  56  * defines the behaviors that our service provides.
  57  */
  58 public class RestAdapterImpl implements RestAdapter {
  59
  60     /**
  61      * The constant for the status code for a failed outcome
  62      */
  63     @SuppressWarnings("nls")
  64     private static final String OUTCOME_FAILURE = "failure";
  65
  66     /**
  67      * The constant for the status code for a successful outcome
  68      */
  69     @SuppressWarnings("nls")
  70     private static final String OUTCOME_SUCCESS = "success";
  71
  72     /**
  73      * The logger to be used
  74      */
  75     private final EELFLogger logger = EELFManager.getInstance().getLogger(RestAdapterImpl.class);
  76
  77     /**
  78      * A reference to the adapter configuration object.
  79      */
  80     private Configuration configuration;
  81
  82     /**
  83      * This default constructor is used as a work around because the activator
  84      * wasnt getting called
  85      */
  86     public RestAdapterImpl() {
  87         initialize();
  88
  89     }
  90
  91     /**
  92      * Returns the symbolic name of the adapter
  93      *
  94      * @return The adapter name
  95      * @see org.onap.appc.adapter.rest.RestAdapter#getAdapterName()
  96      */
  97     @Override
  98     public String getAdapterName() {
  99         return configuration.getProperty(Constants.PROPERTY_ADAPTER_NAME);
 100     }
 101
 102     public void commonGet(Map<String, String> params, SvcLogicContext ctx) {
 103         logger.info("Run get method");
 104
 105         RequestContext rc = new RequestContext(ctx);
 106         rc.isAlive();
 107
 108         HttpGet httpGet = (HttpGet) createHttpRequest("GET", params, rc);
 109         executeHttpRequest(httpGet, rc);
 110     }
 111
 112     public void commonDelete(Map<String, String> params, SvcLogicContext ctx) {
 113         logger.info("Run Delete method");
 114
 115         RequestContext rc = new RequestContext(ctx);
 116         rc.isAlive();
 117
 118         HttpDelete httpDelete = (HttpDelete) createHttpRequest("DELETE", params, rc);
 119         executeHttpRequest(httpDelete, rc);
 120     }
 121
 122     public void commonPost(Map<String, String> params, SvcLogicContext ctx) {
 123         logger.info("Run post method");
 124
 125         RequestContext rc = new RequestContext(ctx);
 126         rc.isAlive();
 127
 128         HttpPost httpPost = (HttpPost) createHttpRequest("POST", params, rc);
 129         executeHttpRequest(httpPost, rc);
 130     }
 131
 132     public void commonPut(Map<String, String> params, SvcLogicContext ctx) {
 133         logger.info("Run put method");
 134
 135         RequestContext rc = new RequestContext(ctx);
 136         rc.isAlive();
 137
 138         HttpPut httpPut = (HttpPut) createHttpRequest("PUT", params, rc);
 139         executeHttpRequest(httpPut, rc);
 140     }
 141
 142     @SuppressWarnings("static-method")
 143     private void doFailure(RequestContext rc, HttpStatus code, String message) {
 144         SvcLogicContext svcLogic = rc.getSvcLogicContext();
 145         String msg = (message == null) ? code.getReasonPhrase() : message;
 146         if (msg.contains("\n")) {
 147             msg = msg.substring(msg.indexOf("\n"));
 148         }
 149
 150         String status;
 151         try {
 152             status = Integer.toString(code.getStatusCode());
 153         } catch (Exception e) {
 154             status = "500";
 155         }
 156         svcLogic.setStatus(OUTCOME_FAILURE);
 157         svcLogic.setAttribute(Constants.ATTRIBUTE_ERROR_CODE, status);
 158         svcLogic.setAttribute(Constants.ATTRIBUTE_ERROR_MESSAGE, msg);
 159         svcLogic.setAttribute("org.openecomp.rest.result.code", status);
 160         svcLogic.setAttribute("org.openecomp.rest.result.message", msg);
 161     }
 162
 163
 164     /**
 165      * @param rc
 166      *            The request context that manages the state and recovery of the
 167      *            request for the life of its processing.
 168      */
 169     @SuppressWarnings("static-method")
 170     private void doSuccess(RequestContext rc, int code, String message) {
 171         SvcLogicContext svcLogic = rc.getSvcLogicContext();
 172         svcLogic.setStatus(OUTCOME_SUCCESS);
 173         svcLogic.setAttribute(Constants.ATTRIBUTE_ERROR_CODE, Integer.toString(HttpStatus.OK_200.getStatusCode()));
 174         svcLogic.setAttribute(Constants.ATTRIBUTE_ERROR_MESSAGE, message);
 175         svcLogic.setAttribute("org.openecomp.rest.agent.result.code",Integer.toString(code));
 176         svcLogic.setAttribute("org.openecomp.rest.agent.result.message",message);
 177         svcLogic.setAttribute("org.openecomp.rest.result.code",Integer.toString(HttpStatus.OK_200.getStatusCode()));
 178     }
 179
 180     public void executeHttpRequest(HttpRequestBase httpRequest, RequestContext rc){
 181         try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
 182             HttpResponse response = httpClient.execute(httpRequest);
 183             int responseCode = response.getStatusLine().getStatusCode();
 184             HttpEntity entity = response.getEntity();
 185             String responseOutput = EntityUtils.toString(entity);
 186             if(responseCode == 200){
 187                 doSuccess(rc,responseCode,responseOutput);
 188             } else {
 189                 doFailure(rc, HttpStatus.getHttpStatus(responseCode), response.getStatusLine().getReasonPhrase());
 190             }
 191         }
 192         catch (Exception ex) {
 193             doFailure(rc, HttpStatus.INTERNAL_SERVER_ERROR_500, ex.toString());
 194         }
 195     }
 196
 197     public HttpRequestBase createHttpRequest(String method, Map<String, String> params, RequestContext rc){
 198         HttpRequestBase httpRequest = null;
 199         try {
 200             String tUrl = params.get("org.onap.appc.instance.URI");
 201             String haveHeader = params.get("org.onap.appc.instance.haveHeader");
 202             String headers = params.get("org.onap.appc.instance.headers");
 203
 204             Supplier<RequestFactory> requestFactory =  RequestFactory::new;
 205             httpRequest = requestFactory.get().getHttpRequest(method, tUrl);
 206
 207             if (haveHeader.equals("true")) {
 208                 JSONObject JsonHeaders = new JSONObject(headers);
 209                 Iterator keys = JsonHeaders.keys();
 210                 while (keys.hasNext()) {
 211                     String String1 = (String) keys.next();
 212                     String String2 = JsonHeaders.getString(String1);
 213                     httpRequest.addHeader(String1, String2);
 214                 }
 215             }
 216             if (params.containsKey("org.onap.appc.instance.requestBody")) {
 217                 String body = params.get("org.onap.appc.instance.requestBody");
 218                 StringEntity bodyParams = new StringEntity (body,"UTF-8");
 219                 if (method.equals("PUT")){
 220                     HttpPut httpPut = (HttpPut) httpRequest;
 221                     httpPut.setEntity(bodyParams);
 222                 }
 223                 if (method.equals("POST")){
 224                     HttpPost httpPost = (HttpPost) httpRequest;
 225                     httpPost.setEntity(bodyParams);
 226                 }
 227             }
 228         } catch (Exception ex) {
 229             doFailure(rc, HttpStatus.INTERNAL_SERVER_ERROR_500, ex.toString());
 230         }
 231         return httpRequest;
 232     }
 233
 234
 235     /**
 236      * initialize the provider adapter by building the context cache
 237      */
 238     private void initialize() {
 239         configuration = ConfigurationFactory.getConfiguration();
 240
 241         logger.info("init rest adapter!!!!!");
 242     }
 243
 244 }