Add 1st draft of Java ServerEventsClient

Author: mythz

src/AndroidClient/client/src/main/java/net/servicestack/client/JsonServiceClient.java

@@ -46,15 +46,19 @@ public class JsonServiceClient implements ServiceClient {
     Gson gson;
 
     public JsonServiceClient(String baseUrl) {
-        this.baseUrl = baseUrl.endsWith("/") ? baseUrl : baseUrl + "/";
-        this.replyUrl = this.baseUrl + "json/reply/";
+        setBaseUrl(baseUrl);
 
         //Automatically populate response cookies
         if (CookieHandler.getDefault() == null){
             CookieHandler.setDefault(new CookieManager());
         }
     }
 
+    public void setBaseUrl(String baseUrl) {
+        this.baseUrl = baseUrl.endsWith("/") ? baseUrl : baseUrl + "/";
+        this.replyUrl = this.baseUrl + "json/reply/";
+    }
+
     public void setTimeout(int timeoutMs) {
         this.timeoutMs = timeoutMs;
     }

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ExceptionCallback.java

@@ -0,0 +1,9 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public interface ExceptionCallback {
+    void execute(Exception ex);
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/HttpRequestFilter.java

@@ -0,0 +1,11 @@
+package net.servicestack.client.sse;
+
+import java.net.HttpURLConnection;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public interface HttpRequestFilter {
+    void execute(HttpURLConnection req);
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/HttpResponseFilter.java

@@ -0,0 +1,11 @@
+package net.servicestack.client.sse;
+
+import java.net.HttpURLConnection;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public interface HttpResponseFilter {
+    void execute(HttpURLConnection req);
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventCallback.java

@@ -0,0 +1,9 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public interface ServerEventCallback {
+    void execute(ServerEventsClient client, ServerEventMessage e);
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventCommand.java

@@ -0,0 +1,72 @@
+package net.servicestack.client.sse;
+
+import com.google.gson.JsonObject;
+
+import net.servicestack.client.JsonUtils;
+import net.servicestack.client.Utils;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public class ServerEventCommand extends ServerEventMessage {
+    private String userId;
+    private String displayName;
+    private String profileUrl;
+    private boolean isAuthenticated;
+    private String[] channels;
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getDisplayName() {
+        return displayName;
+    }
+
+    public void setDisplayName(String displayName) {
+        this.displayName = displayName;
+    }
+
+    public String getProfileUrl() {
+        return profileUrl;
+    }
+
+    public void setProfileUrl(String profileUrl) {
+        this.profileUrl = profileUrl;
+    }
+
+    public boolean isAuthenticated() {
+        return isAuthenticated;
+    }
+
+    public void setAuthenticated(boolean authenticated) {
+        isAuthenticated = authenticated;
+    }
+
+    public String[] getChannels() {
+        return channels;
+    }
+
+    public void setChannels(String[] channels) {
+        this.channels = channels;
+    }
+
+    @Override
+    protected void populate(JsonObject obj) {
+        super.populate(obj);
+
+        this.userId = JsonUtils.asString(obj, "userId");
+        this.displayName = JsonUtils.asString(obj, "displayName");
+        this.isAuthenticated = "true".equals(JsonUtils.asString(obj, "isAuthenticated"));
+        this.profileUrl = JsonUtils.asString(obj, "profileUrl");
+
+        String channels = JsonUtils.asString(obj, "channels");
+        if (!Utils.isNullOrEmpty(channels))
+            this.channels = channels.split(",");
+    }
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventConnect.java

@@ -0,0 +1,63 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public class ServerEventConnect extends ServerEventCommand  {
+    private String id;
+    private String unRegisterUrl;
+    private String heartbeatUrl;
+    private long heartbeatIntervalMs;
+    private long idleTimeoutMs;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getUnRegisterUrl() {
+        return unRegisterUrl;
+    }
+
+    public void setUnRegisterUrl(String unRegisterUrl) {
+        this.unRegisterUrl = unRegisterUrl;
+    }
+
+    public String getHeartbeatUrl() {
+        return heartbeatUrl;
+    }
+
+    public void setHeartbeatUrl(String heartbeatUrl) {
+        this.heartbeatUrl = heartbeatUrl;
+    }
+
+    public long getHeartbeatIntervalMs() {
+        return heartbeatIntervalMs;
+    }
+
+    public void setHeartbeatIntervalMs(long heartbeatIntervalMs) {
+        this.heartbeatIntervalMs = heartbeatIntervalMs;
+    }
+
+    public long getIdleTimeoutMs() {
+        return idleTimeoutMs;
+    }
+
+    public void setIdleTimeoutMs(long idleTimeoutMs) {
+        this.idleTimeoutMs = idleTimeoutMs;
+    }
+
+    @Override
+    public String toString() {
+        return "(" + this.getClass().getSimpleName() +
+                "\n id: " + id +
+                "\n unRegisterUrl: " + unRegisterUrl +
+                "\n heartbeatUrl: " + heartbeatUrl +
+                "\n heartbeatIntervalMs: " + heartbeatIntervalMs +
+                "\n idleTimeoutMs: " + idleTimeoutMs + "\n)";
+    }
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventConnectCallback.java

@@ -0,0 +1,9 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+
+public interface ServerEventConnectCallback {
+    void execute(ServerEventConnect e);
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventHeartbeat.java

@@ -0,0 +1,7 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+public class ServerEventHeartbeat extends ServerEventCommand {
+}

src/AndroidClient/client/src/main/java/net/servicestack/client/sse/ServerEventJoin.java

@@ -0,0 +1,7 @@
+package net.servicestack.client.sse;
+
+/**
+ * Created by mythz on 2/10/2017.
+ */
+public class ServerEventJoin extends ServerEventCommand {
+}