Last consumer

2026-03-20 20:33:56 +01:00
parent 62283bd403
commit 93a975e9b5
3 changed files with 68 additions and 49 deletions
@@ -0,0 +1,30 @@
+using MassTransit;
+using Musify.Application.Events;
+using Musify.Infrastructure.Messaging.Activities;
+using Musify.Infrastructure.Messaging.Activities.Arguments;
+
+namespace Musify.Infrastructure.Messaging.Consumers
+{
+    public class RemoveFileConsumer(IBus bus)
+        : IConsumer<RemoveFileEvent>
+    {
+        public const string QueueName = "Remove-File";
+
+        public async Task Consume(ConsumeContext<RemoveFileEvent> consumeContext)
+        {
+            var routingSlipBuilder = new RoutingSlipBuilder(NewId.NextGuid());
+
+            routingSlipBuilder.AddActivity(
+                "RemoveFile",
+                BuildExecuteUri(RemoveFilesActivity.ExecuteEndpointName),
+                new RemoveFileArguments(
+                    consumeContext.Message.BucketName,
+                    consumeContext.Message.KeyName));
+
+            var routingSlip = routingSlipBuilder.Build();
+            await bus.Execute(routingSlip);
+        }
+
+        static Uri BuildExecuteUri(string endpointName) => new($"queue:{endpointName}_execute");
+    }
+}