extend hopping pt configuarbility. Allow to set min- and maxHopPort, hopJitter and minHopSeconds

2 files changed, 57 insertions, 5 deletions

diff --git a/app/src/main/java/se/leap/bitmaskclient/base/models/Constants.java b/app/src/main/java/se/leap/bitmaskclient/base/models/Constants.java
index 44fc6e89..cc6f3077 100644
--- a/app/src/main/java/se/leap/bitmaskclient/base/models/Constants.java
+++ b/app/src/main/java/se/leap/bitmaskclient/base/models/Constants.java
@@ -203,6 +203,10 @@ public interface Constants {
     String ENDPOINTS = "endpoints";
     String PORT_SEED = "port_seed";
     String PORT_COUNT = "port_count";
+    String HOP_JITTER = "hop_jitter";
+    String MIN_HOP_PORT = "min_hop_port";
+    String MAX_HOP_PORT = "max_hop_port";
+    String MIN_HOP_SECONDS = "min_hop_seconds";
     String EXPERIMENTAL = "experimental";
     String VERSION = "version";
     String NAME = "name";
diff --git a/app/src/main/java/se/leap/bitmaskclient/base/models/Transport.java b/app/src/main/java/se/leap/bitmaskclient/base/models/Transport.java
index abd42812..3b695692 100644
--- a/app/src/main/java/se/leap/bitmaskclient/base/models/Transport.java
+++ b/app/src/main/java/se/leap/bitmaskclient/base/models/Transport.java
@@ -1,10 +1,17 @@
 package se.leap.bitmaskclient.base.models;
 
+import static de.blinkt.openvpn.core.connection.Connection.TransportType.OBFS4_HOP;
 import static de.blinkt.openvpn.core.connection.Connection.TransportType.OPENVPN;
 import static se.leap.bitmaskclient.base.models.Constants.CAPABILITIES;
 import static se.leap.bitmaskclient.base.models.Constants.CERT;
+import static se.leap.bitmaskclient.base.models.Constants.HOP_JITTER;
 import static se.leap.bitmaskclient.base.models.Constants.IAT_MODE;
+import static se.leap.bitmaskclient.base.models.Constants.MAX_HOP_PORT;
+import static se.leap.bitmaskclient.base.models.Constants.MIN_HOP_PORT;
+import static se.leap.bitmaskclient.base.models.Constants.MIN_HOP_SECONDS;
 import static se.leap.bitmaskclient.base.models.Constants.PORTS;
+import static se.leap.bitmaskclient.base.models.Constants.PORT_COUNT;
+import static se.leap.bitmaskclient.base.models.Constants.PORT_SEED;
 import static se.leap.bitmaskclient.base.models.Constants.PROTOCOLS;
 import static se.leap.bitmaskclient.base.models.Constants.TRANSPORT;
 
@@ -21,6 +28,7 @@ import org.json.JSONObject;
 
 import java.io.Serializable;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Vector;
 
 import de.blinkt.openvpn.core.connection.Connection;
@@ -94,6 +102,14 @@ public class Transport implements Serializable {
         }
         Map<String, Object> options = modelsBridge.getOptions();
         Transport.Options transportOptions = new Transport.Options((String) options.get(CERT), (String) options.get(IAT_MODE));
+        if (OBFS4_HOP.toString().equals(modelsBridge.getType())) {
+            transportOptions.minHopSeconds = getIntOption(options, MIN_HOP_SECONDS, 5);
+            transportOptions.minHopPort = getIntOption(options, MIN_HOP_PORT, 49152);
+            transportOptions.maxHopPort = getIntOption(options, MAX_HOP_PORT, 65535);
+            transportOptions.hopJitter = getIntOption(options, HOP_JITTER, 10);
+            transportOptions.portCount = getIntOption(options, PORT_COUNT, 100);
+            transportOptions.portSeed = getIntOption(options, PORT_SEED, 1);
+        }
         Transport transport = new Transport(
                 modelsBridge.getType(),
                 new String[]{modelsBridge.getTransport()},
@@ -103,6 +119,16 @@ public class Transport implements Serializable {
         return transport;
     }
 
+    private static int getIntOption(Map<String, Object> options, String key, int defaultValue) {
+        try {
+            Object o = options.get(key);
+            return (int) o;
+        } catch (NullPointerException | ClassCastException e){
+            e.printStackTrace();
+            return defaultValue;
+        }
+    }
+
     public static Transport createTransportFrom(ModelsGateway modelsGateway) {
         if (modelsGateway == null) {
             return null;
@@ -165,7 +191,6 @@ public class Transport implements Serializable {
         private final String cert;
         @SerializedName("iatMode")
         private final String iatMode;
-
         @Nullable
         private Endpoint[] endpoints;
 
@@ -174,23 +199,30 @@ public class Transport implements Serializable {
         private int portSeed;
 
         private int portCount;
-
+        private int minHopPort;
+        private int maxHopPort;
+        private int minHopSeconds;
+        private int hopJitter;
 
         public Options(String cert, String iatMode) {
             this.cert = cert;
             this.iatMode = iatMode;
         }
 
-        public Options(String iatMode, Endpoint[] endpoints, int portSeed, int portCount, boolean experimental) {
-            this(iatMode, endpoints, null, portSeed, portCount, experimental);
+        public Options(String iatMode, Endpoint[] endpoints, int portSeed, int portCount, int minHopPort, int maxHopPort, int minHopSeconds, int hopJitter, boolean experimental) {
+            this(iatMode, endpoints, null, portSeed, portCount, minHopPort, maxHopPort, minHopSeconds, hopJitter, experimental);
         }
 
-        public Options(String iatMode, Endpoint[] endpoints, String cert, int portSeed, int portCount, boolean experimental) {
+        public Options(String iatMode, Endpoint[] endpoints, String cert, int portSeed, int portCount,  int minHopPort, int maxHopPort, int minHopSeconds, int hopJitter, boolean experimental) {
             this.iatMode = iatMode;
             this.endpoints = endpoints;
             this.portSeed = portSeed;
             this.portCount = portCount;
             this.experimental = experimental;
+            this.minHopPort = minHopPort;
+            this.maxHopPort = maxHopPort;
+            this.minHopSeconds = minHopSeconds;
+            this.hopJitter = hopJitter;
             this.cert = cert;
         }
 
@@ -221,6 +253,22 @@ public class Transport implements Serializable {
             return portCount;
         }
 
+        public int getMinHopPort() {
+            return minHopPort;
+        }
+
+        public int getMaxHopPort() {
+            return maxHopPort;
+        }
+
+        public int getMinHopSeconds() {
+            return minHopSeconds;
+        }
+
+        public int getHopJitter() {
+            return hopJitter;
+        }
+
         @Override
         public String toString() {
             return new Gson().toJson(this);