Change type to enable prevalidation

Energinet-DataHub · Mar 20, 2023 · ec1191d · ec1191d
1 parent 1b96c90
commit ec1191d
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/source/Api/OutgoingMessages/DequeueRequestListener.cs b/source/Api/OutgoingMessages/DequeueRequestListener.cs
@@ -38,7 +38,7 @@ public async Task<HttpResponseData> RunAsync(
         FunctionContext executionContext,
         string messageId)
     {
-        var result = await _mediator.Send(new DequeueRequest(Guid.Parse(messageId))).ConfigureAwait(false);
+        var result = await _mediator.Send(new DequeueRequest(messageId)).ConfigureAwait(false);
         return result.Success
             ? request.CreateResponse(HttpStatusCode.OK)
             : request.CreateResponse(HttpStatusCode.BadRequest);

diff --git a/source/Application/OutgoingMessages/Dequeue/DequeueRequestHandler.cs b/source/Application/OutgoingMessages/Dequeue/DequeueRequestHandler.cs
@@ -34,10 +34,10 @@ public Task<DequeueResult> Handle(DequeueRequest request, CancellationToken canc
     {
        ArgumentNullException.ThrowIfNull(request);
 
-       return _bundledMessages.DequeueAsync(request.MessageId);
+       return _bundledMessages.DequeueAsync(Guid.Parse(request.MessageId));
     }
 }
 
-public record DequeueRequest(Guid MessageId) : ICommand<DequeueResult>;
+public record DequeueRequest(string MessageId) : ICommand<DequeueResult>;
 
 public record DequeueResult(bool Success);
diff --git a/source/IntegrationTests/Application/OutgoingMessages/WhenADequeueIsRequestedTests.cs b/source/IntegrationTests/Application/OutgoingMessages/WhenADequeueIsRequestedTests.cs
@@ -37,7 +37,7 @@ public WhenADequeueIsRequestedTests(DatabaseFixture databaseFixture)
     [Fact]
     public async Task Dequeue_is_unsuccessful_when_bundle_does_not_exist()
     {
-        var dequeueResult = await InvokeCommandAsync(new DequeueRequest(Guid.NewGuid())).ConfigureAwait(false);
+        var dequeueResult = await InvokeCommandAsync(new DequeueRequest(Guid.NewGuid().ToString())).ConfigureAwait(false);
 
         Assert.False(dequeueResult.Success);
     }
@@ -50,7 +50,7 @@ public async Task Dequeue_is_Successful()
             ActorNumber.Create(SampleData.NewEnergySupplierNumber),
             MessageCategory.MasterData)).ConfigureAwait(false);
 
-        var dequeueResult = await InvokeCommandAsync(new DequeueRequest(peekResult.MessageId.GetValueOrDefault())).ConfigureAwait(false);
+        var dequeueResult = await InvokeCommandAsync(new DequeueRequest(peekResult.MessageId.GetValueOrDefault().ToString())).ConfigureAwait(false);
 
         using var connection = await GetService<IDatabaseConnectionFactory>().GetConnectionAndOpenAsync().ConfigureAwait(false);
         var found = await connection