add serialization for FailedConnectionAttempt list

Author: marv1913

src/main/java/net/sharksystem/hub/BasicHubConnectionManager.java

@@ -68,12 +68,7 @@ protected void syncLists() {
                 }
             }
             if(recordedOldAttempt != null) this.failedConnectionAttempts.remove(recordedOldAttempt);
-            this.failedConnectionAttempts.add(new HubConnectionManager.FailedConnectionAttempt() {
-                @Override
-                public HubConnectorDescription getHubConnectorDescription() { return failedConnection; }
-                @Override
-                public long getTimeStamp() { return lastConnectionAttempt; }
-            });
+            this.failedConnectionAttempts.add(new FailedConnectionAttemptImpl(failedConnection, lastConnectionAttempt));
         }
     }
 

src/main/java/net/sharksystem/hub/FailedConnectionAttemptImpl.java

@@ -0,0 +1,63 @@
+package net.sharksystem.hub;
+
+import net.sharksystem.asap.ASAPException;
+import net.sharksystem.asap.utils.ASAPSerialization;
+import net.sharksystem.hub.peerside.HubConnectorDescription;
+import net.sharksystem.hub.peerside.TCPHubConnectorDescriptionImpl;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class FailedConnectionAttemptImpl implements HubConnectionManager.FailedConnectionAttempt {
+
+    private final HubConnectorDescription hubConnectorDescription;
+    private final long timestamp;
+
+    public FailedConnectionAttemptImpl(HubConnectorDescription hubConnectorDescription, long timestamp){
+        this.hubConnectorDescription = hubConnectorDescription;
+        this.timestamp = timestamp;
+    }
+
+    @Override
+    public HubConnectorDescription getHubConnectorDescription() {
+        return hubConnectorDescription;
+    }
+
+    @Override
+    public long getTimeStamp() {
+        return timestamp;
+    }
+
+    public static byte[] serializeFailedConnectionAttempts(List<HubConnectionManager.FailedConnectionAttempt> failedConnectionAttempts) throws IOException {
+        ByteArrayOutputStream baos = new ByteArrayOutputStream();
+        if(failedConnectionAttempts == null || failedConnectionAttempts.isEmpty()) {
+            // no hcd
+            ASAPSerialization.writeIntegerParameter(0, baos);
+        }else {
+            // write number of descriptions
+            ASAPSerialization.writeIntegerParameter(failedConnectionAttempts.size(), baos);
+            for (HubConnectionManager.FailedConnectionAttempt failedConnectionAttempt : failedConnectionAttempts) {
+                // HubConnectorDescription
+                baos.write(failedConnectionAttempt.getHubConnectorDescription().serialize());
+                // timestamp
+                ASAPSerialization.writeLongParameter(failedConnectionAttempt.getTimeStamp(), baos);
+            }
+        }
+        return baos.toByteArray();
+    }
+
+    public static List<HubConnectionManager.FailedConnectionAttempt> deserializeFailedConnectionAttempts(byte[] serializedConnectionAttempts) throws IOException, ASAPException {
+        List<HubConnectionManager.FailedConnectionAttempt> connectionAttempts = new ArrayList<>();
+        ByteArrayInputStream is = new ByteArrayInputStream(serializedConnectionAttempts);
+        int number = ASAPSerialization.readIntegerParameter(is);
+        while(number-- > 0) {
+            HubConnectorDescription hcd = TCPHubConnectorDescriptionImpl.readDescription(is);
+            long timestamp = ASAPSerialization.readLongParameter(is);
+            connectionAttempts.add(new FailedConnectionAttemptImpl(hcd, timestamp));
+        }
+        return connectionAttempts;
+    }
+}

src/test/java/net/sharksystem/hub/FailedConnectionAttemptImplTest.java

@@ -0,0 +1,39 @@
+package net.sharksystem.hub;
+
+import net.sharksystem.asap.ASAPException;
+import net.sharksystem.hub.peerside.HubConnectorDescription;
+import net.sharksystem.hub.peerside.TCPHubConnectorDescriptionImpl;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.Assert.*;
+
+public class FailedConnectionAttemptImplTest {
+
+    @Test
+    public void serializeFailedConnectionAttempts() throws IOException, ASAPException {
+        HubConnectorDescription hubConnectorDescription1 = new TCPHubConnectorDescriptionImpl("localhost", 6000);
+        HubConnectorDescription hubConnectorDescription2 = new TCPHubConnectorDescriptionImpl("localhost", 6600);
+        long timestamp1 = 10;
+        long timestamp2 = 10;
+        List<HubConnectionManager.FailedConnectionAttempt> failedConnectionAttempts = new ArrayList<>();
+        failedConnectionAttempts.add(new FailedConnectionAttemptImpl(hubConnectorDescription1, timestamp1));
+        failedConnectionAttempts.add(new FailedConnectionAttemptImpl(hubConnectorDescription2, timestamp2));
+
+        byte[] serializedAttempts = FailedConnectionAttemptImpl.serializeFailedConnectionAttempts(failedConnectionAttempts);
+
+        List<HubConnectionManager.FailedConnectionAttempt> deserializedAttempts = FailedConnectionAttemptImpl.deserializeFailedConnectionAttempts(serializedAttempts);
+
+        // list should contain two items
+        assertEquals(2, deserializedAttempts.size());
+        // verify first FailedConnectionAttempt
+        assertTrue(deserializedAttempts.get(0).getHubConnectorDescription().isSame(hubConnectorDescription1));
+        assertEquals(timestamp1, deserializedAttempts.get(0).getTimeStamp());
+        // verify second FailedConnectionAttempt
+        assertTrue(deserializedAttempts.get(1).getHubConnectorDescription().isSame(hubConnectorDescription2));
+        assertEquals(timestamp2, deserializedAttempts.get(1).getTimeStamp());
+    }
+}