btcpayserver/BTCPayServer/PayoutProcessors/UIPayoutProcessorsController.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using BTCPayServer.Abstractions.Constants;
using BTCPayServer.Abstractions.Extensions;
using BTCPayServer.Abstractions.Models;
using BTCPayServer.Client;
using BTCPayServer.Data;
using BTCPayServer.Payouts;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Localization;

namespace BTCPayServer.PayoutProcessors;

public class UIPayoutProcessorsController : Controller
{
    private readonly EventAggregator _eventAggregator;
    private readonly IEnumerable<IPayoutProcessorFactory> _payoutProcessorFactories;
    private readonly PayoutProcessorService _payoutProcessorService;
    private IStringLocalizer StringLocalizer { get; }

    public UIPayoutProcessorsController(
        EventAggregator eventAggregator,
        IEnumerable<IPayoutProcessorFactory> payoutProcessorFactories,
        PayoutProcessorService payoutProcessorService,
        IStringLocalizer stringLocalizer)
    {
        _eventAggregator = eventAggregator;
        _payoutProcessorFactories = payoutProcessorFactories;
        _payoutProcessorService = payoutProcessorService;
        StringLocalizer = stringLocalizer;
    }

    [HttpGet("~/stores/{storeId}/payout-processors")]
    [Authorize(AuthenticationSchemes = AuthenticationSchemes.Cookie)]
    [Authorize(Policy = Policies.CanViewStoreSettings, AuthenticationSchemes = AuthenticationSchemes.Cookie)]
    public async Task<IActionResult> ConfigureStorePayoutProcessors(string storeId)
    {
        var activeProcessors =
            (await _payoutProcessorService.GetProcessors(
                new PayoutProcessorService.PayoutProcessorQuery() { Stores = new[] { storeId } }))
            .GroupBy(data => data.Processor);

        return View(_payoutProcessorFactories.Select(factory =>
        {
            var conf = activeProcessors.FirstOrDefault(datas => datas.Key == factory.Processor)
                           ?.ToDictionary(data => data.GetPayoutMethodId(), data => data) ??
                       new Dictionary<PayoutMethodId, PayoutProcessorData>();
            foreach (var supportedPaymentMethod in factory.GetSupportedPayoutMethods())
            {
                conf.TryAdd(supportedPaymentMethod, null);
            }

            return new StorePayoutProcessorsView() { Factory = factory, Configured = conf };
        }).ToList());
    }

    [HttpPost("~/stores/{storeId}/payout-processors/{id}/remove")]
    [Authorize(AuthenticationSchemes = AuthenticationSchemes.Cookie)]
    [Authorize(Policy = Policies.CanModifyStoreSettings, AuthenticationSchemes = AuthenticationSchemes.Cookie)]
    public async Task<IActionResult> Remove(string storeId, string id)
    {
        var tcs = new TaskCompletionSource();
        _eventAggregator.Publish(new PayoutProcessorUpdated()
        {
            Data = null,
            Id = id,
            Processed = tcs
        });
        TempData.SetStatusMessageModel(new StatusMessageModel
        {
            Severity = StatusMessageModel.StatusSeverity.Success,
            Message = StringLocalizer["Payout Processor removed"].Value
        });
        await tcs.Task;
        return RedirectToAction("ConfigureStorePayoutProcessors", new { storeId });

    }

    public class StorePayoutProcessorsView
    {
        public Dictionary<PayoutMethodId, PayoutProcessorData> Configured { get; set; }
        public IPayoutProcessorFactory Factory { get; set; }
    }
}