Changeset 671e9dd

Timestamp:

Jan 9, 2019 6:41:36 PM (21 months ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

8cd7e7d

Parents:

4ff9092

Message:

I2CP: Stub out client-side creation of meta and enc. LS2

Location:

core/java/src/net/i2p/client/impl

Files:

• RequestLeaseSetMessageHandler.java (modified) (7 diffs)
• RequestVariableLeaseSetMessageHandler.java (modified) (3 diffs)

core/java/src/net/i2p/client/impl/RequestLeaseSetMessageHandler.java

@@ -26 +26 @@
 import net.i2p.data.DataHelper;
 import net.i2p.data.Destination;
+import net.i2p.data.EncryptedLeaseSet;
 import net.i2p.data.Hash;
 import net.i2p.data.Lease;
@@ -31 +32 @@
 import net.i2p.data.LeaseSet;
 import net.i2p.data.LeaseSet2;
+import net.i2p.data.MetaLease;
+import net.i2p.data.MetaLeaseSet;
 import net.i2p.data.PrivateKey;
 import net.i2p.data.PublicKey;
@@ -49 +52 @@
 class RequestLeaseSetMessageHandler extends HandlerImpl {
     private final Map<Destination, LeaseInfo> _existingLeaseSets;
+    protected int _ls2Type = DatabaseEntry.KEY_TYPE_LS2;
 
     // LS 1
@@ -75 +79 @@
     /**
      *  Do we send a LeaseSet or a LeaseSet2?
+     *
+     *  Side effect: sets _ls2Type
+     *
      *  @since 0.9.38
      */
-    protected static boolean requiresLS2(I2PSessionImpl session) {
+    protected boolean requiresLS2(I2PSessionImpl session) {
         if (!session.supportsLS2())
             return false;
@@ -92 +99 @@
             try {
                 int type = Integer.parseInt(s);
+                _ls2Type = type;
                 if (type != DatabaseEntry.KEY_TYPE_LEASESET)
                     return true;
-            } catch (NumberFormatException nfe) {}
+            } catch (NumberFormatException nfe) {
+              session.propogateError("Bad LS2 type", nfe);
+              return true;
+            }
         }
         return false;
@@ -104 +115 @@
         RequestLeaseSetMessage msg = (RequestLeaseSetMessage) message;
         boolean isLS2 = requiresLS2(session);
-        LeaseSet leaseSet = isLS2 ? new LeaseSet2() : new LeaseSet();
+        LeaseSet leaseSet;
+        if (isLS2) {
+            if (_ls2Type == DatabaseEntry.KEY_TYPE_LS2) {
+                leaseSet = new LeaseSet2();
+            } else if (_ls2Type == DatabaseEntry.KEY_TYPE_ENCRYPTED_LS2) {
+                leaseSet = new EncryptedLeaseSet();
+            } else if (_ls2Type == DatabaseEntry.KEY_TYPE_META_LS2) {
+                leaseSet = new MetaLeaseSet();
+            } else {
+              session.propogateError("Unsupported LS2 type", new Exception());
+              return;
+            }
+        } else {
+            leaseSet = new LeaseSet();
+        }
+        // Full Meta and Encrypted support TODO
         for (int i = 0; i < msg.getEndpoints(); i++) {
-            Lease lease = isLS2 ? new Lease2() : new Lease();
+            Lease lease;
+            if (_ls2Type == DatabaseEntry.KEY_TYPE_META_LS2) {
+                lease = new MetaLease();
+            } else if (isLS2) {
+                lease = new Lease2();
+                lease.setTunnelId(msg.getTunnelId(i));
+            } else {
+                lease = new Lease();
+                lease.setTunnelId(msg.getTunnelId(i));
+            }
             lease.setGateway(msg.getRouter(i));
-            lease.setTunnelId(msg.getTunnelId(i));
             lease.setEndDate(msg.getEndDate());
             //lease.setStartDate(msg.getStartDate());
@@ -219 +253 @@
         }
 
-        leaseSet.setEncryptionKey(li.getPublicKey());
+        if (_ls2Type != DatabaseEntry.KEY_TYPE_META_LS2)
+            leaseSet.setEncryptionKey(li.getPublicKey());
         leaseSet.setSigningKey(li.getSigningPublicKey());
         // SubSession options aren't updated via the gui, so use the primary options

core/java/src/net/i2p/client/impl/RequestVariableLeaseSetMessageHandler.java

@@ -11 +11 @@
 
 import net.i2p.I2PAppContext;
+import net.i2p.data.DatabaseEntry;
+import net.i2p.data.EncryptedLeaseSet;
 import net.i2p.data.Lease;
 import net.i2p.data.Lease2;
 import net.i2p.data.LeaseSet;
 import net.i2p.data.LeaseSet2;
+import net.i2p.data.MetaLease;
+import net.i2p.data.MetaLeaseSet;
 import net.i2p.data.i2cp.I2CPMessage;
 import net.i2p.data.i2cp.RequestVariableLeaseSetMessage;
@@ -37 +41 @@
         RequestVariableLeaseSetMessage msg = (RequestVariableLeaseSetMessage) message;
         boolean isLS2 = requiresLS2(session);
-        LeaseSet leaseSet = isLS2 ? new LeaseSet2() : new LeaseSet();
+        LeaseSet leaseSet;
+        if (isLS2) {
+            if (_ls2Type == DatabaseEntry.KEY_TYPE_LS2) {
+                leaseSet = new LeaseSet2();
+            } else if (_ls2Type == DatabaseEntry.KEY_TYPE_ENCRYPTED_LS2) {
+                leaseSet = new EncryptedLeaseSet();
+            } else if (_ls2Type == DatabaseEntry.KEY_TYPE_META_LS2) {
+                leaseSet = new MetaLeaseSet();
+            } else {
+              session.propogateError("Unsupported LS2 type", new Exception());
+              return;
+            }
+        } else {
+            leaseSet = new LeaseSet();
+        }
+        // Full Meta and Encrypted support TODO
         for (int i = 0; i < msg.getEndpoints(); i++) {
             Lease lease;
@@ -43 +62 @@
                 // convert Lease to Lease2
                 Lease old = msg.getEndpoint(i);
-                lease = new Lease2();
+                if (_ls2Type == DatabaseEntry.KEY_TYPE_META_LS2) {
+                    lease = new MetaLease();
+                } else {
+                    lease = new Lease2();
+                    lease.setTunnelId(old.getTunnelId());
+                }
                 lease.setGateway(old.getGateway());
-                lease.setTunnelId(old.getTunnelId());
                 lease.setEndDate(old.getEndDate());
             } else {