Add gateway fake worker end-to-end smoke

src/MxGateway.Tests/Gateway/Workers/Fakes/FakeWorkerHarness.cs

@@ -205,6 +205,7 @@ public sealed class FakeWorkerHarness : IAsyncDisposable
         WorkerEnvelope commandEnvelope,
         ProtocolStatusCode statusCode = ProtocolStatusCode.Ok,
         string statusMessage = "OK",
+        Action<MxCommandReply>? configureReply = null,
         CancellationToken cancellationToken = default)
     {
         if (commandEnvelope.BodyCase != WorkerEnvelope.BodyOneofCase.WorkerCommand)
@@ -213,22 +214,25 @@ public sealed class FakeWorkerHarness : IAsyncDisposable
         }
 
         MxCommandKind kind = commandEnvelope.WorkerCommand.Command?.Kind ?? MxCommandKind.Unspecified;
+        MxCommandReply reply = new()
+        {
+            SessionId = SessionId,
+            CorrelationId = commandEnvelope.CorrelationId,
+            Kind = kind,
+            ProtocolStatus = new ProtocolStatus
+            {
+                Code = statusCode,
+                Message = statusMessage,
+            },
+        };
+        configureReply?.Invoke(reply);
+
         await _writer.WriteAsync(
             CreateEnvelope(
                 commandEnvelope.CorrelationId,
                 envelope => envelope.WorkerCommandReply = new WorkerCommandReply
                 {
-                    Reply = new MxCommandReply
-                    {
-                        SessionId = SessionId,
-                        CorrelationId = commandEnvelope.CorrelationId,
-                        Kind = kind,
-                        ProtocolStatus = new ProtocolStatus
-                        {
-                            Code = statusCode,
-                            Message = statusMessage,
-                        },
-                    },
+                    Reply = reply,
                     CompletedTimestamp = Timestamp.FromDateTimeOffset(DateTimeOffset.UtcNow),
                 }),
             cancellationToken).ConfigureAwait(false);
@@ -236,21 +240,25 @@ public sealed class FakeWorkerHarness : IAsyncDisposable
 
     public async Task EmitEventAsync(
         MxEventFamily family,
-        CancellationToken cancellationToken = default)
+        CancellationToken cancellationToken = default,
+        Action<MxEvent>? configureEvent = null)
     {
         ulong sequence = NextWorkerSequence + 1;
+        MxEvent mxEvent = new()
+        {
+            SessionId = SessionId,
+            Family = family,
+            WorkerSequence = sequence,
+            WorkerTimestamp = Timestamp.FromDateTimeOffset(DateTimeOffset.UtcNow),
+        };
+        configureEvent?.Invoke(mxEvent);
+
         await _writer.WriteAsync(
             CreateEnvelope(
                 correlationId: string.Empty,
                 envelope => envelope.WorkerEvent = new WorkerEvent
                 {
-                    Event = new MxEvent
-                    {
-                        SessionId = SessionId,
-                        Family = family,
-                        WorkerSequence = sequence,
-                        WorkerTimestamp = Timestamp.FromDateTimeOffset(DateTimeOffset.UtcNow),
-                    },
+                    Event = mxEvent,
                 }),
             cancellationToken).ConfigureAwait(false);
     }