gerrit.onap Code Review - so/libs.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * Licensed under the Apache License, Version 2.0 (the "License");
   4  * you may not use this file except in compliance with the License.
   5  * You may obtain a copy of the License at
   6  *
   7  *      http://www.apache.org/licenses/LICENSE-2.0
   8  *
   9  * Unless required by applicable law or agreed to in writing, software
  10  * distributed under the License is distributed on an "AS IS" BASIS,
  11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12  * See the License for the specific language governing permissions and
  13  * limitations under the License.
  14  * ============LICENSE_END=========================================================
  15  */
  16
  17 package com.woorea.openstack.connector;
  18
  19 /*
  20  * Modifications copyright (c) 2017 AT&T Intellectual Property
  21  */
  22
  23 import java.io.InputStream;
  24 import java.util.HashMap;
  25 import java.util.Map;
  26
  27 import javax.ws.rs.core.Response;
  28
  29 import com.woorea.openstack.base.client.OpenStackResponse;
  30 import com.woorea.openstack.base.client.OpenStackResponseException;
  31
  32 public class JaxRs20Response implements OpenStackResponse {
  33
  34     private Response response;
  35
  36     public JaxRs20Response(Response response) {
  37         this.response = response;
  38     }
  39
  40     @Override
  41     public <T> T getEntity(Class<T> returnType) {
  42         if(response.getStatus() >= 400) {
  43             throw new OpenStackResponseException(response.getStatusInfo().getReasonPhrase(),
  44                     response.getStatusInfo().getStatusCode(), this);
  45         }
  46         return response.readEntity(returnType);
  47     }
  48
  49     @Override
  50     public <T> T getErrorEntity(Class<T> returnType) {
  51         if(response.getStatus() >= 400 && response.hasEntity()) {
  52             return response.readEntity(returnType);
  53         }
  54         return null;
  55     }
  56
  57
  58     @Override
  59     public InputStream getInputStream() {
  60         return (InputStream) response.getEntity();
  61     }
  62
  63     @Override
  64     public String header(String name) {
  65         return response.getHeaderString(name);
  66     }
  67
  68     @Override
  69     public Map<String, String> headers() {
  70         Map<String, String> headers = new HashMap<>();
  71         for(String k : response.getHeaders().keySet()) {
  72             headers.put(k, response.getHeaderString(k));
  73         }
  74         return headers;
  75     }
  76
  77 }