diff --git a/Directory.Packages.props b/Directory.Packages.props
index 5e199922..8ff98f4f 100644
--- a/Directory.Packages.props
+++ b/Directory.Packages.props
@@ -1,6 +1,7 @@
true
+ $(NoWarn);NU1507
@@ -101,4 +102,4 @@
-
\ No newline at end of file
+
diff --git a/NuGet.Config b/NuGet.Config
index 66b50e02..eeaf9358 100644
--- a/NuGet.Config
+++ b/NuGet.Config
@@ -4,6 +4,22 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/TransactionProcessor.Aggregates.Tests/FloatAggregateTests.cs b/TransactionProcessor.Aggregates.Tests/FloatAggregateTests.cs
index 7f5ac511..460e20ca 100644
--- a/TransactionProcessor.Aggregates.Tests/FloatAggregateTests.cs
+++ b/TransactionProcessor.Aggregates.Tests/FloatAggregateTests.cs
@@ -23,22 +23,20 @@ public void FloatAggregate_CanBeCreated_IsCreated()
public void FloatAggregate_CreateFloat_IsCreated()
{
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- Result result = aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ Result result = aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
result.IsSuccess.ShouldBeTrue();
aggregate.AggregateId.ShouldBe(TestData.FloatAggregateId);
aggregate.EstateId.ShouldBe(TestData.EstateId);
- aggregate.ContractId.ShouldBe(TestData.ContractId);
- aggregate.ProductId.ShouldBe(TestData.ProductId);
aggregate.CreatedDateTime.ShouldBe(TestData.FloatCreatedDateTime);
}
[Fact]
public void FloatAggregate_CreateFloat_FloatAlreadyCreated_NoErrorThrown() {
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
- Result result = aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ Result result = aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
result.IsSuccess.ShouldBeTrue();
}
@@ -46,7 +44,7 @@ public void FloatAggregate_CreateFloat_FloatAlreadyCreated_NoErrorThrown() {
public void FloatAggregate_RecordCreditPurchase_CreditPurchaseIsRecorded()
{
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
Result result = aggregate.RecordCreditPurchase(DateTime.Now, 1000, 900);
result.IsSuccess.ShouldBeTrue();
aggregate.NumberOfCreditPurchases.ShouldBe(1);
@@ -70,7 +68,7 @@ public void FloatAggregate_RecordCreditPurchase_FloatNotCreated_ErrorThrown()
public void FloatAggregate_RecordCreditPurchase_MultipleCreditPurchases_AllCreditPurchasesAreRecorded()
{
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
aggregate.RecordCreditPurchase(DateTime.Now, 1000, 900);
aggregate.NumberOfCreditPurchases.ShouldBe(1);
@@ -103,7 +101,7 @@ public void FloatAggregate_RecordCreditPurchase_MultipleCreditPurchases_AllCredi
public void FloatAggregate_RecordCreditPurchase_DuplicateCreditPurchase_ErrorThrown()
{
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
DateTime purchaseDateTime = DateTime.Now;
aggregate.RecordCreditPurchase(purchaseDateTime, 1000, 900);
@@ -118,7 +116,7 @@ public void FloatAggregate_RecordCreditPurchase_DuplicateCreditPurchase_ErrorThr
public void FloatAggregate_GetTotalCostPrice_TotalCostReturned()
{
Aggregates.FloatAggregate aggregate = Aggregates.FloatAggregate.Create(TestData.FloatAggregateId);
- aggregate.CreateFloat(TestData.EstateId, TestData.ContractId, TestData.ProductId, TestData.FloatCreatedDateTime);
+ aggregate.CreateFloat(TestData.EstateId, TestData.FloatCreatedDateTime);
DateTime purchaseDateTime = DateTime.Now;
aggregate.RecordCreditPurchase(purchaseDateTime, 1000, 900);
diff --git a/TransactionProcessor.Aggregates/FloatAggregate.cs b/TransactionProcessor.Aggregates/FloatAggregate.cs
index 368e6b6a..14ad61e8 100644
--- a/TransactionProcessor.Aggregates/FloatAggregate.cs
+++ b/TransactionProcessor.Aggregates/FloatAggregate.cs
@@ -9,11 +9,16 @@ namespace TransactionProcessor.Aggregates
{
public static class FloatAggregateExtensions
{
+ public static void PlayEvent(this FloatAggregate aggregate, FloatDomainEvents.FloatCreatedEvent domainEvent)
+ {
+ aggregate.EstateId = domainEvent.EstateId;
+ aggregate.CreatedDateTime = domainEvent.CreatedDateTime;
+ aggregate.IsCreated = true;
+ }
+
public static void PlayEvent(this FloatAggregate aggregate, FloatDomainEvents.FloatCreatedForContractProductEvent domainEvent)
{
aggregate.EstateId = domainEvent.EstateId;
- aggregate.ContractId = domainEvent.ContractId;
- aggregate.ProductId = domainEvent.ProductId;
aggregate.CreatedDateTime = domainEvent.CreatedDateTime;
aggregate.IsCreated = true;
}
@@ -29,18 +34,16 @@ public static void PlayEvent(this FloatAggregate aggregate, FloatDomainEvents.Fl
public static Result CreateFloat(this FloatAggregate aggregate,
Guid estateId,
- Guid contractId,
- Guid productId,
DateTime createdDateTime)
{
if (aggregate.IsCreated) {
return Result.Success(); // Idempotent
}
- FloatDomainEvents.FloatCreatedForContractProductEvent floatCreatedForContractProductEvent = new(aggregate.AggregateId,
- estateId, contractId, productId, createdDateTime);
+ FloatDomainEvents.FloatCreatedEvent floatCreatedEvent = new(aggregate.AggregateId,
+ estateId, createdDateTime);
- aggregate.ApplyAndAppend(floatCreatedForContractProductEvent);
+ aggregate.ApplyAndAppend(floatCreatedEvent);
return Result.Success();
}
@@ -129,9 +132,6 @@ private FloatAggregate(Guid aggregateId)
public Boolean IsCreated { get; internal set; }
public Guid EstateId { get; internal set; }
-
- public Guid ContractId { get; internal set; }
- public Guid ProductId { get; internal set; }
public DateTime CreatedDateTime { get; internal set; }
public Int32 NumberOfCreditPurchases { get; internal set; }
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ContractDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ContractDomainEventHandlerTests.cs
index 940c6fee..6600901f 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ContractDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ContractDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using Moq;
+using Moq;
using Shared.Logger;
using Shared.Serialisation;
using Shouldly;
@@ -32,7 +32,7 @@ public void ContractDomainEventHandler_ContractCreatedEvent_EventIsHandled()
{
ContractDomainEvents.ContractCreatedEvent contractCreatedEvent = TestData.DomainEvents.ContractCreatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(contractCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(contractCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -40,7 +40,7 @@ public void ContractDomainEventHandler_FixedValueProductAddedToContractEvent_Eve
{
ContractDomainEvents.FixedValueProductAddedToContractEvent fixedValueProductAddedToContractEvent = TestData.DomainEvents.FixedValueProductAddedToContractEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(fixedValueProductAddedToContractEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(fixedValueProductAddedToContractEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -48,7 +48,7 @@ public void ContractDomainEventHandler_TransactionFeeForProductAddedToContractEv
{
ContractDomainEvents.TransactionFeeForProductAddedToContractEvent transactionFeeForProductAddedToContractEvent = TestData.DomainEvents.TransactionFeeForProductAddedToContractEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(transactionFeeForProductAddedToContractEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(transactionFeeForProductAddedToContractEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -56,7 +56,7 @@ public void ContractDomainEventHandler_TransactionFeeForProductDisabledEvent_Eve
{
ContractDomainEvents.TransactionFeeForProductDisabledEvent transactionFeeForProductDisabledEvent = TestData.DomainEvents.TransactionFeeForProductDisabledEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(transactionFeeForProductDisabledEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(transactionFeeForProductDisabledEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -64,8 +64,8 @@ public void ContractDomainEventHandler_VariableValueProductAddedToContractEvent_
{
ContractDomainEvents.VariableValueProductAddedToContractEvent variableValueProductAddedToContractEvent = TestData.DomainEvents.VariableValueProductAddedToContractEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(variableValueProductAddedToContractEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(variableValueProductAddedToContractEvent, TestContext.Current.CancellationToken); });
}
#endregion
-}
\ No newline at end of file
+}
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/EstateDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/EstateDomainEventHandlerTests.cs
index 232a9b05..6ecf4946 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/EstateDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/EstateDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using Moq;
+using Moq;
using Shared.Logger;
using Shared.Serialisation;
using Shouldly;
@@ -38,7 +38,7 @@ public void EstateDomainEventHandler_EstateCreatedEvent_EventIsHandled()
.Setup(r => r.CreateReadModel(It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Success);
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(estateCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(estateCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -49,7 +49,7 @@ public async Task EstateDomainEventHandler_EstateCreatedEvent_CreateReadModelFai
.Setup(r => r.CreateReadModel(It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Failure);
- Result result = await this.DomainEventHandler.Handle(estateCreatedEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(estateCreatedEvent, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -58,7 +58,7 @@ public void EstateDomainEventHandler_EstateReferenceAllocatedEvent_EventIsHandle
{
EstateDomainEvents.EstateReferenceAllocatedEvent estateReferenceAllocatedEvent = TestData.DomainEvents.EstateReferenceAllocatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(estateReferenceAllocatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(estateReferenceAllocatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -66,8 +66,8 @@ public void EstateDomainEventHandler_SecurityUserAddedEvent_EventIsHandled()
{
EstateDomainEvents.SecurityUserAddedToEstateEvent securityUserAddedEvent = TestData.DomainEvents.EstateSecurityUserAddedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(securityUserAddedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(securityUserAddedEvent, TestContext.Current.CancellationToken); });
}
#endregion
-}
\ No newline at end of file
+}
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantDomainEventHandlerTests.cs
index b81d6e37..3bfecd01 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
using System.Threading;
using System.Threading.Tasks;
using MediatR;
@@ -40,7 +40,7 @@ public async Task MerchantDomainEventHandler_Handle_CallbackReceivedEnrichedEven
this.Mediator.Setup(m => m.Send(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success);
CallbackReceivedEnrichedEvent domainEvent = TestData.DomainEvents.CallbackReceivedEnrichedEventDeposit;
- var result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ var result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -50,7 +50,7 @@ public async Task MerchantDomainEventHandler_Handle_CallbackReceivedEnrichedEven
{
CallbackReceivedEnrichedEvent domainEvent = TestData.DomainEvents.CallbackReceivedEnrichedEventOtherType;
- var result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ var result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -62,7 +62,7 @@ public async Task MerchantDomainEventHandler_Handle_CallbackReceivedEnrichedEven
CallbackReceivedEnrichedEvent domainEvent = TestData.DomainEvents.CallbackReceivedEnrichedEventDeposit;
- var result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ var result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -74,7 +74,7 @@ public void MerchantDomainEventHandler_AddressAddedEvent_EventIsHandled()
{
MerchantDomainEvents.AddressAddedEvent addressAddedEvent = TestData.DomainEvents.AddressAddedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(addressAddedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(addressAddedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -82,7 +82,7 @@ public void MerchantDomainEventHandler_ContactAddedEvent_EventIsHandled()
{
MerchantDomainEvents.ContactAddedEvent contactAddedEvent = TestData.DomainEvents.ContactAddedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(contactAddedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(contactAddedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -90,7 +90,7 @@ public void MerchantDomainEventHandler_MerchantReferenceAllocatedEvent_EventIsHa
{
MerchantDomainEvents.MerchantReferenceAllocatedEvent merchantReferenceAllocatedEvent = TestData.DomainEvents.MerchantReferenceAllocatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantReferenceAllocatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantReferenceAllocatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -98,7 +98,7 @@ public void MerchantDomainEventHandler_DeviceAddedToMerchantEvent_EventIsHandled
{
MerchantDomainEvents.DeviceAddedToMerchantEvent deviceAddedToMerchantEvent = TestData.DomainEvents.DeviceAddedToMerchantEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(deviceAddedToMerchantEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(deviceAddedToMerchantEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -106,7 +106,7 @@ public void MerchantDomainEventHandler_MerchantCreatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantCreatedEvent merchantCreatedEvent = TestData.DomainEvents.MerchantCreatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -114,7 +114,7 @@ public void MerchantDomainEventHandler_OperatorAssignedToMerchantEvent_EventIsHa
{
MerchantDomainEvents.OperatorAssignedToMerchantEvent operatorAssignedToMerchantEvent = TestData.DomainEvents.OperatorAssignedToMerchantEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorAssignedToMerchantEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorAssignedToMerchantEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -122,7 +122,7 @@ public void MerchantDomainEventHandler_SecurityUserAddedEvent_EventIsHandled()
{
MerchantDomainEvents.SecurityUserAddedToMerchantEvent merchantSecurityUserAddedEvent = TestData.DomainEvents.MerchantSecurityUserAddedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantSecurityUserAddedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(merchantSecurityUserAddedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -130,7 +130,7 @@ public void MerchantDomainEventHandler_SettlementScheduleChangedEvent_EventIsHan
{
MerchantDomainEvents.SettlementScheduleChangedEvent settlementScheduleChangedEvent = TestData.DomainEvents.SettlementScheduleChangedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(settlementScheduleChangedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(settlementScheduleChangedEvent, TestContext.Current.CancellationToken); });
}
[Fact(Skip = "No event yet")]
@@ -138,7 +138,7 @@ public void MerchantDomainEventHandler_SettlementGeneratedEvent_EventIsHandled()
{
//StatementGeneratedEvent statementGeneratedEvent = TestData.StatementGeneratedEvent;
- //Should.NotThrow(async () => { await this.DomainEventHandler.Handle(statementGeneratedEvent, CancellationToken.None); });
+ //Should.NotThrow(async () => { await this.DomainEventHandler.Handle(statementGeneratedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -146,7 +146,7 @@ public void MerchantDomainEventHandler_TransactionHasBeenCompletedEvent_EventIsH
{
TransactionDomainEvents.TransactionHasBeenCompletedEvent domainEvent = TestData.DomainEvents.TransactionHasBeenCompletedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -154,7 +154,7 @@ public void MerchantDomainEventHandler_MerchantNameUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantNameUpdatedEvent domainEvent = TestData.DomainEvents.MerchantNameUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -162,91 +162,91 @@ public void MerchantDomainEventHandler_DeviceSwappedForMerchantEvent_EventIsHand
{
MerchantDomainEvents.DeviceSwappedForMerchantEvent domainEvent = TestData.DomainEvents.DeviceSwappedForMerchantEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_OperatorRemovedFromMerchantEvent_EventIsHandled()
{
MerchantDomainEvents.OperatorRemovedFromMerchantEvent domainEvent = TestData.DomainEvents.OperatorRemovedFromMerchantEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantAddressLine1UpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantAddressLine1UpdatedEvent domainEvent = TestData.DomainEvents.MerchantAddressLine1UpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantAddressLine2UpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantAddressLine2UpdatedEvent domainEvent = TestData.DomainEvents.MerchantAddressLine2UpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantAddressLine3UpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantAddressLine3UpdatedEvent domainEvent = TestData.DomainEvents.MerchantAddressLine3UpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantAddressLine4UpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantAddressLine4UpdatedEvent domainEvent = TestData.DomainEvents.MerchantAddressLine4UpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantCountyUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantCountyUpdatedEvent domainEvent = TestData.DomainEvents.MerchantCountyUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantRegionUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantRegionUpdatedEvent domainEvent = TestData.DomainEvents.MerchantRegionUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantTownUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantTownUpdatedEvent domainEvent = TestData.DomainEvents.MerchantTownUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantPostalCodeUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantPostalCodeUpdatedEvent domainEvent = TestData.DomainEvents.MerchantPostalCodeUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantContactNameUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantContactNameUpdatedEvent domainEvent = TestData.DomainEvents.MerchantContactNameUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantContactEmailAddressUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantContactEmailAddressUpdatedEvent domainEvent = TestData.DomainEvents.MerchantContactEmailAddressUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
public void MerchantDomainEventHandler_MerchantContactPhoneNumberUpdatedEvent_EventIsHandled()
{
MerchantDomainEvents.MerchantContactPhoneNumberUpdatedEvent domainEvent = TestData.DomainEvents.MerchantContactPhoneNumberUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -254,7 +254,7 @@ public void MerchantDomainEventHandler_ContractAddedToMerchantEvent_EventIsHandl
{
MerchantDomainEvents.ContractAddedToMerchantEvent domainEvent = TestData.DomainEvents.ContractAddedToMerchantEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -262,9 +262,10 @@ public void MerchantDomainEventHandler_EstateCreatedEvent_EventIsHandled()
{
EstateDomainEvents.EstateCreatedEvent domainEvent = TestData.DomainEvents.EstateCreatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken); });
}
#endregion
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantScheduleDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantScheduleDomainEventHandlerTests.cs
index 0732e1c3..b4f1af5f 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantScheduleDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantScheduleDomainEventHandlerTests.cs
@@ -35,7 +35,7 @@ public async Task MerchantScheduleDomainEventHandler_MerchantScheduleCreatedEven
.Setup(r => r.AddMerchantSchedule(domainEvent, It.IsAny()))
.ReturnsAsync(Result.Success);
- Result result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.EstateReportingRepository.Verify(r => r.AddMerchantSchedule(domainEvent, It.IsAny()), Times.Once);
@@ -49,9 +49,10 @@ public async Task MerchantScheduleDomainEventHandler_MerchantScheduleMonthUpdate
.Setup(r => r.UpdateMerchantSchedule(domainEvent, It.IsAny()))
.ReturnsAsync(Result.Success);
- Result result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.EstateReportingRepository.Verify(r => r.UpdateMerchantSchedule(domainEvent, It.IsAny()), Times.Once);
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantStatementDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantStatementDomainEventHandlerTests.cs
index 085581cf..8d6b34ac 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantStatementDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/MerchantStatementDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
@@ -30,7 +30,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_StatementGeneratedE
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementGeneratedEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementGeneratedEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -40,7 +40,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_StatementBuiltEvent
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementBuiltEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementBuiltEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -50,7 +50,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_TransactionHasBeenC
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -63,7 +63,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_TransactionHasBeenC
.ReturnsAsync(Result.Failure(errors))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.Mediator.Verify(m => m.Send(It.IsAny>(), It.IsAny()), Times.Exactly(2));
}
@@ -80,7 +80,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_TransactionHasBeenC
.ReturnsAsync(Result.Failure(errors))
.ReturnsAsync(Result.Failure(errors));
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.TransactionHasBeenCompletedEvent, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
this.Mediator.Verify(m => m.Send(It.IsAny>(), It.IsAny()), Times.Exactly(6));
}
@@ -91,7 +91,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_MerchantFeeSettledE
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -104,7 +104,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_MerchantFeeSettledE
.ReturnsAsync(Result.Failure(errors))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.Mediator.Verify(m => m.Send(It.IsAny>(), It.IsAny()), Times.Exactly(2));
}
@@ -121,7 +121,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_MerchantFeeSettledE
.ReturnsAsync(Result.Failure(errors))
.ReturnsAsync(Result.Failure(errors));
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.MerchantFeeSettledEvent, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
this.Mediator.Verify(m => m.Send(It.IsAny>(), It.IsAny()), Times.Exactly(6));
}
@@ -132,7 +132,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_StatementCreatedFor
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementCreatedForDateEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.StatementCreatedForDateEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -142,7 +142,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_AutomaticDepositMad
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.AutomaticDepositMadeEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.AutomaticDepositMadeEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -152,7 +152,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_ManualDepositMadeEv
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.ManualDepositMadeEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.ManualDepositMadeEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
@@ -162,7 +162,7 @@ public async Task MerchantStatementDomainEventHandler_Handle_WithdrawalMadeEvent
this.Mediator.Setup(m => m.Send(It.IsAny>(), It.IsAny()))
.ReturnsAsync(Result.Success());
- Result result = await this.EventHandler.Handle(TestData.DomainEvents.WithdrawalMadeEvent, CancellationToken.None);
+ Result result = await this.EventHandler.Handle(TestData.DomainEvents.WithdrawalMadeEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
-}
\ No newline at end of file
+}
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/OperatorDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/OperatorDomainEventHandlerTests.cs
index c5a5186c..dc12bd22 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/OperatorDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/OperatorDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using Moq;
+using Moq;
using Shared.Logger;
using Shared.Serialisation;
using Shouldly;
@@ -30,7 +30,7 @@ public void OperatorDomainEventHandler_OperatorCreatedEvent_EventIsHandled()
{
OperatorDomainEvents.OperatorCreatedEvent operatorCreatedEvent = TestData.DomainEvents.OperatorCreatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -38,7 +38,7 @@ public void OperatorDomainEventHandler_OperatorNameUpdatedEvent_EventIsHandled()
{
OperatorDomainEvents.OperatorNameUpdatedEvent operatorCreatedEvent = TestData.DomainEvents.OperatorNameUpdatedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -46,7 +46,7 @@ public void OperatorDomainEventHandler_OperatorRequireCustomMerchantNumberChange
{
OperatorDomainEvents.OperatorRequireCustomMerchantNumberChangedEvent operatorCreatedEvent = TestData.DomainEvents.OperatorRequireCustomMerchantNumberChangedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, TestContext.Current.CancellationToken); });
}
[Fact]
@@ -54,6 +54,6 @@ public void OperatorDomainEventHandler_OperatorRequireCustomTerminalNumberChange
{
OperatorDomainEvents.OperatorRequireCustomTerminalNumberChangedEvent operatorCreatedEvent = TestData.DomainEvents.OperatorRequireCustomTerminalNumberChangedEvent;
- Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, CancellationToken.None); });
+ Should.NotThrow(async () => { await this.DomainEventHandler.Handle(operatorCreatedEvent, TestContext.Current.CancellationToken); });
}
-}
\ No newline at end of file
+}
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ReadModelDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ReadModelDomainEventHandlerTests.cs
index 733f7b93..82bb626e 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ReadModelDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/ReadModelDomainEventHandlerTests.cs
@@ -49,7 +49,7 @@ public async Task ReadModelDomainEventHandler_Handle_AdditionalRequestDataRecord
.Setup(r => r.SetTransactionAmount(domainEvent, It.IsAny()))
.ReturnsAsync(Result.Success);
- Result result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.EstateReportingRepository.Verify(r => r.RecordTransactionAdditionalRequestData(domainEvent, It.IsAny()), Times.Once);
@@ -65,7 +65,7 @@ public async Task ReadModelDomainEventHandler_Handle_StatementGeneratedEvent_Mar
.Setup(r => r.MarkStatementAsGenerated(domainEvent, It.IsAny()))
.ReturnsAsync(Result.Failure);
- Result result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
this.EstateReportingRepository.Verify(r => r.MarkStatementAsGenerated(domainEvent, It.IsAny()), Times.Once);
@@ -77,9 +77,10 @@ public async Task ReadModelDomainEventHandler_Handle_UnhandledDomainEvent_Return
{
UnhandledDomainEvent domainEvent = new();
- Result result = await this.DomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ Result result = await this.DomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
this.EstateReportingRepository.VerifyNoOtherCalls();
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/TransactionDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/TransactionDomainEventHandlerTests.cs
index 1587d757..0325e0d5 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/TransactionDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/TransactionDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using EventStore.Client;
+using EventStore.Client;
using Grpc.Core;
using MediatR;
using SimpleResults;
@@ -68,10 +68,11 @@ public async Task TransactionDomainEventHandler_EventPassedIn_EventIsHandled(Typ
_ => throw new NotSupportedException($"Event {eventType.Name} not supported")
};
- var result = await this.TransactionDomainEventHandler.Handle(domainEvent, CancellationToken.None);
+ var result = await this.TransactionDomainEventHandler.Handle(domainEvent, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
}
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/VoucherDomainEventHandlerTests.cs b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/VoucherDomainEventHandlerTests.cs
index 8c1953f1..cf8054a3 100644
--- a/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/VoucherDomainEventHandlerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/DomainEventHandlers/VoucherDomainEventHandlerTests.cs
@@ -1,4 +1,4 @@
-using SimpleResults;
+using SimpleResults;
using TransactionProcessor.Aggregates;
using TransactionProcessor.BusinessLogic.Services;
using TransactionProcessor.Database.Contexts;
@@ -107,9 +107,9 @@ public async Task VoucherDomainEventHandler_VoucherIssuedEvent_WithEmailAddress_
EstateId = TestData.EstateId,
Description = TestData.OperatorIdentifier
});
- await this.Context.SaveChangesAsync(CancellationToken.None);
+ await this.Context.SaveChangesAsync(TestContext.Current.CancellationToken);
- await this.VoucherDomainEventHandler.Handle(TestData.VoucherIssuedEvent, CancellationToken.None);
+ await this.VoucherDomainEventHandler.Handle(TestData.VoucherIssuedEvent, TestContext.Current.CancellationToken);
}
[Fact]
@@ -132,8 +132,8 @@ public async Task VoucherDomainEventHandler_VoucherIssuedEvent_WithRecipientMobi
EstateId = TestData.EstateId,
Description = TestData.OperatorIdentifier
});
- await this.Context.SaveChangesAsync(CancellationToken.None);
+ await this.Context.SaveChangesAsync(TestContext.Current.CancellationToken);
- await VoucherDomainEventHandler.Handle(TestData.VoucherIssuedEvent, CancellationToken.None);
+ await VoucherDomainEventHandler.Handle(TestData.VoucherIssuedEvent, TestContext.Current.CancellationToken);
}
-}
\ No newline at end of file
+}
diff --git a/TransactionProcessor.BusinessLogic.Tests/Manager/TransactionProcessorManagerTests.cs b/TransactionProcessor.BusinessLogic.Tests/Manager/TransactionProcessorManagerTests.cs
index 74906abf..589dcd42 100644
--- a/TransactionProcessor.BusinessLogic.Tests/Manager/TransactionProcessorManagerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/Manager/TransactionProcessorManagerTests.cs
@@ -1,4 +1,4 @@
-using Moq;
+using Moq;
using Shared.DomainDrivenDesign.EventSourcing;
using Shared.EventStore.Aggregate;
using Shared.Logger;
@@ -48,7 +48,7 @@ public async Task TransactionProcessorManager_GetEstates_EstatesAreReturned()
this.AggregateService.Setup(a => a.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedEstateAggregate()));
this.TransactionProcessorReadModelRepository.Setup(e => e.GetEstate(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.EstateModel));
- Result> getEstatesResult = await this.TransactionProcessorManager.GetEstates(TestData.EstateId, CancellationToken.None);
+ Result> getEstatesResult = await this.TransactionProcessorManager.GetEstates(TestData.EstateId, TestContext.Current.CancellationToken);
getEstatesResult.IsSuccess.ShouldBeTrue();
List estateModels = getEstatesResult.Data;
estateModels.ShouldNotBeNull();
@@ -63,7 +63,7 @@ public async Task TransactionProcessorManager_GetEstates_RepoCallFails_ResultFai
this.AggregateService.Setup(a => a.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedEstateAggregate()));
this.TransactionProcessorReadModelRepository.Setup(e => e.GetEstate(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> getEstatesResult = await this.TransactionProcessorManager.GetEstates(TestData.EstateId, CancellationToken.None);
+ Result> getEstatesResult = await this.TransactionProcessorManager.GetEstates(TestData.EstateId, TestContext.Current.CancellationToken);
getEstatesResult.IsFailed.ShouldBeTrue();
}
@@ -72,9 +72,9 @@ public async Task TransactionProcessorManager_GetEstate_EstateIsReturned()
{
this.AggregateService.Setup(a => a.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EstateAggregateWithOperator()));
this.TransactionProcessorReadModelRepository.Setup(e => e.GetEstate(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.EstateModel));
- this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), CancellationToken.None)).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedOperatorAggregate()));
+ this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), TestContext.Current.CancellationToken)).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedOperatorAggregate()));
- Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, CancellationToken.None);
+ Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, TestContext.Current.CancellationToken);
getEstateResult.IsSuccess.ShouldBeTrue();
Estate estateModel = getEstateResult.Data;
estateModel.ShouldNotBeNull();
@@ -92,7 +92,7 @@ public async Task TransactionProcessorManager_GetEstate_InvalidEstateId_ErrorIsT
this.AggregateService.Setup(a => a.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EmptyEstateAggregate));
this.TransactionProcessorReadModelRepository.Setup(e => e.GetEstate(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.EstateModel));
- Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, CancellationToken.None);
+ Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, TestContext.Current.CancellationToken);
getEstateResult.IsFailed.ShouldBeTrue();
}
@@ -102,7 +102,7 @@ public async Task TransactionProcessorManager_GetEstate_GetLatestFailed_ErrorIsT
this.AggregateService.Setup(a => a.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
this.TransactionProcessorReadModelRepository.Setup(e => e.GetEstate(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.EstateModel));
- Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, CancellationToken.None);
+ Result getEstateResult = await this.TransactionProcessorManager.GetEstate(TestData.EstateId, TestContext.Current.CancellationToken);
getEstateResult.IsFailed.ShouldBeTrue();
}
@@ -111,7 +111,7 @@ public async Task TransactionProcessorManager_GetContract_ContractIsReturned()
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedContractAggregateWithAProductAndTransactionFee(CalculationType.Fixed, FeeType.Merchant)));
- Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, CancellationToken.None);
+ Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, TestContext.Current.CancellationToken);
getContractResult.IsSuccess.ShouldBeTrue();
Contract contractModel = getContractResult.Data;
@@ -130,7 +130,7 @@ public async Task TransactionProcessorManager_GetContract_ContractNotCreated_Err
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EmptyContractAggregate()));
- Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, CancellationToken.None);
+ Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, TestContext.Current.CancellationToken);
getContractResult.IsFailed.ShouldBeTrue();
}
@@ -139,7 +139,7 @@ public async Task TransactionProcessorManager_GetContract_GetLatestFails_ErrorIs
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, CancellationToken.None);
+ Result getContractResult = await this.TransactionProcessorManager.GetContract(TestData.EstateId, TestData.ContractId, TestContext.Current.CancellationToken);
getContractResult.IsFailed.ShouldBeTrue();
}
@@ -148,7 +148,7 @@ public async Task TransactionProcessorManager_GetContracts_ContractAreReturned()
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetContracts(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(new List() { TestData.ContractModelWithProductsAndTransactionFees }));
- Result> getContractsResult = await this.TransactionProcessorManager.GetContracts(TestData.EstateId, CancellationToken.None);
+ Result> getContractsResult = await this.TransactionProcessorManager.GetContracts(TestData.EstateId, TestContext.Current.CancellationToken);
getContractsResult.IsSuccess.ShouldBeTrue();
List contractModelList = getContractsResult.Data;
contractModelList.ShouldNotBeNull();
@@ -160,7 +160,7 @@ public async Task TransactionProcessorManager_GetContracts_RepoCallFails_Contrac
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetContracts(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> getContractsResult = await this.TransactionProcessorManager.GetContracts(TestData.EstateId, CancellationToken.None);
+ Result> getContractsResult = await this.TransactionProcessorManager.GetContracts(TestData.EstateId, TestContext.Current.CancellationToken);
getContractsResult.IsFailed.ShouldBeTrue();
}
@@ -169,7 +169,7 @@ public async Task TransactionProcessorManager_GetTransactionFeesForProduct_Trans
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedContractAggregateWithAProductAndTransactionFee(CalculationType.Fixed, FeeType.Merchant)));
- Result> getTransactionFeesForProductResult = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.VariableContractProductId, CancellationToken.None);
+ Result> getTransactionFeesForProductResult = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.VariableContractProductId, TestContext.Current.CancellationToken);
getTransactionFeesForProductResult.IsSuccess.ShouldBeTrue();
List transactionFees = getTransactionFeesForProductResult.Data;
transactionFees.ShouldNotBeNull();
@@ -182,7 +182,7 @@ public async Task TransactionProcessorManager_GetTransactionFeesForProduct_Contr
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EmptyContractAggregate()));
- Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, CancellationToken.None);
+ Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -191,7 +191,7 @@ public async Task TransactionProcessorManager_GetTransactionFeesForProduct_Produ
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedContractAggregate()));
- Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, CancellationToken.None);
+ Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -200,7 +200,7 @@ public async Task TransactionProcessorManager_GetTransactionFeesForProduct_GetLa
{
this.AggregateService.Setup(c => c.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, CancellationToken.None);
+ Result> result = await this.TransactionProcessorManager.GetTransactionFeesForProduct(TestData.EstateId, TestData.MerchantId, TestData.ContractId, TestData.FixedContractProductId, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
/*
@@ -210,7 +210,7 @@ public async Task EstateManagementManager_GetFileDetails_FileDetailsAreReturned(
{
this.EstateManagementRepository.Setup(e => e.GetFileDetails(It.IsAny(), It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.FileModel));
- var getFileDetailsResult = await this.EstateManagementManager.GetFileDetails(TestData.EstateId, TestData.FileId, CancellationToken.None);
+ var getFileDetailsResult = await this.EstateManagementManager.GetFileDetails(TestData.EstateId, TestData.FileId, TestContext.Current.CancellationToken);
getFileDetailsResult.IsSuccess.ShouldBeTrue();
var fileDetails = getFileDetailsResult.Data;
fileDetails.ShouldNotBeNull();
@@ -221,7 +221,7 @@ public async Task EstateManagementManager_GetFileDetails_RepoCallFailed_FileDeta
{
this.EstateManagementRepository.Setup(e => e.GetFileDetails(It.IsAny(), It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- var getFileDetailsResult = await this.EstateManagementManager.GetFileDetails(TestData.EstateId, TestData.FileId, CancellationToken.None);
+ var getFileDetailsResult = await this.EstateManagementManager.GetFileDetails(TestData.EstateId, TestData.FileId, TestContext.Current.CancellationToken);
getFileDetailsResult.IsFailed.ShouldBeTrue();
}
*/
@@ -230,7 +230,7 @@ public async Task TransactionProcessorManager_GetOperator_OperatorDetailsAreRetu
{
this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedOperatorAggregate()));
- Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, CancellationToken.None);
+ Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, TestContext.Current.CancellationToken);
getOperatorResult.IsSuccess.ShouldBeTrue();
Operator operatorDetails = getOperatorResult.Data;
operatorDetails.ShouldNotBeNull();
@@ -241,7 +241,7 @@ public async Task TransactionProcessorManager_GetOperator_OperatorNotCreated_Exc
{
this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EmptyOperatorAggregate()));
- Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, CancellationToken.None);
+ Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, TestContext.Current.CancellationToken);
getOperatorResult.IsFailed.ShouldBeTrue();
}
@@ -250,7 +250,7 @@ public async Task TransactionProcessorManager_GetOperator_GetLatestFails_Excepti
{
this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, CancellationToken.None);
+ Result getOperatorResult = await this.TransactionProcessorManager.GetOperator(TestData.EstateId, TestData.OperatorId, TestContext.Current.CancellationToken);
getOperatorResult.IsFailed.ShouldBeTrue();
}
@@ -261,7 +261,7 @@ public async Task TransactionProcessorManager_GetOperators_OperatorDetailsAreRet
TestData.OperatorModel
}));
- Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, CancellationToken.None);
+ Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, TestContext.Current.CancellationToken);
getOperatorsResult.IsSuccess.ShouldBeTrue();
List operators = getOperatorsResult.Data;
operators.ShouldNotBeNull();
@@ -274,7 +274,7 @@ public async Task TransactionProcessorManager_GetOperators_EmptyList_ExceptionTh
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetOperators(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(new List()));
- Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, CancellationToken.None);
+ Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, TestContext.Current.CancellationToken);
getOperatorsResult.IsSuccess.ShouldBeTrue();
}
@@ -283,7 +283,7 @@ public async Task TransactionProcessorManager_GetOperators_RepoCallFails_Excepti
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetOperators(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, CancellationToken.None);
+ Result> getOperatorsResult = await this.TransactionProcessorManager.GetOperators(TestData.EstateId, TestContext.Current.CancellationToken);
getOperatorsResult.IsFailed.ShouldBeTrue();
}
@@ -291,14 +291,14 @@ public async Task TransactionProcessorManager_GetOperators_RepoCallFails_Excepti
public async Task TransactionProcessorManager_GetMerchant_MerchantIsReturned()
{
this.AggregateService.Setup(m => m.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.MerchantAggregateWithEverything(SettlementSchedule.Immediate)));
- this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), CancellationToken.None)).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedOperatorAggregate()));
+ this.AggregateService.Setup(o => o.GetLatest(It.IsAny(), TestContext.Current.CancellationToken)).ReturnsAsync(Result.Success(TestData.Aggregates.CreatedOperatorAggregate()));
this.TransactionProcessorReadModelRepository
.Setup(r => r.GetMerchant(It.IsAny(), It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Success(TestData.MerchantModelWithAddressesContactsDevicesAndOperatorsAndContracts()));
Merchant expectedModel = TestData.MerchantModelWithAddressesContactsDevicesAndOperatorsAndContracts();
- Result getMerchantResult = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result getMerchantResult = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
getMerchantResult.IsSuccess.ShouldBeTrue();
Merchant merchantModel = getMerchantResult.Data;
@@ -345,7 +345,7 @@ public async Task TransactionProcessorManager_GetMerchant_MerchantNotCreated_Err
{
this.AggregateService.Setup(m => m.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.Aggregates.EmptyMerchantAggregate()));
- Result result = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -354,7 +354,7 @@ public async Task TransactionProcessorManager_GetMerchant_GetLatestFails_ErrorTh
{
this.AggregateService.Setup(m => m.GetLatest(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result result = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchant(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -368,7 +368,7 @@ public async Task TransactionProcessorManager_GetMerchantSchedule_MerchantSchedu
.Setup(m => m.GetLatest(It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Success(merchantScheduleAggregate));
- Result result = await this.TransactionProcessorManager.GetMerchantSchedule(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchantSchedule(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.Year.ShouldBe(TestData.MerchantScheduleYear);
@@ -384,7 +384,7 @@ public async Task TransactionProcessorManager_GetMerchantSchedule_MerchantSchedu
.Setup(m => m.GetLatest(It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Success(TestData.Aggregates.EmptyMerchantScheduleAggregate()));
- Result result = await this.TransactionProcessorManager.GetMerchantSchedule(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchantSchedule(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -397,7 +397,7 @@ public async Task TransactionProcessorManager_GetMerchantScheduleFromReadModel_M
.Setup(m => m.GetMerchantSchedule(It.IsAny(), It.IsAny(), It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Success(expectedSchedule));
- Result result = await this.TransactionProcessorManager.GetMerchantScheduleFromReadModel(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchantScheduleFromReadModel(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.Year.ShouldBe(TestData.MerchantScheduleYear);
@@ -413,7 +413,7 @@ public async Task TransactionProcessorManager_GetMerchantScheduleFromReadModel_M
.Setup(m => m.GetMerchantSchedule(It.IsAny(), It.IsAny(), It.IsAny(), It.IsAny()))
.ReturnsAsync(Result.Failure());
- Result result = await this.TransactionProcessorManager.GetMerchantScheduleFromReadModel(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, CancellationToken.None);
+ Result result = await this.TransactionProcessorManager.GetMerchantScheduleFromReadModel(TestData.EstateId, TestData.MerchantId, TestData.MerchantScheduleYear, TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
}
@@ -423,7 +423,7 @@ public async Task TransactionProcessorManager_GetMerchantContracts_MerchantContr
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchantContracts(It.IsAny(), It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.MerchantContracts));
- Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
getMerchantContractsResult.IsSuccess.ShouldBeTrue();
List merchantContracts = getMerchantContractsResult.Data;
merchantContracts.ShouldNotBeNull();
@@ -436,7 +436,7 @@ public async Task TransactionProcessorManager_GetMerchantContracts_EmptyListRetu
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchantContracts(It.IsAny(), It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.MerchantContractsEmptyList));
- Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
getMerchantContractsResult.IsFailed.ShouldBeTrue();
}
@@ -445,7 +445,7 @@ public async Task TransactionProcessorManager_GetMerchantContracts_RepoCallFaile
{
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchantContracts(It.IsAny(), It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
getMerchantContractsResult.IsFailed.ShouldBeTrue();
}
@@ -456,7 +456,7 @@ public async Task TransactionProcessorManager_GetMerchantContracts_RepositoryThr
.Setup(e => e.GetMerchantContracts(It.IsAny(), It.IsAny(), It.IsAny()))
.ThrowsAsync(new Exception("Test exception"));
- Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, CancellationToken.None);
+ Result> getMerchantContractsResult = await this.TransactionProcessorManager.GetMerchantContracts(TestData.EstateId, TestData.MerchantId, TestContext.Current.CancellationToken);
getMerchantContractsResult.IsFailed.ShouldBeTrue();
getMerchantContractsResult.Message.ShouldBe("Test exception");
@@ -471,7 +471,7 @@ public async Task TransactionProcessorManager_GetMerchants_MerchantListIsReturne
.MerchantModelWithAddressesContactsDevicesAndOperatorsAndContracts()
}));
- Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, CancellationToken.None);
+ Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, TestContext.Current.CancellationToken);
getMerchantsResult.IsSuccess.ShouldBeTrue();
List merchantList = getMerchantsResult.Data;
@@ -486,7 +486,7 @@ public async Task TransactionProcessorManager_GetMerchants_NullMerchants_Excepti
List merchants = null;
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchants(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(merchants));
- Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, CancellationToken.None);
+ Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, TestContext.Current.CancellationToken);
getMerchantsResult.IsFailed.ShouldBeTrue();
}
@@ -496,7 +496,7 @@ public async Task TransactionProcessorManager_GetMerchants_EmptyMerchants_Except
List merchants = new List();
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchants(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(merchants));
- Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, CancellationToken.None);
+ Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, TestContext.Current.CancellationToken);
getMerchantsResult.IsFailed.ShouldBeTrue();
}
@@ -506,8 +506,9 @@ public async Task TransactionProcessorManager_GetMerchants_RepoCallFails_Excepti
List merchants = new List();
this.TransactionProcessorReadModelRepository.Setup(e => e.GetMerchants(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Failure());
- Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, CancellationToken.None);
+ Result> getMerchantsResult = await this.TransactionProcessorManager.GetMerchants(TestData.EstateId, TestContext.Current.CancellationToken);
getMerchantsResult.IsFailed.ShouldBeTrue();
}
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/Manager/VoucherManagementManagerTests.cs b/TransactionProcessor.BusinessLogic.Tests/Manager/VoucherManagementManagerTests.cs
index 657ba13a..2eaa9898 100644
--- a/TransactionProcessor.BusinessLogic.Tests/Manager/VoucherManagementManagerTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/Manager/VoucherManagementManagerTests.cs
@@ -1,4 +1,4 @@
-using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using Moq;
using Shared.DomainDrivenDesign.EventSourcing;
@@ -65,12 +65,12 @@ await this.Context.VoucherProjectionStates.AddAsync(new VoucherProjectionState
VoucherCode = TestData.VoucherCode,
Barcode = TestData.Barcode,
Timestamp = b
- });
- await this.Context.SaveChangesAsync(CancellationToken.None);
+ }, TestContext.Current.CancellationToken);
+ await this.Context.SaveChangesAsync(TestContext.Current.CancellationToken);
this.AggregateService.Setup(v => v.Get(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.GetVoucherAggregateWithRecipientMobile()));
- Result result = await this.VoucherManagementManager.GetVoucherByCode(TestData.EstateId, TestData.VoucherCode, CancellationToken.None);
+ Result result = await this.VoucherManagementManager.GetVoucherByCode(TestData.EstateId, TestData.VoucherCode, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
Models.Voucher voucher = result.Data;
voucher.ShouldNotBeNull();
@@ -84,7 +84,7 @@ public async Task VoucherManagementManager_GetVoucherByCode_VoucherNotFound_Erro
Should.Throw(async () =>
{
- await this.VoucherManagementManager.GetVoucherByCode(TestData.EstateId, TestData.VoucherCode, CancellationToken.None);
+ await this.VoucherManagementManager.GetVoucherByCode(TestData.EstateId, TestData.VoucherCode, TestContext.Current.CancellationToken);
});
}
@@ -100,12 +100,12 @@ await this.Context.VoucherProjectionStates.AddAsync(new VoucherProjectionState
VoucherCode = TestData.VoucherCode,
Barcode = TestData.Barcode,
Timestamp = b
- });
- await this.Context.SaveChangesAsync(CancellationToken.None);
+ }, TestContext.Current.CancellationToken);
+ await this.Context.SaveChangesAsync(TestContext.Current.CancellationToken);
this.AggregateService.Setup(v => v.Get(It.IsAny(), It.IsAny())).ReturnsAsync(Result.Success(TestData.GetVoucherAggregateWithRecipientMobile()));
- var result = await VoucherManagementManager.GetVoucherByTransactionId(TestData.EstateId, TestData.TransactionId, CancellationToken.None);
+ var result = await VoucherManagementManager.GetVoucherByTransactionId(TestData.EstateId, TestData.TransactionId, TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
Models.Voucher voucher = result.Data;
voucher.ShouldNotBeNull();
@@ -118,8 +118,9 @@ public async Task VoucherManagementManager_GetVoucherByTransactionId_VoucherNotF
Should.Throw(async () =>
{
- await this.VoucherManagementManager.GetVoucherByTransactionId(TestData.EstateId, TestData.TransactionId, CancellationToken.None);
+ await this.VoucherManagementManager.GetVoucherByTransactionId(TestData.EstateId, TestData.TransactionId, TestContext.Current.CancellationToken);
});
}
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/Mediator/MediatorTests.cs b/TransactionProcessor.BusinessLogic.Tests/Mediator/MediatorTests.cs
index 18e5e148..180d0af9 100644
--- a/TransactionProcessor.BusinessLogic.Tests/Mediator/MediatorTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/Mediator/MediatorTests.cs
@@ -134,7 +134,7 @@ public async Task Mediator_Send_RequestHandled()
{
try
{
- await mediator.Send(baseRequest);
+ await mediator.Send(baseRequest, TestContext.Current.CancellationToken);
}
catch (Exception ex)
{
diff --git a/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/AgencyBankingProxyTests.cs b/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/AgencyBankingProxyTests.cs
index e94466cd..53b46d24 100644
--- a/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/AgencyBankingProxyTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/AgencyBankingProxyTests.cs
@@ -35,7 +35,7 @@ public async Task AgencyBankingProxy_ProcessLogonMessage_ReturnsSuccessfulResult
AgencyBankingConfiguration configuration = CreateConfiguration();
IOperatorProxy proxy = new AgencyBankingProxy(httpClient, configuration);
- var result = await proxy.ProcessLogonMessage(CancellationToken.None);
+ var result = await proxy.ProcessLogonMessage(TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldBeNull();
@@ -59,7 +59,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MissingMessageType_Retur
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -84,7 +84,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MissingAccountNumber_Ret
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -110,7 +110,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_UnsupportedMessageType_R
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -142,7 +142,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_BalanceEnquiryFailure_Re
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -176,7 +176,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_BalanceEnquiryTimeout_Re
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Failure);
@@ -209,7 +209,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_BalanceEnquirySuccess_Re
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldNotBeNull();
@@ -221,7 +221,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_BalanceEnquirySuccess_Re
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/balance-enquiry"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -253,7 +253,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositFailure_ReturnsIn
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -263,7 +263,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositFailure_ReturnsIn
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/deposit"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -290,7 +290,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositMissingAmount_Ret
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -318,7 +318,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositInvalidAmount_Ret
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -351,7 +351,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositSuccess_ReturnsMa
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldNotBeNull();
@@ -364,7 +364,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_DepositSuccess_ReturnsMa
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/deposit"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -398,7 +398,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalFailure_Return
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -408,7 +408,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalFailure_Return
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/withdrawal"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -435,7 +435,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalMissingAmount_
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -463,7 +463,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalInvalidAmount_
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -496,7 +496,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalSuccess_Return
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldNotBeNull();
@@ -509,7 +509,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalSuccess_Return
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/withdrawal"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -543,7 +543,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalSuccess_WithMi
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldNotBeNull();
@@ -556,7 +556,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_WithdrawalSuccess_WithMi
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/withdrawal"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -589,7 +589,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MiniStatementFailure_Ret
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsFailed.ShouldBeTrue();
result.Status.ShouldBe(ResultStatus.Invalid);
@@ -599,7 +599,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MiniStatementFailure_Ret
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/mini-statement"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -648,7 +648,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MiniStatementSuccess_Ret
TestData.TransactionDateTime,
TestData.TransactionReference,
metadata,
- CancellationToken.None);
+ TestContext.Current.CancellationToken);
result.IsSuccess.ShouldBeTrue();
result.Data.ShouldNotBeNull();
@@ -674,7 +674,7 @@ public async Task AgencyBankingProxy_ProcessSaleMessage_MiniStatementSuccess_Ret
capturedRequest.Method.ShouldBe(HttpMethod.Post);
capturedRequest.RequestUri.ShouldBe(new Uri("http://localhost/transactions/mini-statement"));
- String requestBody = await capturedRequest.Content.ReadAsStringAsync();
+ String requestBody = await capturedRequest.Content.ReadAsStringAsync(TestContext.Current.CancellationToken);
using JsonDocument requestJson = JsonDocument.Parse(requestBody);
requestJson.RootElement.GetProperty("agentId").GetString().ShouldBe(TestData.Merchant.MerchantId.ToString());
requestJson.RootElement.GetProperty("accountNumber").GetString().ShouldBe("123456789");
@@ -701,3 +701,4 @@ private static HttpClient SetupMockHttpClient(HttpResponseMessage responseMessag
}
}
}
+
diff --git a/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/PataPawaPostPayProxyTests.cs b/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/PataPawaPostPayProxyTests.cs
index de8c3a26..ad6917ae 100644
--- a/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/PataPawaPostPayProxyTests.cs
+++ b/TransactionProcessor.BusinessLogic.Tests/OperatorInterfaces/PataPawaPostPayProxyTests.cs
@@ -1,4 +1,4 @@
-using SimpleResults;
+using SimpleResults;
using System;
using System.Threading.Tasks;
@@ -47,7 +47,7 @@ public async Task PataPawaPostPayProxy_ProcessLogonMessage_SuccessfulResponse_Me
PataPawaPostPayService.Setup(s => s.getLoginRequestAsync(It.IsAny