#15 Adds pending transactions api (#50)

Co-authored-by: Eren <[email protected]>

Author: erenalpaslan

src/main/java/mobi/appcent/helium/Main.java

@@ -1,26 +1,19 @@
 package mobi.appcent.helium;
 
-import com.google.gson.Gson;
 import mobi.appcent.helium.api.HeliumApi;
-import mobi.appcent.helium.model.*;
-import mobi.appcent.helium.model.account.Account;
-import mobi.appcent.helium.response.account.AccountsResponse;
-import mobi.appcent.helium.response.city.CitiesResponse;
+
 
 public class Main {
 
     public static void main(String[] args) {
         try {
             HeliumApi heliumApi = new HeliumApi();
-
             System.out.println(
                     heliumApi.assertLocations()
                             .getListOfAssertLocations()
                             .execute()
                             .toString()
             );
-
-
         } catch (Exception e) {
             System.out.println(e.getMessage());
         }

src/main/java/mobi/appcent/helium/api/HeliumApi.java

@@ -20,11 +20,13 @@ public class HeliumApi {
     private final ChallengesApi challengesApi = ChallengesApi.getInstance();
     private final DCBurnsApi dcBurnsApi = DCBurnsApi.getInstance();
     private final OraclePricesApi oraclePricesApi = OraclePricesApi.getInstance();
+    private final PendingTransactionsApi pendingTransactionsApi = PendingTransactionsApi.getInstance();
     private final StateChannelsApi stateChannelsApi = StateChannelsApi.getInstance();
     private final LocationsApi locationsApi = LocationsApi.getInstance();
     private final AssertLocationsApi assertLocationsApi = AssertLocationsApi.getInstance();
     private final ElectionsApi electionsApi = ElectionsApi.getInstance();
     private final TransactionsApi transactionsApi = TransactionsApi.getInstance();
+
     private static final HeliumSdkClient sdkClient = new HeliumSdkClient();
 
     public HeliumApi() {
@@ -49,6 +51,7 @@ private void initOkHttpClients(OkHttpClient client) {
         challengesApi.setSdkClient(sdkClient);
         dcBurnsApi.setSdkClient(sdkClient);
         oraclePricesApi.setSdkClient(sdkClient);
+        pendingTransactionsApi.setSdkClient(sdkClient);
         stateChannelsApi.setSdkClient(sdkClient);
         locationsApi.setSdkClient(sdkClient);
         assertLocationsApi.setSdkClient(sdkClient);
@@ -86,6 +89,8 @@ public CityApi cities() {
 
     public OraclePricesApi oraclePrices() { return oraclePricesApi; }
 
+    public PendingTransactionsApi pendingTransactions() { return pendingTransactionsApi; }
+
     public StateChannelsApi stateChannels() { return stateChannelsApi; }
 
     public LocationsApi locations() { return locationsApi; }

src/main/java/mobi/appcent/helium/api/IPendingTransactions.java

@@ -0,0 +1,12 @@
+package mobi.appcent.helium.api;
+
+import mobi.appcent.helium.request.pendingtransactions.PendingTransactionsStatusRequest;
+import mobi.appcent.helium.request.pendingtransactions.PostSubmitNewTransactionRequest;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+public interface IPendingTransactions {
+    PendingTransactionsStatusRequest getPendingTransactionsStatus(String hash);
+    PostSubmitNewTransactionRequest submitNewTransaction(String txn, String hash);
+}

src/main/java/mobi/appcent/helium/api/PendingTransactionsApi.java

@@ -0,0 +1,30 @@
+package mobi.appcent.helium.api;
+
+import mobi.appcent.helium.request.pendingtransactions.PendingTransactionsStatusRequest;
+import mobi.appcent.helium.request.pendingtransactions.PostSubmitNewTransactionRequest;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+public class PendingTransactionsApi extends BaseApi implements IPendingTransactions {
+    @Override
+    String path() {
+        return BASE_URL + "/pending_transactions";
+    }
+
+    public static PendingTransactionsApi getInstance() {
+        return new PendingTransactionsApi();
+    }
+
+    //region getPendingTransactionsStatus
+    @Override
+    public PendingTransactionsStatusRequest getPendingTransactionsStatus(String hash) {
+        return new PendingTransactionsStatusRequest(sdkClient, hash);
+    }
+    //endregion
+
+    @Override
+    public PostSubmitNewTransactionRequest submitNewTransaction(String txn, String hash) {
+        return new PostSubmitNewTransactionRequest(sdkClient, txn, hash);
+    }
+}

src/main/java/mobi/appcent/helium/common/HeaderConstant.java

@@ -0,0 +1,9 @@
+package mobi.appcent.helium.common;
+
+/**
+ * Created by erenalpaslan on 26.11.2022
+ */
+public class HeaderConstant {
+    public static final String CONTENT_TYPE = "Content-Type";
+    public static final String APPLICATION_JSON = "application/json";
+}

src/main/java/mobi/appcent/helium/model/payment/Payment.java

@@ -0,0 +1,21 @@
+package mobi.appcent.helium.model.payment;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.math.BigInteger;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+@Data
+@AllArgsConstructor
+public class Payment {
+    @SerializedName("token_type")
+    private String tokenType;
+    private String payee;
+    private String memo;
+    private Boolean max;
+    private BigInteger amount;
+}

src/main/java/mobi/appcent/helium/model/pendingtransaction/PendingTransactionStatus.java

@@ -0,0 +1,24 @@
+package mobi.appcent.helium.model.pendingtransaction;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import mobi.appcent.helium.model.txn.Txn;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+@Data
+@AllArgsConstructor
+public class PendingTransactionStatus {
+    @SerializedName("updated_at")
+    private String updatedAt;
+    private String type;
+    private Txn txn;
+    private String status;
+    private String hash;
+    @SerializedName("failed_reason")
+    private String failedReason;
+    @SerializedName("created_at")
+    private String createdAt;
+}

src/main/java/mobi/appcent/helium/model/pendingtransaction/SubmitTransaction.java

@@ -0,0 +1,13 @@
+package mobi.appcent.helium.model.pendingtransaction;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+@Data
+@AllArgsConstructor
+public class SubmitTransaction {
+    private String hash;
+}

src/main/java/mobi/appcent/helium/model/txn/Txn.java

@@ -0,0 +1,21 @@
+package mobi.appcent.helium.model.txn;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import mobi.appcent.helium.model.payment.Payment;
+
+import java.util.List;
+
+/**
+ * Created by erenalpaslan on 20.11.2022
+ */
+@Data
+@AllArgsConstructor
+public class Txn {
+    private String type;
+    private List<Payment> payments;
+    private String payer;
+    private Integer nonce;
+    private String hash;
+    private Integer fee;
+}

src/main/java/mobi/appcent/helium/request/pendingtransactions/PendingTransactionsStatusRequest.java

@@ -0,0 +1,36 @@
+package mobi.appcent.helium.request.pendingtransactions;
+
+import com.google.gson.reflect.TypeToken;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+import mobi.appcent.helium.HeliumSdkClient;
+import mobi.appcent.helium.api.PendingTransactionsApi;
+import mobi.appcent.helium.common.UrlConstant;
+import mobi.appcent.helium.httpClient.HttpMethod;
+import mobi.appcent.helium.request.BaseRequest;
+import mobi.appcent.helium.response.pendingTransaction.PendingTransactionsStatusResponse;
+import okhttp3.Call;
+
+import java.io.IOException;
+import java.lang.reflect.Type;
+import java.util.Collections;
+
+/**
+ * Created by erenalpaslan on 26.11.2022
+ */
+@AllArgsConstructor
+@Getter
+@Setter
+public class PendingTransactionsStatusRequest extends BaseRequest {
+    private final HeliumSdkClient client;
+    private final String hash;
+
+    public PendingTransactionsStatusResponse execute() throws IOException {
+        String path = UrlConstant.PENDING_TRANSACTION_PATH + "/" + hash;
+        Call call = client.buildCall(path, HttpMethod.GET, Collections.emptyList(), null, null);
+        Type type = TypeToken.get(PendingTransactionsStatusResponse.class).getType();
+        return execute(call, type);
+    }
+}