add stopArchive implementation, adds tests #11

Author: aoberoi

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

@@ -400,18 +400,16 @@ public Archive startArchive(String sessionId, String name) throws OpenTokExcepti
      * @param archiveId The archive ID of the archive you want to stop recording.
      * @return The Archive object corresponding to the archive being STOPPED.
      */
-//    public Archive stopArchive(String archiveId) throws OpenTokException {
-//        HashMap<String, String> headers = new HashMap<String, String>();
-//        headers.put("content-type", "application/json");
-//        String archive = HttpClient.makePostRequest("/v2/partner/" + this.apiKey + "/archive/" + archiveId + "/stop", headers, null,
-//                "");
-//        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 stopArchive(String archiveId) throws OpenTokException {
+
+        String archive = this.client.stopArchive(archiveId);
+        ObjectMapper mapper = new ObjectMapper();
+        try {
+            return mapper.readValue(archive, Archive.class);
+        } catch (Exception e) {
+            throw new RequestException("Exception mapping json: " + e.getMessage());
+        }
+    }
 
     /**
      * Deletes an OpenTok archive.

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

@@ -139,7 +139,6 @@ public String startArchive(String sessionId, String name) {
         // 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);
@@ -179,6 +178,36 @@ public String startArchive(String sessionId, String name) {
         return responseString;
     }
 
+    public String stopArchive(String archiveId) {
+        String responseString = null;
+        Future<Response> request = null;
+        // TODO: maybe use a StringBuilder?
+        String url = this.apiUrl+"/v2/partner/"+this.apiKey+"/archive/stop";
+
+        try {
+            request = this.preparePost(url).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

@@ -502,4 +502,35 @@ public void testStartArchive() throws OpenTokException {
 
     // TODO: test start archive failure scenarios
 
+    @Test
+    public void testStopArchive() throws OpenTokException {
+        String archiveId = "ARCHIVEID";
+
+        stubFor(post(urlEqualTo("/v2/partner/"+this.apiKey+"/archive/stop"))
+                .willReturn(aResponse()
+                        .withStatus(200)
+                        .withHeader("Content-Type", "application/json")
+                        .withBody("{\n" +
+                                "          \"createdAt\" : 1395183243000,\n" +
+                                "          \"duration\" : 0,\n" +
+                                "          \"id\" : \"ARCHIVEID\",\n" +
+                                "          \"name\" : \"\",\n" +
+                                "          \"partnerId\" : 123456,\n" +
+                                "          \"reason\" : \"\",\n" +
+                                "          \"sessionId\" : \"SESSIONID\",\n" +
+                                "          \"size\" : 0,\n" +
+                                "          \"status\" : \"stopped\",\n" +
+                                "          \"url\" : null\n" +
+                                "        }")));
+
+        Archive archive = sdk.stopArchive(archiveId);
+        assertNotNull(archive);
+        assertEquals("SESSIONID", archive.getSessionId());
+        assertEquals(archiveId, archive.getId());
+
+        verify(postRequestedFor(urlMatching("/v2/partner/"+this.apiKey+"/archive/stop"))
+                .withHeader("X-TB-PARTNER-AUTH", matching(this.apiKey+":"+this.apiSecret))
+                .withHeader("User-Agent", matching(".*Opentok-Java-SDK/"+ Version.VERSION+".*")));
+    }
+
 }