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

cleanup

Browse Source
This commit is contained in:
Kukks
2023-02-23 12:39:43 +01:00
parent 6a83de4ee6
commit 1a44b774aa
31 changed files with 99 additions and 579 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
Plugins/BTCPayServer.Plugins.Wabisabi/AffiliateServer/AffiliateServerController.cs
View File

@@ -15,8 +15,10 @@ using Microsoft.Extensions.Options;
using NBitcoin.DataEncoders;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using WalletWasabi.Affiliation;
using WalletWasabi.Affiliation.Models;
using WalletWasabi.Affiliation.Models.CoinjoinRequest;
using WalletWasabi.Affiliation.Models.CoinJoinNotification;
using WalletWasabi.Affiliation.Serialization;
namespace BTCPayServer.Plugins.Wabisabi.AffiliateServer;
@@ -84,8 +86,8 @@ public class AffiliateServerController:Controller
[AllowAnonymous]
[HttpPost("get_coinjoin_request")]
public async Task<IActionResult> GetCoinjoinRequest([FromBody] GetCoinjoinRequestRequest request)
[HttpPost("notify_coinjoin")]
public async Task<IActionResult> GetCoinjoinRequest()
{
var settings = await _settingsRepository.GetSettingAsync<WabisabiAffiliateSettings>();
@@ -93,11 +95,13 @@ public class AffiliateServerController:Controller
{
return NotFound();
}
var keyB = Encoders.Hex.DecodeData(settings.SigningKey);
ecdsa.ImportSubjectPublicKeyInfo(keyB.AsSpan(), out _);
Payload payload = new(new Header(), request.Body);
using var reader = new StreamReader(Request.Body);
var request =
AffiliateServerHttpApiClient.Deserialize<CoinJoinNotificationRequest>(await reader.ReadToEndAsync());
Payload payload = new(Header.Instance, request.Body);
try
{
@@ -109,8 +113,9 @@ public class AffiliateServerController:Controller
await System.IO.File.AppendAllLinesAsync(path, new[] {JObject.FromObject(request).ToString(Formatting.None).Replace(Environment.NewLine, "")}, Encoding.UTF8);
return Ok(new GetCoinjoinRequestResponse(Array.Empty<byte>()));
var response = new CoinJoinNotificationResponse(Array.Empty<byte>());
return Json(response, AffiliationJsonSerializationOptions.Settings);
}
catch (Exception e)
{