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

Refactor invoice entity to not have to inject the NetworkProvider (#858)

Browse Source
This commit is contained in:
Nicolas Dorier
2019-05-24 22:22:38 +09:00
committed by GitHub
parent 15dc0d60db
commit 512ee16620
11 changed files with 59 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
BTCPayServer.Tests/UnitTest1.cs
View File

@@ -201,7 +201,7 @@ namespace BTCPayServer.Tests
entity.SetPaymentMethod(new PaymentMethod() { CryptoCode = "BTC", Rate = 5000, NextNetworkFee = Money.Coins(0.1m) }); entity.SetPaymentMethod(new PaymentMethod() { CryptoCode = "BTC", Rate = 5000, NextNetworkFee = Money.Coins(0.1m) });
entity.ProductInformation = new ProductInformation() { Price = 5000 }; entity.ProductInformation = new ProductInformation() { Price = 5000 };
var paymentMethod = entity.GetPaymentMethods(null).TryGet("BTC", PaymentTypes.BTCLike); var paymentMethod = entity.GetPaymentMethods().TryGet("BTC", PaymentTypes.BTCLike);
var accounting = paymentMethod.Calculate(); var accounting = paymentMethod.Calculate();
Assert.Equal(Money.Coins(1.1m), accounting.Due); Assert.Equal(Money.Coins(1.1m), accounting.Due);
Assert.Equal(Money.Coins(1.1m), accounting.TotalDue); Assert.Equal(Money.Coins(1.1m), accounting.TotalDue);
@@ -364,7 +364,7 @@ namespace BTCPayServer.Tests
entity.PaymentTolerance = 0; entity.PaymentTolerance = 0;
var paymentMethod = entity.GetPaymentMethods(null).TryGet("BTC", PaymentTypes.BTCLike); var paymentMethod = entity.GetPaymentMethods().TryGet("BTC", PaymentTypes.BTCLike);
var accounting = paymentMethod.Calculate(); var accounting = paymentMethod.Calculate();
Assert.Equal(Money.Coins(1.1m), accounting.Due); Assert.Equal(Money.Coins(1.1m), accounting.Due);
Assert.Equal(Money.Coins(1.1m), accounting.TotalDue); Assert.Equal(Money.Coins(1.1m), accounting.TotalDue);

4
BTCPayServer/Controllers/InvoiceController.API.cs
View File

@@ -51,7 +51,7 @@ namespace BTCPayServer.Controllers
})).FirstOrDefault(); })).FirstOrDefault();
if (invoice == null) if (invoice == null)
throw new BitpayHttpException(404, "Object not found"); throw new BitpayHttpException(404, "Object not found");
var resp = invoice.EntityToDTO(_NetworkProvider); var resp = invoice.EntityToDTO();
return new DataWrapper<InvoiceResponse>(resp); return new DataWrapper<InvoiceResponse>(resp);
} }
[HttpGet] [HttpGet]
@@ -82,7 +82,7 @@ namespace BTCPayServer.Controllers
}; };
var entities = (await _InvoiceRepository.GetInvoices(query)) var entities = (await _InvoiceRepository.GetInvoices(query))
.Select((o) => o.EntityToDTO(_NetworkProvider)).ToArray(); .Select((o) => o.EntityToDTO()).ToArray();
return DataWrapper.Create(entities); return DataWrapper.Create(entities);
} }

10
BTCPayServer/Controllers/InvoiceController.UI.cs
View File

@@ -96,7 +96,7 @@ namespace BTCPayServer.Controllers
{ {
var model = new InvoiceDetailsModel(); var model = new InvoiceDetailsModel();
foreach (var data in invoice.GetPaymentMethods(null)) foreach (var data in invoice.GetPaymentMethods())
{ {
var accounting = data.Calculate(); var accounting = data.Calculate();
var paymentMethodId = data.GetId(); var paymentMethodId = data.GetId();
@@ -248,18 +248,18 @@ namespace BTCPayServer.Controllers
{ {
if (!isDefaultPaymentId) if (!isDefaultPaymentId)
return null; return null;
var paymentMethodTemp = invoice.GetPaymentMethods(_NetworkProvider) var paymentMethodTemp = invoice.GetPaymentMethods()
.Where(c => paymentMethodId.CryptoCode == c.GetId().CryptoCode) .Where(c => paymentMethodId.CryptoCode == c.GetId().CryptoCode)
.FirstOrDefault(); .FirstOrDefault();
if (paymentMethodTemp == null) if (paymentMethodTemp == null)
paymentMethodTemp = invoice.GetPaymentMethods(_NetworkProvider).First(); paymentMethodTemp = invoice.GetPaymentMethods().First();
network = paymentMethodTemp.Network; network = paymentMethodTemp.Network;
paymentMethodId = paymentMethodTemp.GetId(); paymentMethodId = paymentMethodTemp.GetId();
} }
var paymentMethod = invoice.GetPaymentMethod(paymentMethodId, _NetworkProvider); var paymentMethod = invoice.GetPaymentMethod(paymentMethodId, _NetworkProvider);
var paymentMethodDetails = paymentMethod.GetPaymentMethodDetails(); var paymentMethodDetails = paymentMethod.GetPaymentMethodDetails();
var dto = invoice.EntityToDTO(_NetworkProvider); var dto = invoice.EntityToDTO();
var cryptoInfo = dto.CryptoInfo.First(o => o.GetpaymentMethodId() == paymentMethodId); var cryptoInfo = dto.CryptoInfo.First(o => o.GetpaymentMethodId() == paymentMethodId);
var storeBlob = store.GetStoreBlob(); var storeBlob = store.GetStoreBlob();
var currency = invoice.ProductInformation.Currency; var currency = invoice.ProductInformation.Currency;
@@ -332,7 +332,7 @@ namespace BTCPayServer.Controllers
CoinSwitchMerchantId = coinswitch?.MerchantId, CoinSwitchMerchantId = coinswitch?.MerchantId,
CoinSwitchMode = coinswitch?.Mode, CoinSwitchMode = coinswitch?.Mode,
StoreId = store.Id, StoreId = store.Id,
AvailableCryptos = invoice.GetPaymentMethods(_NetworkProvider) AvailableCryptos = invoice.GetPaymentMethods()
.Where(i => i.Network != null) .Where(i => i.Network != null)
.Select(kv => new PaymentModel.AvailableCrypto() .Select(kv => new PaymentModel.AvailableCrypto()
{ {

7
BTCPayServer/Controllers/InvoiceController.cs
View File

@@ -75,7 +75,8 @@ namespace BTCPayServer.Controllers
var entity = new InvoiceEntity var entity = new InvoiceEntity
{ {
Version = InvoiceEntity.Lastest_Version, Version = InvoiceEntity.Lastest_Version,
InvoiceTime = DateTimeOffset.UtcNow InvoiceTime = DateTimeOffset.UtcNow,
Networks = _NetworkProvider
}; };
var getAppsTaggingStore = _InvoiceRepository.GetAppsTaggingStore(store.Id); var getAppsTaggingStore = _InvoiceRepository.GetAppsTaggingStore(store.Id);
@@ -208,7 +209,7 @@ namespace BTCPayServer.Controllers
using (logs.Measure("Saving invoice")) using (logs.Measure("Saving invoice"))
{ {
entity = await _InvoiceRepository.CreateInvoiceAsync(store.Id, entity, _NetworkProvider); entity = await _InvoiceRepository.CreateInvoiceAsync(store.Id, entity);
} }
_ = Task.Run(async () => _ = Task.Run(async () =>
{ {
@@ -223,7 +224,7 @@ namespace BTCPayServer.Controllers
await _InvoiceRepository.AddInvoiceLogs(entity.Id, logs); await _InvoiceRepository.AddInvoiceLogs(entity.Id, logs);
}); });
_EventAggregator.Publish(new Events.InvoiceEvent(entity, 1001, InvoiceEvent.Created)); _EventAggregator.Publish(new Events.InvoiceEvent(entity, 1001, InvoiceEvent.Created));
var resp = entity.EntityToDTO(_NetworkProvider); var resp = entity.EntityToDTO();
return new DataWrapper<InvoiceResponse>(resp) { Facade = "pos/invoice" }; return new DataWrapper<InvoiceResponse>(resp) { Facade = "pos/invoice" };
} }

2
BTCPayServer/HostedServices/InvoiceNotificationManager.cs
View File

@@ -64,7 +64,7 @@ namespace BTCPayServer.HostedServices
void Notify(InvoiceEntity invoice, InvoiceEvent invoiceEvent, bool extendedNotification) void Notify(InvoiceEntity invoice, InvoiceEvent invoiceEvent, bool extendedNotification)
{ {
var dto = invoice.EntityToDTO(_NetworkProvider); var dto = invoice.EntityToDTO();
var notification = new InvoicePaymentNotificationEventWrapper() var notification = new InvoicePaymentNotificationEventWrapper()
{ {
Data = new InvoicePaymentNotification() Data = new InvoicePaymentNotification()

2
BTCPayServer/HostedServices/InvoiceWatcher.cs
View File

@@ -74,7 +74,7 @@ namespace BTCPayServer.HostedServices
} }
var payments = invoice.GetPayments().Where(p => p.Accounted).ToArray(); var payments = invoice.GetPayments().Where(p => p.Accounted).ToArray();
var allPaymentMethods = invoice.GetPaymentMethods(_NetworkProvider); var allPaymentMethods = invoice.GetPaymentMethods();
var paymentMethod = GetNearestClearedPayment(allPaymentMethods, out var accounting, _NetworkProvider); var paymentMethod = GetNearestClearedPayment(allPaymentMethods, out var accounting, _NetworkProvider);
if (paymentMethod == null) if (paymentMethod == null)
return; return;

2
BTCPayServer/Hosting/BTCPayServerServices.cs
View File

@@ -74,7 +74,7 @@ namespace BTCPayServer.Hosting
var dbpath = Path.Combine(opts.DataDir, "InvoiceDB"); var dbpath = Path.Combine(opts.DataDir, "InvoiceDB");
if (!Directory.Exists(dbpath)) if (!Directory.Exists(dbpath))
Directory.CreateDirectory(dbpath); Directory.CreateDirectory(dbpath);
return new InvoiceRepository(dbContext, dbpath); return new InvoiceRepository(dbContext, dbpath, o.GetRequiredService<BTCPayNetworkProvider>());
}); });
services.AddSingleton<BTCPayServerEnvironment>(); services.AddSingleton<BTCPayServerEnvironment>();
services.TryAddSingleton<TokenRepository>(); services.TryAddSingleton<TokenRepository>();

2
BTCPayServer/Payments/Bitcoin/NBXplorerListener.cs
View File

@@ -345,7 +345,7 @@ namespace BTCPayServer.Payments.Bitcoin
private DerivationStrategyBase GetDerivationStrategy(InvoiceEntity invoice, BTCPayNetwork network) private DerivationStrategyBase GetDerivationStrategy(InvoiceEntity invoice, BTCPayNetwork network)
{ {
return invoice.GetSupportedPaymentMethod<DerivationSchemeSettings>(new PaymentMethodId(network.CryptoCode, PaymentTypes.BTCLike), _ExplorerClients.NetworkProviders) return invoice.GetSupportedPaymentMethod<DerivationSchemeSettings>(new PaymentMethodId(network.CryptoCode, PaymentTypes.BTCLike))
.Select(d => d.AccountDerivation) .Select(d => d.AccountDerivation)
.FirstOrDefault(); .FirstOrDefault();
} }

4
BTCPayServer/Payments/Lightning/LightningListener.cs
View File

@@ -95,13 +95,13 @@ namespace BTCPayServer.Payments.Lightning
{ {
var listenedInvoices = new List<ListenedInvoice>(); var listenedInvoices = new List<ListenedInvoice>();
var invoice = await _InvoiceRepository.GetInvoice(invoiceId); var invoice = await _InvoiceRepository.GetInvoice(invoiceId);
foreach (var paymentMethod in invoice.GetPaymentMethods(_NetworkProvider) foreach (var paymentMethod in invoice.GetPaymentMethods()
.Where(c => c.GetId().PaymentType == PaymentTypes.LightningLike)) .Where(c => c.GetId().PaymentType == PaymentTypes.LightningLike))
{ {
var lightningMethod = paymentMethod.GetPaymentMethodDetails() as LightningLikePaymentMethodDetails; var lightningMethod = paymentMethod.GetPaymentMethodDetails() as LightningLikePaymentMethodDetails;
if (lightningMethod == null) if (lightningMethod == null)
continue; continue;
var lightningSupportedMethod = invoice.GetSupportedPaymentMethod<LightningSupportedPaymentMethod>(_NetworkProvider) var lightningSupportedMethod = invoice.GetSupportedPaymentMethod<LightningSupportedPaymentMethod>()
.FirstOrDefault(c => c.CryptoCode == paymentMethod.GetId().CryptoCode); .FirstOrDefault(c => c.CryptoCode == paymentMethod.GetId().CryptoCode);
if (lightningSupportedMethod == null) if (lightningSupportedMethod == null)
continue; continue;

38
BTCPayServer/Services/Invoices/InvoiceEntity.cs
View File

@@ -113,6 +113,8 @@ namespace BTCPayServer.Services.Invoices
} }
public class InvoiceEntity public class InvoiceEntity
{ {
[JsonIgnore]
public BTCPayNetworkProvider Networks { get; set; }
public const int InternalTagSupport_Version = 1; public const int InternalTagSupport_Version = 1;
public const int Lastest_Version = 1; public const int Lastest_Version = 1;
public int Version { get; set; } public int Version { get; set; }
@@ -190,18 +192,18 @@ namespace BTCPayServer.Services.Invoices
get; get;
set; set;
} }
public IEnumerable<T> GetSupportedPaymentMethod<T>(PaymentMethodId paymentMethodId, BTCPayNetworkProvider networks) where T : ISupportedPaymentMethod public IEnumerable<T> GetSupportedPaymentMethod<T>(PaymentMethodId paymentMethodId) where T : ISupportedPaymentMethod
{ {
return return
GetSupportedPaymentMethod(networks) GetSupportedPaymentMethod()
.Where(p => paymentMethodId == null || p.PaymentId == paymentMethodId) .Where(p => paymentMethodId == null || p.PaymentId == paymentMethodId)
.OfType<T>(); .OfType<T>();
} }
public IEnumerable<T> GetSupportedPaymentMethod<T>(BTCPayNetworkProvider networks) where T : ISupportedPaymentMethod public IEnumerable<T> GetSupportedPaymentMethod<T>() where T : ISupportedPaymentMethod
{ {
return GetSupportedPaymentMethod<T>(null, networks); return GetSupportedPaymentMethod<T>(null);
} }
public IEnumerable<ISupportedPaymentMethod> GetSupportedPaymentMethod(BTCPayNetworkProvider networks) public IEnumerable<ISupportedPaymentMethod> GetSupportedPaymentMethod()
{ {
#pragma warning disable CS0618 #pragma warning disable CS0618
bool btcReturned = false; bool btcReturned = false;
@@ -211,10 +213,10 @@ namespace BTCPayServer.Services.Invoices
foreach (var strat in strategies.Properties()) foreach (var strat in strategies.Properties())
{ {
var paymentMethodId = PaymentMethodId.Parse(strat.Name); var paymentMethodId = PaymentMethodId.Parse(strat.Name);
var network = networks.GetNetwork(paymentMethodId.CryptoCode); var network = Networks.GetNetwork(paymentMethodId.CryptoCode);
if (network != null) if (network != null)
{ {
if (network == networks.BTC && paymentMethodId.PaymentType == PaymentTypes.BTCLike) if (network == Networks.BTC && paymentMethodId.PaymentType == PaymentTypes.BTCLike)
btcReturned = true; btcReturned = true;
yield return PaymentMethodExtensions.Deserialize(paymentMethodId, strat.Value, network); yield return PaymentMethodExtensions.Deserialize(paymentMethodId, strat.Value, network);
} }
@@ -223,9 +225,9 @@ namespace BTCPayServer.Services.Invoices
if (!btcReturned && !string.IsNullOrEmpty(DerivationStrategy)) if (!btcReturned && !string.IsNullOrEmpty(DerivationStrategy))
{ {
if (networks.BTC != null) if (Networks.BTC != null)
{ {
yield return BTCPayServer.DerivationSchemeSettings.Parse(DerivationStrategy, networks.BTC); yield return BTCPayServer.DerivationSchemeSettings.Parse(DerivationStrategy, Networks.BTC);
} }
} }
#pragma warning restore CS0618 #pragma warning restore CS0618
@@ -362,7 +364,7 @@ namespace BTCPayServer.Services.Invoices
return DateTimeOffset.UtcNow > ExpirationTime; return DateTimeOffset.UtcNow > ExpirationTime;
} }
public InvoiceResponse EntityToDTO(BTCPayNetworkProvider networkProvider) public InvoiceResponse EntityToDTO()
{ {
ServerUrl = ServerUrl ?? ""; ServerUrl = ServerUrl ?? "";
InvoiceResponse dto = new InvoiceResponse InvoiceResponse dto = new InvoiceResponse
@@ -391,7 +393,7 @@ namespace BTCPayServer.Services.Invoices
dto.Url = ServerUrl.WithTrailingSlash() + $"invoice?id=" + Id; dto.Url = ServerUrl.WithTrailingSlash() + $"invoice?id=" + Id;
dto.CryptoInfo = new List<NBitpayClient.InvoiceCryptoInfo>(); dto.CryptoInfo = new List<NBitpayClient.InvoiceCryptoInfo>();
dto.MinerFees = new Dictionary<string, MinerFeeInfo>(); dto.MinerFees = new Dictionary<string, MinerFeeInfo>();
foreach (var info in this.GetPaymentMethods(networkProvider)) foreach (var info in this.GetPaymentMethods())
{ {
var accounting = info.Calculate(); var accounting = info.Calculate();
var cryptoInfo = new NBitpayClient.InvoiceCryptoInfo(); var cryptoInfo = new NBitpayClient.InvoiceCryptoInfo();
@@ -510,13 +512,13 @@ namespace BTCPayServer.Services.Invoices
internal bool Support(PaymentMethodId paymentMethodId) internal bool Support(PaymentMethodId paymentMethodId)
{ {
var rates = GetPaymentMethods(null); var rates = GetPaymentMethods();
return rates.TryGet(paymentMethodId) != null; return rates.TryGet(paymentMethodId) != null;
} }
public PaymentMethod GetPaymentMethod(PaymentMethodId paymentMethodId, BTCPayNetworkProvider networkProvider) public PaymentMethod GetPaymentMethod(PaymentMethodId paymentMethodId, BTCPayNetworkProvider networkProvider)
{ {
GetPaymentMethods(networkProvider).TryGetValue(paymentMethodId, out var data); GetPaymentMethods().TryGetValue(paymentMethodId, out var data);
return data; return data;
} }
public PaymentMethod GetPaymentMethod(BTCPayNetwork network, PaymentTypes paymentType, BTCPayNetworkProvider networkProvider) public PaymentMethod GetPaymentMethod(BTCPayNetwork network, PaymentTypes paymentType, BTCPayNetworkProvider networkProvider)
@@ -524,7 +526,7 @@ namespace BTCPayServer.Services.Invoices
return GetPaymentMethod(new PaymentMethodId(network.CryptoCode, paymentType), networkProvider); return GetPaymentMethod(new PaymentMethodId(network.CryptoCode, paymentType), networkProvider);
} }
public PaymentMethodDictionary GetPaymentMethods(BTCPayNetworkProvider networkProvider) public PaymentMethodDictionary GetPaymentMethods()
{ {
PaymentMethodDictionary paymentMethods = new PaymentMethodDictionary(); PaymentMethodDictionary paymentMethods = new PaymentMethodDictionary();
var serializer = new Serializer(Dummy); var serializer = new Serializer(Dummy);
@@ -538,8 +540,8 @@ namespace BTCPayServer.Services.Invoices
r.CryptoCode = paymentMethodId.CryptoCode; r.CryptoCode = paymentMethodId.CryptoCode;
r.PaymentType = paymentMethodId.PaymentType.ToString(); r.PaymentType = paymentMethodId.PaymentType.ToString();
r.ParentEntity = this; r.ParentEntity = this;
r.Network = networkProvider?.GetNetwork(r.CryptoCode); r.Network = Networks?.GetNetwork(r.CryptoCode);
if (r.Network != null || networkProvider == null) if (r.Network != null || Networks == null)
paymentMethods.Add(r); paymentMethods.Add(r);
} }
} }
@@ -551,7 +553,7 @@ namespace BTCPayServer.Services.Invoices
public void SetPaymentMethod(PaymentMethod paymentMethod) public void SetPaymentMethod(PaymentMethod paymentMethod)
{ {
var dict = GetPaymentMethods(null); var dict = GetPaymentMethods();
dict.AddOrReplace(paymentMethod); dict.AddOrReplace(paymentMethod);
SetPaymentMethods(dict); SetPaymentMethods(dict);
} }
@@ -830,7 +832,7 @@ namespace BTCPayServer.Services.Invoices
public PaymentMethodAccounting Calculate(Func<PaymentEntity, bool> paymentPredicate = null) public PaymentMethodAccounting Calculate(Func<PaymentEntity, bool> paymentPredicate = null)
{ {
paymentPredicate = paymentPredicate ?? new Func<PaymentEntity, bool>((p) => true); paymentPredicate = paymentPredicate ?? new Func<PaymentEntity, bool>((p) => true);
var paymentMethods = ParentEntity.GetPaymentMethods(null); var paymentMethods = ParentEntity.GetPaymentMethods();
var totalDue = ParentEntity.ProductInformation.Price / Rate; var totalDue = ParentEntity.ProductInformation.Price / Rate;
var paid = 0m; var paid = 0m;

35
BTCPayServer/Services/Invoices/InvoiceRepository.cs
View File

@@ -37,8 +37,9 @@ namespace BTCPayServer.Services.Invoices
} }
private ApplicationDbContextFactory _ContextFactory; private ApplicationDbContextFactory _ContextFactory;
private readonly BTCPayNetworkProvider _Networks;
private CustomThreadPool _IndexerThread; private CustomThreadPool _IndexerThread;
public InvoiceRepository(ApplicationDbContextFactory contextFactory, string dbreezePath) public InvoiceRepository(ApplicationDbContextFactory contextFactory, string dbreezePath, BTCPayNetworkProvider networks)
{ {
int retryCount = 0; int retryCount = 0;
retry: retry:
@@ -49,6 +50,7 @@ retry:
catch when (retryCount++ < 5) { goto retry; } catch when (retryCount++ < 5) { goto retry; }
_IndexerThread = new CustomThreadPool(1, "Invoice Indexer"); _IndexerThread = new CustomThreadPool(1, "Invoice Indexer");
_ContextFactory = contextFactory; _ContextFactory = contextFactory;
_Networks = networks;
} }
public async Task<bool> RemovePendingInvoice(string invoiceId) public async Task<bool> RemovePendingInvoice(string invoiceId)
@@ -118,10 +120,11 @@ retry:
} }
} }
public async Task<InvoiceEntity> CreateInvoiceAsync(string storeId, InvoiceEntity invoice, BTCPayNetworkProvider networkProvider) public async Task<InvoiceEntity> CreateInvoiceAsync(string storeId, InvoiceEntity invoice)
{ {
List<string> textSearch = new List<string>(); List<string> textSearch = new List<string>();
invoice = Clone(invoice, null); invoice = NBitcoin.JsonConverters.Serializer.ToObject<InvoiceEntity>(ToString(invoice, null), null);
invoice.Networks = _Networks;
invoice.Id = Encoders.Base58.EncodeData(RandomUtils.GetBytes(16)); invoice.Id = Encoders.Base58.EncodeData(RandomUtils.GetBytes(16));
#pragma warning disable CS0618 #pragma warning disable CS0618
invoice.Payments = new List<PaymentEntity>(); invoice.Payments = new List<PaymentEntity>();
@@ -143,7 +146,7 @@ retry:
CustomerEmail = invoice.RefundMail CustomerEmail = invoice.RefundMail
}); });
foreach (var paymentMethod in invoice.GetPaymentMethods(networkProvider)) foreach (var paymentMethod in invoice.GetPaymentMethods())
{ {
if (paymentMethod.Network == null) if (paymentMethod.Network == null)
throw new InvalidOperationException("CryptoCode unsupported"); throw new InvalidOperationException("CryptoCode unsupported");
@@ -217,7 +220,7 @@ retry:
if (invoice == null) if (invoice == null)
return false; return false;
var invoiceEntity = ToObject<InvoiceEntity>(invoice.Blob, network.NBitcoinNetwork); var invoiceEntity = ToObject(invoice.Blob);
var currencyData = invoiceEntity.GetPaymentMethod(network, paymentMethod.GetPaymentType(), null); var currencyData = invoiceEntity.GetPaymentMethod(network, paymentMethod.GetPaymentType(), null);
if (currencyData == null) if (currencyData == null)
return false; return false;
@@ -278,7 +281,7 @@ retry:
private static void MarkUnassigned(string invoiceId, InvoiceEntity entity, ApplicationDbContext context, PaymentMethodId paymentMethodId) private static void MarkUnassigned(string invoiceId, InvoiceEntity entity, ApplicationDbContext context, PaymentMethodId paymentMethodId)
{ {
foreach (var address in entity.GetPaymentMethods(null)) foreach (var address in entity.GetPaymentMethods())
{ {
if (paymentMethodId != null && paymentMethodId != address.GetId()) if (paymentMethodId != null && paymentMethodId != address.GetId())
continue; continue;
@@ -298,7 +301,7 @@ retry:
var invoiceData = await context.FindAsync<Data.InvoiceData>(invoiceId).ConfigureAwait(false); var invoiceData = await context.FindAsync<Data.InvoiceData>(invoiceId).ConfigureAwait(false);
if (invoiceData == null) if (invoiceData == null)
return; return;
var invoiceEntity = ToObject<InvoiceEntity>(invoiceData.Blob, null); var invoiceEntity = ToObject(invoiceData.Blob);
MarkUnassigned(invoiceId, invoiceEntity, context, null); MarkUnassigned(invoiceId, invoiceEntity, context, null);
try try
{ {
@@ -393,7 +396,7 @@ retry:
private InvoiceEntity ToEntity(Data.InvoiceData invoice) private InvoiceEntity ToEntity(Data.InvoiceData invoice)
{ {
var entity = ToObject<InvoiceEntity>(invoice.Blob, null); var entity = ToObject(invoice.Blob);
PaymentMethodDictionary paymentMethods = null; PaymentMethodDictionary paymentMethods = null;
#pragma warning disable CS0618 #pragma warning disable CS0618
entity.Payments = invoice.Payments.Select(p => entity.Payments = invoice.Payments.Select(p =>
@@ -406,7 +409,7 @@ retry:
if (paymentEntity.Version == 0) if (paymentEntity.Version == 0)
{ {
if (paymentMethods == null) if (paymentMethods == null)
paymentMethods = entity.GetPaymentMethods(null); paymentMethods = entity.GetPaymentMethods();
var paymentMethodDetails = paymentMethods.TryGet(paymentEntity.GetPaymentMethodId())?.GetPaymentMethodDetails(); var paymentMethodDetails = paymentMethods.TryGet(paymentEntity.GetPaymentMethodId())?.GetPaymentMethodDetails();
if (paymentMethodDetails != null) // == null should never happen, but we never know. if (paymentMethodDetails != null) // == null should never happen, but we never know.
paymentEntity.NetworkFee = paymentMethodDetails.GetNextNetworkFee(); paymentEntity.NetworkFee = paymentMethodDetails.GetNextNetworkFee();
@@ -604,7 +607,7 @@ retry:
var invoice = context.Invoices.Find(invoiceId); var invoice = context.Invoices.Find(invoiceId);
if (invoice == null) if (invoice == null)
return null; return null;
InvoiceEntity invoiceEntity = ToObject<InvoiceEntity>(invoice.Blob, network.NBitcoinNetwork); InvoiceEntity invoiceEntity = ToObject(invoice.Blob);
PaymentMethod paymentMethod = invoiceEntity.GetPaymentMethod(new PaymentMethodId(network.CryptoCode, paymentData.GetPaymentType()), null); PaymentMethod paymentMethod = invoiceEntity.GetPaymentMethod(new PaymentMethodId(network.CryptoCode, paymentData.GetPaymentType()), null);
IPaymentMethodDetails paymentMethodDetails = paymentMethod.GetPaymentMethodDetails(); IPaymentMethodDetails paymentMethodDetails = paymentMethod.GetPaymentMethodDetails();
PaymentEntity entity = new PaymentEntity PaymentEntity entity = new PaymentEntity
@@ -669,21 +672,23 @@ retry:
} }
} }
private InvoiceEntity ToObject(byte[] value)
{
var entity = NBitcoin.JsonConverters.Serializer.ToObject<InvoiceEntity>(ZipUtils.Unzip(value), null);
entity.Networks = _Networks;
return entity;
}
private T ToObject<T>(byte[] value, Network network) private T ToObject<T>(byte[] value, Network network)
{ {
return NBitcoin.JsonConverters.Serializer.ToObject<T>(ZipUtils.Unzip(value), network); return NBitcoin.JsonConverters.Serializer.ToObject<T>(ZipUtils.Unzip(value), network);
} }
private byte[] ToBytes<T>(T obj, Network network) private byte[] ToBytes<T>(T obj, Network network)
{ {
return ZipUtils.Zip(NBitcoin.JsonConverters.Serializer.ToString(obj, network)); return ZipUtils.Zip(NBitcoin.JsonConverters.Serializer.ToString(obj, network));
} }
private T Clone<T>(T invoice, Network network)
{
return NBitcoin.JsonConverters.Serializer.ToObject<T>(ToString(invoice, network), network);
}
private string ToString<T>(T data, Network network) private string ToString<T>(T data, Network network)
{ {
return NBitcoin.JsonConverters.Serializer.ToString(data, network); return NBitcoin.JsonConverters.Serializer.ToString(data, network);