Add page signatures for address example.

examples/src/main/java/software/sava/anchor/program/examples/PageMeteoraTransactions.java

@@ -0,0 +1,112 @@
+package software.sava.anchor.program.examples;
+
+import software.sava.anchor.programs.meteora.dlmm.anchor.LbClmmProgram;
+import software.sava.core.accounts.PublicKey;
+import software.sava.core.tx.TransactionSkeleton;
+import software.sava.rpc.json.http.client.SolanaRpcClient;
+
+import java.net.http.HttpClient;
+import java.util.Arrays;
+import java.util.Base64;
+
+import static software.sava.rpc.json.http.SolanaNetwork.MAIN_NET;
+
+public final class PageMeteoraTransactions {
+
+  public static void main(final String[] args) throws InterruptedException {
+    final var meteoraProgramId = PublicKey.fromBase58Encoded("LBUZKhRxPF3XUpBCjp4YzTKgLccjZhTSDM9YuVaPwxo");
+
+    try (final var httpClient = HttpClient.newHttpClient()) {
+      final var rpcEndpoint = MAIN_NET.getEndpoint();
+      final var rpcClient = SolanaRpcClient.createClient(rpcEndpoint, httpClient);
+
+      final int pageLimit = 100;
+      long beginRequest = System.currentTimeMillis();
+      var signaturesFuture = rpcClient.getSignaturesForAddress(
+          meteoraProgramId, pageLimit
+      );
+
+      for (long minMillisBetweenRequests = 5_000; ; ) {
+        final var signatures = signaturesFuture.join();
+        System.out.format("Fetched %d signatures%n", signatures.size());
+
+        if (signatures.isEmpty()) {
+          break;
+        }
+
+        for (final var txSig : signatures) {
+          final var signature = txSig.signature();
+          System.out.format("""
+              ------------------------------------------------------------------------------------
+              %s
+              
+              """, signature);
+
+          delay(minMillisBetweenRequests, beginRequest);
+          beginRequest = System.currentTimeMillis();
+          final var transactionFuture = rpcClient.getTransaction(signature);
+          final var transaction = transactionFuture.join();
+          final var txData = transaction.data();
+
+          try {
+            final var skeleton = TransactionSkeleton.deserializeSkeleton(txData);
+
+            final var instructions = skeleton.isLegacy()
+                ? skeleton.parseInstructions(skeleton.parseAccounts())
+                : skeleton.parseInstructionsWithoutAccounts();
+
+            final var addLiquidityIxParams = Arrays.stream(instructions)
+                .filter(LbClmmProgram.ADD_LIQUIDITY_BY_STRATEGY_DISCRIMINATOR)
+                .map(LbClmmProgram.AddLiquidityByStrategyIxData::read)
+                .map(LbClmmProgram.AddLiquidityByStrategyIxData::liquidityParameter)
+                .toList();
+            for (final var addLiquidityIxParam : addLiquidityIxParams) {
+              System.out.format("""
+                      Found add-liquidity-by-strategy with the following params on block %d:
+                      AmountX: %d
+                      AmountY: %d
+                      ActiveId: %d
+                      MaxActiveBinSlippage: %d
+                      MinBinId: %d
+                      MaxBinId: %d
+                      StrategyType: %s
+                      Transaction: %s
+                      
+                      """,
+                  transaction.blockTime().orElse(-1),
+                  addLiquidityIxParam.amountX(),
+                  addLiquidityIxParam.amountY(),
+                  addLiquidityIxParam.activeId(),
+                  addLiquidityIxParam.maxActiveBinSlippage(),
+                  addLiquidityIxParam.strategyParameters().minBinId(),
+                  addLiquidityIxParam.strategyParameters().maxBinId(),
+                  addLiquidityIxParam.strategyParameters().strategyType(),
+                  transaction);
+            }
+            System.out.format("Contained %d add liquidity instructions.%n", addLiquidityIxParams.size());
+          } catch (final RuntimeException ex) {
+            System.out.println(Base64.getEncoder().encodeToString(txData));
+            throw ex;
+          }
+        }
+
+        delay(minMillisBetweenRequests, beginRequest);
+        beginRequest = System.currentTimeMillis();
+        signaturesFuture = rpcClient.getSignaturesForAddressBefore(
+            meteoraProgramId, pageLimit, signatures.getLast().signature()
+        );
+      }
+    }
+  }
+
+  private static void delay(final long minMillisBetweenRequests, final long beginRequest) throws InterruptedException {
+    final long millisBetweenRequests = System.currentTimeMillis() - beginRequest;
+    final long sleepMillis = minMillisBetweenRequests - millisBetweenRequests;
+    if (sleepMillis > 0) {
+      Thread.sleep(sleepMillis);
+    }
+  }
+
+  private PageMeteoraTransactions() {
+  }
+}

examples/src/main/java/software/sava/anchor/program/examples/ParseDriftPlaceOrdersTransaction.java

@@ -11,7 +11,6 @@
 import software.sava.core.accounts.meta.AccountMeta;
 import software.sava.core.tx.Instruction;
 import software.sava.core.tx.TransactionSkeleton;
-import software.sava.rpc.json.http.SolanaNetwork;
 import software.sava.rpc.json.http.client.SolanaRpcClient;
 import software.sava.rpc.json.http.response.AccountInfo;
 import software.sava.solana.programs.clients.NativeProgramClient;
@@ -23,12 +22,14 @@
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
+import static software.sava.rpc.json.http.SolanaNetwork.MAIN_NET;
+
 public final class ParseDriftPlaceOrdersTransaction {
 
   public static void main(final String[] args) {
     try (final var httpClient = HttpClient.newHttpClient()) {
 
-      final var rpcClient = SolanaRpcClient.createClient(SolanaNetwork.MAIN_NET.getEndpoint(), httpClient);
+      final var rpcClient = SolanaRpcClient.createClient(MAIN_NET.getEndpoint(), httpClient);
 
       // Fetch a Drift placeOrders Transaction
       final var txFuture = rpcClient.getTransaction(

settings.gradle

@@ -18,7 +18,7 @@ dependencyResolutionManagement {
   }
   versionCatalogs {
     libs {
-      from("software.sava:solana-version-catalog:0.2.10")
+      from("software.sava:solana-version-catalog:0.2.29")
     }
   }
 }