Merge pull request #131 from threefoldtech/development_get_transactions_pagination

Paginate get transactions in Stellar client

Author: zaelgohary

packages/stellar_client/lib/src/client.dart

@@ -381,43 +381,68 @@ class Client {
     }
   }
 
-  Future<List<ITransaction>> getTransactions({String? assetCodeFilter}) async {
-    Page<OperationResponse> payments = await _sdk.payments
-        .forAccount(accountId)
-        .order(RequestBuilderOrder.DESC)
-        .execute();
-    List<ITransaction> transactionDetails = [];
-
-    if (payments.records.isNotEmpty) {
-      for (OperationResponse response in payments.records) {
-        if (response is PaymentOperationResponse) {
-          final memoText = await this
-              .getMemoText(response.links.transaction.toJson()["href"]);
-          String assetCode = response.assetCode ?? 'XLM';
-          if (assetCodeFilter == null || assetCode == assetCodeFilter) {
-            final details = PaymentTransaction(
-                hash: response.transactionHash,
-                from: response.from,
-                to: response.to,
-                asset: response.assetCode.toString(),
-                amount: response.amount,
-                type: response.to == this.accountId
-                    ? TransactionType.Receive
-                    : TransactionType.Payment,
-                status: response.transactionSuccessful,
-                date: DateTime.parse(response.createdAt).toLocal().toString(),
-                memo: memoText);
-
-            transactionDetails.add(details);
+  Future<List<ITransaction>> getTransactions(
+      {String? assetCodeFilter, int? limit, int? offset}) async {
+    try {
+      var paymentsRequest =
+          _sdk.payments.forAccount(accountId).order(RequestBuilderOrder.DESC);
+
+      // Add pagination
+      if (limit != null) {
+        paymentsRequest = paymentsRequest.limit(limit);
+      }
+
+      // get first page
+      if (offset != null && offset > 0) {
+        var initialPage = await _sdk.payments
+            .forAccount(accountId)
+            .order(RequestBuilderOrder.DESC)
+            .limit(offset)
+            .execute();
+
+        if (initialPage.records.isNotEmpty) {
+          // Use the last record's paging token as cursor
+          paymentsRequest =
+              paymentsRequest.cursor(initialPage.records.last.pagingToken);
+        }
+      }
+
+      Page<OperationResponse> payments = await paymentsRequest.execute();
+      List<ITransaction> transactionDetails = [];
+
+      if (payments.records.isNotEmpty) {
+        for (OperationResponse response in payments.records) {
+          if (response is PaymentOperationResponse) {
+            final memoText = await this
+                .getMemoText(response.links.transaction.toJson()["href"]);
+            String assetCode = response.assetCode ?? 'XLM';
+            if (assetCodeFilter == null || assetCode == assetCodeFilter) {
+              final details = PaymentTransaction(
+                  hash: response.transactionHash,
+                  from: response.from,
+                  to: response.to,
+                  asset: response.assetCode.toString(),
+                  amount: response.amount,
+                  type: response.to == this.accountId
+                      ? TransactionType.Receive
+                      : TransactionType.Payment,
+                  status: response.transactionSuccessful,
+                  date: DateTime.parse(response.createdAt).toLocal().toString(),
+                  memo: memoText);
+
+              transactionDetails.add(details);
+            }
+          } else {
+            logger.i("Unhandled operation type: ${response.runtimeType}");
           }
-        } else {
-          logger.i("Unhandled operation type: ${response.runtimeType}");
         }
       }
-    } else {
-      logger.i("No payment records found.");
+
+      return transactionDetails;
+    } catch (e) {
+      logger.e('Failed to get transactions: $e');
+      throw Exception('Could not get transactions due to $e');
     }
-    return transactionDetails;
   }
 
   Future<List<BalanceInfo>> getBalance() async {