mirrors/btcpayserver
1
0
Fork 0
mirror of https://github.com/btcpayserver/btcpayserver.git synced 2025-02-20 13:34:37 +01:00
Code Issues Projects Releases Packages Wiki Activity

Conversion of LnrpcInvoice into LightningInvoice

Browse source
This commit is contained in:
lepipele 2018-04-28 00:39:43 -05:00
parent 131328b42c
commit 1743919cd4
1 changed files with 46 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

51
BTCPayServer/Payments/Lightning/Lnd/LndClient.cs
View file

@ -1,5 +1,6 @@
using System;
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Linq;
using System.Net.Http;
@ -33,7 +34,16 @@ namespace BTCPayServer.Payments.Lightning.Lnd
Memo = description,
Expiry = (long)expiry.TotalSeconds
});
throw new NotImplementedException();
var invoice = new LightningInvoice
{
// TODO: Verify id corresponds to R_hash
Id = BitString(resp.R_hash),
Amount = amount,
BOLT11 = resp.Payment_request,
Status = "unpaid"
};
return invoice;
}
public async Task<LightningNodeInformation> GetInfo(CancellationToken cancellation = default(CancellationToken))
@ -52,8 +62,8 @@ namespace BTCPayServer.Payments.Lightning.Lnd
public async Task<LightningInvoice> GetInvoice(string invoiceId, CancellationToken cancellation = default(CancellationToken))
{
// var resp = await _decorator.LookupInvoiceAsync(invoiceId, null, cancellation);
throw new NotImplementedException();
var resp = await _Decorator.LookupInvoiceAsync(invoiceId, null, cancellation);
return ConvertLndInvoice(resp);
}
public Task<ILightningListenInvoiceSession> Listen(CancellationToken cancellation = default(CancellationToken))
@ -63,14 +73,45 @@ namespace BTCPayServer.Payments.Lightning.Lnd
async Task<LightningInvoice> ILightningListenInvoiceSession.WaitInvoice(CancellationToken cancellation)
{
//var resp = await _decorator.SubscribeInvoicesAsync(cancellation);
throw new NotImplementedException();
var resp = await _Decorator.SubscribeInvoicesAsync(cancellation);
return ConvertLndInvoice(resp);
}
public void Dispose()
{
_HttpClient?.Dispose();
}
private static string BitString(byte[] bytes)
{
return BitConverter.ToString(bytes)
.Replace("-", "", StringComparison.InvariantCulture)
.ToLower(CultureInfo.InvariantCulture);
}
private static LightningInvoice ConvertLndInvoice(LnrpcInvoice resp)
{
var invoice = new LightningInvoice
{
// TODO: Verify id corresponds to R_hash
Id = BitString(resp.R_hash),
Amount = resp.Value,
BOLT11 = resp.Payment_request,
Status = "unpaid"
};
if (resp.Settle_date.HasValue)
{
invoice.PaidAt = DateTimeOffset.FromUnixTimeSeconds(resp.Settle_date.Value);
invoice.Status = "paid";
}
else if (DateTimeOffset.FromUnixTimeSeconds(resp.Creation_date.Value + resp.Expiry.Value) > DateTimeOffset.UtcNow)
{
invoice.Status = "expired";
}
return invoice;
}
}
internal class HttpClientFactoryForLnd