Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
namespace TransactionProcessor.BusinessLogic.Tests.Mediator;

using System;
using System.Threading;
using System.Threading.Tasks;
using BusinessLogic.Services;
using Models;

public class DummySettlementDomainService : ISettlementDomainService
{
public async Task<ProcessSettlementResponse> ProcessSettlement(DateTime pendingSettlementDate,
Guid estateId,
CancellationToken cancellationToken) {
return new ProcessSettlementResponse();
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,53 @@
namespace TransactionProcessor.BusinessLogic.Tests.Mediator;

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using BusinessLogic.Services;
using Models;

public class DummyTransactionDomainService : ITransactionDomainService
{
public async Task<ProcessLogonTransactionResponse> ProcessLogonTransaction(Guid transactionId,
Guid estateId,
Guid merchantId,
DateTime transactionDateTime,
String transactionNumber,
String deviceIdentifier,
CancellationToken cancellationToken) {
return new ProcessLogonTransactionResponse();
}

public async Task<ProcessSaleTransactionResponse> ProcessSaleTransaction(Guid transactionId,
Guid estateId,
Guid merchantId,
DateTime transactionDateTime,
String transactionNumber,
String deviceIdentifier,
String operatorId,
String customerEmailAddress,
Dictionary<String, String> additionalTransactionMetadata,
Guid contractId,
Guid productId,
Int32 transactionSource,
CancellationToken cancellationToken) {
return new ProcessSaleTransactionResponse();
}

public async Task<ProcessReconciliationTransactionResponse> ProcessReconciliationTransaction(Guid transactionId,
Guid estateId,
Guid merchantId,
String deviceIdentifier,
DateTime transactionDateTime,
Int32 transactionCount,
Decimal transactionValue,
CancellationToken cancellationToken) {
return new ProcessReconciliationTransactionResponse();
}

public async Task ResendTransactionReceipt(Guid transactionId,
Guid estateId,
CancellationToken cancellationToken) {
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
namespace TransactionProcessor.BusinessLogic.Tests.Mediator;

using System;
using System.Threading;
using System.Threading.Tasks;
using BusinessLogic.Services;
using Models;

public class DummyVoucherDomainService : IVoucherDomainService
{
public async Task<IssueVoucherResponse> IssueVoucher(Guid voucherId,
String operatorId,
Guid estateId,
Guid transactionId,
DateTime issuedDateTime,
Decimal value,
String recipientEmail,
String recipientMobile,
CancellationToken cancellationToken) {
return new IssueVoucherResponse();
}

public async Task<RedeemVoucherResponse> RedeemVoucher(Guid estateId,
String voucherCode,
DateTime redeemedDateTime,
CancellationToken cancellationToken) {
return new RedeemVoucherResponse();
}
}
99 changes: 99 additions & 0 deletions TransactionProcessor.BusinessLogic.Tests/Mediator/MediatorTests.cs
Original file line number Diff line number Diff line change
@@ -0,0 +1,99 @@
using MediatR;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
using Moq;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Xunit;

namespace TransactionProcessor.BusinessLogic.Tests.Mediator
{
using BusinessLogic.Services;
using Lamar;
using Microsoft.Extensions.DependencyInjection;
using Testing;

public class MediatorTests
{
private List<IBaseRequest> Requests = new List<IBaseRequest>();

public MediatorTests()
{
this.Requests.Add(TestData.ProcessLogonTransactionRequest);
this.Requests.Add(TestData.ProcessReconciliationRequest);
this.Requests.Add(TestData.ProcessSaleTransactionRequest);
this.Requests.Add(TestData.ProcessSettlementRequest);
}

[Fact]
public async Task Mediator_Send_RequestHandled()
{
Mock<IWebHostEnvironment> hostingEnvironment = new Mock<IWebHostEnvironment>();
hostingEnvironment.Setup(he => he.EnvironmentName).Returns("Development");
hostingEnvironment.Setup(he => he.ContentRootPath).Returns("/home");
hostingEnvironment.Setup(he => he.ApplicationName).Returns("Test Application");

ServiceRegistry services = new ServiceRegistry();
Startup s = new Startup(hostingEnvironment.Object);
Startup.Configuration = this.SetupMemoryConfiguration();

this.AddTestRegistrations(services, hostingEnvironment.Object);
s.ConfigureContainer(services);
Startup.Container.AssertConfigurationIsValid(AssertMode.Full);

List<String> errors = new List<String>();
IMediator mediator = Startup.Container.GetService<IMediator>();
foreach (IBaseRequest baseRequest in this.Requests)
{
try
{
await mediator.Send(baseRequest);
}
catch (Exception ex)
{
errors.Add(ex.Message);
}
}

if (errors.Any() == true)
{
String errorMessage = String.Join(Environment.NewLine, errors);
throw new Exception(errorMessage);
}
}

private IConfigurationRoot SetupMemoryConfiguration()
{
Dictionary<String, String> configuration = new Dictionary<String, String>();

IConfigurationBuilder builder = new ConfigurationBuilder();

builder.AddInMemoryCollection(TestData.DefaultAppSettings);

return builder.Build();
}

private void AddTestRegistrations(ServiceRegistry services,
IWebHostEnvironment hostingEnvironment)
{
services.AddLogging();
DiagnosticListener diagnosticSource = new DiagnosticListener(hostingEnvironment.ApplicationName);
services.AddSingleton<DiagnosticSource>(diagnosticSource);
services.AddSingleton<DiagnosticListener>(diagnosticSource);
services.AddSingleton<IWebHostEnvironment>(hostingEnvironment);
services.AddSingleton<IHostEnvironment>(hostingEnvironment);
services.AddSingleton<IConfiguration>(Startup.Configuration);

services.OverrideServices(s => {
s.AddSingleton<ISettlementDomainService, DummySettlementDomainService>();
s.AddSingleton<IVoucherDomainService, DummyVoucherDomainService>();
s.AddSingleton<ITransactionDomainService, DummyTransactionDomainService>();
});
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,12 @@

<PropertyGroup>
<TargetFramework>net7.0</TargetFramework>
<DebugType>Full</DebugType>
<DebugType>None</DebugType>
<IsPackable>false</IsPackable>
</PropertyGroup>

<ItemGroup>
<PackageReference Include="Lamar" Version="8.1.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="7.0.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="7.0.0" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.4.0" />
Expand All @@ -28,6 +29,7 @@
<ItemGroup>
<ProjectReference Include="..\TransactionProcessor.BusinessLogic\TransactionProcessor.BusinessLogic.csproj" />
<ProjectReference Include="..\TransactionProcessor.Testing\TransactionProcessor.Testing.csproj" />
<ProjectReference Include="..\TransactionProcessor\TransactionProcessor.csproj" />
</ItemGroup>

</Project>
Loading