Initial support for testing

pom.xml

@@ -12,6 +12,7 @@
   <properties>
     <dropwizard.version>0.9.1</dropwizard.version>
     <jetty.version>9.2.13.v20150730</jetty.version>
+    <junit.version>4.12</junit.version>
   </properties>
 
   <dependencies>
@@ -30,6 +31,18 @@
       <artifactId>jetty-proxy</artifactId>
       <version>${jetty.version}</version>
     </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+      <version>${junit.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>com.github.tomakehurst</groupId>
+      <artifactId>wiremock</artifactId>
+      <version>1.58</version>
+    </dependency>
+
   </dependencies>
 
   <build>

src/main/java/com/o19s/grandcentral/kubernetes/KubernetesConfiguration.java

@@ -2,8 +2,6 @@
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import io.dropwizard.jackson.JsonSnakeCase;
-import io.dropwizard.setup.Environment;
-import org.apache.http.client.HttpClient;
 import org.hibernate.validator.constraints.NotEmpty;
 
 import javax.validation.constraints.NotNull;
@@ -27,6 +25,9 @@ public class KubernetesConfiguration {
   @NotEmpty
   private String namespace;
 
+  // this can be null
+  private String protocol;
+
   @JsonProperty
   public String getMasterIp() {
     return masterIp;
@@ -42,6 +43,16 @@ public String getUsername() {
     return username;
   }
 
+  @JsonProperty
+  public String getProtocol() {
+    return (protocol == null) ? "https" : protocol;
+  }
+
+  @JsonProperty
+  public void setProtocol(String protocol) {
+    this.protocol = protocol;
+  }
+
   @JsonProperty
   public void setUsername(String username) {
     this.username = username;

src/main/java/com/o19s/grandcentral/kubernetes/PodManager.java

@@ -75,6 +75,7 @@ public class PodManager {
    * @param keystorePath Path to the Java Keystore containing trusted certificates
    * @param maximumPodCount Maximum number of pods to ever have running at once
    * @param refreshIntervalInMs Interval with which to refresh the pods
+   * @param podYamlPath the location of the yaml config for the application pod
    */
   public PodManager(KubernetesConfiguration k8sConfiguration,
                     String keystorePath,
@@ -343,7 +344,7 @@ else if (left.getLastRequest() < right.getLastRequest())
    * @throws IOException
    */
   private void refreshPods() throws IOException {
-    HttpGet podsGet = new HttpGet("https://" + k8sConfiguration.getMasterIp() + ":443/api/v1/namespaces/" + k8sConfiguration.getNamespace() + "/pods");
+    HttpGet podsGet = new HttpGet(k8sConfiguration.getProtocol() + "://" + k8sConfiguration.getMasterIp() + "/api/v1/namespaces/" + k8sConfiguration.getNamespace() + "/pods");
 
     try (CloseableHttpResponse response = httpClient.execute(podsGet, httpContext)) {
       HttpEntity entity = response.getEntity();

src/test/com/o19s/grandcentral/kubernetes/PodManagerTest.java

@@ -0,0 +1,77 @@
+package com.o19s.grandcentral.kubernetes;
+import com.github.tomakehurst.wiremock.junit.WireMockRule;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+;
+/**
+ * Created by Omnifroodle on 5/17/16.
+ */
+public class PodManagerTest {
+    private KubernetesConfiguration kubecfg;
+    @Rule
+    public WireMockRule wireMockRule = new WireMockRule(8888);
+
+    @Before
+    public void setUp() throws Exception {
+        this.kubecfg = new KubernetesConfiguration();
+        kubecfg.setMasterIp("127.0.0.1:8888");
+        kubecfg.setProtocol("http");
+        kubecfg.setNamespace("test");
+        kubecfg.setUsername("fred");
+        kubecfg.setPassword("flintstone");
+    }
+
+    @After
+    public void tearDown() throws Exception {
+    }
+
+    @Test
+    public void testGet() throws Exception {
+
+    }
+
+    @Test
+    public void testContains() throws Exception {
+
+    }
+
+    @Test
+    public void testAdd() throws Exception {
+
+    }
+
+    @Test
+    public void testRefreshPods() throws Exception {
+        stubFor(get(urlEqualTo("/api/v1/namespaces/test/pods"))
+                .willReturn(aResponse()
+                        .withStatus(200)
+                        .withHeader("Content-Type", "text/json")
+                        .withBody("{\"items\":[" +
+                                "   {" +
+                                "       \"metadata\":{" +
+                                "           \"name\": \"abc\"" +
+                                "       }," +
+                                "       \"status\": {" +
+                                "           \"phase\": \"Running\"," +
+                                "           \"podIP\": \"1.1.1.1\"" +
+                                "       }" +
+                                "   }," +
+                                "   {" +
+                                "       \"metadata\":{" +
+                                "           \"name\": \"abcd\"" +
+                                "       }," +
+                                "       \"status\": {" +
+                                "           \"phase\": \"Running\"," +
+                                "           \"podIP\": \"1.1.1.2\"" +
+                                "       }" +
+                                "   }" +
+                                "   ]}")));
+
+        PodManager manager = new PodManager(this.kubecfg, "config/grandcentral.jks", 100, 1, "./config/configuration.yml");
+    }
+}