add startArchive implementation, adds tests #11

Author: aoberoi

src/main/java/com/opentok/OpenTok.java

@@ -377,21 +377,19 @@ public List<Archive> listArchives(int offset, int count) throws OpenTokException
      *
      * @return The Archive object. This object includes properties defining the archive, including the archive ID.
      */
-//    public Archive startArchive(String sessionId, String name) throws OpenTokException {
-//        if (sessionId == null || sessionId == "") {
-//            throw new InvalidArgumentException("Session not valid");
-//        }
-//        HashMap<String, String> headers = new HashMap<String, String>();
-//        headers.put("content-type", "application/json");
-//        String archive = HttpClient.makePostRequest("/v2/partner/" + this.apiKey + "/archive", headers, null,
-//                "{ \"sessionId\" : \"" + sessionId + "\", \"name\": \"" + name + "\" }");
-//        ObjectMapper mapper = new ObjectMapper();
-//        try {
-//            return mapper.readValue(archive, Archive.class);
-//        } catch (Exception e) {
-//            throw new RequestException(500, "Exception mapping json: " + e.getMessage());
-//        }
-//    }
+    public Archive startArchive(String sessionId, String name) throws OpenTokException {
+        if (sessionId == null || sessionId == "") {
+            throw new InvalidArgumentException("Session not valid");
+        }
+        // TODO: do validation on sessionId and name
+        String archive = this.client.startArchive(sessionId, name);
+        ObjectMapper mapper = new ObjectMapper();
+        try {
+            return mapper.readValue(archive, Archive.class);
+        } catch (Exception e) {
+            throw new RequestException("Exception mapping json: " + e.getMessage());
+        }
+    }
 
     /**
      * Stops an OpenTok archive that is being recorded.

src/main/java/com/opentok/util/HttpClient.java

@@ -2,10 +2,13 @@
 
 import java.io.IOException;
 import java.util.Collection;
+import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Future;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.ning.http.client.*;
 import com.ning.http.client.filter.FilterContext;
 import com.ning.http.client.filter.FilterException;
@@ -129,6 +132,53 @@ public String getArchives(int offset, int count) {
         return responseString;
     }
 
+    public String startArchive(String sessionId, String name) {
+        String responseString = null;
+        Future<Response> request = null;
+        String requestBody = null;
+        // TODO: maybe use a StringBuilder?
+        String url = this.apiUrl+"/v2/partner/"+this.apiKey+"/archive";
+
+        // TODO: create JSON body string from sessionId and name
+        ObjectMapper mapper = new ObjectMapper();
+        HashMap<String, String> jsonBody = new HashMap<String, String>();
+        jsonBody.put("sessionId", sessionId);
+        if (name != null) {
+            jsonBody.put("name", name);
+        }
+        try {
+            requestBody = mapper.writeValueAsString(jsonBody);
+        } catch (JsonProcessingException e) {
+            // TODO: throw OpenTokException
+            e.printStackTrace();
+        }
+        try {
+            request = this.preparePost(url)
+                    .setBody(requestBody)
+                    .setHeader("Content-Type", "application/json")
+                    .execute();
+        } catch (IOException e) {
+            // TODO: throw OpenTokException
+            e.printStackTrace();
+        }
+
+        try {
+            Response response = request.get();
+            // TODO: check response code
+            responseString = response.getResponseBody();
+        } catch (InterruptedException e) {
+            // TODO: throw OpenTokException
+            e.printStackTrace();
+        } catch (ExecutionException e) {
+            // TODO: throw OpenTokException
+            e.printStackTrace();
+        } catch (IOException e) {
+            // TODO: throw OpenTokException
+            e.printStackTrace();
+        }
+        return responseString;
+    }
+
 //    protected static String makeDeleteRequest(String resource) throws OpenTokException {
 //        BoundRequestBuilder get = client.prepareDelete(apiUrl + resource);
 //        addCommonHeaders(get);

src/test/java/com/opentok/test/OpenTokTest.java

@@ -467,4 +467,39 @@ public void testListArchives() throws OpenTokException {
 
     // TODO: test list archives failure scenarios
 
+    @Test
+    public void testStartArchive() throws OpenTokException {
+        String sessionId = "SESSIONID";
+
+        stubFor(post(urlEqualTo("/v2/partner/"+this.apiKey+"/archive"))
+                .willReturn(aResponse()
+                        .withStatus(200)
+                        .withHeader("Content-Type", "application/json")
+                        .withBody("{\n" +
+                                "          \"createdAt\" : 1395183243556,\n" +
+                                "          \"duration\" : 0,\n" +
+                                "          \"id\" : \"30b3ebf1-ba36-4f5b-8def-6f70d9986fe9\",\n" +
+                                "          \"name\" : \"\",\n" +
+                                "          \"partnerId\" : 123456,\n" +
+                                "          \"reason\" : \"\",\n" +
+                                "          \"sessionId\" : \"SESSIONID\",\n" +
+                                "          \"size\" : 0,\n" +
+                                "          \"status\" : \"started\",\n" +
+                                "          \"url\" : null\n" +
+                                "        }")));
+
+        Archive archive = sdk.startArchive(sessionId, null);
+        assertNotNull(archive);
+        assertEquals(sessionId, archive.getSessionId());
+        assertNotNull(archive.getId());
+
+        verify(postRequestedFor(urlMatching("/v2/partner/"+this.apiKey+"/archive"))
+                .withHeader("X-TB-PARTNER-AUTH", matching(this.apiKey+":"+this.apiSecret))
+                .withHeader("User-Agent", matching(".*Opentok-Java-SDK/"+ Version.VERSION+".*")));
+    }
+
+    // TODO: test start archive with name
+
+    // TODO: test start archive failure scenarios
+
 }