Merge pull request #1 from evanwong/develop

Merging develop to master

Author: Evan Wong

.travis.yml

@@ -0,0 +1,9 @@
+language: java
+
+jdk:
+  - oraclejdk8
+
+branches:
+  only:
+    - master
+    - develop

README.md

@@ -1,2 +1,4 @@
+[![Build Status](https://snap-ci.com/evanwong/hipchat-java/branch/develop/build_image)](https://snap-ci.com/evanwong/hipchat-java/branch/develop)
+
 hipchat-java
 ============

build.gradle

@@ -1,7 +1,19 @@
-apply plugin: 'java'
+apply plugin: 'groovy'
 
 repositories {
-        mavenCentral()
+    mavenCentral()
+    maven { url "http://oss.sonatype.org/content/repositories/snapshots/" }
+}
+
+sourceCompatibility = 1.8
+
+dependencies {
+    compile 'org.apache.httpcomponents:httpclient:4.3.5'
+    compile 'org.slf4j:slf4j-api:1.7.7'
+    runtime 'org.slf4j:slf4j-simple:1.7.7'
+    compile 'com.fasterxml.jackson.core:jackson-databind:2.4.2'
+    compile "org.codehaus.groovy:groovy-all:2.3.7"
+    testCompile "org.spockframework:spock-core:1.0-groovy-2.3-SNAPSHOT"
 }
 
 task wrapper(type: Wrapper) {

src/main/java/io/evanwong/hipchat/v2/HipChatClient.java

@@ -0,0 +1,79 @@
+package io.evanwong.hipchat.v2;
+
+import io.evanwong.hipchat.v2.rooms.GetAllRoomsRequestBuilder;
+import io.evanwong.hipchat.v2.rooms.SendRoomNotificationRequestBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public class HipChatClient {
+
+    private static final Logger log = LoggerFactory.getLogger(HipChatClient.class);
+
+    private CloseableHttpClient httpClient;
+    private ExecutorService executorService;
+    private String defaultAccessToken;
+    //TODO move this out
+    private int maxConnections = 20;
+    //TODO move this out
+    private int maxConnectionsPerRoute = 4;
+
+
+    public HipChatClient() {
+        init();
+    }
+
+    public HipChatClient(String defaultAccessToken) {
+        this.defaultAccessToken = defaultAccessToken;
+        init();
+    }
+
+    private void init() {
+        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
+        cm.setMaxTotal(maxConnections);
+        log.debug("Max pool size: {}", maxConnections);
+        cm.setDefaultMaxPerRoute(maxConnectionsPerRoute);
+        log.debug("Max per route: {}", maxConnectionsPerRoute);
+
+        httpClient = HttpClients.custom().setConnectionManager(cm).build();
+        //setting the thread pool size equal to the max connections size
+        executorService = Executors.newFixedThreadPool(maxConnections);
+    }
+
+    public void setDefaultAccessToken(String defaultAccessToken) {
+        this.defaultAccessToken = defaultAccessToken;
+    }
+
+    public GetAllRoomsRequestBuilder prepareGetAllRoomsRequestBuilder(String accessToken) {
+        return new GetAllRoomsRequestBuilder(accessToken, httpClient, executorService);
+    }
+
+    public GetAllRoomsRequestBuilder prepareGetAllRoomsRequestBuilder() {
+        return prepareGetAllRoomsRequestBuilder(defaultAccessToken);
+    }
+
+    public SendRoomNotificationRequestBuilder prepareSendRoomNotificationRequestBuilder(String idOrName, String message, String accessToken) {
+        return new SendRoomNotificationRequestBuilder(idOrName, message, accessToken, httpClient, executorService);
+    }
+
+    public SendRoomNotificationRequestBuilder prepareSendRoomNotificationRequestBuilder(String idOrName, String message) {
+        return prepareSendRoomNotificationRequestBuilder(idOrName, message, defaultAccessToken);
+    }
+
+    public void close() {
+        log.info("Shutting down...");
+        try {
+            httpClient.close();
+        } catch (IOException e) {
+            log.error("Failed to close the HttpClient.", e);
+        }
+        executorService.shutdown();
+    }
+
+}

src/main/java/io/evanwong/hipchat/v2/commons/ExpandableRequestBuilder.java

@@ -0,0 +1,22 @@
+package io.evanwong.hipchat.v2.commons;
+
+import org.apache.http.client.HttpClient;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+
+public abstract class ExpandableRequestBuilder<T> extends RequestBuilder {
+
+    protected final List<String> expansions;
+
+    public ExpandableRequestBuilder(String accessToken, HttpClient httpClient, ExecutorService executorService) {
+        super(accessToken, httpClient, executorService);
+        expansions = new ArrayList<>();
+    }
+
+    public T addExpansion(String title) {
+        expansions.add(title);
+        return (T)this;
+    }
+}

src/main/java/io/evanwong/hipchat/v2/commons/GetRequest.java

@@ -0,0 +1,46 @@
+package io.evanwong.hipchat.v2.commons;
+
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.protocol.HttpClientContext;
+import org.apache.http.message.BasicHeader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+public abstract class GetRequest<T> extends Request {
+
+    private static final Logger log = LoggerFactory.getLogger(GetRequest.class);
+    protected List<String> expansions = new ArrayList<>();
+
+    @Override
+    protected HttpResponse request() throws IOException {
+        Map<String, Object> params = toQueryMap();
+        if (!expansions.isEmpty()) {
+            params.put("expand", expansions.stream().collect(Collectors.joining(",")));
+        }
+        log.info("GET - path: {}, params: {}", getPath(), params);
+        String query = params != null && params.size() > 0 ? "?" : "";
+        for (String key : params.keySet()) {
+            query += key + "=" + params.get(key) + "&";
+        }
+
+        HttpGet httpGet = new HttpGet(BASE_URL + getPath() + query);
+        httpGet.addHeader(new BasicHeader("Authorization", "Bearer " + accessToken));
+        return httpClient.execute(httpGet, HttpClientContext.create());
+    }
+
+    public boolean addExpansion(String title) {
+        return expansions.add(title);
+    }
+
+    public List<String> getExpansions() {
+        return new ArrayList<>(expansions);
+    }
+}
+

src/main/java/io/evanwong/hipchat/v2/commons/NoContent.java

@@ -0,0 +1,4 @@
+package io.evanwong.hipchat.v2.commons;
+
+public class NoContent {
+}

src/main/java/io/evanwong/hipchat/v2/commons/PagingLinks.java

@@ -0,0 +1,34 @@
+package io.evanwong.hipchat.v2.commons;
+
+public class PagingLinks {
+    private String self;
+    private String prev;
+    private String next;
+
+    public PagingLinks() {
+    }
+
+    public String getSelf() {
+        return self;
+    }
+
+    public void setSelf(String self) {
+        this.self = self;
+    }
+
+    public String getPrev() {
+        return prev;
+    }
+
+    public void setPrev(String prev) {
+        this.prev = prev;
+    }
+
+    public String getNext() {
+        return next;
+    }
+
+    public void setNext(String next) {
+        this.next = next;
+    }
+}

src/main/java/io/evanwong/hipchat/v2/commons/PostRequest.java

@@ -0,0 +1,29 @@
+package io.evanwong.hipchat.v2.commons;
+
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.protocol.HttpClientContext;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.message.BasicHeader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.Map;
+
+public abstract class PostRequest<T> extends Request {
+
+    private static final Logger log = LoggerFactory.getLogger(PostRequest.class);
+
+    @Override
+    protected HttpResponse request() throws IOException {
+        Map<String, Object> params = toQueryMap();
+        log.info("POST - path: {}, params: {}", getPath(), params);
+
+        HttpPost httpPost = new HttpPost(BASE_URL + getPath());
+        httpPost.addHeader(new BasicHeader("Authorization", "Bearer " + accessToken));
+        httpPost.addHeader(new BasicHeader("Content-Type", "application/json"));
+        httpPost.setEntity(new StringEntity(objectWriter.writeValueAsString(params)));
+        return httpClient.execute(httpPost, HttpClientContext.create());
+    }
+}

src/main/java/io/evanwong/hipchat/v2/commons/Request.java

@@ -0,0 +1,58 @@
+package io.evanwong.hipchat.v2.commons;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.ObjectReader;
+import com.fasterxml.jackson.databind.ObjectWriter;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.HttpClient;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.lang.reflect.ParameterizedType;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Future;
+
+public abstract class Request<T> {
+
+    private static final Logger log = LoggerFactory.getLogger(PostRequest.class);
+
+    protected static final String BASE_URL = "https://api.hipchat.com/v2";
+    protected ExecutorService executorService;
+    protected String accessToken;
+    protected HttpClient httpClient;
+    private final ObjectMapper objectMapper = new ObjectMapper();
+    protected final ObjectWriter objectWriter = objectMapper.writer();
+    protected final ObjectReader objectReader = objectMapper.reader(getParameterClass());
+    protected abstract Map<String, Object> toQueryMap();
+    protected abstract HttpResponse request() throws IOException;
+    protected abstract String getPath();
+
+    public Future<T> execute() {
+
+        Future<T> future = executorService.submit(() -> {
+            HttpResponse response = request();
+            int status = response.getStatusLine().getStatusCode();
+            HttpEntity entity = response.getEntity();
+            String content = entity != null ? EntityUtils.toString(entity) : null;
+            if (status >= 200 && status < 300) {
+                if (content == null) {
+                    //should be NoContent
+                    return getParameterClass().newInstance();
+                }
+                return objectReader.readValue(content);
+            } else {
+                log.error("Invalid response status: {}, content: {}", status, content);
+                return null;
+            }
+        });
+        return future;
+    }
+
+    protected Class<T> getParameterClass() {
+        return (Class<T>) (((ParameterizedType) this.getClass().getGenericSuperclass()).getActualTypeArguments()[0]);
+    }
+}