Skip to content

Commit

Permalink
Ãcleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
jvandaal committed Feb 6, 2025
1 parent e1d12fe commit 920b1e5
Showing 1 changed file with 0 additions and 37 deletions.
Original file line number Diff line number Diff line change
@@ -1,11 +1,9 @@
namespace RoadRegistry.BackOffice.Handlers.Sqs.Lambda.Tests;

using Abstractions;
using Autofac;
using AutoFixture;
using BackOffice.Uploads;
using Be.Vlaanderen.Basisregisters.Aws.Lambda;
using Be.Vlaanderen.Basisregisters.Sqs.Lambda.Requests;
using Be.Vlaanderen.Basisregisters.Sqs.Requests;
using FluentAssertions;
using MediatR;
Expand All @@ -20,41 +18,6 @@ public MessageHandlerTests(ITestOutputHelper testOutputHelper)
{
}

// todo-rik why is this method not called?
private async Task WhenProcessing_SqsRequest_Then_SqsLambdaRequest_IsSent<TSqsRequest, TSqsLambdaRequest, TBackOfficeRequest>()
where TSqsRequest : SqsRequest, IHasBackOfficeRequest<TBackOfficeRequest>
where TSqsLambdaRequest : SqsLambdaRequest, IHasBackOfficeRequest<TBackOfficeRequest>
{
// Arrange
var mediator = new Mock<IMediator>();
var containerBuilder = new ContainerBuilder();
containerBuilder.Register(_ => mediator.Object);
var container = containerBuilder.Build();
var blobClient = new SqsMessagesBlobClient(Client, new SqsJsonMessageSerializer(new FakeSqsOptions()));

var messageData = ObjectProvider.Create<TSqsRequest>();
var messageMetadata = new MessageMetadata { MessageGroupId = ObjectProvider.Create<string>() };

var sut = new MessageHandler(container, blobClient);

// Act
await sut.HandleMessage(
messageData,
messageMetadata,
CancellationToken.None);

// Assert
mediator
.Verify(x => x.Send(It.Is<TSqsLambdaRequest>(request =>
request.TicketId == messageData.TicketId &&
request.MessageGroupId == messageMetadata.MessageGroupId &&
Equals(request.Request, messageData.Request) &&
request.IfMatchHeaderValue == messageData.IfMatchHeaderValue &&
request.Provenance == messageData.ProvenanceData.ToProvenance() &&
request.Metadata == messageData.Metadata
), CancellationToken.None), Times.Once);
}

[Fact]
public async Task WhenProcessingSqsRequestWithoutCorrespondingSqsLambdaRequest_ThenThrowsNotImplementedException()
{
Expand Down

0 comments on commit 920b1e5

Please sign in to comment.