feat: show incoming link amount

packages/espressocash_app/lib/data/db/db.dart

@@ -29,7 +29,7 @@ class OutgoingTransferRows extends Table {
   Set<Column<Object>> get primaryKey => {id};
 }
 
-const int latestVersion = 48;
+const int latestVersion = 49;
 
 const _tables = [
   OutgoingTransferRows,
@@ -211,6 +211,9 @@ class MyDatabase extends _$MyDatabase {
             await m.addColumn(offRampOrderRows, offRampOrderRows.feeAmount);
             await m.addColumn(offRampOrderRows, offRampOrderRows.feeToken);
           }
+          if (from >= 39 && from < 49) {
+            await m.addColumn(iLPRows, iLPRows.receivedAmount);
+          }
         },
       );
 

packages/espressocash_app/lib/features/incoming_link_payments/data/ilp_repository.dart

@@ -81,6 +81,7 @@ class ILPRows extends Table with EntityMixin, TxStatusMixin {
   IntColumn get status => intEnum<ILPStatusDto>()();
 
   IntColumn get feeAmount => integer().nullable()();
+  IntColumn get receivedAmount => integer().nullable()();
 }
 
 enum ILPStatusDto {
@@ -118,12 +119,19 @@ extension on ILPStatusDto {
         );
       case ILPStatusDto.success:
         final feeAmount = row.feeAmount;
+        final receivedAmount = row.receivedAmount;
 
         return ILPStatus.success(
           tx: tx ?? StubSignedTx(txId!),
           fee: feeAmount != null
               ? CryptoAmount(value: feeAmount, cryptoCurrency: Currency.usdc)
               : null,
+          receivedAmount: receivedAmount != null
+              ? CryptoAmount(
+                  value: receivedAmount,
+                  cryptoCurrency: Currency.usdc,
+                )
+              : null,
         );
       case ILPStatusDto.txFailure:
         return ILPStatus.txFailure(
@@ -147,6 +155,10 @@ extension on IncomingLinkPayment {
           ILPStatusSuccess(:final fee) => fee?.value,
           _ => null,
         },
+        receivedAmount: switch (status) {
+          ILPStatusSuccess(:final receivedAmount) => receivedAmount?.value,
+          _ => null,
+        },
       );
 }
 

packages/espressocash_app/lib/features/incoming_link_payments/models/incoming_link_payment.dart

@@ -35,6 +35,7 @@ sealed class ILPStatus with _$ILPStatus {
   const factory ILPStatus.success({
     required SignedTx tx,
     required CryptoAmount? fee,
+    required CryptoAmount? receivedAmount,
   }) = ILPStatusSuccess;
 
   /// Failed to create the tx, a new tx should be created.

packages/espressocash_app/lib/features/incoming_link_payments/screens/incoming_link_payment_screen.dart

@@ -1,7 +1,6 @@
 import 'package:auto_route/auto_route.dart';
 import 'package:dfunc/dfunc.dart';
 import 'package:flutter/material.dart';
-
 import '../../../core/amount.dart';
 import '../../../core/presentation/format_amount.dart';
 import '../../../di.dart';
@@ -60,7 +59,12 @@ class _IncomingLinkPaymentScreenState extends State<IncomingLinkPaymentScreen> {
                     onBack: () => context.router.pop(),
                     onOkPressed: () => context.router.pop(),
                     content: e.fee?.let(_FeeNotice.new),
-                    statusContent: context.l10n.moneyReceived,
+                    statusContent: e.receivedAmount?.let(
+                          (it) => context.l10n.incomingLinkSuccessMessage(
+                            it.format(context.locale, maxDecimals: 2),
+                          ),
+                        ) ??
+                        context.l10n.moneyReceived,
                   ),
                   txFailure: (it) => it.reason == TxFailureReason.escrowFailure
                       ? const InvalidEscrowErrorWidget()

packages/espressocash_app/lib/features/incoming_link_payments/services/tx_sent_watcher.dart

@@ -11,6 +11,8 @@ import 'package:solana/solana.dart';
 import '../../../core/amount.dart';
 import '../../../core/cancelable_job.dart';
 import '../../../core/currency.dart';
+import '../../accounts/models/ec_wallet.dart';
+import '../../tokens/token.dart';
 import '../../transactions/models/tx_results.dart';
 import '../../transactions/services/tx_sender.dart';
 import '../data/ilp_repository.dart';
@@ -21,16 +23,24 @@ import 'payment_watcher.dart';
 /// confirmed.
 @injectable
 class TxSentWatcher extends PaymentWatcher {
-  TxSentWatcher(super._repository, this._sender, this._ecClient);
+  TxSentWatcher(
+    super._repository,
+    this._sender,
+    this._ecClient,
+    this._rpcClient,
+    this._wallet,
+  );
 
   final TxSender _sender;
   final EspressoCashClient _ecClient;
+  final RpcClient _rpcClient;
+  final ECWallet _wallet;
 
   @override
   CancelableJob<IncomingLinkPayment> createJob(
     IncomingLinkPayment payment,
   ) =>
-      _ILPTxSentJob(payment, _sender, _ecClient);
+      _ILPTxSentJob(payment, _sender, _ecClient, _rpcClient, _wallet);
 
   @override
   Stream<IList<IncomingLinkPayment>> watchPayments(
@@ -40,11 +50,19 @@ class TxSentWatcher extends PaymentWatcher {
 }
 
 class _ILPTxSentJob extends CancelableJob<IncomingLinkPayment> {
-  const _ILPTxSentJob(this.payment, this.sender, this._ecClient);
+  const _ILPTxSentJob(
+    this.payment,
+    this.sender,
+    this._ecClient,
+    this._rpcClient,
+    this._wallet,
+  );
 
   final IncomingLinkPayment payment;
   final TxSender sender;
   final EspressoCashClient _ecClient;
+  final RpcClient _rpcClient;
+  final ECWallet _wallet;
 
   @override
   Future<IncomingLinkPayment?> process() async {
@@ -64,11 +82,53 @@ class _ILPTxSentJob extends CancelableJob<IncomingLinkPayment> {
                   .then((value) => value.escrowPaymentAtaFee)
               : null;
 
+          final tx = await _rpcClient.getTransaction(
+            status.tx.id,
+            commitment: Commitment.confirmed,
+          );
+
+          final tokenAddress = await findAssociatedTokenAddress(
+            owner: _wallet.publicKey,
+            mint: Token.usdc.publicKey,
+          );
+
+          final accountIndex = status.tx.compiledMessage.accountKeys.indexWhere(
+            (e) => e == tokenAddress,
+          );
+
+          final previousBalance = tx?.meta?.preTokenBalances
+                  .where((e) => e.accountIndex == accountIndex)
+                  .firstOrNull
+                  ?.uiTokenAmount
+                  .amount
+                  .let(int.tryParse) ??
+              0;
+
+          final postBalance = tx?.meta?.postTokenBalances
+                  .where(
+                    (e) => e.accountIndex == accountIndex,
+                  )
+                  .firstOrNull
+                  ?.uiTokenAmount
+                  .amount
+                  .let(int.tryParse) ??
+              0;
+
+          final amount = postBalance - previousBalance;
+
           return ILPStatus.success(
             tx: status.tx,
             fee: fee?.let(
               (fee) => CryptoAmount(value: fee, cryptoCurrency: Currency.usdc),
             ),
+            receivedAmount: amount.let(
+              (amount) => amount <= 0
+                  ? null
+                  : CryptoAmount(
+                      value: amount,
+                      cryptoCurrency: Currency.usdc,
+                    ),
+            ),
           );
         } on Object {
           return null;

packages/espressocash_app/lib/features/token_search/data/coingecko_client.dart

@@ -1,4 +1,4 @@
-// ignore_for_file: invalid_annotation_target
+// ignore_for_file: invalid_annotation_target, avoid-missing-interpolation
 
 import 'package:dio/dio.dart';
 import 'package:freezed_annotation/freezed_annotation.dart';

packages/espressocash_app/lib/l10n/intl_en.arb

@@ -1057,5 +1057,7 @@
   "onRampMorePartnersTitle": "Additional Add Cash Partners:",
   "@onRampMorePartnersTitle": {},
   "offRampMorePartnersTitle": "Additional Payment Partners:",
-  "@offRampMorePartnersTitle": {}
+  "@offRampMorePartnersTitle": {},
+  "incomingLinkSuccessMessage": "{amount} Transaction successfully received.",
+  "@incomingLinkSuccessMessage": {}
 }