Merge pull request 'increased payout timeout' (#213) from timeout-210 into main

Reviewed-on: #213

api/gateway/mntx/client/client.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/tech/sendico/pkg/merrors"
 	mntxv1 "github.com/tech/sendico/pkg/proto/gateway/mntx/v1"
+	"go.uber.org/zap"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
 )
@@ -23,6 +24,7 @@ type gatewayClient struct {
 	conn   *grpc.ClientConn
 	client mntxv1.MntxGatewayServiceClient
 	cfg    Config
+	logger *zap.Logger
 }
 
 // New dials the Monetix gateway.
@@ -47,6 +49,7 @@ func New(ctx context.Context, cfg Config, opts ...grpc.DialOption) (Client, erro
 		conn:   conn,
 		client: mntxv1.NewMntxGatewayServiceClient(conn),
 		cfg:    cfg,
+		logger: cfg.Logger,
 	}, nil
 }
 
@@ -57,28 +60,39 @@ func (g *gatewayClient) Close() error {
 	return nil
 }
 
-func (g *gatewayClient) callContext(ctx context.Context) (context.Context, context.CancelFunc) {
+func (g *gatewayClient) callContext(ctx context.Context, method string) (context.Context, context.CancelFunc) {
+	if ctx == nil {
+		ctx = context.Background()
+	}
 	timeout := g.cfg.CallTimeout
 	if timeout <= 0 {
 		timeout = 5 * time.Second
 	}
+	fields := []zap.Field{
+		zap.String("method", method),
+		zap.Duration("timeout", timeout),
+	}
+	if deadline, ok := ctx.Deadline(); ok {
+		fields = append(fields, zap.Time("parent_deadline", deadline), zap.Duration("parent_deadline_in", time.Until(deadline)))
+	}
+	g.logger.Info("Mntx gateway client call timeout applied", fields...)
 	return context.WithTimeout(ctx, timeout)
 }
 
 func (g *gatewayClient) CreateCardPayout(ctx context.Context, req *mntxv1.CardPayoutRequest) (*mntxv1.CardPayoutResponse, error) {
-	ctx, cancel := g.callContext(ctx)
+	ctx, cancel := g.callContext(ctx, "CreateCardPayout")
 	defer cancel()
 	return g.client.CreateCardPayout(ctx, req)
 }
 
 func (g *gatewayClient) CreateCardTokenPayout(ctx context.Context, req *mntxv1.CardTokenPayoutRequest) (*mntxv1.CardTokenPayoutResponse, error) {
-	ctx, cancel := g.callContext(ctx)
+	ctx, cancel := g.callContext(ctx, "CreateCardTokenPayout")
 	defer cancel()
 	return g.client.CreateCardTokenPayout(ctx, req)
 }
 
 func (g *gatewayClient) GetCardPayoutStatus(ctx context.Context, req *mntxv1.GetCardPayoutStatusRequest) (*mntxv1.GetCardPayoutStatusResponse, error) {
-	ctx, cancel := g.callContext(ctx)
+	ctx, cancel := g.callContext(ctx, "GetCardPayoutStatus")
 	defer cancel()
 	return g.client.GetCardPayoutStatus(ctx, req)
 }

api/gateway/mntx/client/config.go

@@ -1,12 +1,17 @@
 package client
 
-import "time"
+import (
+	"time"
+
+	"go.uber.org/zap"
+)
 
 // Config holds Monetix gateway client settings.
 type Config struct {
 	Address     string
 	DialTimeout time.Duration
 	CallTimeout time.Duration
+	Logger      *zap.Logger
 }
 
 func (c *Config) setDefaults() {
@@ -16,4 +21,7 @@ func (c *Config) setDefaults() {
 	if c.CallTimeout <= 0 {
 		c.CallTimeout = 10 * time.Second
 	}
+	if c.Logger == nil {
+		c.Logger = zap.NewNop()
+	}
 }

api/gateway/mntx/internal/service/gateway/card_processor.go

@@ -343,7 +343,12 @@ func (p *cardPayoutProcessor) ProcessCallback(ctx context.Context, payload []byt
 		return http.StatusBadRequest, merrors.InvalidArgument("signature is missing")
 	}
 	if err := verifyCallbackSignature(cb, p.config.SecretKey); err != nil {
-		p.logger.Warn("Monetix callback signature check failed", zap.Error(err))
+		p.logger.Warn("Monetix callback signature check failed",
+			zap.String("payout_id", cb.Payment.ID),
+			zap.String("signature", cb.Signature),
+			zap.String("payload", string(payload)),
+			zap.Error(err),
+		)
 		return http.StatusForbidden, err
 	}
 

api/gateway/mntx/internal/service/monetix/sender.go

@@ -106,12 +106,23 @@ func (c *Client) sendTokenization(ctx context.Context, req CardTokenizeRequest)
 		zap.String("masked_pan", MaskPAN(req.Card.PAN)),
 	)
 
+	logRequestDeadline(c.logger, ctx, url)
 	start := time.Now()
 	resp, err := c.client.Do(httpReq)
 	duration := time.Since(start)
 	if err != nil {
 		observeRequest(outcomeNetworkError, duration)
-		c.logger.Warn("Monetix tokenization request failed", zap.Error(err))
+		fields := []zap.Field{
+			zap.String("url", url),
+			zap.Error(err),
+		}
+		if ctxErr := ctx.Err(); ctxErr != nil {
+			fields = append(fields, zap.NamedError("ctx_error", ctxErr))
+		}
+		if deadline, ok := ctx.Deadline(); ok {
+			fields = append(fields, zap.Time("deadline", deadline), zap.Duration("time_until_deadline", time.Until(deadline)))
+		}
+		c.logger.Warn("Monetix tokenization request failed", fields...)
 		return nil, merrors.Internal("monetix tokenization request failed: " + err.Error())
 	}
 	defer resp.Body.Close()
@@ -221,11 +232,23 @@ func (c *Client) send(ctx context.Context, req any, path string, dispatchLog fun
 		dispatchLog()
 	}
 
+	logRequestDeadline(c.logger, ctx, url)
 	start := time.Now()
 	resp, err := c.client.Do(httpReq)
 	duration := time.Since(start)
 	if err != nil {
 		observeRequest(outcomeNetworkError, duration)
+		fields := []zap.Field{
+			zap.String("url", url),
+			zap.Error(err),
+		}
+		if ctxErr := ctx.Err(); ctxErr != nil {
+			fields = append(fields, zap.NamedError("ctx_error", ctxErr))
+		}
+		if deadline, ok := ctx.Deadline(); ok {
+			fields = append(fields, zap.Time("deadline", deadline), zap.Duration("time_until_deadline", time.Until(deadline)))
+		}
+		c.logger.Warn("Monetix request failed", fields...)
 		return nil, merrors.Internal("monetix request failed: " + err.Error())
 	}
 	defer resp.Body.Close()
@@ -288,3 +311,23 @@ func clearSignature(req any) (func(string), error) {
 		return nil, merrors.Internal("unsupported monetix payload type for signing")
 	}
 }
+
+func logRequestDeadline(logger *zap.Logger, ctx context.Context, url string) {
+	if logger == nil {
+		return
+	}
+	if ctx == nil {
+		logger.Info("Monetix request context is nil", zap.String("url", url))
+		return
+	}
+	deadline, ok := ctx.Deadline()
+	if !ok {
+		logger.Info("Monetix request context has no deadline", zap.String("url", url))
+		return
+	}
+	logger.Info("Monetix request context deadline",
+		zap.String("url", url),
+		zap.Time("deadline", deadline),
+		zap.Duration("time_until_deadline", time.Until(deadline)),
+	)
+}

api/payments/orchestrator/config.yml

@@ -54,7 +54,7 @@ gateway:
 mntx:
   address: "sendico_mntx_gateway:50075"
   dial_timeout_seconds: 5
-  call_timeout_seconds: 3
+  call_timeout_seconds: 15
   insecure: true
 
 oracle:

api/payments/orchestrator/internal/server/internal/serverimp.go

@@ -273,6 +273,7 @@ func (i *Imp) initMntxClient(cfg clientConfig) mntxclient.Client {
 		Address:     addr,
 		DialTimeout: cfg.dialTimeout(),
 		CallTimeout: cfg.callTimeout(),
+		Logger:      i.logger.Named("client.mntx"),
 	})
 	if err != nil {
 		i.logger.Warn("Failed to connect to mntx gateway service", zap.String("address", addr), zap.Error(err))

frontend/pshared/lib/data/mapper/payment/payment.dart

@@ -2,25 +2,16 @@ import 'package:pshared/data/dto/payment/card.dart';
 import 'package:pshared/data/dto/payment/card_token.dart';
 import 'package:pshared/data/dto/payment/endpoint.dart';
 import 'package:pshared/data/dto/payment/external_chain.dart';
-import 'package:pshared/data/dto/payment/iban.dart';
 import 'package:pshared/data/dto/payment/ledger.dart';
 import 'package:pshared/data/dto/payment/managed_wallet.dart';
-import 'package:pshared/data/dto/payment/russian_bank.dart';
-import 'package:pshared/data/dto/payment/wallet.dart';
 import 'package:pshared/data/mapper/payment/asset.dart';
-import 'package:pshared/data/mapper/payment/iban.dart';
 import 'package:pshared/data/mapper/payment/type.dart';
-import 'package:pshared/data/mapper/payment/russian_bank.dart';
-import 'package:pshared/data/mapper/payment/wallet.dart';
 import 'package:pshared/models/payment/methods/card.dart';
 import 'package:pshared/models/payment/methods/card_token.dart';
 import 'package:pshared/models/payment/methods/crypto_address.dart';
 import 'package:pshared/models/payment/methods/data.dart';
-import 'package:pshared/models/payment/methods/iban.dart';
 import 'package:pshared/models/payment/methods/ledger.dart';
 import 'package:pshared/models/payment/methods/managed_wallet.dart';
-import 'package:pshared/models/payment/methods/russian_bank.dart';
-import 'package:pshared/models/payment/methods/wallet.dart';
 import 'package:pshared/models/payment/type.dart';
 
 
@@ -84,27 +75,8 @@ extension PaymentMethodDataEndpointMapper on PaymentMethodData {
           ).toJson(),
           metadata: metadata,
         );
-      case PaymentType.iban:
+      default:
-        final payload = this as IbanPaymentMethod;
+        throw UnsupportedError('Unsupported payment endpoint type: $type');
-        return PaymentEndpointDTO(
-          type: paymentTypeToValue(type),
-          data: payload.toDTO().toJson(),
-          metadata: metadata,
-        );
-      case PaymentType.bankAccount:
-        final payload = this as RussianBankAccountPaymentMethod;
-        return PaymentEndpointDTO(
-          type: paymentTypeToValue(type),
-          data: payload.toDTO().toJson(),
-          metadata: metadata,
-        );
-      case PaymentType.wallet:
-        final payload = this as WalletPaymentMethod;
-        return PaymentEndpointDTO(
-          type: paymentTypeToValue(type),
-          data: payload.toDTO().toJson(),
-          metadata: metadata,
-        );
     }
   }
 }
@@ -154,15 +126,8 @@ extension PaymentEndpointDTOMapper on PaymentEndpointDTO {
           maskedPan: payload.maskedPan,
           metadata: metadata,
         );
-      case PaymentType.iban:
+      default:
-        final payload = IbanPaymentDataDTO.fromJson(data);
+        throw UnsupportedError('Unsupported payment endpoint type: ${paymentTypeFromValue(type)}');
-        return payload.toDomain();
-      case PaymentType.bankAccount:
-        final payload = RussianBankAccountPaymentDataDTO.fromJson(data);
-        return payload.toDomain();
-      case PaymentType.wallet:
-        final payload = WalletPaymentDataDTO.fromJson(data);
-        return payload.toDomain();
     }
   }
 }

frontend/pshared/lib/provider/payment/amount.dart

@@ -4,11 +4,9 @@ import 'package:flutter/material.dart';
 class PaymentAmountProvider with ChangeNotifier {
   double _amount = 10.0;
   bool _payerCoversFee = true;
-  bool _isEditing = false;
 
   double get amount => _amount;
   bool get payerCoversFee => _payerCoversFee;
-  bool get isEditing => _isEditing;
 
   void setAmount(double value) {
     _amount = value;
@@ -19,10 +17,4 @@ class PaymentAmountProvider with ChangeNotifier {
     _payerCoversFee = value;
     notifyListeners();
   }
-
-  void setEditing(bool value) {
-    if (_isEditing == value) return;
-    _isEditing = value;
-    notifyListeners();
-  }
 }

frontend/pshared/lib/provider/payment/provider.dart

@@ -31,7 +31,7 @@ class PaymentProvider extends ChangeNotifier {
 
   Future<Payment?> pay({String? idempotencyKey, Map<String, String>? metadata}) async {
     if (!_organization.isOrganizationSet) throw StateError('Organization is not set');
-    if (!_quotation.hasLiveQuote) throw StateError('Quotation is not ready');
+    if (!_quotation.isReady) throw StateError('Quotation is not ready');
     final quoteRef = _quotation.quotation?.quoteRef;
     if (quoteRef == null || quoteRef.isEmpty) {
       throw StateError('Quotation reference is not set');

frontend/pshared/lib/provider/payment/quotation.dart

@@ -1,6 +1,3 @@
-import 'dart:async';
-import 'dart:convert';
-
 import 'package:flutter/material.dart';
 
 import 'package:collection/collection.dart';
@@ -18,7 +15,6 @@ import 'package:pshared/models/payment/kind.dart';
 import 'package:pshared/models/payment/methods/managed_wallet.dart';
 import 'package:pshared/models/payment/methods/type.dart';
 import 'package:pshared/models/payment/money.dart';
-import 'package:pshared/models/payment/type.dart';
 import 'package:pshared/models/payment/settlement_mode.dart';
 import 'package:pshared/models/payment/intent.dart';
 import 'package:pshared/models/payment/quote.dart';
@@ -38,16 +34,6 @@ class QuotationProvider extends ChangeNotifier {
   Resource<PaymentQuote> _quotation = Resource(data: null, isLoading: false, error: null);
   late OrganizationsProvider _organizations;
   bool _isLoaded = false;
-  bool _organizationAttached = false;
-  PaymentIntent? _pendingIntent;
-  String? _lastRequestSignature;
-  Timer? _debounceTimer;
-  Timer? _expirationTimer;
-  bool _autoRefreshEnabled = true;
-  bool _amountEditing = false;
-
-  static const _inputDebounce = Duration(milliseconds: 500);
-  static const _expiryGracePeriod = Duration(seconds: 1);
 
   void update(
     OrganizationsProvider venue, 
@@ -58,81 +44,44 @@ class QuotationProvider extends ChangeNotifier {
     PaymentMethodsProvider methods,
   ) {
     _organizations = venue;
-    _organizationAttached = true;
+    final t = flow.selectedType;
-    final wasEditing = _amountEditing;
+    final method = methods.methods.firstWhereOrNull((m) => m.type == t);
-    _amountEditing = payment.isEditing;
+    if ((wallets.selectedWallet != null) && (method != null)) {
-    final editingJustEnded = wasEditing && !_amountEditing;
+      final customer = _buildCustomer(
-    _pendingIntent = _buildIntent(
+        recipient: recipients.currentObject,
-      payment: payment,
+        method: method,
-      wallets: wallets,
+      );
-      flow: flow,
+      getQuotation(PaymentIntent(
-      recipients: recipients,
+        kind: PaymentKind.payout,
-      methods: methods,
+        amount: Money(
-    );
+          amount: payment.amount.toString(), 
-
+          // TODO: adapt to possible other sources
-    if (_pendingIntent == null) {
+          currency: currencyCodeToString(wallets.selectedWallet!.currency),
-      _reset();
+        ),
-      return;
+        destination: method.data,
+        source: ManagedWalletPaymentMethod(
+          managedWalletRef: wallets.selectedWallet!.id,
+        ),
+        fx: FxIntent(
+          pair: CurrencyPair(
+            base: currencyCodeToString(wallets.selectedWallet!.currency), 
+            quote: 'RUB', // TODO: exentd target currencies
+          ),
+          side: FxSide.sellBaseBuyQuote,
+        ),
+        settlementMode: payment.payerCoversFee ? SettlementMode.fixReceived : SettlementMode.fixSource,
+        customer: customer,
+      ));
     }
-
-    if (_amountEditing) {
-      _debounceTimer?.cancel();
-      return;
-    }
-
-    if (editingJustEnded) {
-      refreshNow(force: false);
-      return;
-    }
-
-    _scheduleQuotationRefresh();
   }
 
-  PaymentQuote? get quotation => hasQuoteForCurrentIntent ? _quotation.data : null;
+  PaymentQuote? get quotation => _quotation.data;
-  bool get isLoading => _quotation.isLoading;
-  Exception? get error => _quotation.error;
-  bool get autoRefreshEnabled => _autoRefreshEnabled;
-  bool get canRequestQuote => _organizationAttached && _pendingIntent != null && _organizations.isOrganizationSet;
 
-  bool get _isExpired {
+  bool get isReady => _isLoaded && !_quotation.isLoading && _quotation.error == null;
-    final remaining = timeToExpire;
-    return remaining != null && remaining <= Duration.zero;
-  }
 
-  bool get hasQuoteForCurrentIntent {
+  Asset? get fee => quotation == null ? null : createAsset(quotation!.expectedFeeTotal!.currency, quotation!.expectedFeeTotal!.amount);
-    if (_pendingIntent == null || _lastRequestSignature == null) return false;
+  Asset? get total => quotation == null ? null : createAsset(quotation!.debitAmount!.currency, quotation!.debitAmount!.amount);
-    return _lastRequestSignature == _signature(_pendingIntent!);
+  Asset? get recipientGets => quotation == null ? null : createAsset(quotation!.expectedSettlementAmount!.currency, quotation!.expectedSettlementAmount!.amount);
-  }
-
-  bool get isReady => _isLoaded && !_isExpired && !_quotation.isLoading && _quotation.error == null;
-
-  bool get hasLiveQuote => isReady && quotation != null;
-
-  Duration? get timeToExpire {
-    final expiresAt = _quoteExpiry;
-    if (expiresAt == null) return null;
-    final diff = expiresAt.difference(DateTime.now().toUtc());
-    return diff.isNegative ? Duration.zero : diff;
-  }
-
-  Asset? get fee => quotation == null
-      ? null
-      : createAsset(
-          quotation!.expectedFeeTotal!.currency,
-          quotation!.expectedFeeTotal!.amount,
-        );
-  Asset? get total => quotation == null
-      ? null
-      : createAsset(
-          quotation!.debitAmount!.currency,
-          quotation!.debitAmount!.amount,
-        );
-  Asset? get recipientGets => quotation == null
-      ? null
-      : createAsset(
-          quotation!.expectedSettlementAmount!.currency,
-          quotation!.expectedSettlementAmount!.amount,
-        );
 
   Customer _buildCustomer({
     required Recipient? recipient,
@@ -191,117 +140,10 @@ class QuotationProvider extends ChangeNotifier {
     notifyListeners();
   }
 
-  void refreshNow({bool force = true}) {
+  Future<PaymentQuote?> getQuotation(PaymentIntent intent) async {
-    _debounceTimer?.cancel();
+    if (!_organizations.isOrganizationSet) throw StateError('Organization is not set');
-    if (!canRequestQuote) {
-      if (_pendingIntent == null) {
-        _reset();
-      }
-      return;
-    }
-    unawaited(_requestQuotation(_pendingIntent!, force: force));
-  }
-
-  void setAutoRefresh(bool enabled) {
-    if (!_organizationAttached) return;
-    if (_autoRefreshEnabled == enabled) return;
-    _autoRefreshEnabled = enabled;
-    if (_autoRefreshEnabled && (!hasLiveQuote || _isExpired) && _pendingIntent != null) {
-      unawaited(_requestQuotation(_pendingIntent!, force: true));
-    } else {
-      _startExpirationTimer();
-      notifyListeners();
-    }
-  }
-
-  @override
-  void dispose() {
-    _debounceTimer?.cancel();
-    _expirationTimer?.cancel();
-    super.dispose();
-  }
-
-  PaymentIntent? _buildIntent({
-    required PaymentAmountProvider payment,
-    required WalletsProvider wallets,
-    required PaymentFlowProvider flow,
-    required RecipientsProvider recipients,
-    required PaymentMethodsProvider methods,
-  }) {
-    if (!_organizationAttached || !_organizations.isOrganizationSet) return null;
-    final type = flow.selectedType;
-    final method = methods.methods.firstWhereOrNull((m) => m.type == type);
-    final wallet = wallets.selectedWallet;
-
-    if (wallet == null || method == null) return null;
-
-    final customer = _buildCustomer(
-      recipient: recipients.currentObject,
-      method: method,
-    );
-
-    return PaymentIntent(
-      kind: PaymentKind.payout,
-      amount: Money(
-        amount: payment.amount.toString(),
-        // TODO: adapt to possible other sources
-        currency: currencyCodeToString(wallet.currency),
-      ),
-      destination: method.data,
-      source: ManagedWalletPaymentMethod(
-        managedWalletRef: wallet.id,
-      ),
-      fx: FxIntent(
-        pair: CurrencyPair(
-          base: currencyCodeToString(wallet.currency),
-          quote: 'RUB', // TODO: exentd target currencies
-        ),
-        side: FxSide.sellBaseBuyQuote,
-      ),
-      settlementMode: payment.payerCoversFee ? SettlementMode.fixReceived : SettlementMode.fixSource,
-      customer: customer,
-    );
-  }
-
-  void _scheduleQuotationRefresh() {
-    _debounceTimer?.cancel();
-    if (_pendingIntent == null) {
-      _reset();
-      return;
-    }
-
-    _debounceTimer = Timer(_inputDebounce, () {
-      unawaited(_requestQuotation(_pendingIntent!, force: false));
-    });
-  }
-
-  Future<PaymentQuote?> _requestQuotation(PaymentIntent intent, {required bool force}) async {
-    if (!_organizationAttached || !_organizations.isOrganizationSet) {
-      _reset();
-      return null;
-    }
-
-    final destinationType = intent.destination?.type;
-    if (destinationType == PaymentType.bankAccount) {
-      _setResource(
-        _quotation.copyWith(
-          data: null,
-          isLoading: false,
-          error: Exception('Unsupported payment endpoint type: $destinationType'),
-        ),
-      );
-      return null;
-    }
-
-    final signature = _signature(intent);
-    final isSameIntent = _lastRequestSignature == signature;
-    if (!force && isSameIntent && hasLiveQuote) {
-      _startExpirationTimer();
-      return _quotation.data;
-    }
-
-    _setResource(_quotation.copyWith(isLoading: true, error: null));
     try {
+      _quotation = _quotation.copyWith(isLoading: true, error: null);
       final response = await QuotationService.getQuotation(
         _organizations.current.id, 
         QuotePaymentRequest(
@@ -310,9 +152,7 @@ class QuotationProvider extends ChangeNotifier {
         ),
       );
       _isLoaded = true;
-      _lastRequestSignature = signature;
       _setResource(_quotation.copyWith(data: response, isLoading: false, error: null));
-      _startExpirationTimer();
     } catch (e) {
       _setResource(_quotation.copyWith(
         data: null,
@@ -320,68 +160,13 @@ class QuotationProvider extends ChangeNotifier {
         isLoading: false,
       ));
     }
+    notifyListeners();
     return _quotation.data;
   }
 
-  void _startExpirationTimer() {
-    _expirationTimer?.cancel();
-    final remaining = timeToExpire;
-    if (remaining == null) return;
-
-    final triggerOffset = _autoRefreshEnabled ? _expiryGracePeriod : Duration.zero;
-    final duration = remaining > triggerOffset ? remaining - triggerOffset : Duration.zero;
-    _expirationTimer = Timer(duration, () {
-      if (_autoRefreshEnabled && _pendingIntent != null) {
-        unawaited(_requestQuotation(_pendingIntent!, force: true));
-      } else {
-        notifyListeners();
-      }
-    });
-  }
-
-  void _reset() {
-    _debounceTimer?.cancel();
-    _expirationTimer?.cancel();
-    _pendingIntent = null;
-    _lastRequestSignature = null;
-    _isLoaded = false;
-    _setResource(Resource(data: null, isLoading: false, error: null));
-  }
-
-  DateTime? get _quoteExpiry {
-    final expiresAt = quotation?.fxQuote?.expiresAtUnixMs;
-    if (expiresAt == null) return null;
-    return DateTime.fromMillisecondsSinceEpoch(expiresAt, isUtc: true);
-  }
-
-  String _signature(PaymentIntent intent) {
-    try {
-      return jsonEncode(intent.toDTO().toJson());
-    } catch (_) {
-      return jsonEncode({
-        'kind': intent.kind.toString(),
-        'source': intent.source?.type.toString(),
-        'destination': intent.destination?.type.toString(),
-        'amount': {
-          'value': intent.amount?.amount,
-          'currency': intent.amount?.currency,
-        },
-        'fx': intent.fx == null
-            ? null
-            : {
-                'pair': {
-                  'base': intent.fx?.pair?.base,
-                  'quote': intent.fx?.pair?.quote,
-                },
-                'side': intent.fx?.side.toString(),
-              },
-        'settlementMode': intent.settlementMode.toString(),
-        'customer': intent.customer?.id,
-      });
-    }
-  }
-
   void reset() {
-    _reset();
+    _setResource(Resource(data: null, isLoading: false, error: null));
+    _isLoaded = false;
+    notifyListeners();
   }
 }

frontend/pweb/caddy/Caddyfile

@@ -39,7 +39,7 @@
     @monetixSuccess {
       path /gateway/m/success*
       method POST
-      # remote_ip 88.218.112.16 88.218.112.16/32 88.218.113.16 88.218.113.16/32 93.179.90.141 93.179.90.128/25 93.179.90.161 93.179.91.0/24 178.57.67.47 178.57.66.128/25 178.57.67.154 178.57.67.0/24 178.57.68.244
+      remote_ip 88.218.112.16 88.218.112.16/32 88.218.113.16 88.218.113.16/32 93.179.90.141 93.179.90.128/25 93.179.90.161 93.179.91.0/24 178.57.67.47 178.57.66.128/25 178.57.67.154 178.57.67.0/24 178.57.68.244
     }
     handle @monetixSuccess {
       rewrite * /monetix/callback
@@ -50,7 +50,7 @@
     @monetixFail {
       path /gateway/m/fail*
       method POST
-      # remote_ip 88.218.112.16 88.218.112.16/32 88.218.113.16 88.218.113.16/32 93.179.90.141 93.179.90.128/25 93.179.90.161 93.179.91.0/24 178.57.67.47 178.57.66.128/25 178.57.67.154 178.57.67.0/24 178.57.68.244
+      remote_ip 88.218.112.16 88.218.112.16/32 88.218.113.16 88.218.113.16/32 93.179.90.141 93.179.90.128/25 93.179.90.161 93.179.91.0/24 178.57.67.47 178.57.66.128/25 178.57.67.154 178.57.67.0/24 178.57.68.244
     }
     handle @monetixFail {
       rewrite * /monetix/callback

frontend/pweb/lib/l10n/en.arb

@@ -383,19 +383,6 @@
   "payout": "Payout",
   "sendTo": "Send Payout To",
   "send": "Send Payout",
-  "quoteUnavailable": "Waiting for a quote...",
-  "quoteUpdating": "Refreshing quote...",
-  "quoteExpiresIn": "Quote expires in {time}",
-  "@quoteExpiresIn": {
-    "placeholders": {
-      "time": {
-        "type": "String"
-      }
-    }
-  },
-  "quoteExpired": "Quote expired, request a new one",
-  "quoteAutoRefresh": "Auto-refresh quote",
-  "quoteErrorGeneric": "Could not refresh quote, try again later",
   "recipientPaysFee": "Recipient pays the fee",
 
   "sentAmount": "Sent amount: {amount}",

frontend/pweb/lib/l10n/ru.arb

@@ -383,19 +383,6 @@
   "payout": "Выплата",
   "sendTo": "Отправить выплату",
   "send": "Отправить выплату",
-  "quoteUnavailable": "Ожидание котировки...",
-  "quoteUpdating": "Обновляем котировку...",
-  "quoteExpiresIn": "Котировка истекает через {time}",
-  "@quoteExpiresIn": {
-    "placeholders": {
-      "time": {
-        "type": "String"
-      }
-    }
-  },
-  "quoteExpired": "Срок котировки истек, запросите новую",
-  "quoteAutoRefresh": "Автообновление котировки",
-  "quoteErrorGeneric": "Не удалось обновить котировку, повторите позже",
   "recipientPaysFee": "Получатель оплачивает комиссию",
 
   "sentAmount": "Отправленная сумма: {amount}",

frontend/pweb/lib/models/button_state.dart

@@ -1 +0,0 @@
-enum ButtonState { enabled, disabled, loading }

frontend/pweb/lib/pages/dashboard/payouts/amount.dart

@@ -3,7 +3,6 @@ import 'package:flutter/material.dart';
 import 'package:provider/provider.dart';
 
 import 'package:pshared/provider/payment/amount.dart';
-import 'package:pshared/provider/payment/quotation.dart';
 import 'package:pshared/utils/currency.dart';
 
 import 'package:pweb/generated/i18n/app_localizations.dart';
@@ -18,7 +17,6 @@ class PaymentAmountWidget extends StatefulWidget {
 
 class _PaymentAmountWidgetState extends State<PaymentAmountWidget> {
   late final TextEditingController _controller;
-  late final FocusNode _focusNode;
   bool _isSyncingText = false;
 
   @override
@@ -26,14 +24,10 @@ class _PaymentAmountWidgetState extends State<PaymentAmountWidget> {
     super.initState();
     final initialAmount = context.read<PaymentAmountProvider>().amount;
     _controller = TextEditingController(text: amountToString(initialAmount));
-    _focusNode = FocusNode()..addListener(_handleFocusChange);
   }
 
   @override
   void dispose() {
-    _focusNode.removeListener(_handleFocusChange);
-    _focusNode.dispose();
-    context.read<PaymentAmountProvider>().setEditing(false);
     _controller.dispose();
     super.dispose();
   }
@@ -62,16 +56,6 @@ class _PaymentAmountWidgetState extends State<PaymentAmountWidget> {
     }
   }
 
-  void _handleFocusChange() {
-    final amountProvider = context.read<PaymentAmountProvider>();
-    if (_focusNode.hasFocus) {
-      amountProvider.setEditing(true);
-      return;
-    }
-
-    amountProvider.setEditing(false);
-  }
-
   @override
   Widget build(BuildContext context) {
     final amount = context.select<PaymentAmountProvider, double>((provider) => provider.amount);
@@ -79,14 +63,12 @@ class _PaymentAmountWidgetState extends State<PaymentAmountWidget> {
 
     return TextField(
       controller: _controller,
-      focusNode: _focusNode,
       keyboardType: const TextInputType.numberWithOptions(decimal: true),
       decoration: InputDecoration(
         labelText: AppLocalizations.of(context)!.amount,
         border: const OutlineInputBorder(),
       ),
       onChanged: _onChanged,
-      onEditingComplete: () => _focusNode.unfocus(),
     );
   }
 }

frontend/pweb/lib/pages/payment_methods/page.dart

@@ -6,7 +6,6 @@ import 'package:pshared/models/payment/type.dart';
 import 'package:pshared/models/recipient/recipient.dart';
 import 'package:pshared/provider/payment/flow.dart';
 import 'package:pshared/provider/payment/provider.dart';
-import 'package:pshared/provider/payment/quotation.dart';
 import 'package:pshared/provider/recipient/pmethods.dart';
 import 'package:pshared/provider/recipient/provider.dart';
 import 'package:pshared/provider/payment/wallets.dart';
@@ -82,16 +81,8 @@ class _PaymentPageState extends State<PaymentPage> {
   void _handleSendPayment() {
     final flowProvider = context.read<PaymentFlowProvider>();
     final paymentProvider = context.read<PaymentProvider>();
-    final quotationProvider = context.read<QuotationProvider>();
     if (paymentProvider.isLoading) return;
 
-    if (!quotationProvider.hasLiveQuote) {
-      if (quotationProvider.canRequestQuote) {
-        quotationProvider.refreshNow();
-      }
-      return;
-    }
-
     paymentProvider.pay().then((_) {
       PosthogService.paymentInitiated(method: flowProvider.selectedType);
     }).catchError((error) {

frontend/pweb/lib/pages/payment_methods/payment_page/page.dart

@@ -3,12 +3,11 @@ import 'package:flutter/material.dart';
 import 'package:pshared/models/payment/wallet.dart';
 import 'package:pshared/models/recipient/recipient.dart';
 import 'package:pshared/provider/recipient/provider.dart';
-
 import 'package:pweb/pages/dashboard/payouts/form.dart';
+
 import 'package:pweb/pages/payment_methods/payment_page/back_button.dart';
 import 'package:pweb/pages/payment_methods/payment_page/header.dart';
 import 'package:pweb/pages/payment_methods/payment_page/method_selector.dart';
-import 'package:pweb/pages/payment_methods/payment_page/quote/quote_status.dart';
 import 'package:pweb/pages/payment_methods/payment_page/send_button.dart';
 import 'package:pweb/pages/payment_methods/widgets/payment_info_section.dart';
 import 'package:pweb/pages/payment_methods/widgets/recipient_section.dart';
@@ -95,9 +94,7 @@ class PaymentPageContent extends StatelessWidget {
                   PaymentInfoSection(dimensions: dimensions),
                   SizedBox(height: dimensions.paddingLarge),
                   const PaymentFormWidget(),
-                  SizedBox(height: dimensions.paddingLarge),
+                  SizedBox(height: dimensions.paddingXXXLarge),
-                  const QuoteStatus(),
-                  SizedBox(height: dimensions.paddingXXLarge),
                   SendButton(onPressed: onSend),
                   SizedBox(height: dimensions.paddingLarge),
                 ],

frontend/pweb/lib/pages/payment_methods/payment_page/quote/actions.dart

@@ -1,54 +0,0 @@
-import 'package:flutter/material.dart';
-
-import 'package:pweb/utils/dimensions.dart';
-
-
-class QuoteStatusActions extends StatelessWidget {
-  final bool isLoading;
-  final bool canRefresh;
-  final bool autoRefreshEnabled;
-  final ValueChanged<bool>? onToggleAutoRefresh;
-  final VoidCallback? onRefresh;
-  final String autoRefreshLabel;
-  final String refreshLabel;
-  final AppDimensions dimensions;
-  final TextTheme theme;
-
-  const QuoteStatusActions({
-    super.key,
-    required this.isLoading,
-    required this.canRefresh,
-    required this.autoRefreshEnabled,
-    required this.onToggleAutoRefresh,
-    required this.onRefresh,
-    required this.autoRefreshLabel,
-    required this.refreshLabel,
-    required this.dimensions,
-    required this.theme,
-  });
-
-  @override
-  Widget build(BuildContext context) => Row(
-        children: [
-          Expanded(
-            child: SwitchListTile.adaptive(
-              contentPadding: EdgeInsets.zero,
-              value: autoRefreshEnabled,
-              title: Text(autoRefreshLabel, style: theme.bodyMedium),
-              onChanged: onToggleAutoRefresh,
-            ),
-          ),
-          TextButton.icon(
-            onPressed: canRefresh ? onRefresh : null,
-            icon: isLoading
-                ? SizedBox(
-                    width: 16,
-                    height: 16,
-                    child: CircularProgressIndicator(strokeWidth: 2),
-                  )
-                : const Icon(Icons.refresh),
-            label: Text(refreshLabel),
-          ),
-        ],
-      );
-}

frontend/pweb/lib/pages/payment_methods/payment_page/quote/message.dart

@@ -1,49 +0,0 @@
-import 'package:flutter/material.dart';
-
-import 'package:pweb/utils/dimensions.dart';
-
-
-class QuoteStatusMessage extends StatelessWidget {
-  final String statusText;
-  final String? errorText;
-  final bool showDetails;
-  final VoidCallback onToggleDetails;
-  final AppDimensions dimensions;
-  final TextTheme theme;
-  final String showLabel;
-  final String hideLabel;
-
-  const QuoteStatusMessage({
-    super.key,
-    required this.statusText,
-    required this.errorText,
-    required this.showDetails,
-    required this.onToggleDetails,
-    required this.dimensions,
-    required this.theme,
-    required this.showLabel,
-    required this.hideLabel,
-  });
-
-  @override
-  Widget build(BuildContext context) => Column(
-        crossAxisAlignment: CrossAxisAlignment.start,
-        children: [
-          Text(statusText, style: theme.bodyMedium),
-          if (errorText != null) ...[
-            SizedBox(height: dimensions.paddingSmall),
-            TextButton(
-              onPressed: onToggleDetails,
-              child: Text(showDetails ? hideLabel : showLabel),
-            ),
-            if (showDetails) ...[
-              SizedBox(height: dimensions.paddingSmall),
-              Text(
-                errorText!,
-                style: theme.bodySmall,
-              ),
-            ],
-          ],
-        ],
-      );
-}

frontend/pweb/lib/pages/payment_methods/payment_page/quote/quote_status.dart

@@ -1,115 +0,0 @@
-import 'package:flutter/material.dart';
-
-import 'package:provider/provider.dart';
-
-import 'package:pshared/provider/payment/quotation.dart';
-
-import 'package:pweb/generated/i18n/app_localizations.dart';
-import 'package:pweb/pages/payment_methods/payment_page/quote/actions.dart';
-import 'package:pweb/pages/payment_methods/payment_page/quote/message.dart';
-import 'package:pweb/utils/dimensions.dart';
-
-
-class QuoteStatus extends StatefulWidget {
-  const QuoteStatus({super.key});
-
-  @override
-  State<QuoteStatus> createState() => _QuoteStatusState();
-}
-
-class _QuoteStatusState extends State<QuoteStatus> {
-  bool _showDetails = false;
-
-  @override
-  Widget build(BuildContext context) {
-    final theme = Theme.of(context);
-    final dimensions = AppDimensions();
-    final loc = AppLocalizations.of(context)!;
-
-    return Consumer<QuotationProvider>(
-      builder: (context, provider, _) {
-        final statusText = _statusText(provider, loc);
-        final canRefresh = provider.canRequestQuote && !provider.isLoading;
-        final refreshLabel = provider.isLoading ? loc.quoteUpdating : loc.retry;
-        final error = provider.error;
-        final backgroundColor = theme.colorScheme.surfaceContainerHighest.withValues(alpha: 0.3);
-
-        return Container(
-          width: double.infinity,
-          padding: EdgeInsets.all(dimensions.paddingMedium),
-          decoration: BoxDecoration(
-            color: backgroundColor,
-            borderRadius: BorderRadius.circular(dimensions.borderRadiusSmall),
-          ),
-          child: Column(
-            crossAxisAlignment: CrossAxisAlignment.start,
-            children: [
-              QuoteStatusMessage(
-                statusText: statusText,
-                errorText: error?.toString(),
-                showDetails: _showDetails,
-                onToggleDetails: () => setState(() => _showDetails = !_showDetails),
-                dimensions: dimensions,
-                theme: theme.textTheme,
-                showLabel: loc.showDetails,
-                hideLabel: loc.hideDetails,
-              ),
-              SizedBox(height: dimensions.paddingSmall),
-              QuoteStatusActions(
-                isLoading: provider.isLoading,
-                canRefresh: canRefresh,
-                autoRefreshEnabled: provider.autoRefreshEnabled,
-                onToggleAutoRefresh: provider.canRequestQuote
-                    ? (value) => context.read<QuotationProvider>().setAutoRefresh(value)
-                    : null,
-                onRefresh: canRefresh ? () => context.read<QuotationProvider>().refreshNow() : null,
-                autoRefreshLabel: loc.quoteAutoRefresh,
-                refreshLabel: refreshLabel,
-                dimensions: dimensions,
-                theme: theme.textTheme,
-              ),
-            ],
-          ),
-        );
-      },
-    );
-  }
-
-  String _statusText(QuotationProvider provider, AppLocalizations loc) {
-    if (provider.error != null) {
-      return loc.quoteErrorGeneric;
-    }
-
-    if (!provider.canRequestQuote) {
-      return loc.quoteUnavailable;
-    }
-
-    if (provider.isLoading) {
-      return loc.quoteUpdating;
-    }
-
-    if (provider.hasLiveQuote) {
-      final remaining = provider.timeToExpire;
-      if (remaining != null) {
-        return loc.quoteExpiresIn(_formatDuration(remaining));
-      }
-    }
-
-    if (provider.hasQuoteForCurrentIntent) {
-      return loc.quoteExpired;
-    }
-
-    return loc.quoteUnavailable;
-  }
-
-  String _formatDuration(Duration duration) {
-    final minutes = duration.inMinutes;
-    final seconds = duration.inSeconds.remainder(60).toString().padLeft(2, '0');
-    if (duration.inHours > 0) {
-      final hours = duration.inHours;
-      final mins = minutes.remainder(60).toString().padLeft(2, '0');
-      return '$hours:$mins:$seconds';
-    }
-    return '$minutes:$seconds';
-  }
-}

frontend/pweb/lib/pages/payment_methods/payment_page/send_button.dart

@@ -1,76 +1,44 @@
 import 'package:flutter/material.dart';
 
-import 'package:provider/provider.dart';
-
-import 'package:pshared/provider/payment/provider.dart';
-import 'package:pshared/provider/payment/quotation.dart';
-
-import 'package:pweb/models/button_state.dart';
 import 'package:pweb/utils/dimensions.dart';
 
 import 'package:pweb/generated/i18n/app_localizations.dart';
 
 
 class SendButton extends StatelessWidget {
-  final VoidCallback? onPressed;
+  final VoidCallback onPressed;
 
-  const SendButton({
+  const SendButton({super.key, required this.onPressed});
-    super.key,
-    required this.onPressed,
-  });
 
   @override
-  Widget build(BuildContext context) => Consumer2<QuotationProvider, PaymentProvider>(
+  Widget build(BuildContext context) {
-        builder: (context, quotation, payment, _) {
+    final theme = Theme.of(context);
-          final theme = Theme.of(context);
+    final dimensions = AppDimensions();
-          final dimensions = AppDimensions();
 
-          final canSend = quotation.hasLiveQuote && !payment.isLoading;
+    return Center(
-          final state = payment.isLoading
+      child: SizedBox(
-              ? ButtonState.loading
+        width: dimensions.buttonWidth,
-              : (canSend ? ButtonState.enabled : ButtonState.disabled);
+        height: dimensions.buttonHeight,
-          final isLoading = state == ButtonState.loading;
+        child: InkWell(
-          final isActive = state == ButtonState.enabled && onPressed != null;
+          borderRadius: BorderRadius.circular(dimensions.borderRadiusSmall),
-
+          onTap: onPressed,
-          final backgroundColor = isActive
+          child: Container(
-              ? theme.colorScheme.primary
+            decoration: BoxDecoration(
-              : theme.colorScheme.primary.withValues(alpha: 0.5);
+              color: theme.colorScheme.primary,
-          final textColor = theme.colorScheme.onSecondary.withValues(alpha: isActive ? 1 : 0.7);
+              borderRadius: BorderRadius.circular(dimensions.borderRadiusSmall),
-
+            ),
-          return Center(
+            child: Center(
-            child: SizedBox(
+              child: Text(
-              width: dimensions.buttonWidth,
+                AppLocalizations.of(context)!.send,
-              height: dimensions.buttonHeight,
+                style: theme.textTheme.bodyLarge?.copyWith(
-              child: InkWell(
+                  color: theme.colorScheme.onSecondary,
-                borderRadius: BorderRadius.circular(dimensions.borderRadiusSmall),
+                  fontWeight: FontWeight.w600,
-                onTap: isActive ? onPressed : null,
-                child: Container(
-                  decoration: BoxDecoration(
-                    color: backgroundColor,
-                    borderRadius: BorderRadius.circular(dimensions.borderRadiusSmall),
-                  ),
-                  child: Center(
-                    child: isLoading
-                        ? SizedBox(
-                            height: dimensions.iconSizeSmall,
-                            width: dimensions.iconSizeSmall,
-                            child: CircularProgressIndicator(
-                              strokeWidth: 2,
-                              valueColor: AlwaysStoppedAnimation<Color>(textColor),
-                            ),
-                          )
-                        : Text(
-                            AppLocalizations.of(context)!.send,
-                            style: theme.textTheme.bodyLarge?.copyWith(
-                              color: textColor,
-                              fontWeight: FontWeight.w600,
-                            ),
-                          ),
-                  ),
                 ),
               ),
             ),
-          );
+          ),
-        },
+        ),
-      );
+      ),
+    );
+  }
 }

frontend/pweb/lib/providers/mock_payment.dart

@@ -1,24 +0,0 @@
-import 'package:flutter/material.dart';
-
-
-class MockPaymentProvider with ChangeNotifier {
-  double _amount = 10.0;
-  bool _payerCoversFee = true;
-
-  double get amount => _amount;
-  bool get payerCoversFee => _payerCoversFee;
-
-  double get fee => _amount * 0.05;
-  double get total => payerCoversFee ? (_amount + fee) : _amount;
-  double get recipientGets => payerCoversFee ? _amount : (_amount - fee);
-
-  void setAmount(double value) {
-    _amount = value;
-    notifyListeners();
-  }
-
-  void setPayerCoversFee(bool value) {
-    _payerCoversFee = value;
-    notifyListeners();
-  }
-}

frontend/pweb/lib/utils/payment/dropdown.dart

@@ -23,7 +23,7 @@ class PaymentMethodDropdown extends StatelessWidget {
   @override
   Widget build(BuildContext context) => DropdownButtonFormField<Wallet>(
     dropdownColor: Theme.of(context).colorScheme.onSecondary,
-    initialValue: _getSelectedMethod(),
+    value: _getSelectedMethod(),
     decoration: InputDecoration(
       labelText: AppLocalizations.of(context)!.whereGetMoney,
       border: OutlineInputBorder(borderRadius: BorderRadius.circular(8)),