feat: implement TransactionRepository for Hedera Mirror Node integration

Author: belloibrahv

hedera-base/src/main/java/com/openelements/hedera/base/TransactionRepository.java

@@ -0,0 +1,49 @@
+package com.openelements.hedera.base;
+
+import java.util.Objects;
+import java.util.Optional;
+
+import org.jspecify.annotations.NonNull;
+
+import com.hedera.hashgraph.sdk.AccountId;
+import com.openelements.hedera.base.mirrornode.Page;
+import com.openelements.hedera.base.mirrornode.TransactionInfo;
+
+/**
+ * Interface for interacting with transactions on a Hedera network.
+ * This interface provides methods for querying transactions.
+ */
+public interface TransactionRepository {
+    /**
+     * Find all transactions associated with a specific account.
+     *
+     * @param accountId id of the account
+     * @return page of transactions
+     * @throws HederaException if the search fails
+     */
+    @NonNull
+    Page<TransactionInfo> findByAccount(@NonNull AccountId accountId) throws HederaException;
+
+    /**
+     * Find all transactions associated with a specific account.
+     *
+     * @param accountId id of the account as a string
+     * @return page of transactions
+     * @throws HederaException if the search fails
+     */
+    @NonNull
+    default Page<TransactionInfo> findByAccount(@NonNull String accountId) throws HederaException {
+        Objects.requireNonNull(accountId, "accountId must not be null");
+        return findByAccount(AccountId.fromString(accountId));
+    }
+
+    /**
+     * Find a specific transaction by its ID.
+     *
+     * @param transactionId the transaction ID
+     * @return Optional containing the transaction if found
+     * @throws HederaException if the search fails
+     */
+    @NonNull
+    Optional<TransactionInfo> findById(@NonNull String transactionId) throws HederaException;
+}

hedera-base/src/main/java/com/openelements/hedera/base/implementation/TransactionRepositoryImpl.java

@@ -0,0 +1,36 @@
+package com.openelements.hedera.base.implementation;
+
+import java.util.Objects;
+import java.util.Optional;
+
+import org.jspecify.annotations.NonNull;
+
+import com.hedera.hashgraph.sdk.AccountId;
+import com.openelements.hedera.base.HederaException;
+import com.openelements.hedera.base.TransactionRepository;
+import com.openelements.hedera.base.mirrornode.MirrorNodeClient;
+import com.openelements.hedera.base.mirrornode.Page;
+import com.openelements.hedera.base.mirrornode.TransactionInfo;
+
+
+public class TransactionRepositoryImpl implements TransactionRepository {
+    private final MirrorNodeClient mirrorNodeClient;
+
+    public TransactionRepositoryImpl(@NonNull final MirrorNodeClient mirrorNodeClient) {
+        this.mirrorNodeClient = Objects.requireNonNull(mirrorNodeClient, "mirrorNodeClient must not be null");
+    }
+
+    @NonNull
+    @Override
+    public Page<TransactionInfo> findByAccount(@NonNull final AccountId accountId) throws HederaException {
+        Objects.requireNonNull(accountId, "accountId must not be null");
+        return this.mirrorNodeClient.queryTransactionsByAccount(accountId);
+    }
+
+    @NonNull
+    @Override
+    public Optional<TransactionInfo> findById(@NonNull final String transactionId) throws HederaException {
+        Objects.requireNonNull(transactionId, "transactionId must not be null");
+        return this.mirrorNodeClient.queryTransaction(transactionId);
+    }
+}

hedera-base/src/main/java/com/openelements/hedera/base/mirrornode/MirrorNodeClient.java

@@ -1,12 +1,14 @@
 package com.openelements.hedera.base.mirrornode;
 
+import java.util.Objects;
+import java.util.Optional;
+
+import org.jspecify.annotations.NonNull;
+
 import com.hedera.hashgraph.sdk.AccountId;
 import com.hedera.hashgraph.sdk.TokenId;
 import com.openelements.hedera.base.HederaException;
 import com.openelements.hedera.base.Nft;
-import java.util.Objects;
-import java.util.Optional;
-import org.jspecify.annotations.NonNull;
 
 /**
  * A client for querying the Hedera Mirror Node REST API.
@@ -144,6 +146,17 @@ default Optional<Nft> queryNftsByAccountAndTokenIdAndSerial(@NonNull String acco
                 serialNumber);
     }
 
+    /**
+     * Queries all transactions for a specific account.
+     *
+     * @param accountId the account ID to query transactions for
+     * @return a page of transaction information
+     * @throws HederaException if an error occurs during the query
+     */
+    @NonNull
+    Page<TransactionInfo> queryTransactionsByAccount(@NonNull AccountId accountId) throws HederaException;
+
+
     /**
      * Queries the transaction information for a specific transaction ID.
      *