AdnlLiteClient - WIP

Author: neodix42

adnl/src/main/java/org/ton/java/adnl/AdnlTcpTransport.java

@@ -4,6 +4,7 @@
 import java.net.*;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
+import java.nio.charset.StandardCharsets;
 import java.security.MessageDigest;
 import java.security.SecureRandom;
 import java.util.*;
@@ -150,7 +151,7 @@ private byte[] calculateKeyId(byte[] publicKey) throws Exception {
     // Calculate TL constructor ID for pub.ed25519 schema
     String tlSchema = "pub.ed25519 key:int256 = PublicKey";
     CRC32 crc32 = new CRC32();
-    crc32.update(tlSchema.getBytes("UTF-8"));
+    crc32.update(tlSchema.getBytes(StandardCharsets.UTF_8));
     long constructorId = crc32.getValue();
 
     // Build TL-serialized structure: constructor_id + key
@@ -176,7 +177,7 @@ private void waitForHandshakeConfirmation() throws Exception {
     long timeout = System.currentTimeMillis() + 10000; // 10 second timeout
 
     while (System.currentTimeMillis() < timeout && !connected) {
-      Thread.sleep(100);
+      Utils.sleepMs(100);
       // Check if listener thread is still running
       if (listenerThread != null && !listenerThread.isAlive()) {
         throw new Exception("Packet listener thread died during handshake");
@@ -211,9 +212,6 @@ private void listenForPackets() {
         if (packetSizeLong > 16 * 1024 * 1024) { // 16MB limit
           throw new IOException("Packet too large: " + packetSizeLong);
         }
-        if (packetSizeLong < 0) { // Negative size is invalid
-          throw new IOException("Invalid packet size: " + packetSizeLong);
-        }
 
         int packetSize = (int) packetSizeLong;
 

adnl/src/main/java/org/ton/java/adnl/CryptoUtils.java

@@ -27,8 +27,7 @@ public class CryptoUtils {
   public static byte[] getSharedKey(byte[] privateKey, byte[] publicKey) {
     TweetNaclFast.Box box = new TweetNaclFast.Box(publicKey, privateKey);
     byte[] zero = new byte[24];
-    byte[] sharedKey = box.before();
-    return sharedKey;
+    return box.before();
   }
 
   /**

adnl/src/main/java/org/ton/java/adnl/LiteClientConnectionPool.java

@@ -5,6 +5,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.function.Function;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.NotImplementedException;
 import org.ton.java.adnl.globalconfig.LiteServers;
 import org.ton.java.adnl.globalconfig.TonGlobalConfig;
 import org.ton.ton4j.utils.Utils;
@@ -23,8 +24,9 @@ public class LiteClientConnectionPool {
 
   /** Create connection pool */
   public LiteClientConnectionPool() {
-    this.healthChecker = Executors.newSingleThreadScheduledExecutor();
-    startHealthChecker();
+    throw new NotImplementedException();
+    // this.healthChecker = Executors.newSingleThreadScheduledExecutor();
+    // startHealthChecker();
   }
 
   /**

adnl/src/main/java/org/ton/java/adnl/Server.java

@@ -722,6 +722,17 @@ void testGetTransactionsByLtHash() throws Exception {
     }
   }
 
+  @Test
+  void testLookupBlockMode1() throws Exception { // by LT
+    log.info("Testing lookupBlock query");
+    assertTrue(client.isConnected(), "Client should be connected");
+
+    MasterchainInfo masterchainInfo = client.getMasterchainInfo();
+
+    BlockHeader blockHeader = client.lookupBlock(masterchainInfo.getLast().getBlockId(), 1, 0, 0);
+    log.info("blockHeader {}", blockHeader);
+  }
+
   @Test
   void testLookupBlockMode2() throws Exception { // by LT
     log.info("Testing lookupBlock query");
@@ -1132,10 +1143,9 @@ void testValidatorStatsMode4() throws Exception {
 
     MasterchainInfo masterchainInfo = client.getMasterchainInfo();
     ValidatorStats validatorStats =
-        client.getValidatorStats(masterchainInfo.getLast(), 4, 10, null, 0);
+        client.getValidatorStats(masterchainInfo.getLast(), 4, 10, new byte[32], 0);
 
     log.info("validatorStats {}", validatorStats);
-    // todo
   }
 
   @Test