diff options
Diffstat (limited to 'openstack-client/src/main/java')
| -rw-r--r-- | openstack-client/src/main/java/com/woorea/openstack/base/client/OpenStackClient.java | 160 |
1 files changed, 81 insertions, 79 deletions
diff --git a/openstack-client/src/main/java/com/woorea/openstack/base/client/OpenStackClient.java b/openstack-client/src/main/java/com/woorea/openstack/base/client/OpenStackClient.java index 7d5f14f..89c7840 100644 --- a/openstack-client/src/main/java/com/woorea/openstack/base/client/OpenStackClient.java +++ b/openstack-client/src/main/java/com/woorea/openstack/base/client/OpenStackClient.java @@ -24,83 +24,85 @@ import java.util.Properties; import java.util.ServiceLoader; public class OpenStackClient { - - protected String endpoint; - - protected OpenStackTokenProvider tokenProvider; - - protected static int AUTHENTICATION_RETRIES = 1; - - protected OpenStackClientConnector connector; - - protected Properties properties = new Properties(); - - protected static OpenStackClientConnector DEFAULT_CONNECTOR; - - static { - ServiceLoader<OpenStackClientConnector> connectorLoader; - connectorLoader = ServiceLoader.load(OpenStackClientConnector.class); - - for (OpenStackClientConnector clientConnector : connectorLoader) { - DEFAULT_CONNECTOR = clientConnector; - break; - } - } - - public OpenStackClient(String endpoint) { - this.endpoint = endpoint; - this.connector = DEFAULT_CONNECTOR; - } - - public OpenStackClient(String endpoint, OpenStackClientConnector connector) { - this.endpoint = endpoint; - this.connector = (connector == null) ? DEFAULT_CONNECTOR : connector; - } - - public <T> OpenStackResponse request(OpenStackRequest<T> request) { - OpenStackResponseException authException = null; - System.out.println("Openstack query:"+request.toString()); - for (int i = 0; i <= AUTHENTICATION_RETRIES; i++) { - request.endpoint(endpoint); - - if (tokenProvider != null) { - request.header("X-Auth-Token", tokenProvider.getToken()); - } - - try { - return connector.request(request); - } catch (OpenStackResponseException e) { - if (e.getStatus() != OpenStackResponseStatus.NOT_AUTHORIZED - || tokenProvider == null) { - throw e; - } - authException = e; - tokenProvider.expireToken(); - } - } - - throw authException; - } - - public <T> T execute(OpenStackRequest<T> request) { - OpenStackResponse response = request(request); - return (request.returnType() != null && request.returnType() != Void.class) ? response.getEntity(request.returnType()) : null; - } - - public void property(String property, String value) { - properties.put(property, value); - } - - public void setTokenProvider(OpenStackTokenProvider tokenProvider) { - this.tokenProvider = tokenProvider; - } - - public void token(String token) { - setTokenProvider(new OpenStackSimpleTokenProvider(token)); - } - - public <R> OpenStackRequest<R> get(String path, Class<R> returnType) { - return new OpenStackRequest<>(this, HttpMethod.GET, path, null, returnType); - } - + + protected String endpoint; + + protected OpenStackTokenProvider tokenProvider; + + protected static int AUTHENTICATION_RETRIES = 1; + + protected OpenStackClientConnector connector; + + protected Properties properties = new Properties(); + + protected static OpenStackClientConnector DEFAULT_CONNECTOR; + + static { + ServiceLoader<OpenStackClientConnector> connectorLoader; + connectorLoader = ServiceLoader.load(OpenStackClientConnector.class); + + for (OpenStackClientConnector clientConnector : connectorLoader) { + DEFAULT_CONNECTOR = clientConnector; + break; + } + } + + public OpenStackClient(String endpoint) { + this.endpoint = endpoint; + this.connector = DEFAULT_CONNECTOR; + } + + public OpenStackClient(String endpoint, OpenStackClientConnector connector) { + this.endpoint = endpoint; + this.connector = (connector == null) ? DEFAULT_CONNECTOR : connector; + } + + public <T> OpenStackResponse request(OpenStackRequest<T> request) { + OpenStackResponseException authException = null; + System.out.println("Openstack query:"+request.toString()); + for (int i = 0; i <= AUTHENTICATION_RETRIES; i++) { + request.endpoint(endpoint); + + if (tokenProvider != null) { + request.header("X-Auth-Token", tokenProvider.getToken()); + } + + try { + return connector.request(request); + } catch (OpenStackResponseException e) { + if (e.getStatus() != OpenStackResponseStatus.NOT_AUTHORIZED + || tokenProvider == null) { + throw e; + } + authException = e; + tokenProvider.expireToken(); + } + } + if(null == authException){ + authException = new OpenStackResponseException("Unknown issue",500); + } + throw authException; + } + + public <T> T execute(OpenStackRequest<T> request) { + OpenStackResponse response = request(request); + return (request.returnType() != null && request.returnType() != Void.class) ? response.getEntity(request.returnType()) : null; + } + + public void property(String property, String value) { + properties.put(property, value); + } + + public void setTokenProvider(OpenStackTokenProvider tokenProvider) { + this.tokenProvider = tokenProvider; + } + + public void token(String token) { + setTokenProvider(new OpenStackSimpleTokenProvider(token)); + } + + public <R> OpenStackRequest<R> get(String path, Class<R> returnType) { + return new OpenStackRequest<>(this, HttpMethod.GET, path, null, returnType); + } + } |