feat: custom mempool url

lib/core/core_locator.dart

@@ -6,6 +6,7 @@ import 'package:bb_mobile/core/exchange/exchange_locator.dart';
 import 'package:bb_mobile/core/fees/fees_locator.dart';
 import 'package:bb_mobile/core/labels/labels_locator.dart';
 import 'package:bb_mobile/core/ledger/ledger_locator.dart';
+import 'package:bb_mobile/core/mempool/mempool_locator.dart';
 import 'package:bb_mobile/core/payjoin/payjoin_locator.dart';
 import 'package:bb_mobile/core/recoverbull/recoverbull_locator.dart';
 import 'package:bb_mobile/core/seed/seed_locator.dart';
@@ -29,6 +30,7 @@ class CoreLocator {
     await ElectrumLocator.registerDatasources(locator);
     ExchangeLocator.registerDatasources(locator);
     FeesLocator.registerDatasources(locator);
+    await MempoolLocator.registerDatasources(locator);
     PayjoinLocator.registerDatasources(locator);
     await RecoverbullLocator.registerDatasources(locator);
     SeedLocator.registerDatasources(locator);
@@ -44,6 +46,7 @@ class CoreLocator {
   static void registerPorts() {
     ElectrumLocator.registerPorts(locator);
     BlockchainLocator.registerPorts(locator);
+    MempoolLocator.registerPorts(locator);
     SwapsLocator.registerPorts(locator);
     WalletLocator.registerPorts(locator);
   }
@@ -55,6 +58,7 @@ class CoreLocator {
     ElectrumLocator.registerRepositories(locator);
     ExchangeLocator.registerRepositories(locator);
     FeesLocator.registerRepositories(locator);
+    MempoolLocator.registerRepositories(locator);
     PayjoinLocator.registerRepositories(locator);
     SeedLocator.registerRepositories(locator);
     StorageLocator.registerRepositories(locator);
@@ -68,6 +72,7 @@ class CoreLocator {
   }
 
   static void registerServices() {
+    MempoolLocator.registerServices(locator);
     SeedLocator.registerServices(locator);
     SwapsLocator.registerServices(locator);
   }
@@ -78,6 +83,7 @@ class CoreLocator {
     BlockchainLocator.registerUsecases(locator);
     ExchangeLocator.registerUseCases(locator);
     FeesLocator.registerUseCases(locator);
+    MempoolLocator.registerUsecases(locator);
     PayjoinLocator.registerUsecases(locator);
     RecoverbullLocator.registerUsecases(locator);
     SeedLocator.registerUsecases(locator);

lib/core/fees/data/fees_datasource.dart

@@ -1,36 +1,47 @@
 import 'package:bb_mobile/core/fees/domain/fees_entity.dart';
+import 'package:bb_mobile/core/mempool/application/usecases/get_active_mempool_server_usecase.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_settings_repository.dart';
+import 'package:bb_mobile/core/mempool/domain/value_objects/mempool_server_network.dart';
 import 'package:bb_mobile/core/utils/constants.dart';
 import 'package:dio/dio.dart';
 
 class FeesDatasource {
-  final Dio _bitcoinMainnetMempoolHttpClient;
-  final Dio _bitcoinTestnetMempoolHttpClient;
+  final GetActiveMempoolServerUsecase _getActiveMempoolServerUsecase;
+  final MempoolSettingsRepository _mempoolSettingsRepository;
 
   FeesDatasource({
-    String? bitcoinMainnetMempoolUrl,
-    String? bitcoinTestnetMempoolUrl,
-  }) : _bitcoinMainnetMempoolHttpClient = Dio(
-         BaseOptions(
-           baseUrl:
-               bitcoinMainnetMempoolUrl ??
-               'https://${ApiServiceConstants.bbMempoolUrlPath}',
-         ),
-       ),
-       _bitcoinTestnetMempoolHttpClient = Dio(
-         BaseOptions(
-           baseUrl:
-               bitcoinTestnetMempoolUrl ??
-               'https://${ApiServiceConstants.testnetMempoolUrlPath}',
-         ),
-       );
+    required GetActiveMempoolServerUsecase getActiveMempoolServerUsecase,
+    required MempoolSettingsRepository mempoolSettingsRepository,
+  })  : _getActiveMempoolServerUsecase = getActiveMempoolServerUsecase,
+        _mempoolSettingsRepository = mempoolSettingsRepository;
 
   Future<FeeOptions> getBitcoinNetworkFeeOptions({
     required bool isTestnet,
   }) async {
-    final http =
-        isTestnet
-            ? _bitcoinTestnetMempoolHttpClient
-            : _bitcoinMainnetMempoolHttpClient;
+    // Get network settings
+    final network = MempoolServerNetwork.fromEnvironment(
+      isTestnet: isTestnet,
+      isLiquid: false,
+    );
+    final settings = await _mempoolSettingsRepository.fetchByNetwork(network);
+
+    // Determine which mempool server to use
+    String baseUrl;
+    if (settings.useForFeeEstimation) {
+      // Use custom or default mempool server from settings
+      final server = await _getActiveMempoolServerUsecase.execute(
+        isTestnet: isTestnet,
+        isLiquid: false,
+      );
+      baseUrl = server.fullUrl;
+    } else {
+      // Fall back to BB's mempool
+      baseUrl = isTestnet
+          ? 'https://${ApiServiceConstants.testnetMempoolUrlPath}'
+          : 'https://${ApiServiceConstants.bbMempoolUrlPath}';
+    }
+
+    final http = Dio(BaseOptions(baseUrl: baseUrl));
     const path = '/api/v1/fees/recommended';
 
     final resp = await http.get(path);

lib/core/fees/fees_locator.dart

@@ -1,12 +1,20 @@
 import 'package:bb_mobile/core/fees/data/fees_datasource.dart';
 import 'package:bb_mobile/core/fees/data/fees_repository.dart';
 import 'package:bb_mobile/core/fees/domain/get_network_fees_usecase.dart';
+import 'package:bb_mobile/core/mempool/application/usecases/get_active_mempool_server_usecase.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_settings_repository.dart';
 import 'package:bb_mobile/core/settings/data/settings_repository.dart';
 import 'package:get_it/get_it.dart';
 
 class FeesLocator {
   static void registerDatasources(GetIt locator) {
-    locator.registerLazySingleton<FeesDatasource>(() => FeesDatasource());
+    locator.registerLazySingleton<FeesDatasource>(
+      () => FeesDatasource(
+        getActiveMempoolServerUsecase:
+            locator<GetActiveMempoolServerUsecase>(),
+        mempoolSettingsRepository: locator<MempoolSettingsRepository>(),
+      ),
+    );
   }
 
   static void registerRepositories(GetIt locator) {

lib/core/mempool/application/dtos/mempool_server_dto.dart

@@ -0,0 +1,47 @@
+import 'package:bb_mobile/core/mempool/domain/entities/mempool_server.dart';
+
+class MempoolServerDto {
+  final String url;
+  final bool isCustom;
+  final bool isTestnet;
+  final bool isLiquid;
+
+  MempoolServerDto({
+    required this.url,
+    required this.isCustom,
+    required this.isTestnet,
+    required this.isLiquid,
+  });
+
+  factory MempoolServerDto.fromEntity(MempoolServer entity) {
+    return MempoolServerDto(
+      url: entity.url,
+      isCustom: entity.isCustom,
+      isTestnet: entity.isTestnet,
+      isLiquid: entity.isLiquid,
+    );
+  }
+
+  String get fullUrl => 'https://$url';
+
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      other is MempoolServerDto &&
+          runtimeType == other.runtimeType &&
+          url == other.url &&
+          isCustom == other.isCustom &&
+          isTestnet == other.isTestnet &&
+          isLiquid == other.isLiquid;
+
+  @override
+  int get hashCode =>
+      url.hashCode ^
+      isCustom.hashCode ^
+      isTestnet.hashCode ^
+      isLiquid.hashCode;
+
+  @override
+  String toString() =>
+      'MempoolServerDto(url: $url, isCustom: $isCustom, isTestnet: $isTestnet, isLiquid: $isLiquid)';
+}

lib/core/mempool/application/dtos/mempool_settings_dto.dart

@@ -0,0 +1,33 @@
+import 'package:bb_mobile/core/mempool/domain/entities/mempool_settings.dart';
+
+class MempoolSettingsDto {
+  final String network;
+  final bool useForFeeEstimation;
+
+  MempoolSettingsDto({
+    required this.network,
+    required this.useForFeeEstimation,
+  });
+
+  factory MempoolSettingsDto.fromEntity(MempoolSettings entity) {
+    return MempoolSettingsDto(
+      network: entity.network.networkString,
+      useForFeeEstimation: entity.useForFeeEstimation,
+    );
+  }
+
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      other is MempoolSettingsDto &&
+          runtimeType == other.runtimeType &&
+          network == other.network &&
+          useForFeeEstimation == other.useForFeeEstimation;
+
+  @override
+  int get hashCode => network.hashCode ^ useForFeeEstimation.hashCode;
+
+  @override
+  String toString() =>
+      'MempoolSettingsDto(network: $network, useForFeeEstimation: $useForFeeEstimation)';
+}

lib/core/mempool/application/dtos/requests/delete_custom_mempool_server_request.dart

@@ -0,0 +1,7 @@
+class DeleteCustomMempoolServerRequest {
+  final bool isLiquid;
+
+  DeleteCustomMempoolServerRequest({
+    required this.isLiquid,
+  });
+}

lib/core/mempool/application/dtos/requests/load_mempool_server_data_request.dart

@@ -0,0 +1,7 @@
+class LoadMempoolServerDataRequest {
+  final bool isLiquid;
+
+  LoadMempoolServerDataRequest({
+    required this.isLiquid,
+  });
+}

lib/core/mempool/application/dtos/requests/set_custom_mempool_server_request.dart

@@ -0,0 +1,9 @@
+class SetCustomMempoolServerRequest {
+  final String url;
+  final bool isLiquid;
+
+  SetCustomMempoolServerRequest({
+    required this.url,
+    required this.isLiquid,
+  });
+}

lib/core/mempool/application/dtos/requests/update_mempool_settings_request.dart

@@ -0,0 +1,9 @@
+class UpdateMempoolSettingsRequest {
+  final bool isLiquid;
+  final bool useForFeeEstimation;
+
+  UpdateMempoolSettingsRequest({
+    required this.isLiquid,
+    required this.useForFeeEstimation,
+  });
+}

lib/core/mempool/application/dtos/responses/load_mempool_server_data_response.dart

@@ -0,0 +1,20 @@
+import 'package:bb_mobile/core/mempool/application/dtos/mempool_server_dto.dart';
+import 'package:bb_mobile/core/mempool/application/dtos/mempool_settings_dto.dart';
+
+class LoadMempoolServerDataResponse {
+  final MempoolServerDto defaultServer;
+  final MempoolServerDto? customServer;
+  final MempoolSettingsDto settings;
+
+  LoadMempoolServerDataResponse({
+    required this.defaultServer,
+    this.customServer,
+    required this.settings,
+  });
+
+  bool get hasCustomServer => customServer != null;
+
+  @override
+  String toString() =>
+      'LoadMempoolServerDataResponse(defaultServer: $defaultServer, customServer: $customServer, settings: $settings)';
+}

lib/core/mempool/application/usecases/delete_custom_mempool_server_usecase.dart

@@ -0,0 +1,28 @@
+import 'package:bb_mobile/core/mempool/application/dtos/requests/delete_custom_mempool_server_request.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_server_repository.dart';
+import 'package:bb_mobile/core/mempool/domain/value_objects/mempool_server_network.dart';
+import 'package:bb_mobile/core/mempool/domain/ports/environment_port.dart';
+import 'package:bb_mobile/core/settings/domain/settings_entity.dart';
+
+class DeleteCustomMempoolServerUsecase {
+  final MempoolServerRepository _serverRepository;
+  final MempoolEnvironmentPort _environmentPort;
+
+  DeleteCustomMempoolServerUsecase({
+    required MempoolServerRepository serverRepository,
+    required MempoolEnvironmentPort environmentPort,
+  }) : _serverRepository = serverRepository,
+       _environmentPort = environmentPort;
+
+  Future<void> execute(DeleteCustomMempoolServerRequest request) async {
+    final environment = await _environmentPort.getEnvironment();
+    final isTestnet = environment == Environment.testnet;
+
+    final network = MempoolServerNetwork.fromEnvironment(
+      isTestnet: isTestnet,
+      isLiquid: request.isLiquid,
+    );
+
+    await _serverRepository.deleteCustomServer(network);
+  }
+}

lib/core/mempool/application/usecases/get_active_mempool_server_usecase.dart

@@ -0,0 +1,29 @@
+import 'package:bb_mobile/core/mempool/domain/entities/mempool_server.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_server_repository.dart';
+import 'package:bb_mobile/core/mempool/domain/value_objects/mempool_server_network.dart';
+
+class GetActiveMempoolServerUsecase {
+  final MempoolServerRepository _serverRepository;
+
+  GetActiveMempoolServerUsecase({
+    required MempoolServerRepository serverRepository,
+  }) : _serverRepository = serverRepository;
+
+  Future<MempoolServer> execute({
+    required bool isTestnet,
+    required bool isLiquid,
+  }) async {
+    final network = MempoolServerNetwork.fromEnvironment(
+      isTestnet: isTestnet,
+      isLiquid: isLiquid,
+    );
+
+    // custom server is given priority over default
+    final customServer = await _serverRepository.fetchCustomServer(network);
+    if (customServer != null) {
+      return customServer;
+    }
+
+    return _serverRepository.fetchDefaultServer(network);
+  }
+}

lib/core/mempool/application/usecases/load_mempool_server_data_usecase.dart

@@ -0,0 +1,49 @@
+import 'package:bb_mobile/core/mempool/application/dtos/mempool_server_dto.dart';
+import 'package:bb_mobile/core/mempool/application/dtos/mempool_settings_dto.dart';
+import 'package:bb_mobile/core/mempool/application/dtos/requests/load_mempool_server_data_request.dart';
+import 'package:bb_mobile/core/mempool/application/dtos/responses/load_mempool_server_data_response.dart';
+import 'package:bb_mobile/core/mempool/domain/ports/environment_port.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_server_repository.dart';
+import 'package:bb_mobile/core/mempool/domain/repositories/mempool_settings_repository.dart';
+import 'package:bb_mobile/core/mempool/domain/value_objects/mempool_server_network.dart';
+import 'package:bb_mobile/core/settings/domain/settings_entity.dart';
+
+class LoadMempoolServerDataUsecase {
+  final MempoolServerRepository _serverRepository;
+  final MempoolSettingsRepository _settingsRepository;
+  final MempoolEnvironmentPort _environmentPort;
+
+  LoadMempoolServerDataUsecase({
+    required MempoolServerRepository serverRepository,
+    required MempoolSettingsRepository settingsRepository,
+    required MempoolEnvironmentPort environmentPort,
+  }) : _serverRepository = serverRepository,
+       _settingsRepository = settingsRepository,
+       _environmentPort = environmentPort;
+
+  Future<LoadMempoolServerDataResponse> execute(
+    LoadMempoolServerDataRequest request,
+  ) async {
+    final environment = await _environmentPort.getEnvironment();
+    final isTestnet = environment == Environment.testnet;
+
+    final network = MempoolServerNetwork.fromEnvironment(
+      isTestnet: isTestnet,
+      isLiquid: request.isLiquid,
+    );
+
+    final (defaultServer, customServer, settings) = await (
+      _serverRepository.fetchDefaultServer(network),
+      _serverRepository.fetchCustomServer(network),
+      _settingsRepository.fetchByNetwork(network),
+    ).wait;
+
+    return LoadMempoolServerDataResponse(
+      defaultServer: MempoolServerDto.fromEntity(defaultServer),
+      customServer: customServer != null
+          ? MempoolServerDto.fromEntity(customServer)
+          : null,
+      settings: MempoolSettingsDto.fromEntity(settings),
+    );
+  }
+}