Added reconnect logic

Author: joshbooks

README.md

@@ -46,7 +46,7 @@ Step 2: Add dependency to pom.xml:
 <dependency>
     <groupId>com.github.CaliDog</groupId>
     <artifactId>certstream-java</artifactId>
-    <version>0.2</version>
+    <version>0.3</version>
 </dependency>
 ```
 

src/io/calidog/certstream/BoringParts.java

@@ -1,11 +1,16 @@
 package io.calidog.certstream;
 
+import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.handshake.ServerHandshake;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.function.Supplier;
+
 /**
- * The class that takes care of ll the boring parts
+ * The class that takes care of all the boring parts
  * of talking over WebSockets, most notably the onClose
  * which will get called if your internet connection
  * hiccups.
@@ -15,15 +20,50 @@ public class BoringParts implements
         CertStreamCloseHandler,
         CertStreamOpenHandler {
     private static final Logger logger = LoggerFactory.getLogger(BoringParts.class);
-    private boolean notClosed = true;
+    private final long sleepBeforeReconnect;
+
+    private HashSet<Integer> recoverableCloseCodes = new HashSet<>(Arrays.asList(1001, 1005, 1006, 1009));
+
+    private final Supplier<WebSocketClient> webSocketClientSupplier;
+    private WebSocketClient webSocketClient;
+
+    private final CertStreamClientImplFactory defaultImplFactory =
+            new CertStreamClientImplFactory(this,
+                    this,
+                    this);
+
+    public BoringParts(CertStreamStringMessageHandler handler)
+    {
+        this(handler, 0);
+    }
+
+    public BoringParts(CertStreamStringMessageHandler messageHandler, long sleepBeforeReconnect) {
+        this.sleepBeforeReconnect = sleepBeforeReconnect;
+        this.webSocketClientSupplier = () -> defaultImplFactory.make(messageHandler);
+        webSocketClient = webSocketClientSupplier.get();
+    }
 
     //todo reconnection logic
     @Override
     public void onClose(int i, String s, boolean b) {
         logger.warn("OnClose was called wih i = " + i + ", s = "+s + ", b = b");
         System.out.println("OnClose was called wih i = " + i + ", s = "+s + ", b = b");
 
-        notClosed = false;
+        if (recoverableCloseCodes.contains(i))
+        {
+            if (sleepBeforeReconnect >= 0)
+            {
+                try {
+                    Thread.yield();
+                    Thread.sleep(sleepBeforeReconnect);
+                } catch (InterruptedException e) {
+                    logger.info("Thread sleep interrupted, weird, exiting", e);
+                    return;
+                }
+            }
+
+            webSocketClient = webSocketClientSupplier.get();
+        }
     }
 
     @Override
@@ -51,6 +91,6 @@ public void onOpen(ServerHandshake serverHandshake) {
      * @return whether or not onClose has been called
      */
     public boolean isNotClosed() {
-        return notClosed;
+        return !webSocketClient.isClosed();
     }
 }

src/io/calidog/certstream/CertStream.java

@@ -15,13 +15,6 @@ public class CertStream{
 
     private static final Logger logger = LoggerFactory.getLogger(CertStream.class);
 
-    private static BoringParts theBoringParts = new BoringParts();
-
-    private static CertStreamClientImplFactory defaultImplFactory =
-            new CertStreamClientImplFactory(theBoringParts,
-                    theBoringParts,
-                    theBoringParts);
-
     /**
      * @param handler A {@link Consumer<String>} that we'll
      *                run in a Thread that stays alive as long
@@ -31,14 +24,17 @@ public static void onMessageString(Consumer<String> handler)
     {
         new Thread(() ->
         {
-            defaultImplFactory.make(handler::accept);
+            BoringParts theBoringParts = new BoringParts(handler::accept);
 
             while (theBoringParts.isNotClosed())
             {
                 Thread.yield();
                 try {
-                    Thread.sleep(3000);
-                } catch (InterruptedException e) {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {}
+
+                if (Thread.interrupted())
+                {
                     break;
                 }
             }

src/io/calidog/certstream/CertStreamClientImpl.java

@@ -7,11 +7,9 @@
 import java.net.URISyntaxException;
 
 public class CertStreamClientImpl extends WebSocketClient{
-
     private static final String certStreamUriString = "wss://certstream.calidog.io";
 
     private static URI tempUri = null;
-
     static {
         try
         {