Filter UTXOs by wallet for sending ignoreOutputs to nbxplorer

src/Data/Repositories/FUTXORepository.cs

@@ -144,5 +144,31 @@ public async Task<List<FMUTXO>> GetLockedUTXOs(int? ignoredWalletWithdrawalReque
 
             return result;
         }
+
+        public async Task<List<FMUTXO>> GetLockedUTXOsByWalletId(int walletId)
+        {
+            await using var applicationDbContext = await _dbContextFactory.CreateDbContextAsync();
+
+            var walletWithdrawalRequestsLockedUTXOs = await applicationDbContext.WalletWithdrawalRequests
+                    .Include(x => x.UTXOs)
+                    .Where(x => x.Status == WalletWithdrawalRequestStatus.Pending ||
+                                x.Status == WalletWithdrawalRequestStatus.PSBTSignaturesPending ||
+                                x.Status == WalletWithdrawalRequestStatus.FinalizingPSBT ||
+                                x.Status == WalletWithdrawalRequestStatus.OnChainConfirmationPending)
+                    .Where(x => x.WalletId == walletId)
+                    .SelectMany(x => x.UTXOs)
+                    .ToListAsync();
+
+            var channelOperationRequestsLockedUTXOs = await applicationDbContext.ChannelOperationRequests.Include(x => x.Utxos)
+                    .Where(x => x.Status == ChannelOperationRequestStatus.Pending ||
+                                x.Status == ChannelOperationRequestStatus.PSBTSignaturesPending ||
+                                x.Status == ChannelOperationRequestStatus.FinalizingPSBT ||
+                                x.Status == ChannelOperationRequestStatus.OnChainConfirmationPending)
+                    .Where(x => x.WalletId == walletId)
+                    .SelectMany(x => x.Utxos)
+                    .ToListAsync();
+
+            return walletWithdrawalRequestsLockedUTXOs.Union(channelOperationRequestsLockedUTXOs).ToList();
+        }
     }
 }

src/Data/Repositories/Interfaces/IFMUTXORepository.cs

@@ -42,4 +42,5 @@ public interface IFMUTXORepository
     /// </summary>
     /// <returns></returns>
     Task<List<FMUTXO>> GetLockedUTXOs(int? ignoredWalletWithdrawalRequestId = null, int? ignoredChannelOperationRequestId = null);
+    Task<List<FMUTXO>> GetLockedUTXOsByWalletId(int walletId);
 }

src/Rpc/NodeGuardService.cs

@@ -1003,10 +1003,19 @@ public override async Task<GetUtxosResponse> GetAvailableUtxos(GetAvailableUtxos
             throw new Exception("Derivation strategy not found for wallet with id {walletId}");
         }
 
-        var lockedUtxos = await _fmutxoRepository.GetLockedUTXOs();
+        var walletUtxos = await _nbXplorerService.GetUTXOsAsync(derivationStrategy);
+        var lockedUtxos = await _fmutxoRepository.GetLockedUTXOsByWalletId(wallet.Id);
         var ignoreOutpoints = new List<string>();
         var listLocked = lockedUtxos.Select(utxo => $"{utxo.TxId}-{utxo.OutputIndex}").ToList();
         var listFrozen = await _coinSelectionService.GetFrozenUTXOs();
+
+        // filter frozen list by only including UTXOs that belong to the wallet
+        // TODO: find a way to add wallet id to the UTXOTag model
+        listFrozen = listFrozen
+            .Where(utxo => walletUtxos.Confirmed.UTXOs.Any(u => u.Outpoint.ToString() == utxo) ||
+                           walletUtxos.Unconfirmed.UTXOs.Any(u => u.Outpoint.ToString() == utxo))
+                           .ToList();
+
         ignoreOutpoints.AddRange(listLocked);
         ignoreOutpoints.AddRange(listFrozen);