Simplify TestWebhook method

This commit is contained in:
Umar Bolatov 2021-04-20 18:54:51 -07:00
parent 7c16f8f134
commit cb6e8a6937
No known key found for this signature in database
GPG key ID: 2C1F9AEB371D2A28

View file

@ -126,16 +126,14 @@ namespace BTCPayServer.HostedServices
{ {
var delivery = NewDelivery(webhookId); var delivery = NewDelivery(webhookId);
var webhook = (await StoreRepository.GetWebhooks(storeId)).Where(w => w.Id == webhookId).FirstOrDefault(); var webhook = (await StoreRepository.GetWebhooks(storeId)).Where(w => w.Id == webhookId).FirstOrDefault();
var channel = Channel.CreateUnbounded<WebhookDeliveryRequest>();
var deliveryRequest = new WebhookDeliveryRequest( var deliveryRequest = new WebhookDeliveryRequest(
webhookId, webhookId,
GetTestWebHook(storeId, webhookId, webhookEventType, delivery), GetTestWebHook(storeId, webhookId, webhookEventType, delivery),
delivery, delivery,
webhook.GetBlob() webhook.GetBlob()
); );
channel.Writer.TryWrite(deliveryRequest);
_ = Process(webhookId, channel); var result = await SendDelivery(deliveryRequest);
} }
protected override async Task ProcessEvent(object evt, CancellationToken cancellationToken) protected override async Task ProcessEvent(object evt, CancellationToken cancellationToken)