encoders and decoders for the hosted games request message with datatype and test

#story[1188]

racevisionGame/src/main/java/network/MessageDecoders/HostedGamesRequestDecoder.java

@@ -0,0 +1,34 @@
+package network.MessageDecoders;
+
+import network.Exceptions.InvalidMessageException;
+import network.Messages.AC35Data;
+import network.Messages.HostGame;
+import network.Messages.HostGamesRequest;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import static network.Utils.ByteConverter.bytesToInt;
+
+public class HostedGamesRequestDecoder  implements MessageDecoder{
+    @Override
+    public AC35Data decode(byte[] encodedMessage) throws InvalidMessageException {
+        try{
+            int numberOfGames = bytesToInt(Arrays.copyOfRange(encodedMessage, 0, 4));
+
+            HostGameMessageDecoder lineDecoder = new HostGameMessageDecoder();
+            List<HostGame> knownGames = new ArrayList<>();
+            int byteIndex = 4;
+            for (int i = 0; i < numberOfGames; i++){
+                knownGames.add((HostGame) lineDecoder.decode(Arrays.copyOfRange(encodedMessage, byteIndex, byteIndex+14)));
+                byteIndex += 14;
+            }
+
+            return new HostGamesRequest(knownGames);
+
+        } catch (Exception e) {
+            throw new InvalidMessageException("Could not decode Host game message.", e);
+        }
+    }
+}

racevisionGame/src/main/java/network/MessageEncoders/HostedGamesRequestEncoder.java

@@ -0,0 +1,44 @@
+package network.MessageEncoders;
+
+import network.Exceptions.InvalidMessageException;
+import network.Messages.AC35Data;
+import network.Messages.HostGame;
+import network.Messages.HostGamesRequest;
+
+import java.nio.ByteBuffer;
+import java.util.List;
+
+import static network.Utils.ByteConverter.intToBytes;
+
+public class HostedGamesRequestEncoder implements MessageEncoder{
+
+    /**
+     * Constructor
+     */
+    public HostedGamesRequestEncoder() {
+    }
+
+    @Override
+    public byte[] encode(AC35Data message) throws InvalidMessageException {
+        try{
+            //Downcast
+            HostGamesRequest hostGamesRequest = (HostGamesRequest) message;
+
+            int numGames = hostGamesRequest.getKnownGames().size();
+
+            ByteBuffer hostedGamesRequestMessage = ByteBuffer.allocate(4+14*numGames);
+
+            hostedGamesRequestMessage.put(intToBytes(numGames));
+
+            HostGameMessageEncoder lineEncoder = new HostGameMessageEncoder();
+            for (HostGame line: hostGamesRequest.getKnownGames()) {
+                hostedGamesRequestMessage.put(lineEncoder.encode(line));
+            }
+
+            return hostedGamesRequestMessage.array();
+
+        }catch(Exception e){
+            throw new InvalidMessageException("Could not encode Host game message.", e);
+        }
+    }
+}

racevisionGame/src/main/java/network/Messages/Enums/MessageType.java

@@ -41,6 +41,8 @@ public enum MessageType {
 
     HOST_GAME(108),
 
+    HOSTED_GAMES_REQUEST(109),
+
     NOTAMESSAGE(0);
 
 

racevisionGame/src/main/java/network/Messages/HostGamesRequest.java

@@ -0,0 +1,22 @@
+package network.Messages;
+
+import network.Messages.Enums.MessageType;
+
+import java.util.List;
+
+public class HostGamesRequest extends AC35Data{
+
+    private List<HostGame> knownGames;
+
+    /**
+     * Constructor
+     */
+    public HostGamesRequest(List knownGames) {
+        super(MessageType.HOSTED_GAMES_REQUEST);
+        this.knownGames = knownGames;
+    }
+
+    public List<HostGame> getKnownGames() {
+        return knownGames;
+    }
+}

racevisionGame/src/test/java/network/MessageDecoders/HostedGamesRequestDecoderTest.java

@@ -0,0 +1,38 @@
+package network.MessageDecoders;
+
+
+import network.MessageEncoders.HostGameMessageEncoder;
+import network.MessageEncoders.HostedGamesRequestEncoder;
+import network.Messages.Enums.RaceStatusEnum;
+import network.Messages.HostGame;
+import network.Messages.HostGamesRequest;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.util.Arrays;
+import java.util.List;
+
+public class HostedGamesRequestDecoderTest {
+    @Test
+    public void hostGamesRequestMessageDecoderTest() throws Exception {
+        HostGame testHostGame1 = new HostGame("127.0.0.1", 3779, (byte) 1, (byte) 2, RaceStatusEnum.PRESTART, (byte) 6, (byte) 2);
+        HostGame testHostGame2 = new HostGame("127.0.0.1", 3780, (byte) 1, (byte) 2, RaceStatusEnum.PRESTART, (byte) 6, (byte) 2);
+
+        List knownGames = Arrays.asList(testHostGame1, testHostGame2);
+
+        HostedGamesRequestEncoder encoder = new HostedGamesRequestEncoder();
+
+        byte[] encodedMessage = encoder.encode(new HostGamesRequest(knownGames));
+
+        HostedGamesRequestDecoder decoder = new HostedGamesRequestDecoder();
+
+        HostGamesRequest decodedTest = (HostGamesRequest) decoder.decode(encodedMessage);
+
+        compareHostGamesRequestMessage(knownGames, decodedTest.getKnownGames());
+    }
+
+    public static void compareHostGamesRequestMessage(List<HostGame> original, List<HostGame> decoded) {
+        Assert.assertEquals(original.get(0).getIp(), decoded.get(0).getIp());
+        Assert.assertEquals(original.get(1).getPort(), decoded.get(1).getPort());
+    }
+}