aljaz/BTCPayServerPlugins
1
0
Fork 0
mirror of https://github.com/aljazceru/BTCPayServerPlugins.git synced 2025-12-18 08:04:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

make prism extendable in a different way

Browse Source
This commit is contained in:
Kukks
2023-07-18 11:22:18 +02:00
parent 6a17ba426a
commit 8bab2d7660
2 changed files with 33 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
Plugins/BTCPayServer.Plugins.Prism/SatBreaker.cs
View File

@@ -406,47 +406,44 @@ namespace BTCPayServer.Plugins.Prism
{
continue;
}
IClaimDestination dest = null;
var dest2 = await _pluginHookService.ApplyFilter("prism-claim-destination", destinationSettings?.Destination??destination);
dest = dest2 switch
{
IClaimDestination claimDestination => claimDestination,
string destStr when !string.IsNullOrEmpty(destStr) => new LNURLPayClaimDestinaton(destStr),
_ => null
};
if (dest is null)
{
continue;
}
var pmi = string.IsNullOrEmpty(destinationSettings?.PaymentMethodId) ||
!PaymentMethodId.TryParse(destinationSettings?.PaymentMethodId, out var pmi2)
? new PaymentMethodId("BTC", LightningPaymentType.Instance)
: pmi2;
var payout = await _pullPaymentHostedService.Claim(new ClaimRequest()
var claimRequest = new ClaimRequest()
{
Destination = dest,
Destination = new LNURLPayClaimDestinaton(destinationSettings?.Destination??destination),
PreApprove = true,
StoreId = storeId,
PaymentMethodId = pmi,
Value = Money.Satoshis(payoutAmount).ToDecimal(MoneyUnit.BTC),
});
if (payout.Result == ClaimRequest.ClaimResult.Ok)
{
prismSettings.PendingPayouts ??= new();
prismSettings.PendingPayouts.Add(payout.PayoutData.Id,
new PendingPayout(payoutAmount, reserveFee));
var newAmount = amtMsats - (payoutAmount + reserveFee) * 1000;
if(newAmount == 0)
prismSettings.DestinationBalance.Remove(destination);
else
Metadata = JObject.FromObject(new
{
prismSettings.DestinationBalance.AddOrReplace(destination,newAmount);
}
result = true;
Source = "Prism"
})
};
claimRequest = (await _pluginHookService.ApplyFilter("prism-claim-create", claimRequest)) as ClaimRequest;
if (claimRequest is null)
{
continue;
}
var payout = await _pullPaymentHostedService.Claim(claimRequest);
if (payout.Result != ClaimRequest.ClaimResult.Ok) continue;
prismSettings.PendingPayouts ??= new Dictionary<string, PendingPayout>();
prismSettings.PendingPayouts.Add(payout.PayoutData.Id,
new PendingPayout(payoutAmount, reserveFee));
var newAmount = amtMsats - (payoutAmount + reserveFee) * 1000;
if(newAmount == 0)
prismSettings.DestinationBalance.Remove(destination);
else
{
prismSettings.DestinationBalance.AddOrReplace(destination,newAmount);
}
result = true;
}
}