X: Updated for some manual testing in Main

src/main/tjava/com/r35157/libs/jupiter/perps/impl/anchoridl/AnchorIdlJupiterPerpsCustodyDecoder.tjava

@@ -1,7 +1,8 @@
 package com.r35157.libs.jupiter.perps.impl.anchoridl;
 
+import com.r35157.libs.codec.Base58Codec;
+import com.r35157.libs.codec.impl.ref.Base58CodecImpl;
 import com.r35157.libs.solana.SolanaAccountInfo;
-import org.apache.commons.codec.binary.Base58;
 
 import java.util.Base64;
 
@@ -45,5 +46,5 @@ class AnchorIdlJupiterPerpsCustodyDecoder {
             ANCHOR_DISCRIMINATOR_LENGTH
                     + PUBLIC_KEY_LENGTH; // pool
 
-    private static final Base58 base58 = Base58.getInstance();
+    private static final Base58Codec base58 = new Base58CodecImpl();
 }

src/main/tjava/com/r35157/libs/jupiter/perps/impl/anchoridl/AnchorIdlJupiterPerpsPositionDecoder.tjava

@@ -1,5 +1,7 @@
 package com.r35157.libs.jupiter.perps.impl.anchoridl;
 
+import com.r35157.libs.codec.Base58Codec;
+import com.r35157.libs.codec.impl.ref.Base58CodecImpl;
 import com.r35157.libs.jupiter.perps.JupiterPerpsPosition;
 import com.r35157.libs.jupiter.perps.JupiterPerpsPositionDirection;
 import com.r35157.libs.solana.SolanaAccountInfo;
@@ -46,6 +48,21 @@ class AnchorIdlJupiterPerpsPositionDecoder {
         return pos;
     }
 
+    ΩSolanaAddressΩ decodeCustodyAccount(SolanaAccountInfo accountInfo) {
+        byte[] data = Base64.getDecoder().decode(accountInfo.dataBase64());
+
+        if (data.length < CUSTODY_OFFSET + PUBLIC_KEY_LENGTH) {
+            throw new IllegalArgumentException(
+                    "Jupiter Perps position account data is too short: " + data.length
+            );
+        }
+
+        return readPublicKey(
+                data,
+                CUSTODY_OFFSET
+        );
+    }
+
     private JupiterPerpsPositionDirection decodeDirection(
             byte rawSide
     ) {
@@ -61,22 +78,37 @@ class AnchorIdlJupiterPerpsPositionDecoder {
         return direction;
     }
 
+    private ΩSolanaAddressΩ readPublicKey(
+            byte[] data,
+            int offset
+    ) {
+        byte[] publicKeyBytes = new byte[PUBLIC_KEY_LENGTH];
+
+        System.arraycopy(
+                data,
+                offset,
+                publicKeyBytes,
+                0,
+                PUBLIC_KEY_LENGTH
+        );
+
+        return base58.encode(publicKeyBytes);
+    }
+
     private static final int ANCHOR_DISCRIMINATOR_LENGTH = 8;
     private static final int PUBLIC_KEY_LENGTH = 32;
     private static final int I64_LENGTH = 8;
-    private static final int U64_LENGTH = 8;
     private static final int SIDE_ENUM_LENGTH = 1;
+    private static final int U64_LENGTH = 8;
 
-    private static final int SIDE_OFFSET =
+    private static final int OWNER_OFFSET = ANCHOR_DISCRIMINATOR_LENGTH;
-            ANCHOR_DISCRIMINATOR_LENGTH
+    private static final int POOL_OFFSET = OWNER_OFFSET + PUBLIC_KEY_LENGTH;
-                    + PUBLIC_KEY_LENGTH // owner
+    private static final int CUSTODY_OFFSET = POOL_OFFSET + PUBLIC_KEY_LENGTH;
-                    + PUBLIC_KEY_LENGTH // pool
+    private static final int COLLATERAL_CUSTODY_OFFSET = CUSTODY_OFFSET + PUBLIC_KEY_LENGTH; // custody
-                    + PUBLIC_KEY_LENGTH // custody
+    private static final int OPEN_TIME_OFFSET = COLLATERAL_CUSTODY_OFFSET + PUBLIC_KEY_LENGTH;
-                    + PUBLIC_KEY_LENGTH // collateralCustody
+    private static final int UPDATE_TIME_OFFSET = OPEN_TIME_OFFSET + I64_LENGTH; // openTime
-                    + I64_LENGTH        // openTime
+    private static final int SIDE_OFFSET = UPDATE_TIME_OFFSET + I64_LENGTH;
-                    + I64_LENGTH;       // updateTime
+    private static final int PRICE_OFFSET = SIDE_OFFSET + SIDE_ENUM_LENGTH;
 
-    private static final int PRICE_OFFSET =
+    private static final Base58Codec base58 = new Base58CodecImpl();
-            SIDE_OFFSET
-                    + SIDE_ENUM_LENGTH; // side
 }

src/main/tjava/com/r35157/libs/jupiter/perps/impl/anchoridl/AnchorIdlJupiterPerpsServiceImpl.tjava

@@ -17,6 +17,7 @@ public class AnchorIdlJupiterPerpsServiceImpl implements JupiterPerpsService {
     ) {
         this.solanaBlockChain = solanaBlockChain;
         this.positionDecoder = new AnchorIdlJupiterPerpsPositionDecoder();
+        this.custodyDecoder = new AnchorIdlJupiterPerpsCustodyDecoder();
     }
 
     @Override
@@ -94,4 +95,5 @@ public class AnchorIdlJupiterPerpsServiceImpl implements JupiterPerpsService {
 
     private final SolanaBlockChain solanaBlockChain;
     private final AnchorIdlJupiterPerpsPositionDecoder positionDecoder;
+    private final AnchorIdlJupiterPerpsCustodyDecoder custodyDecoder;
 }

src/main/tjava/com/r35157/nenjim/hubd/impl/ref/Main.tjava

@@ -24,9 +24,10 @@ public class Main {
     // TODO: Consider if we really need a Main class or we just need to move the main method to NenjimHubImpl?
     static void main(String[] args) throws Exception {
         NenjimHubImpl nenjimHub = new NenjimHubImpl();
+
         /*
         SolanaBlockChain sbc = new SolanaBlockChainImpl();
-        JupiterPerpsPositionService jupiter = new AnchorIdlJupiterPerpsPositionServiceImpl(sbc);
+        JupiterPerpsService jupiter = new AnchorIdlJupiterPerpsServiceImpl(sbc);
         ΩSolanaWalletIdΩ walletId = "vj98roDZ7744EBfxyuDFkKpEGCsKQLr7K8UFRumJNHf";
         Set<JupiterPerpsPosition> positions = jupiter.getOpenPositions(walletId);
         int a=0;