2fe81bb1b41ca485653d6f33b5f6362f819f1d24
[ccsdk/features.git] / sdnr / wt / common / src / main / java / org / onap / ccsdk / features / sdnr / wt / common / database / responses / BaseResponse.java
1 /*
2  * ============LICENSE_START=======================================================
3  * ONAP : ccsdk features
4  * ================================================================================
5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
6  * All rights reserved.
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  */
22 package org.onap.ccsdk.features.sdnr.wt.common.database.responses;
23
24 import java.io.IOException;
25 import java.util.ArrayList;
26 import java.util.List;
27
28 import org.apache.http.util.EntityUtils;
29 import org.elasticsearch.client.Response;
30 import org.json.JSONObject;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
33
34 public class BaseResponse {
35         private static final Logger LOG = LoggerFactory.getLogger(BaseResponse.class);
36
37         private final int responseCode;
38
39         BaseResponse(Response response) {
40                 this.responseCode = response != null ? response.getStatusLine().getStatusCode() : 0;
41         }
42
43         int getResponseCode() {
44                 return this.responseCode;
45         }
46
47         public boolean isResponseSucceeded() {
48                 return this.responseCode < 300;
49         }
50
51         JSONObject getJson(Response response) {
52                 try {
53                         String sresponse = EntityUtils.toString(response.getEntity());
54                         LOG.debug("parsing response={}", sresponse);
55                         return new JSONObject(sresponse);
56                 } catch (UnsupportedOperationException | IOException e) {
57                         LOG.warn("error parsing es response: {}", e.getMessage());
58                         return null;
59                 }
60
61         }
62
63         JSONObject getJson(String json) {
64                 return new JSONObject(json);
65         }
66
67         /**
68          * @param response
69          * @return
70          */
71         List<String> getLines(Response response){
72                 return this.getLines(response,true);
73         }
74         List<String> getLines(Response response,boolean ignoreEmpty) {
75                 try {
76                         String sresponse = EntityUtils.toString(response.getEntity());
77                         LOG.debug("parsing response={}", sresponse);
78                         String[] hlp = sresponse.split("\n");
79                         List<String> lines=new ArrayList<String>();
80                         for(String h:hlp) {
81                                 if(ignoreEmpty && h.trim().length()==0) {
82                                         continue;
83                                 }
84                                 lines.add(h);
85                         }
86                         return lines;
87                 } catch (UnsupportedOperationException | IOException e) {
88                         LOG.warn("error parsing es response: {}", e.getMessage());
89                         return null;
90                 }
91
92         }
93 }