Added unit test for SSE entity

Author: manpreet.singh

sseclient/build.gradle

@@ -13,4 +13,37 @@ dependencies {
     compile group: 'org.apache.httpcomponents', name: 'httpclient', version: '4.5.12'
     compile group: 'org.apache.httpcomponents', name: 'httpclient-cache', version: '4.5.12'
     compile group: 'org.apache.httpcomponents', name: 'httpasyncclient', version: '4.1.4'
+    testCompile group: 'com.fasterxml.jackson.core', name: 'jackson-core', version: '2.10.2'
+    testCompile group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.10.2'
+    testCompile group: 'com.fasterxml.jackson.datatype', name: 'jackson-datatype-jsr310', version: '2.10.2'
+    testCompile group: 'commons-io', name: 'commons-io', version: '2.8.0'
+    testCompile group: 'org.testng', name: 'testng', version: '7.1.0'
 }
+
+jar {
+    manifest {
+        attributes 'Implementation-Title': 'Apache SSE client',
+                'Implementation-Version': '1.0'
+    }
+}
+
+task fatJar(type: Jar) {
+    version("1.0-uber")
+    manifest {
+        attributes 'Implementation-Title': 'Apache SSE client',
+                'Implementation-Version': '1.0'
+    }
+    from { configurations.compile.collect { it.isDirectory() ? it : zipTree(it) } }
+    with jar
+}
+
+test {
+    useTestNG() {
+        def builder = suiteXmlBuilder();
+        builder.suite(name: 'sse-tests') {
+            test(name: 'sse-tests') {
+                builder.packages { 'package'(name: 'org.apache.client.sse.*') {} }
+            }
+        }
+    }
+}

sseclient/src/test/java/org/apache/client/sse/SseEntityTest.java

@@ -0,0 +1,71 @@
+package org.apache.client.sse;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.testng.Assert;
+import org.testng.annotations.BeforeClass;
+import org.testng.annotations.Test;
+
+import com.fasterxml.jackson.databind.JsonNode;
+
+import org.apache.commons.io.FileUtils;
+
+import java.io.*;
+import java.nio.CharBuffer;
+import java.nio.file.Paths;
+
+/**
+ * Unit tests to check that the SseEntity processes the char buffers correctly.
+ */
+public class SseEntityTest {
+
+    private final SseEntity sseEntity = new SseEntity(null);
+
+    @BeforeClass
+    public void pushBuffer() throws IOException {
+        String eventsFilePath = Paths.get(System.getProperty("user.dir"), "src", "test", "resources", "raw_events.txt").toString();
+        String content = FileUtils.readFileToString(new File(eventsFilePath), "UTF-8");
+        CharBuffer buffer = CharBuffer.allocate(1024);
+        buffer.put(content);
+        buffer.rewind();
+        sseEntity.pushBuffer(buffer, null);
+        System.out.println("Size: " + sseEntity.getEvents().size());
+    }
+
+    @Test(groups = { "unit" })
+    public void testLastEventIDMatch() {
+        Assert.assertEquals(sseEntity.getLastEventId(), "dsjfnwuis");
+    }
+
+    @Test(groups = { "unit" })
+    public void testEventsCreated() {
+        Assert.assertTrue(sseEntity.hasMoreEvents());
+        Assert.assertEquals(sseEntity.getEvents().size(), 5);
+    }
+
+    @Test(groups = { "unit" }, dependsOnMethods = { "testEventsCreated" })
+    public void testEventParsing() throws JsonProcessingException {
+        Event firstEvent = sseEntity.getEvents().poll();
+        Assert.assertNotNull(firstEvent);
+        Assert.assertEquals(firstEvent.getId(), "sdjkf36ff");
+        Assert.assertEquals(firstEvent.getEvent(), "added_account");
+        Assert.assertEquals(firstEvent.getRetry(), 5000);
+
+        ObjectMapper jsonMapper = new ObjectMapper();
+        JsonNode jsonNode = jsonMapper.readTree(firstEvent.getData());
+        Assert.assertEquals(jsonNode.get("account_name").asText(), "event_entity_1");
+        Assert.assertEquals(jsonNode.get("owner").asText(), "[email protected]");
+        Assert.assertEquals(jsonNode.get("type").asText(), "basic");
+    }
+
+    @Test(groups = { "unit" }, dependsOnMethods = { "testEventParsing" })
+    public void testEventQueue() {
+        Assert.assertEquals(sseEntity.getEvents().size(), 4);
+        Assert.assertEquals(sseEntity.getEvents().poll().getId(), "kjewf438sd");
+        Assert.assertEquals(sseEntity.getEvents().poll().getId(), "sljf48fsmc");
+        Assert.assertEquals(sseEntity.getEvents().poll().getId(), "jfu438fkjv");
+        Assert.assertEquals(sseEntity.getEvents().poll().getId(), "dsjfnwuis");
+        Assert.assertFalse(sseEntity.hasMoreEvents());
+    }
+
+}

sseclient/src/test/resources/raw_events.txt

@@ -0,0 +1,42 @@
+id:sdjkf36ff
+event:added_account
+retry:5000
+data:{
+data:"account_name":"event_entity_1",
+data:"owner":"[email protected]",
+data:"type":"basic"
+data:}
+
+id:kjewf438sd
+event:updated_account
+data:{
+data:"account_name":"event_entity_1",
+data:"owner":"[email protected]",
+data:"type":"premium"
+data:}
+
+
+id:sljf48fsmc
+event:added_account
+data:{
+data:"account_name":"event_entity_2",
+data:"owner":"[email protected]",
+data:"type":"enterprise"
+data:}
+
+
+id:jfu438fkjv
+event:added_account
+data:{
+data:"account_name":"event_entity_3",
+data:"owner":"[email protected]",
+data:"type":"basic"
+data:}
+
+
+id:dsjfnwuis
+event:deleted_account
+data:{
+data:"account_name":"event_entity_1"
+data:}
+