Add AMM support

xrpl4j-client/src/main/java/org/xrpl/xrpl4j/client/XrplClient.java

@@ -55,6 +55,8 @@
 import org.xrpl.xrpl4j.model.client.accounts.AccountTransactionsResult;
 import org.xrpl.xrpl4j.model.client.accounts.GatewayBalancesRequestParams;
 import org.xrpl.xrpl4j.model.client.accounts.GatewayBalancesResult;
+import org.xrpl.xrpl4j.model.client.amm.AmmInfoRequestParams;
+import org.xrpl.xrpl4j.model.client.amm.AmmInfoResult;
 import org.xrpl.xrpl4j.model.client.channels.ChannelVerifyRequestParams;
 import org.xrpl.xrpl4j.model.client.channels.ChannelVerifyResult;
 import org.xrpl.xrpl4j.model.client.common.LedgerIndex;
@@ -762,6 +764,26 @@ public GatewayBalancesResult gatewayBalances(
     return jsonRpcClient.send(request, GatewayBalancesResult.class);
   }
 
+  /**
+   * Get info about an AMM by making a call to the amm_info rippled RPC method.
+   *
+   * @param params The {@link AmmInfoRequestParams} to send in the request.
+   *
+   * @return A {@link AmmInfoResult}.
+   * @throws JsonRpcClientErrorException if {@code jsonRpcClient} throws an error.
+   */
+  @Beta
+  public AmmInfoResult ammInfo(
+    AmmInfoRequestParams params
+  ) throws JsonRpcClientErrorException {
+    JsonRpcRequest request = JsonRpcRequest.builder()
+      .method(XrplMethods.AMM_INFO)
+      .addParams(params)
+      .build();
+
+    return jsonRpcClient.send(request, AmmInfoResult.class);
+  }
+
   public JsonRpcClient getJsonRpcClient() {
     return jsonRpcClient;
   }

xrpl4j-client/src/test/java/org/xrpl/xrpl4j/client/XrplClientTest.java

@@ -70,6 +70,8 @@
 import org.xrpl.xrpl4j.model.client.accounts.AccountTransactionsResult;
 import org.xrpl.xrpl4j.model.client.accounts.GatewayBalancesRequestParams;
 import org.xrpl.xrpl4j.model.client.accounts.GatewayBalancesResult;
+import org.xrpl.xrpl4j.model.client.amm.AmmInfoRequestParams;
+import org.xrpl.xrpl4j.model.client.amm.AmmInfoResult;
 import org.xrpl.xrpl4j.model.client.channels.ChannelVerifyRequestParams;
 import org.xrpl.xrpl4j.model.client.channels.ChannelVerifyResult;
 import org.xrpl.xrpl4j.model.client.common.LedgerIndex;
@@ -1025,6 +1027,20 @@ public void nftSellOffers() throws JsonRpcClientErrorException {
     assertThat(jsonRpcRequestArgumentCaptor.getValue().params().get(0)).isEqualTo(nftSellOffersRequestParams);
   }
 
+  @Test
+  void ammInfo() throws JsonRpcClientErrorException {
+    AmmInfoRequestParams params = mock(AmmInfoRequestParams.class);
+    JsonRpcRequest expectedRequest = JsonRpcRequest.builder()
+      .method(XrplMethods.AMM_INFO)
+      .addParams(params)
+      .build();
+    AmmInfoResult mockResult = mock(AmmInfoResult.class);
+    when(jsonRpcClientMock.send(expectedRequest, AmmInfoResult.class)).thenReturn(mockResult);
+    AmmInfoResult result = xrplClient.ammInfo(params);
+
+    assertThat(result).isEqualTo(mockResult);
+  }
+
   @Test
   void nftInfo() throws JsonRpcClientErrorException {
     NftInfoRequestParams params = NftInfoRequestParams.builder()

xrpl4j-core/src/main/java/org/xrpl/xrpl4j/codec/binary/types/Issue.java

@@ -0,0 +1,52 @@
+package org.xrpl.xrpl4j.codec.binary.types;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.google.common.base.Preconditions;
+import org.immutables.value.Value;
+
+import java.util.Optional;
+
+/**
+ * JSON mapping object for the Issue serializable type.
+ */
+@Value.Immutable
+@JsonSerialize(as = ImmutableIssue.class)
+@JsonDeserialize(as = ImmutableIssue.class)
+public interface Issue {
+
+  /**
+   * Construct a {@code Issue} builder.
+   *
+   * @return An {@link ImmutableIssue.Builder}.
+   */
+  static ImmutableIssue.Builder builder() {
+    return ImmutableIssue.builder();
+  }
+
+  /**
+   * The currency code of the Issue.
+   *
+   * @return A {@link JsonNode} containing the currency code.
+   */
+  JsonNode currency();
+
+  /**
+   * The address of the issuer of this currency. Will be empty if {@link #currency()} is XRP.
+   *
+   * @return An optionally present {@link JsonNode}.
+   */
+  Optional<JsonNode> issuer();
+
+  /**
+   * Validate that {@link #issuer()} is empty if {@link #currency()} is "XRP".
+   */
+  @Value.Check
+  default void checkIssuerEmptyForXrp() {
+    if (currency().asText().equals("XRP")) {
+      Preconditions.checkState(!issuer().isPresent(), "If Issue is XRP, issuer must be empty.");
+    }
+  }
+
+}

xrpl4j-core/src/main/java/org/xrpl/xrpl4j/codec/binary/types/IssueType.java

@@ -0,0 +1,62 @@
+package org.xrpl.xrpl4j.codec.binary.types;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.xrpl.xrpl4j.codec.addresses.UnsignedByteArray;
+import org.xrpl.xrpl4j.codec.binary.BinaryCodecObjectMapperFactory;
+import org.xrpl.xrpl4j.codec.binary.serdes.BinaryParser;
+
+public class IssueType extends SerializedType<IssueType> {
+
+  private static final ObjectMapper objectMapper = BinaryCodecObjectMapperFactory.getObjectMapper();
+
+  public IssueType() {
+    this(UnsignedByteArray.ofSize(20));
+  }
+
+  public IssueType(UnsignedByteArray bytes) {
+    super(bytes);
+  }
+
+  @Override
+  public IssueType fromJson(JsonNode node) throws JsonProcessingException {
+    if (!node.isObject()) {
+      throw new IllegalArgumentException("node is not an object");
+    }
+
+    Issue issue = objectMapper.treeToValue(node, Issue.class);
+
+    UnsignedByteArray byteArray = new CurrencyType().fromJson(issue.currency()).value();
+    issue.issuer().ifPresent(
+      issuer -> byteArray.append(new AccountIdType().fromJson(issuer).value())
+    );
+
+    return new IssueType(byteArray);
+  }
+
+  @Override
+  public IssueType fromParser(BinaryParser parser) {
+    CurrencyType currency = new CurrencyType().fromParser(parser);
+    if (currency.toJson().asText().equals("XRP")) {
+      return new IssueType(currency.value());
+    }
+    AccountIdType issuer = new AccountIdType().fromParser(parser);
+    return new IssueType(currency.value().append(issuer.value()));
+  }
+
+  @Override
+  public JsonNode toJson() {
+    BinaryParser parser = new BinaryParser(this.toHex());
+    JsonNode currency = new CurrencyType().fromParser(parser).toJson();
+
+    ImmutableIssue.Builder builder = Issue.builder();
+    builder.currency(currency);
+    if (!currency.asText().equals("XRP")) {
+      JsonNode issuer = new AccountIdType().fromParser(parser).toJson();
+      builder.issuer(issuer);
+    }
+
+    return objectMapper.valueToTree(builder.build());
+  }
+}

xrpl4j-core/src/main/java/org/xrpl/xrpl4j/codec/binary/types/SerializedType.java

@@ -9,9 +9,9 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -57,6 +57,7 @@ public abstract class SerializedType<T extends SerializedType<T>> {
       .put("UInt32", () -> new UInt32Type())
       .put("UInt64", () -> new UInt64Type())
       .put("Vector256", () -> new Vector256Type())
+      .put("Issue", () -> new IssueType())
       .build();
   private final UnsignedByteArray bytes;
 

xrpl4j-core/src/main/java/org/xrpl/xrpl4j/crypto/signing/SignatureUtils.java

@@ -31,6 +31,12 @@
 import org.xrpl.xrpl4j.model.transactions.AccountDelete;
 import org.xrpl.xrpl4j.model.transactions.AccountSet;
 import org.xrpl.xrpl4j.model.transactions.Address;
+import org.xrpl.xrpl4j.model.transactions.AmmBid;
+import org.xrpl.xrpl4j.model.transactions.AmmCreate;
+import org.xrpl.xrpl4j.model.transactions.AmmDelete;
+import org.xrpl.xrpl4j.model.transactions.AmmDeposit;
+import org.xrpl.xrpl4j.model.transactions.AmmVote;
+import org.xrpl.xrpl4j.model.transactions.AmmWithdraw;
 import org.xrpl.xrpl4j.model.transactions.CheckCancel;
 import org.xrpl.xrpl4j.model.transactions.CheckCash;
 import org.xrpl.xrpl4j.model.transactions.CheckCreate;
@@ -276,6 +282,30 @@ public <T extends Transaction> SingleSignedTransaction<T> addSignatureToTransact
       transactionWithSignature = Clawback.builder().from((Clawback) transaction)
         .transactionSignature(signature)
         .build();
+    } else if (AmmBid.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmBid.builder().from((AmmBid) transaction)
+        .transactionSignature(signature)
+        .build();
+    } else if (AmmCreate.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmCreate.builder().from((AmmCreate) transaction)
+        .transactionSignature(signature)
+        .build();
+    } else if (AmmDeposit.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmDeposit.builder().from((AmmDeposit) transaction)
+        .transactionSignature(signature)
+        .build();
+    } else if (AmmVote.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmVote.builder().from((AmmVote) transaction)
+        .transactionSignature(signature)
+        .build();
+    } else if (AmmWithdraw.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmWithdraw.builder().from((AmmWithdraw) transaction)
+        .transactionSignature(signature)
+        .build();
+    } else if (AmmDelete.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignature = AmmDelete.builder().from((AmmDelete) transaction)
+        .transactionSignature(signature)
+        .build();
     } else {
       // Should never happen, but will in a unit test if we miss one.
       throw new IllegalArgumentException("Signing fields could not be added to the transaction.");
@@ -414,6 +444,30 @@ public <T extends Transaction> T addMultiSignaturesToTransaction(T transaction,
       transactionWithSignatures = Clawback.builder().from((Clawback) transaction)
         .signers(signers)
         .build();
+    } else if (AmmBid.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmBid.builder().from((AmmBid) transaction)
+        .signers(signers)
+        .build();
+    } else if (AmmCreate.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmCreate.builder().from((AmmCreate) transaction)
+        .signers(signers)
+        .build();
+    } else if (AmmDeposit.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmDeposit.builder().from((AmmDeposit) transaction)
+        .signers(signers)
+        .build();
+    } else if (AmmVote.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmVote.builder().from((AmmVote) transaction)
+        .signers(signers)
+        .build();
+    } else if (AmmWithdraw.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmWithdraw.builder().from((AmmWithdraw) transaction)
+        .signers(signers)
+        .build();
+    } else if (AmmDelete.class.isAssignableFrom(transaction.getClass())) {
+      transactionWithSignatures = AmmDelete.builder().from((AmmDelete) transaction)
+        .signers(signers)
+        .build();
     } else {
       // Should never happen, but will in a unit test if we miss one.
       throw new IllegalArgumentException("Signing fields could not be added to the transaction.");

xrpl4j-core/src/main/java/org/xrpl/xrpl4j/model/client/XrplMethods.java

@@ -9,9 +9,9 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *      http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -20,6 +20,8 @@
  * =========================LICENSE_END==================================
  */
 
+import com.google.common.annotations.Beta;
+
 /**
  * A definition class for all rippled method name constants.
  */
@@ -176,6 +178,12 @@ public class XrplMethods {
    */
   public static final String RIPPLE_PATH_FIND = "ripple_path_find";
 
+  /**
+   * Constant for the <a href="https://xrpl.org/amm_info.html">ripple_path_find</a> rippled API method.
+   */
+  @Beta
+  public static final String AMM_INFO = "amm_info";
+
   // Payment Channel methods
   /**
    * Constant for the <a href="https://xrpl.org/channel_authorize.html">channel_authorize</a> rippled API method.