17: Implement AnchorIdlJupiterPerpsCustodyDecoder

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

@@ -1,8 +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.solana.SolanaAccountInfo;
+import org.apache.commons.codec.binary.Base58;
 
 import java.util.Base64;
 
@@ -46,5 +45,5 @@ class AnchorIdlJupiterPerpsCustodyDecoder {
             ANCHOR_DISCRIMINATOR_LENGTH
                     + PUBLIC_KEY_LENGTH; // pool
 
-    private static final Base58Codec base58 = new Base58CodecImpl();
+    private static final Base58 base58 = Base58.getInstance();
 }

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

@@ -1,7 +1,5 @@
 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;
@@ -48,21 +46,6 @@ 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
     ) {
@@ -78,37 +61,22 @@ 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 SIDE_ENUM_LENGTH = 1;
     private static final int U64_LENGTH = 8;
+    private static final int SIDE_ENUM_LENGTH = 1;
 
-    private static final int OWNER_OFFSET = ANCHOR_DISCRIMINATOR_LENGTH;
-    private static final int POOL_OFFSET = OWNER_OFFSET + PUBLIC_KEY_LENGTH;
-    private static final int CUSTODY_OFFSET = POOL_OFFSET + PUBLIC_KEY_LENGTH;
-    private static final int COLLATERAL_CUSTODY_OFFSET = CUSTODY_OFFSET + PUBLIC_KEY_LENGTH; // custody
-    private static final int OPEN_TIME_OFFSET = COLLATERAL_CUSTODY_OFFSET + PUBLIC_KEY_LENGTH;
-    private static final int UPDATE_TIME_OFFSET = OPEN_TIME_OFFSET + I64_LENGTH; // openTime
-    private static final int SIDE_OFFSET = UPDATE_TIME_OFFSET + I64_LENGTH;
-    private static final int PRICE_OFFSET = SIDE_OFFSET + SIDE_ENUM_LENGTH;
+    private static final int SIDE_OFFSET =
+            ANCHOR_DISCRIMINATOR_LENGTH
+                    + PUBLIC_KEY_LENGTH // owner
+                    + PUBLIC_KEY_LENGTH // pool
+                    + PUBLIC_KEY_LENGTH // custody
+                    + PUBLIC_KEY_LENGTH // collateralCustody
+                    + I64_LENGTH        // openTime
+                    + I64_LENGTH;       // updateTime
 
-    private static final Base58Codec base58 = new Base58CodecImpl();
+    private static final int PRICE_OFFSET =
+            SIDE_OFFSET
+                    + SIDE_ENUM_LENGTH; // side
 }

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

@@ -17,7 +17,6 @@ public class AnchorIdlJupiterPerpsServiceImpl implements JupiterPerpsService {
     ) {
         this.solanaBlockChain = solanaBlockChain;
         this.positionDecoder = new AnchorIdlJupiterPerpsPositionDecoder();
-        this.custodyDecoder = new AnchorIdlJupiterPerpsCustodyDecoder();
     }
 
     @Override
@@ -95,5 +94,4 @@ 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,10 +24,9 @@ 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();
-        JupiterPerpsService jupiter = new AnchorIdlJupiterPerpsServiceImpl(sbc);
+        JupiterPerpsPositionService jupiter = new AnchorIdlJupiterPerpsPositionServiceImpl(sbc);
         ΩSolanaWalletIdΩ walletId = "vj98roDZ7744EBfxyuDFkKpEGCsKQLr7K8UFRumJNHf";
         Set<JupiterPerpsPosition> positions = jupiter.getOpenPositions(walletId);
         int a=0;