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

   1 package com.woorea.openstack.connector;
   2
   3 import java.util.List;
   4 import java.util.Map;
   5 import java.util.logging.Logger;
   6
   7 import javax.ws.rs.ClientErrorException;
   8 import javax.ws.rs.client.Client;
   9 import javax.ws.rs.client.Entity;
  10 import javax.ws.rs.client.Invocation;
  11 import javax.ws.rs.client.WebTarget;
  12 import javax.ws.rs.core.MediaType;
  13
  14 import org.glassfish.jersey.filter.LoggingFilter;
  15
  16 import com.woorea.openstack.base.client.HttpMethod;
  17 import com.woorea.openstack.base.client.OpenStackClientConnector;
  18 import com.woorea.openstack.base.client.OpenStackRequest;
  19 import com.woorea.openstack.base.client.OpenStackResponse;
  20 import com.woorea.openstack.base.client.OpenStackResponseException;
  21
  22 public class JaxRs20Connector implements OpenStackClientConnector {
  23
  24         protected Client client = OpenStack.CLIENT;
  25     private LoggingFilter logger = new LoggingFilter(Logger.getLogger("os"), 10000);
  26
  27         @Override
  28         public <T> OpenStackResponse request(OpenStackRequest<T> request) {
  29                 WebTarget target = client.target(request.endpoint()).path(request.path());
  30
  31                 for(Map.Entry<String, List<Object> > entry : request.queryParams().entrySet()) {
  32                         for (Object o : entry.getValue()) {
  33                                 target = target.queryParam(entry.getKey(), o);
  34                         }
  35                 }
  36         target.register(logger);
  37                 Invocation.Builder invocation = target.request();
  38
  39                 for(Map.Entry<String, List<Object>> h : request.headers().entrySet()) {
  40                         StringBuilder sb = new StringBuilder();
  41                         for(Object v : h.getValue()) {
  42                                 sb.append(String.valueOf(v));
  43                         }
  44                         invocation.header(h.getKey(), sb);
  45                 }
  46
  47                 Entity<?> entity = (request.entity() == null) ? null :
  48                                 Entity.entity(request.entity().getEntity(), request.entity().getContentType());
  49
  50                 try {
  51                         if (entity != null) {
  52                                 return new JaxRs20Response(invocation.method(request.method().name(), entity));
  53                         } else {
  54                                 if(HttpMethod.PUT == request.method()) {
  55                                         return new JaxRs20Response(invocation.method(request.method().name(), Entity.entity("", MediaType.APPLICATION_JSON)));
  56                                 } else {
  57                                         return new JaxRs20Response(invocation.method(request.method().name()));
  58                                 }
  59                         }
  60                 } catch (ClientErrorException e) {
  61                         throw new OpenStackResponseException(e.getResponse()
  62                                         .getStatusInfo().toString(), e.getResponse().getStatus());
  63                 }
  64         }
  65 }