add test for create workflow message but with task and workflow Ids

Signed-off-by: Neil South <[email protected]>

Author: neildsouth

src/WorkflowManager/PayloadListener/Services/PayloadListenerService.cs

@@ -104,7 +104,8 @@ private void SetupPolling()
             _logger.EventSubscription(ServiceName, TaskStatusUpdateRoutingKey);
 
             _messageSubscriber.SubscribeAsync(ExportCompleteRoutingKey, ExportCompleteRoutingKey, OnExportCompleteReceivedCallback);
-            _logger.EventSubscription(ServiceName, ExportCompleteRoutingKey);        }
+            _logger.EventSubscription(ServiceName, ExportCompleteRoutingKey);
+        }
         private async Task OnWorkflowRequestReceivedCallbackAsync(MessageReceivedEventArgs eventArgs)
         {
 

tests/UnitTests/PayloadListener.Tests/Services/EventPayloadRecieverServiceTests.cs

@@ -276,6 +276,28 @@ public void ExportCompletePayload_ErrorIsThrown_MessageIsRejectedAndRequeued()
             _mockMessageBrokerSubscriberService.VerifyNoOtherCalls();
         }
 
+        [Test]
+        public void ReceiveWorkflowPayload_With_WorkflowId_And_TaskID()
+        {
+
+            var exportRequestMessage = new WorkflowRequestEvent
+            {
+                CorrelationId = Guid.NewGuid().ToString(),
+                WorkflowInstanceId = Guid.NewGuid().ToString(),
+                TaskId = "exporttask"
+            };
+            var jsonMessage = new JsonMessage<WorkflowRequestEvent>(exportRequestMessage, MessageBrokerConfiguration.WorkflowManagerApplicationId, exportRequestMessage.CorrelationId);
+            var message = new MessageReceivedEventArgs(jsonMessage.ToMessage(), CancellationToken.None);
+
+            _mockEventPayloadValidator.Setup(p => p.ValidateWorkflowRequest(It.IsAny<WorkflowRequestEvent>())).Returns(true);
+
+            _workflowExecuterService.Setup(p => p.ProcessPayload(It.IsAny<WorkflowRequestEvent>(), It.IsAny<Payload>())).ReturnsAsync(true);
+
+            _eventPayloadReceiverService.ReceiveWorkflowPayload(message);
+
+            _payloadService.Verify(p => p.CreateAsync(It.IsAny<WorkflowRequestEvent>()), Times.Never());
+        }
+
         private static MessageReceivedEventArgs CreateMessageReceivedEventArgs(string[] destinations)
         {
             var exportRequestMessage = new ExportRequestEvent