[FA-misc] Mass transit overhaul, needs testing and review

FictionArchive.Service.AuthenticationService/Controllers/AuthenticationWebhookController.cs

@@ -1,7 +1,6 @@
 using FictionArchive.Service.AuthenticationService.Models.Requests;
-using FictionArchive.Service.AuthenticationService.Models.IntegrationEvents;
-using FictionArchive.Service.Shared.Services.EventBus;
-using Microsoft.AspNetCore.Http;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+using MassTransit;
 using Microsoft.AspNetCore.Mvc;
 
 namespace FictionArchive.Service.AuthenticationService.Controllers
@@ -10,11 +9,11 @@ namespace FictionArchive.Service.AuthenticationService.Controllers
     [ApiController]
     public class AuthenticationWebhookController : ControllerBase
     {
-        private readonly IEventBus _eventBus;
+        private readonly IPublishEndpoint _publishEndpoint;
 
-        public AuthenticationWebhookController(IEventBus eventBus)
+        public AuthenticationWebhookController(IPublishEndpoint publishEndpoint)
         {
-            _eventBus = eventBus;
+            _publishEndpoint = publishEndpoint;
         }
 
         [HttpPost(nameof(UserRegistered))]
@@ -28,7 +27,7 @@ namespace FictionArchive.Service.AuthenticationService.Controllers
                 EventUserUsername = payload.EventUserUsername
             };
 
-            await _eventBus.Publish(authUserAddedEvent);
+            await _publishEndpoint.Publish(authUserAddedEvent);
 
             return Ok();
         }

FictionArchive.Service.AuthenticationService/Models/IntegrationEvents/AuthUserAddedEvent.cs

@@ -1,16 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.AuthenticationService.Models.IntegrationEvents;
-
-public class AuthUserAddedEvent : IIntegrationEvent
-{
-    public string OAuthProviderId { get; set; }
-    
-    public string InviterOAuthProviderId { get; set; }
-
-    // The email of the user that created the event
-    public string EventUserEmail { get; set; }
-
-    // The username of the user that created the event
-    public string EventUserUsername { get; set; }
-}

FictionArchive.Service.AuthenticationService/Program.cs

@@ -1,5 +1,4 @@
-using FictionArchive.Service.Shared;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 
 namespace FictionArchive.Service.AuthenticationService;
 
@@ -16,13 +15,10 @@ public class Program
         builder.Services.AddEndpointsApiExplorer();
         builder.Services.AddSwaggerGen();
 
-        #region Event Bus
+        #region MassTransit
+
+        builder.Services.AddFictionArchiveMassTransit(builder.Configuration);
 
-        builder.Services.AddRabbitMQ(opt =>
-        {
-            builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-        });
-        
         #endregion
 
         builder.Services.AddHealthChecks();

FictionArchive.Service.AuthenticationService/appsettings.json

@@ -6,8 +6,10 @@
     }
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "AuthenticationService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "AllowedHosts": "*"
 }

FictionArchive.Service.FileService/Models/IntegrationEvents/FileUploadRequestCreatedEvent.cs

@@ -1,10 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.FileService.Models.IntegrationEvents;
-
-public class FileUploadRequestCreatedEvent : IIntegrationEvent
-{
-    public Guid RequestId { get; set; }
-    public string FilePath { get; set; }
-    public byte[] FileData { get; set; }
-}

FictionArchive.Service.FileService/Models/IntegrationEvents/FileUploadRequestStatusUpdateEvent.cs

@@ -1,22 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.FileService.Models.IntegrationEvents;
-
-public class FileUploadRequestStatusUpdateEvent : IIntegrationEvent
-{
-    public Guid RequestId { get; set; }
-    public RequestStatus Status { get; set; }
-    
-    #region Success
-    
-    public string? FileAccessUrl { get; set; }
-    
-    #endregion
-    
-    #region Failure
-    
-    public string? ErrorMessage { get; set; }
-    
-    #endregion
-}

FictionArchive.Service.FileService/Program.cs

@@ -2,10 +2,9 @@ using Amazon.Runtime;
 using Amazon.S3;
 using FictionArchive.Common.Extensions;
 using FictionArchive.Service.FileService.Models;
-using FictionArchive.Service.FileService.Models.IntegrationEvents;
 using FictionArchive.Service.FileService.Services.EventHandlers;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using Microsoft.Extensions.Options;
 
 namespace FictionArchive.Service.FileService;
@@ -24,14 +23,15 @@ public class Program
 
         builder.Services.AddHealthChecks();
         
-        #region Event Bus
+        #region MassTransit
+
+        builder.Services.AddFictionArchiveMassTransit(
+            builder.Configuration,
+            x =>
+            {
+                x.AddConsumer<UploadFileCommandConsumer>();
+            });
 
-        builder.Services.AddRabbitMQ(opt =>
-        {
-            builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-        })
-        .Subscribe<FileUploadRequestCreatedEvent, FileUploadRequestCreatedEventHandler>();
-        
         #endregion
         
         // Add authentication with cookie support

FictionArchive.Service.FileService/Services/EventHandlers/UploadFileCommandConsumer.cs

@@ -2,57 +2,62 @@ using Amazon.S3;
 using Amazon.S3.Model;
 using FictionArchive.Common.Enums;
 using FictionArchive.Service.FileService.Models;
-using FictionArchive.Service.FileService.Models.IntegrationEvents;
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+using MassTransit;
 using Microsoft.Extensions.Options;
 
 namespace FictionArchive.Service.FileService.Services.EventHandlers;
 
-public class FileUploadRequestCreatedEventHandler : IIntegrationEventHandler<FileUploadRequestCreatedEvent>
+public class UploadFileCommandConsumer : IConsumer<UploadFileCommand>
 {
-    private readonly ILogger<FileUploadRequestCreatedEventHandler> _logger;
+    private readonly ILogger<UploadFileCommandConsumer> _logger;
     private readonly AmazonS3Client _amazonS3Client;
-    private readonly IEventBus _eventBus;
     private readonly S3Configuration _s3Configuration;
     private readonly ProxyConfiguration _proxyConfiguration;
 
-    public FileUploadRequestCreatedEventHandler(ILogger<FileUploadRequestCreatedEventHandler> logger, AmazonS3Client amazonS3Client, IEventBus eventBus, IOptions<S3Configuration> s3Configuration, IOptions<ProxyConfiguration> proxyConfiguration)
+    public UploadFileCommandConsumer(
+        ILogger<UploadFileCommandConsumer> logger,
+        AmazonS3Client amazonS3Client,
+        IOptions<S3Configuration> s3Configuration,
+        IOptions<ProxyConfiguration> proxyConfiguration)
     {
         _logger = logger;
         _amazonS3Client = amazonS3Client;
-        _eventBus = eventBus;
         _proxyConfiguration = proxyConfiguration.Value;
         _s3Configuration = s3Configuration.Value;
     }
 
-    public async Task Handle(FileUploadRequestCreatedEvent @event)
+    public async Task Consume(ConsumeContext<UploadFileCommand> context)
     {
+        var command = context.Message;
+
         var putObjectRequest = new PutObjectRequest();
         putObjectRequest.BucketName = _s3Configuration.Bucket;
-        putObjectRequest.Key = @event.FilePath;
+        putObjectRequest.Key = command.FilePath;
         putObjectRequest.UseChunkEncoding = false; // Needed to avoid an error with Garage
-        
-        using MemoryStream memoryStream = new MemoryStream(@event.FileData);
+
+        using MemoryStream memoryStream = new MemoryStream(command.FileData);
         putObjectRequest.InputStream = memoryStream;
 
         var s3Response = await _amazonS3Client.PutObjectAsync(putObjectRequest);
         if (s3Response.HttpStatusCode != System.Net.HttpStatusCode.OK)
         {
             _logger.LogError("An error occurred while uploading file to S3. Response code: {responsecode}", s3Response.HttpStatusCode);
-            await _eventBus.Publish(new FileUploadRequestStatusUpdateEvent()
+            await context.Publish(new FileUploadCompletedEvent
             {
-                RequestId = @event.RequestId,
+                RequestId = command.RequestId,
                 Status = RequestStatus.Failed,
                 ErrorMessage = "An error occurred while uploading file to S3."
             });
             return;
         }
 
-        await _eventBus.Publish(new FileUploadRequestStatusUpdateEvent()
+        await context.Publish(new FileUploadCompletedEvent
         {
             Status = RequestStatus.Success,
-            RequestId = @event.RequestId,
-            FileAccessUrl = _proxyConfiguration.BaseUrl + "/" + @event.FilePath
+            RequestId = command.RequestId,
+            FileAccessUrl = _proxyConfiguration.BaseUrl + "/" + command.FilePath
         });
     }
-}
+}

FictionArchive.Service.FileService/appsettings.json

@@ -9,8 +9,10 @@
     "BaseUrl": "https://localhost:7247/api"
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "FileService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "S3": {
     "Url": "https://s3.orfl.xyz",

FictionArchive.Service.NovelService.Tests/NovelUpdateServiceTests.cs

@@ -1,5 +1,4 @@
 using FictionArchive.Common.Enums;
-using FictionArchive.Service.FileService.IntegrationEvents;
 using FictionArchive.Service.NovelService.Models.Configuration;
 using FictionArchive.Service.NovelService.Models.Enums;
 using FictionArchive.Service.NovelService.Models.Images;
@@ -8,8 +7,9 @@ using FictionArchive.Service.NovelService.Models.Novels;
 using FictionArchive.Service.NovelService.Models.SourceAdapters;
 using FictionArchive.Service.NovelService.Services;
 using FictionArchive.Service.NovelService.Services.SourceAdapters;
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
 using FluentAssertions;
+using MassTransit;
 using HtmlAgilityPack;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging.Abstractions;
@@ -72,7 +72,8 @@ public class NovelUpdateServiceTests
     private static NovelUpdateService CreateService(
         NovelServiceDbContext dbContext,
         ISourceAdapter adapter,
-        IEventBus eventBus,
+        IPublishEndpoint publishEndpoint,
+        ISendEndpointProvider sendEndpointProvider,
         string pendingImageUrl = "https://pending/placeholder.jpg")
     {
         var options = Options.Create(new NovelUpdateServiceConfiguration
@@ -80,7 +81,7 @@ public class NovelUpdateServiceTests
             PendingImageUrl = pendingImageUrl
         });
 
-        return new NovelUpdateService(dbContext, NullLogger<NovelUpdateService>.Instance, new[] { adapter }, eventBus, options);
+        return new NovelUpdateService(dbContext, NullLogger<NovelUpdateService>.Instance, new[] { adapter }, publishEndpoint, sendEndpointProvider, options);
     }
 
     [Fact]
@@ -102,13 +103,15 @@ public class NovelUpdateServiceTests
             ImageData = new List<ImageData> { image1, image2 }
         }));
 
-        var publishedEvents = new List<FileUploadRequestCreatedEvent>();
-        var eventBus = Substitute.For<IEventBus>();
-        eventBus.Publish(Arg.Do<FileUploadRequestCreatedEvent>(publishedEvents.Add)).Returns(Task.CompletedTask);
-        eventBus.Publish(Arg.Any<object>(), Arg.Any<string>()).Returns(Task.CompletedTask);
+        var publishedCommands = new List<UploadFileCommand>();
+        var publishEndpoint = Substitute.For<IPublishEndpoint>();
+        var sendEndpointProvider = Substitute.For<ISendEndpointProvider>();
+        var sendEndpoint = Substitute.For<ISendEndpoint>();
+        sendEndpointProvider.GetSendEndpoint(Arg.Any<Uri>()).Returns(Task.FromResult(sendEndpoint));
+        sendEndpoint.Send(Arg.Do<UploadFileCommand>(publishedCommands.Add), Arg.Any<CancellationToken>()).Returns(Task.CompletedTask);
 
         var pendingImageUrl = "https://pending/placeholder.jpg";
-        var service = CreateService(dbContext, adapter, eventBus, pendingImageUrl);
+        var service = CreateService(dbContext, adapter, publishEndpoint, sendEndpointProvider, pendingImageUrl);
 
         var updatedChapter = await service.PullChapterContents(novel.Id, volume.Id, chapter.Order);
 
@@ -127,10 +130,10 @@ public class NovelUpdateServiceTests
             .Should()
             .BeEquivalentTo(updatedChapter.Images.Select(img => img.Id.ToString()));
 
-        publishedEvents.Should().HaveCount(2);
-        publishedEvents.Select(e => e.RequestId).Should().BeEquivalentTo(updatedChapter.Images.Select(i => i.Id));
-        publishedEvents.Select(e => e.FileData).Should().BeEquivalentTo(new[] { image1.Data, image2.Data });
-        publishedEvents.Should().OnlyContain(e => e.FilePath.StartsWith($"{novel.Id}/Images/Chapter-{updatedChapter.Id}/"));
+        publishedCommands.Should().HaveCount(2);
+        publishedCommands.Select(e => e.RequestId).Should().BeEquivalentTo(updatedChapter.Images.Select(i => i.Id));
+        publishedCommands.Select(e => e.FileData).Should().BeEquivalentTo(new[] { image1.Data, image2.Data });
+        publishedCommands.Should().OnlyContain(e => e.FilePath.StartsWith($"{novel.Id}/Images/Chapter-{updatedChapter.Id}/"));
     }
 
     [Fact]
@@ -151,11 +154,12 @@ public class NovelUpdateServiceTests
             ImageData = new List<ImageData> { image }
         }));
 
-        var eventBus = Substitute.For<IEventBus>();
-        eventBus.Publish(Arg.Any<FileUploadRequestCreatedEvent>()).Returns(Task.CompletedTask);
-        eventBus.Publish(Arg.Any<object>(), Arg.Any<string>()).Returns(Task.CompletedTask);
+        var publishEndpoint = Substitute.For<IPublishEndpoint>();
+        var sendEndpointProvider = Substitute.For<ISendEndpointProvider>();
+        var sendEndpoint = Substitute.For<ISendEndpoint>();
+        sendEndpointProvider.GetSendEndpoint(Arg.Any<Uri>()).Returns(Task.FromResult(sendEndpoint));
 
-        var service = CreateService(dbContext, adapter, eventBus);
+        var service = CreateService(dbContext, adapter, publishEndpoint, sendEndpointProvider);
 
         var updatedChapter = await service.PullChapterContents(novel.Id, volume.Id, chapter.Order);
 
@@ -186,8 +190,9 @@ public class NovelUpdateServiceTests
         await dbContext.SaveChangesAsync();
 
         var adapter = Substitute.For<ISourceAdapter>();
-        var eventBus = Substitute.For<IEventBus>();
-        var service = CreateService(dbContext, adapter, eventBus);
+        var publishEndpoint = Substitute.For<IPublishEndpoint>();
+        var sendEndpointProvider = Substitute.For<ISendEndpointProvider>();
+        var service = CreateService(dbContext, adapter, publishEndpoint, sendEndpointProvider);
 
         var newUrl = "https://cdn.example.com/uploaded/cover.jpg";
 
@@ -228,8 +233,9 @@ public class NovelUpdateServiceTests
         await dbContext.SaveChangesAsync();
 
         var adapter = Substitute.For<ISourceAdapter>();
-        var eventBus = Substitute.For<IEventBus>();
-        var service = CreateService(dbContext, adapter, eventBus, pendingUrl);
+        var publishEndpoint = Substitute.For<IPublishEndpoint>();
+        var sendEndpointProvider = Substitute.For<ISendEndpointProvider>();
+        var service = CreateService(dbContext, adapter, publishEndpoint, sendEndpointProvider, pendingUrl);
 
         var newUrl = "https://cdn.example.com/uploaded/image.jpg";
 
@@ -277,8 +283,9 @@ public class NovelUpdateServiceTests
         await dbContext.SaveChangesAsync();
 
         var adapter = Substitute.For<ISourceAdapter>();
-        var eventBus = Substitute.For<IEventBus>();
-        var service = CreateService(dbContext, adapter, eventBus, pendingUrl);
+        var publishEndpoint = Substitute.For<IPublishEndpoint>();
+        var sendEndpointProvider = Substitute.For<ISendEndpointProvider>();
+        var service = CreateService(dbContext, adapter, publishEndpoint, sendEndpointProvider, pendingUrl);
 
         var newUrl = "https://cdn.example.com/uploaded/img1.jpg";
 

FictionArchive.Service.NovelService/GraphQL/Mutation.cs

@@ -1,27 +1,20 @@
-using FictionArchive.Service.NovelService.Models.Enums;
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
-using FictionArchive.Service.NovelService.Models.Localization;
-using FictionArchive.Service.NovelService.Models.Novels;
-using FictionArchive.Service.NovelService.Models.SourceAdapters;
 using FictionArchive.Service.NovelService.Services;
-using FictionArchive.Service.NovelService.Services.SourceAdapters;
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
 using HotChocolate.Authorization;
 using HotChocolate.Types;
-using Microsoft.EntityFrameworkCore;
 
 namespace FictionArchive.Service.NovelService.GraphQL;
 
 public class Mutation
 {
     [Authorize]
-    public async Task<NovelUpdateRequestedEvent> ImportNovel(string novelUrl, NovelUpdateService service)
+    public async Task<ImportNovelCommand> ImportNovel(string novelUrl, NovelUpdateService service)
     {
         return await service.QueueNovelImport(novelUrl);
     }
 
     [Authorize]
-    public async Task<ChapterPullRequestedEvent> FetchChapterContents(
+    public async Task<PullChapterContentCommand> FetchChapterContents(
         uint novelId,
         uint volumeId,
         uint chapterOrder,

FictionArchive.Service.NovelService/Models/IntegrationEvents/ChapterPullRequestedEvent.cs

@@ -1,10 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class ChapterPullRequestedEvent : IIntegrationEvent
-{
-    public uint NovelId { get; set; }
-    public uint VolumeId { get; set; }
-    public uint ChapterOrder { get; set; }
-}

FictionArchive.Service.NovelService/Models/IntegrationEvents/FileUploadRequestCreatedEvent.cs

@@ -1,10 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.FileService.IntegrationEvents;
-
-public class FileUploadRequestCreatedEvent : IIntegrationEvent
-{
-    public Guid RequestId { get; set; }
-    public string FilePath { get; set; }
-    public byte[] FileData { get; set; }
-}

FictionArchive.Service.NovelService/Models/IntegrationEvents/FileUploadRequestStatusUpdateEvent.cs

@@ -1,22 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class FileUploadRequestStatusUpdateEvent : IIntegrationEvent
-{
-    public Guid RequestId { get; set; }
-    public RequestStatus Status { get; set; }
-    
-    #region Success
-    
-    public string? FileAccessUrl { get; set; }
-    
-    #endregion
-    
-    #region Failure
-    
-    public string? ErrorMessage { get; set; }
-    
-    #endregion
-}

FictionArchive.Service.NovelService/Models/IntegrationEvents/NovelUpdateRequestedEvent.cs

@@ -1,8 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class NovelUpdateRequestedEvent : IIntegrationEvent
-{
-    public string NovelUrl { get; set; }
-}

FictionArchive.Service.NovelService/Models/IntegrationEvents/TranslationRequestCompletedEvent.cs

@@ -1,17 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class TranslationRequestCompletedEvent : IIntegrationEvent
-{
-    /// <summary>
-    /// Maps this event back to a triggering request.
-    /// </summary>
-    public Guid? TranslationRequestId { get; set; }
-    
-    /// <summary>
-    /// The resulting text.
-    /// </summary>
-    public string? TranslatedText { get; set; }
-}

FictionArchive.Service.NovelService/Models/IntegrationEvents/TranslationRequestCreatedEvent.cs

@@ -1,13 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class TranslationRequestCreatedEvent : IIntegrationEvent
-{
-    public Guid TranslationRequestId { get; set; }
-    public Language From { get; set; }
-    public Language To { get; set; }
-    public string Body { get; set; }
-    public string TranslationEngineKey { get; set; }
-}

FictionArchive.Service.NovelService/Program.cs

@@ -1,14 +1,13 @@
 using FictionArchive.Common.Extensions;
 using FictionArchive.Service.NovelService.GraphQL;
 using FictionArchive.Service.NovelService.Models.Configuration;
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
 using FictionArchive.Service.NovelService.Services;
-using FictionArchive.Service.NovelService.Services.EventHandlers;
+using FictionArchive.Service.NovelService.Services.Consumers;
 using FictionArchive.Service.NovelService.Services.SourceAdapters;
 using FictionArchive.Service.NovelService.Services.SourceAdapters.Novelpia;
 using FictionArchive.Service.Shared;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using FictionArchive.Service.Shared.Services.GraphQL;
 using Microsoft.EntityFrameworkCore;
 
@@ -25,18 +24,19 @@ public class Program
         
         builder.Services.AddMemoryCache();
         
-        #region Event Bus
+        #region MassTransit
 
         if (!isSchemaExport)
         {
-            builder.Services.AddRabbitMQ(opt =>
-            {
-                builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-            })
-                .Subscribe<TranslationRequestCompletedEvent, TranslationRequestCompletedEventHandler>()
-                .Subscribe<NovelUpdateRequestedEvent, NovelUpdateRequestedEventHandler>()
-                .Subscribe<ChapterPullRequestedEvent, ChapterPullRequestedEventHandler>()
-                .Subscribe<FileUploadRequestStatusUpdateEvent, FileUploadRequestStatusUpdateEventHandler>();
+            builder.Services.AddFictionArchiveMassTransit<NovelServiceDbContext>(
+                builder.Configuration,
+                cfg =>
+                {
+                    cfg.AddConsumer<ImportNovelCommandConsumer>();
+                    cfg.AddConsumer<PullChapterContentCommandConsumer>();
+                    cfg.AddConsumer<TranslationCompletedEventConsumer>();
+                    cfg.AddConsumer<FileUploadCompletedEventConsumer>();
+                });
         }
 
         #endregion

FictionArchive.Service.NovelService/Services/Consumers/FileUploadCompletedEventConsumer.cs

@@ -0,0 +1,53 @@
+using FictionArchive.Common.Enums;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+using MassTransit;
+
+namespace FictionArchive.Service.NovelService.Services.Consumers;
+
+public class FileUploadCompletedEventConsumer : IConsumer<FileUploadCompletedEvent>
+{
+    private readonly ILogger<FileUploadCompletedEventConsumer> _logger;
+    private readonly NovelServiceDbContext _dbContext;
+    private readonly NovelUpdateService _novelUpdateService;
+
+    public FileUploadCompletedEventConsumer(
+        ILogger<FileUploadCompletedEventConsumer> logger,
+        NovelServiceDbContext dbContext,
+        NovelUpdateService novelUpdateService)
+    {
+        _logger = logger;
+        _dbContext = dbContext;
+        _novelUpdateService = novelUpdateService;
+    }
+
+    public async Task Consume(ConsumeContext<FileUploadCompletedEvent> context)
+    {
+        var @event = context.Message;
+
+        var image = await _dbContext.Images.FindAsync(@event.RequestId);
+        if (image == null)
+        {
+            // Not a request we care about.
+            _logger.LogDebug(
+                "FileUploadCompletedEvent received for unknown image: {RequestId}",
+                @event.RequestId);
+            return;
+        }
+
+        if (@event.Status == RequestStatus.Failed)
+        {
+            _logger.LogError(
+                "Image upload failed for image with id {ImageId}: {ErrorMessage}",
+                image.Id, @event.ErrorMessage);
+            return;
+        }
+
+        if (@event.Status == RequestStatus.Success)
+        {
+            _logger.LogInformation(
+                "Image upload succeeded for image with id {ImageId}",
+                image.Id);
+            await _novelUpdateService.UpdateImage(image.Id, @event.FileAccessUrl!);
+        }
+    }
+}

FictionArchive.Service.NovelService/Services/Consumers/ImportNovelCommandConsumer.cs

@@ -0,0 +1,26 @@
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+using MassTransit;
+
+namespace FictionArchive.Service.NovelService.Services.Consumers;
+
+public class ImportNovelCommandConsumer : IConsumer<ImportNovelCommand>
+{
+    private readonly ILogger<ImportNovelCommandConsumer> _logger;
+    private readonly NovelUpdateService _novelUpdateService;
+
+    public ImportNovelCommandConsumer(
+        ILogger<ImportNovelCommandConsumer> logger,
+        NovelUpdateService novelUpdateService)
+    {
+        _logger = logger;
+        _novelUpdateService = novelUpdateService;
+    }
+
+    public async Task Consume(ConsumeContext<ImportNovelCommand> context)
+    {
+        var command = context.Message;
+        _logger.LogInformation("Processing ImportNovelCommand for URL: {NovelUrl}", command.NovelUrl);
+
+        await _novelUpdateService.ImportNovel(command.NovelUrl);
+    }
+}

FictionArchive.Service.NovelService/Services/Consumers/PullChapterContentCommandConsumer.cs

@@ -0,0 +1,28 @@
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+using MassTransit;
+
+namespace FictionArchive.Service.NovelService.Services.Consumers;
+
+public class PullChapterContentCommandConsumer : IConsumer<PullChapterContentCommand>
+{
+    private readonly ILogger<PullChapterContentCommandConsumer> _logger;
+    private readonly NovelUpdateService _novelUpdateService;
+
+    public PullChapterContentCommandConsumer(
+        ILogger<PullChapterContentCommandConsumer> logger,
+        NovelUpdateService novelUpdateService)
+    {
+        _logger = logger;
+        _novelUpdateService = novelUpdateService;
+    }
+
+    public async Task Consume(ConsumeContext<PullChapterContentCommand> context)
+    {
+        var command = context.Message;
+        _logger.LogInformation(
+            "Processing PullChapterContentCommand for Novel: {NovelId}, Volume: {VolumeId}, Chapter: {ChapterOrder}",
+            command.NovelId, command.VolumeId, command.ChapterOrder);
+
+        await _novelUpdateService.PullChapterContents(command.NovelId, command.VolumeId, command.ChapterOrder);
+    }
+}

FictionArchive.Service.NovelService/Services/Consumers/TranslationCompletedEventConsumer.cs

@@ -0,0 +1,52 @@
+using FictionArchive.Service.NovelService.Models.Localization;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+using MassTransit;
+using Microsoft.EntityFrameworkCore;
+
+namespace FictionArchive.Service.NovelService.Services.Consumers;
+
+public class TranslationCompletedEventConsumer : IConsumer<TranslationCompletedEvent>
+{
+    private readonly ILogger<TranslationCompletedEventConsumer> _logger;
+    private readonly NovelServiceDbContext _dbContext;
+
+    public TranslationCompletedEventConsumer(
+        ILogger<TranslationCompletedEventConsumer> logger,
+        NovelServiceDbContext dbContext)
+    {
+        _logger = logger;
+        _dbContext = dbContext;
+    }
+
+    public async Task Consume(ConsumeContext<TranslationCompletedEvent> context)
+    {
+        var @event = context.Message;
+
+        var localizationRequest = await _dbContext.LocalizationRequests
+            .Include(r => r.KeyRequestedForTranslation)
+            .ThenInclude(lk => lk.Texts)
+            .FirstOrDefaultAsync(lk => lk.Id == @event.TranslationRequestId);
+
+        if (localizationRequest == null)
+        {
+            // Not one of our requests, discard it
+            _logger.LogDebug(
+                "TranslationCompletedEvent received for unknown request: {RequestId}",
+                @event.TranslationRequestId);
+            return;
+        }
+
+        localizationRequest.KeyRequestedForTranslation.Texts.Add(new LocalizationText()
+        {
+            Language = localizationRequest.TranslateTo,
+            Text = @event.TranslatedText,
+            TranslationEngine = localizationRequest.Engine
+        });
+        _dbContext.LocalizationRequests.Remove(localizationRequest);
+        await _dbContext.SaveChangesAsync();
+
+        _logger.LogInformation(
+            "Completed translation for request: {RequestId}",
+            @event.TranslationRequestId);
+    }
+}

FictionArchive.Service.NovelService/Services/EventHandlers/ChapterPullRequestedEventHandler.cs

@@ -1,19 +0,0 @@
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Services.EventHandlers;
-
-public class ChapterPullRequestedEventHandler : IIntegrationEventHandler<ChapterPullRequestedEvent>
-{
-    private readonly NovelUpdateService _novelUpdateService;
-
-    public ChapterPullRequestedEventHandler(NovelUpdateService novelUpdateService)
-    {
-        _novelUpdateService = novelUpdateService;
-    }
-
-    public async Task Handle(ChapterPullRequestedEvent @event)
-    {
-        await _novelUpdateService.PullChapterContents(@event.NovelId, @event.VolumeId, @event.ChapterOrder);
-    }
-}

FictionArchive.Service.NovelService/Services/EventHandlers/FileUploadRequestStatusUpdateEventHandler.cs

@@ -1,39 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Services.EventHandlers;
-
-public class FileUploadRequestStatusUpdateEventHandler : IIntegrationEventHandler<FileUploadRequestStatusUpdateEvent>
-{
-    private readonly ILogger<FileUploadRequestStatusUpdateEventHandler> _logger;
-    private readonly NovelServiceDbContext _context;
-    private readonly NovelUpdateService _novelUpdateService;
-
-    public FileUploadRequestStatusUpdateEventHandler(ILogger<FileUploadRequestStatusUpdateEventHandler> logger, NovelServiceDbContext context, NovelUpdateService novelUpdateService)
-    {
-        _logger = logger;
-        _context = context;
-        _novelUpdateService = novelUpdateService;
-    }
-
-    public async Task Handle(FileUploadRequestStatusUpdateEvent @event)
-    {
-        var image = await _context.Images.FindAsync(@event.RequestId);
-        if (image == null)
-        {
-            // Not a request we care about.
-            return;
-        }
-        if (@event.Status == RequestStatus.Failed)
-        {
-            _logger.LogError("Image upload failed for image with id {imageId}", image.Id);
-            return;
-        }
-        else if (@event.Status == RequestStatus.Success)
-        {
-            _logger.LogInformation("Image upload succeeded for image with id {imageId}", image.Id);
-            await _novelUpdateService.UpdateImage(image.Id, @event.FileAccessUrl);
-        }
-    }
-}

FictionArchive.Service.NovelService/Services/EventHandlers/NovelUpdateRequestedEventHandler.cs

@@ -1,23 +0,0 @@
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.NovelService.Services.EventHandlers;
-
-public class NovelUpdateRequestedEventHandler : IIntegrationEventHandler<NovelUpdateRequestedEvent>
-{
-    private readonly ILogger<NovelUpdateRequestedEventHandler> _logger;
-    private readonly IEventBus _eventBus;
-    private readonly NovelUpdateService _novelUpdateService;
-
-    public NovelUpdateRequestedEventHandler(ILogger<NovelUpdateRequestedEventHandler> logger, IEventBus eventBus, NovelUpdateService novelUpdateService)
-    {
-        _logger = logger;
-        _eventBus = eventBus;
-        _novelUpdateService = novelUpdateService;
-    }
-
-    public async Task Handle(NovelUpdateRequestedEvent @event)
-    {
-        await _novelUpdateService.ImportNovel(@event.NovelUrl);
-    }
-}

FictionArchive.Service.NovelService/Services/EventHandlers/TranslationRequestCompletedEventHandler.cs

@@ -1,39 +0,0 @@
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
-using FictionArchive.Service.NovelService.Models.Localization;
-using FictionArchive.Service.Shared.Services.EventBus;
-using Microsoft.EntityFrameworkCore;
-
-namespace FictionArchive.Service.NovelService.Services.EventHandlers;
-
-public class TranslationRequestCompletedEventHandler : IIntegrationEventHandler<TranslationRequestCompletedEvent>
-{
-    private readonly ILogger<TranslationRequestCompletedEventHandler> _logger;
-    private readonly NovelServiceDbContext _dbContext;
-
-    public TranslationRequestCompletedEventHandler(ILogger<TranslationRequestCompletedEventHandler> logger, NovelServiceDbContext dbContext)
-    {
-        _logger = logger;
-        _dbContext = dbContext;
-    }
-
-    public async Task Handle(TranslationRequestCompletedEvent @event)
-    {
-        var localizationRequest = await _dbContext.LocalizationRequests.Include(r => r.KeyRequestedForTranslation)
-            .ThenInclude(lk => lk.Texts)
-            .FirstOrDefaultAsync(lk => lk.Id == @event.TranslationRequestId);
-        if (localizationRequest == null)
-        {
-            // Not one of our requests, discard it
-            return;
-        }
-        
-        localizationRequest.KeyRequestedForTranslation.Texts.Add(new LocalizationText()
-        {
-            Language = localizationRequest.TranslateTo,
-            Text = @event.TranslatedText,
-            TranslationEngine = localizationRequest.Engine
-        });
-        _dbContext.LocalizationRequests.Remove(localizationRequest);
-        await _dbContext.SaveChangesAsync();
-    }
-}

FictionArchive.Service.NovelService/Services/NovelUpdateService.cs

@@ -1,15 +1,15 @@
 using FictionArchive.Common.Enums;
-using FictionArchive.Service.FileService.IntegrationEvents;
 using FictionArchive.Service.NovelService.Models.Configuration;
 using FictionArchive.Service.NovelService.Models.Enums;
 using FictionArchive.Service.NovelService.Models.Images;
-using FictionArchive.Service.NovelService.Models.IntegrationEvents;
 using FictionArchive.Service.NovelService.Models.Localization;
 using FictionArchive.Service.NovelService.Models.Novels;
 using FictionArchive.Service.NovelService.Models.SourceAdapters;
 using FictionArchive.Service.NovelService.Services.SourceAdapters;
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 using HtmlAgilityPack;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Options;
 
@@ -20,15 +20,23 @@ public class NovelUpdateService
     private readonly NovelServiceDbContext _dbContext;
     private readonly ILogger<NovelUpdateService> _logger;
     private readonly IEnumerable<ISourceAdapter> _sourceAdapters;
-    private readonly IEventBus _eventBus;
+    private readonly IPublishEndpoint _publishEndpoint;
+    private readonly ISendEndpointProvider _sendEndpointProvider;
     private readonly NovelUpdateServiceConfiguration _novelUpdateServiceConfiguration;
 
-    public NovelUpdateService(NovelServiceDbContext dbContext, ILogger<NovelUpdateService> logger, IEnumerable<ISourceAdapter> sourceAdapters, IEventBus eventBus, IOptions<NovelUpdateServiceConfiguration> novelUpdateServiceConfiguration)
+    public NovelUpdateService(
+        NovelServiceDbContext dbContext,
+        ILogger<NovelUpdateService> logger,
+        IEnumerable<ISourceAdapter> sourceAdapters,
+        IPublishEndpoint publishEndpoint,
+        ISendEndpointProvider sendEndpointProvider,
+        IOptions<NovelUpdateServiceConfiguration> novelUpdateServiceConfiguration)
     {
         _dbContext = dbContext;
         _logger = logger;
         _sourceAdapters = sourceAdapters;
-        _eventBus = eventBus;
+        _publishEndpoint = publishEndpoint;
+        _sendEndpointProvider = sendEndpointProvider;
         _novelUpdateServiceConfiguration = novelUpdateServiceConfiguration.Value;
     }
 
@@ -393,7 +401,7 @@ public class NovelUpdateService
         // Publish novel created event for new novels
         if (existingNovel == null)
         {
-            await _eventBus.Publish(new NovelCreatedEvent
+            await _publishEndpoint.Publish(new NovelCreatedEvent
             {
                 NovelId = novel.Id,
                 Title = novel.Name.Texts.First(t => t.Language == novel.RawLanguage).Text,
@@ -408,7 +416,7 @@ public class NovelUpdateService
         {
             foreach (var chapter in volume.Chapters.Where(c => !existingChapterIds.Contains(c.Id)))
             {
-                await _eventBus.Publish(new ChapterCreatedEvent
+                await _publishEndpoint.Publish(new ChapterCreatedEvent
                 {
                     ChapterId = chapter.Id,
                     NovelId = novel.Id,
@@ -420,10 +428,11 @@ public class NovelUpdateService
             }
         }
 
-        // Publish cover image event if needed
+        // Send cover image upload command if needed
         if (shouldPublishCoverEvent && novel.CoverImage != null && metadata.CoverImage != null)
         {
-            await _eventBus.Publish(new FileUploadRequestCreatedEvent
+            var uploadEndpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri("queue:upload-file-command"));
+            await uploadEndpoint.Send(new UploadFileCommand
             {
                 RequestId = novel.CoverImage.Id,
                 FileData = metadata.CoverImage.Data,
@@ -431,7 +440,8 @@ public class NovelUpdateService
             });
         }
 
-        // Publish chapter pull events for chapters without body content
+        // Send chapter pull commands for chapters without body content
+        var pullChapterEndpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri("queue:pull-chapter-content-command"));
         foreach (var volume in novel.Volumes)
         {
             var chaptersNeedingPull = volume.Chapters
@@ -440,7 +450,7 @@ public class NovelUpdateService
 
             foreach (var chapter in chaptersNeedingPull)
             {
-                await _eventBus.Publish(new ChapterPullRequestedEvent
+                await pullChapterEndpoint.Send(new PullChapterContentCommand
                 {
                     NovelId = novel.Id,
                     VolumeId = volume.Id,
@@ -513,12 +523,13 @@ public class NovelUpdateService
         localizationText.Text = chapterDoc.DocumentNode.OuterHtml;
         await _dbContext.SaveChangesAsync();
         
-        // Body was updated, raise image request
+        // Body was updated, send upload commands for images
+        var uploadEndpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri("queue:upload-file-command"));
         int imgCount = 0;
         foreach (var image in chapter.Images)
         {
             var data = rawChapter.ImageData.FirstOrDefault(img => img.Url == image.OriginalPath);
-            await _eventBus.Publish(new FileUploadRequestCreatedEvent()
+            await uploadEndpoint.Send(new UploadFileCommand
             {
                 FileData = data.Data,
                 FilePath = $"{novel.Id}/Images/Chapter-{chapter.Id}/{imgCount++}.jpg",
@@ -557,26 +568,28 @@ public class NovelUpdateService
         await _dbContext.SaveChangesAsync();
     }
 
-    public async Task<NovelUpdateRequestedEvent> QueueNovelImport(string novelUrl)
+    public async Task<ImportNovelCommand> QueueNovelImport(string novelUrl)
     {
-        var importNovelRequestEvent = new NovelUpdateRequestedEvent()
+        var command = new ImportNovelCommand
         {
             NovelUrl = novelUrl
         };
-        await _eventBus.Publish(importNovelRequestEvent);
-        return importNovelRequestEvent;
+        var endpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri("queue:import-novel-command"));
+        await endpoint.Send(command);
+        return command;
     }
 
-    public async Task<ChapterPullRequestedEvent> QueueChapterPull(uint novelId, uint volumeId, uint chapterOrder)
+    public async Task<PullChapterContentCommand> QueueChapterPull(uint novelId, uint volumeId, uint chapterOrder)
     {
-        var chapterPullEvent = new ChapterPullRequestedEvent()
+        var command = new PullChapterContentCommand
         {
             NovelId = novelId,
             VolumeId = volumeId,
             ChapterOrder = chapterOrder
         };
-        await _eventBus.Publish(chapterPullEvent);
-        return chapterPullEvent;
+        var endpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri("queue:pull-chapter-content-command"));
+        await endpoint.Send(command);
+        return command;
     }
 
     public async Task DeleteNovel(uint novelId)

FictionArchive.Service.NovelService/appsettings.json

@@ -16,8 +16,10 @@
     "DefaultConnection": "Host=localhost;Database=FictionArchive_NovelService;Username=postgres;password=postgres"
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "NovelService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "AllowedHosts": "*",
   "OIDC": {

FictionArchive.Service.ReportingService/Dockerfile

@@ -0,0 +1,23 @@
+FROM mcr.microsoft.com/dotnet/aspnet:8.0 AS base
+USER $APP_UID
+WORKDIR /app
+EXPOSE 8080
+EXPOSE 8081
+
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["FictionArchive.Service.ReportingService/FictionArchive.Service.ReportingService.csproj", "FictionArchive.Service.ReportingService/"]
+RUN dotnet restore "FictionArchive.Service.ReportingService/FictionArchive.Service.ReportingService.csproj"
+COPY . .
+WORKDIR "/src/FictionArchive.Service.ReportingService"
+RUN dotnet build "./FictionArchive.Service.ReportingService.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./FictionArchive.Service.ReportingService.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "FictionArchive.Service.ReportingService.dll"]

FictionArchive.Service.ReportingService/FictionArchive.Service.ReportingService.csproj

@@ -0,0 +1,20 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+    <PropertyGroup>
+        <TargetFramework>net8.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.11">
+          <PrivateAssets>all</PrivateAssets>
+          <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+        </PackageReference>
+    </ItemGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\FictionArchive.Service.Shared\FictionArchive.Service.Shared.csproj" />
+    </ItemGroup>
+
+</Project>

FictionArchive.Service.ReportingService/GraphQL/Mutation.cs

@@ -0,0 +1,15 @@
+using HotChocolate;
+using HotChocolate.Authorization;
+
+namespace FictionArchive.Service.ReportingService.GraphQL;
+
+public class Mutation
+{
+    /// <summary>
+    /// Placeholder mutation for GraphQL schema requirements.
+    /// The ReportingService is primarily read-only, consuming events from other services.
+    /// </summary>
+    [Authorize(Roles = ["admin"])]
+    [GraphQLDescription("Placeholder mutation. ReportingService is primarily read-only.")]
+    public bool Ping() => true;
+}

FictionArchive.Service.ReportingService/GraphQL/Query.cs

@@ -0,0 +1,52 @@
+using System.Text.Json;
+using FictionArchive.Service.ReportingService.Models.Database;
+using FictionArchive.Service.ReportingService.Models.DTOs;
+using FictionArchive.Service.ReportingService.Services;
+using HotChocolate;
+using HotChocolate.Data;
+using Microsoft.EntityFrameworkCore;
+
+namespace FictionArchive.Service.ReportingService.GraphQL;
+
+public class Query
+{
+    [UseProjection]
+    [UseFiltering]
+    [UseSorting]
+    [GraphQLName("reportingJobs")]
+    public IQueryable<Job> GetReportingJobs(ReportingServiceDbContext dbContext)
+        => dbContext.Jobs.Include(j => j.History);
+
+    [GraphQLName("reportingJob")]
+    public async Task<JobDto?> GetReportingJob(Guid id, ReportingServiceDbContext dbContext)
+    {
+        var job = await dbContext.Jobs
+            .Include(j => j.History.OrderBy(h => h.Timestamp))
+            .FirstOrDefaultAsync(j => j.Id == id);
+
+        if (job == null) return null;
+
+        return new JobDto
+        {
+            Id = job.Id,
+            JobType = job.JobType,
+            Status = job.Status,
+            CurrentStep = job.CurrentStep,
+            ErrorMessage = job.ErrorMessage,
+            Metadata = job.Metadata != null
+                ? JsonSerializer.Deserialize<Dictionary<string, object>>(job.Metadata.RootElement.GetRawText())
+                : null,
+            History = job.History.Select(h => new JobHistoryEntryDto
+            {
+                FromState = h.FromState,
+                ToState = h.ToState,
+                Message = h.Message,
+                Error = h.Error,
+                Timestamp = h.Timestamp
+            }).ToList(),
+            CreatedTime = job.CreatedTime,
+            UpdatedTime = job.UpdatedTime,
+            CompletedTime = job.CompletedTime
+        };
+    }
+}

FictionArchive.Service.ReportingService/Models/DTOs/JobDto.cs

@@ -0,0 +1,17 @@
+using NodaTime;
+
+namespace FictionArchive.Service.ReportingService.Models.DTOs;
+
+public class JobDto
+{
+    public Guid Id { get; set; }
+    public required string JobType { get; set; }
+    public required string Status { get; set; }
+    public string? CurrentStep { get; set; }
+    public string? ErrorMessage { get; set; }
+    public Dictionary<string, object>? Metadata { get; set; }
+    public List<JobHistoryEntryDto> History { get; set; } = new();
+    public Instant CreatedTime { get; set; }
+    public Instant UpdatedTime { get; set; }
+    public Instant? CompletedTime { get; set; }
+}

FictionArchive.Service.ReportingService/Models/DTOs/JobHistoryEntryDto.cs

@@ -0,0 +1,12 @@
+using NodaTime;
+
+namespace FictionArchive.Service.ReportingService.Models.DTOs;
+
+public class JobHistoryEntryDto
+{
+    public required string FromState { get; set; }
+    public required string ToState { get; set; }
+    public string? Message { get; set; }
+    public string? Error { get; set; }
+    public Instant Timestamp { get; set; }
+}

FictionArchive.Service.ReportingService/Models/Database/Job.cs

@@ -0,0 +1,19 @@
+using System.Text.Json;
+using NodaTime;
+
+namespace FictionArchive.Service.ReportingService.Models.Database;
+
+public class Job
+{
+    public Guid Id { get; set; }
+    public required string JobType { get; set; }
+    public required string Status { get; set; }
+    public string? CurrentStep { get; set; }
+    public string? ErrorMessage { get; set; }
+    public JsonDocument? Metadata { get; set; }
+    public Instant CreatedTime { get; set; }
+    public Instant UpdatedTime { get; set; }
+    public Instant? CompletedTime { get; set; }
+
+    public ICollection<JobHistoryEntry> History { get; set; } = new List<JobHistoryEntry>();
+}

FictionArchive.Service.ReportingService/Models/Database/JobHistoryEntry.cs

@@ -0,0 +1,16 @@
+using NodaTime;
+
+namespace FictionArchive.Service.ReportingService.Models.Database;
+
+public class JobHistoryEntry
+{
+    public int Id { get; set; }
+    public Guid JobId { get; set; }
+    public required string FromState { get; set; }
+    public required string ToState { get; set; }
+    public string? Message { get; set; }
+    public string? Error { get; set; }
+    public Instant Timestamp { get; set; }
+
+    public Job Job { get; set; } = null!;
+}

FictionArchive.Service.ReportingService/Program.cs

@@ -0,0 +1,76 @@
+using FictionArchive.Common.Extensions;
+using FictionArchive.Service.ReportingService.GraphQL;
+using FictionArchive.Service.ReportingService.Services;
+using FictionArchive.Service.ReportingService.Services.Consumers;
+using FictionArchive.Service.Shared;
+using FictionArchive.Service.Shared.Extensions;
+using FictionArchive.Service.Shared.MassTransit;
+
+namespace FictionArchive.Service.ReportingService;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        var builder = WebApplication.CreateBuilder(args);
+
+        var isSchemaExport = SchemaExportDetector.IsSchemaExportMode(args);
+
+        builder.AddLocalAppsettings();
+
+        builder.Services.AddHealthChecks();
+
+        #region Database
+
+        builder.Services.RegisterDbContext<ReportingServiceDbContext>(
+            builder.Configuration.GetConnectionString("DefaultConnection")!,
+            skipInfrastructure: isSchemaExport);
+
+        #endregion
+
+        #region MassTransit
+
+        if (!isSchemaExport)
+        {
+            builder.Services.AddFictionArchiveMassTransit<ReportingServiceDbContext>(
+                builder.Configuration,
+                x =>
+                {
+                    x.AddConsumer<JobStateChangedEventConsumer>();
+                });
+        }
+
+        #endregion
+
+        #region GraphQL
+
+        builder.Services.AddDefaultGraphQl<Query, Mutation>()
+            .AddAuthorization();
+
+        #endregion
+
+        // Authentication & Authorization
+        builder.Services.AddOidcAuthentication(builder.Configuration);
+        builder.Services.AddFictionArchiveAuthorization();
+
+        var app = builder.Build();
+
+        if (!isSchemaExport)
+        {
+            using var scope = app.Services.CreateScope();
+            var dbContext = scope.ServiceProvider.GetRequiredService<ReportingServiceDbContext>();
+            dbContext.UpdateDatabase();
+        }
+
+        app.UseHttpsRedirection();
+
+        app.MapHealthChecks("/healthz");
+
+        app.UseAuthentication();
+        app.UseAuthorization();
+
+        app.MapGraphQL();
+
+        app.RunWithGraphQLCommands(args);
+    }
+}

FictionArchive.Service.ReportingService/Properties/launchSettings.json

@@ -0,0 +1,39 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:45320",
+      "sslPort": 44320
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:5180",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "graphql",
+      "applicationUrl": "https://localhost:7320;http://localhost:5180",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

FictionArchive.Service.ReportingService/Services/Consumers/JobStateChangedEventConsumer.cs

@@ -0,0 +1,74 @@
+using System.Text.Json;
+using FictionArchive.Service.ReportingService.Models.Database;
+using FictionArchive.Service.Shared.MassTransit.Contracts;
+using MassTransit;
+
+namespace FictionArchive.Service.ReportingService.Services.Consumers;
+
+public class JobStateChangedEventConsumer : IConsumer<JobStateChangedEvent>
+{
+    private readonly ReportingServiceDbContext _dbContext;
+    private readonly ILogger<JobStateChangedEventConsumer> _logger;
+
+    public JobStateChangedEventConsumer(
+        ReportingServiceDbContext dbContext,
+        ILogger<JobStateChangedEventConsumer> logger)
+    {
+        _dbContext = dbContext;
+        _logger = logger;
+    }
+
+    public async Task Consume(ConsumeContext<JobStateChangedEvent> context)
+    {
+        var @event = context.Message;
+
+        var job = await _dbContext.Jobs.FindAsync(@event.JobId);
+
+        if (job == null)
+        {
+            job = new Job
+            {
+                Id = @event.JobId,
+                JobType = @event.JobType,
+                Status = @event.ToState,
+                CreatedTime = @event.Timestamp,
+                UpdatedTime = @event.Timestamp,
+                Metadata = @event.Metadata != null
+                    ? JsonSerializer.SerializeToDocument(@event.Metadata)
+                    : null
+            };
+            _dbContext.Jobs.Add(job);
+        }
+        else
+        {
+            job.Status = @event.ToState;
+            job.UpdatedTime = @event.Timestamp;
+
+            if (@event.Error != null)
+            {
+                job.ErrorMessage = @event.Error;
+            }
+
+            if (@event.ToState is "Completed" or "Failed")
+            {
+                job.CompletedTime = @event.Timestamp;
+            }
+        }
+
+        var historyEntry = new JobHistoryEntry
+        {
+            JobId = @event.JobId,
+            FromState = @event.FromState,
+            ToState = @event.ToState,
+            Message = @event.Message,
+            Error = @event.Error,
+            Timestamp = @event.Timestamp
+        };
+        _dbContext.JobHistoryEntries.Add(historyEntry);
+
+        await _dbContext.SaveChangesAsync();
+
+        _logger.LogDebug("Recorded job state change: {JobId} {FromState} -> {ToState}",
+            @event.JobId, @event.FromState, @event.ToState);
+    }
+}

FictionArchive.Service.ReportingService/Services/ReportingServiceDbContext.cs

@@ -0,0 +1,36 @@
+using FictionArchive.Service.ReportingService.Models.Database;
+using FictionArchive.Service.Shared.Services.Database;
+using Microsoft.EntityFrameworkCore;
+
+namespace FictionArchive.Service.ReportingService.Services;
+
+public class ReportingServiceDbContext : FictionArchiveDbContext
+{
+    public ReportingServiceDbContext(DbContextOptions options, ILogger<ReportingServiceDbContext> logger)
+        : base(options, logger) { }
+
+    public DbSet<Job> Jobs => Set<Job>();
+    public DbSet<JobHistoryEntry> JobHistoryEntries => Set<JobHistoryEntry>();
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        base.OnModelCreating(modelBuilder);
+
+        modelBuilder.Entity<Job>(entity =>
+        {
+            entity.HasKey(e => e.Id);
+            entity.HasIndex(e => e.JobType);
+            entity.HasIndex(e => e.Status);
+            entity.HasIndex(e => e.CreatedTime);
+        });
+
+        modelBuilder.Entity<JobHistoryEntry>(entity =>
+        {
+            entity.HasKey(e => e.Id);
+            entity.HasOne(e => e.Job)
+                .WithMany(j => j.History)
+                .HasForeignKey(e => e.JobId)
+                .OnDelete(DeleteBehavior.Cascade);
+        });
+    }
+}

FictionArchive.Service.ReportingService/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

FictionArchive.Service.ReportingService/appsettings.json

@@ -0,0 +1,28 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "ConnectionStrings": {
+    "DefaultConnection": "Host=localhost;Database=FictionArchive_ReportingService;Username=postgres;password=postgres"
+  },
+  "RabbitMQ": {
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
+  },
+  "OIDC": {
+    "Authority": "https://auth.orfl.xyz/application/o/fiction-archive/",
+    "ClientId": "ldi5IpEidq2WW0Ka1lehVskb2SOBjnYRaZCpEyBh",
+    "Audience": "ldi5IpEidq2WW0Ka1lehVskb2SOBjnYRaZCpEyBh",
+    "ValidIssuer": "https://auth.orfl.xyz/application/o/fiction-archive/",
+    "ValidateIssuer": true,
+    "ValidateAudience": true,
+    "ValidateLifetime": true,
+    "ValidateIssuerSigningKey": true
+  },
+  "AllowedHosts": "*"
+}

FictionArchive.Service.ReportingService/subgraph-config.json

@@ -0,0 +1,6 @@
+{
+  "subgraph": "Reporting",
+  "http": {
+    "baseAddress": "http://localhost:5180/graphql"
+  }
+}

FictionArchive.Service.SchedulerService/FictionArchive.Service.SchedulerService.csproj

@@ -19,6 +19,7 @@
 
     <ItemGroup>
       <PackageReference Include="AppAny.Quartz.EntityFrameworkCore.Migrations.PostgreSQL" Version="0.5.1" />
+      <PackageReference Include="MassTransit" Version="8.4.0" />
       <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.11">
         <PrivateAssets>all</PrivateAssets>
         <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

FictionArchive.Service.SchedulerService/Models/JobTemplates/EventJobTemplate.cs

@@ -1,4 +1,4 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+using MassTransit;
 using Newtonsoft.Json;
 using Quartz;
 
@@ -6,30 +6,70 @@ namespace FictionArchive.Service.SchedulerService.Models.JobTemplates;
 
 public class EventJobTemplate : IJob
 {
-    private readonly IEventBus _eventBus;
+    private readonly IPublishEndpoint _publishEndpoint;
+    private readonly ISendEndpointProvider _sendEndpointProvider;
     private readonly ILogger<EventJobTemplate> _logger;
 
-    public const string EventTypeParameter = "RoutingKey";
+    public const string EventTypeParameter = "MessageType";
     public const string EventDataParameter = "MessageData";
-    
-    public EventJobTemplate(IEventBus eventBus, ILogger<EventJobTemplate> logger)
+    public const string IsCommandParameter = "IsCommand";
+    public const string DestinationQueueParameter = "DestinationQueue";
+
+    public EventJobTemplate(
+        IPublishEndpoint publishEndpoint,
+        ISendEndpointProvider sendEndpointProvider,
+        ILogger<EventJobTemplate> logger)
     {
-        _eventBus = eventBus;
+        _publishEndpoint = publishEndpoint;
+        _sendEndpointProvider = sendEndpointProvider;
         _logger = logger;
     }
-    
+
     public async Task Execute(IJobExecutionContext context)
     {
         try
         {
-            var eventData = context.MergedJobDataMap.GetString(EventDataParameter);
-            var eventType = context.MergedJobDataMap.GetString(EventTypeParameter);
-            var eventObject = JsonConvert.DeserializeObject(eventData);
-            await _eventBus.Publish(eventObject, eventType);
+            var messageData = context.MergedJobDataMap.GetString(EventDataParameter);
+            var messageTypeName = context.MergedJobDataMap.GetString(EventTypeParameter);
+            var isCommand = context.MergedJobDataMap.GetBoolean(IsCommandParameter);
+
+            var messageType = Type.GetType(messageTypeName!);
+            if (messageType == null)
+            {
+                _logger.LogError("Could not resolve message type: {MessageType}", messageTypeName);
+                return;
+            }
+
+            var message = JsonConvert.DeserializeObject(messageData!, messageType);
+            if (message == null)
+            {
+                _logger.LogError("Could not deserialize message data for type: {MessageType}", messageTypeName);
+                return;
+            }
+
+            if (isCommand)
+            {
+                var destinationQueue = context.MergedJobDataMap.GetString(DestinationQueueParameter);
+                if (string.IsNullOrEmpty(destinationQueue))
+                {
+                    _logger.LogError("Destination queue not specified for command message");
+                    return;
+                }
+
+                var endpoint = await _sendEndpointProvider.GetSendEndpoint(new Uri($"queue:{destinationQueue}"));
+                await endpoint.Send(message, messageType);
+                _logger.LogInformation("Sent command {MessageType} to queue {Queue}", messageTypeName, destinationQueue);
+            }
+            else
+            {
+                await _publishEndpoint.Publish(message, messageType);
+                _logger.LogInformation("Published event {MessageType}", messageTypeName);
+            }
         }
         catch (Exception ex)
         {
             _logger.LogError(ex, "An error occurred while running an event job.");
+            throw; // Re-throw to let Quartz handle retries
         }
     }
-}
+}

FictionArchive.Service.SchedulerService/Program.cs

@@ -2,7 +2,7 @@ using FictionArchive.Service.SchedulerService.GraphQL;
 using FictionArchive.Service.SchedulerService.Services;
 using FictionArchive.Service.Shared;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using Quartz;
 using Quartz.Impl.AdoJobStore;
 
@@ -34,14 +34,11 @@ public class Program
         
         #endregion
         
-        #region Event Bus
+        #region MassTransit
 
         if (!isSchemaExport)
         {
-            builder.Services.AddRabbitMQ(opt =>
-            {
-                builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-            });
+            builder.Services.AddFictionArchiveMassTransit(builder.Configuration);
         }
 
         #endregion

FictionArchive.Service.SchedulerService/Services/JobManagerService.cs

@@ -1,7 +1,6 @@
 using System.Data;
 using FictionArchive.Service.SchedulerService.Models;
 using FictionArchive.Service.SchedulerService.Models.JobTemplates;
-using FictionArchive.Service.Shared.Services.EventBus;
 using Quartz;
 using Quartz.Impl.Matchers;
 

FictionArchive.Service.SchedulerService/appsettings.json

@@ -6,8 +6,10 @@
     }
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "SchedulerService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "ConnectionStrings": {
     "DefaultConnection": "Host=localhost;Database=FictionArchive_SchedulerService;Username=postgres;password=postgres"

FictionArchive.Service.Shared/FictionArchive.Service.Shared.csproj

@@ -31,7 +31,9 @@
         <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
         <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL.NodaTime" Version="9.0.4" />
         <PackageReference Include="Polly" Version="8.6.5" />
-        <PackageReference Include="RabbitMQ.Client" Version="7.2.0" />
+        <PackageReference Include="MassTransit" Version="8.4.0" />
+        <PackageReference Include="MassTransit.RabbitMQ" Version="8.4.0" />
+        <PackageReference Include="MassTransit.EntityFrameworkCore" Version="8.4.0" />
         <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.11" />
     </ItemGroup>
     

FictionArchive.Service.Shared/MassTransit/Configuration/MassTransitOptions.cs

@@ -0,0 +1,9 @@
+namespace FictionArchive.Service.Shared.MassTransit.Configuration;
+
+public class MassTransitOptions
+{
+    public string Host { get; set; } = "localhost";
+    public string VirtualHost { get; set; } = "/";
+    public string Username { get; set; } = "guest";
+    public string Password { get; set; } = "guest";
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Commands/ImportNovelCommand.cs

@@ -0,0 +1,6 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+
+public record ImportNovelCommand : ICommand
+{
+    public required string NovelUrl { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Commands/PullChapterContentCommand.cs

@@ -0,0 +1,8 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+
+public record PullChapterContentCommand : ICommand
+{
+    public required uint NovelId { get; init; }
+    public required uint VolumeId { get; init; }
+    public required uint ChapterOrder { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Commands/TranslateTextCommand.cs

@@ -0,0 +1,12 @@
+using FictionArchive.Common.Enums;
+
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+
+public record TranslateTextCommand : ICommand
+{
+    public Guid TranslationRequestId { get; init; }
+    public Language From { get; init; }
+    public Language To { get; init; }
+    public required string Body { get; init; }
+    public required string TranslationEngineKey { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Commands/UploadFileCommand.cs

@@ -0,0 +1,8 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+
+public record UploadFileCommand : ICommand
+{
+    public Guid RequestId { get; init; }
+    public required string FilePath { get; init; }
+    public required byte[] FileData { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Events/AuthUserAddedEvent.cs

@@ -0,0 +1,9 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+
+public record AuthUserAddedEvent : IEvent
+{
+    public required string OAuthProviderId { get; init; }
+    public required string InviterOAuthProviderId { get; init; }
+    public required string EventUserEmail { get; init; }
+    public required string EventUserUsername { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Events/ChapterCreatedEvent.cs

@@ -1,8 +1,6 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
-
-public class ChapterCreatedEvent : IIntegrationEvent
+public record ChapterCreatedEvent : IEvent
 {
     public required uint ChapterId { get; init; }
     public required uint NovelId { get; init; }

FictionArchive.Service.Shared/MassTransit/Contracts/Events/FileUploadCompletedEvent.cs

@@ -0,0 +1,11 @@
+using FictionArchive.Common.Enums;
+
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+
+public record FileUploadCompletedEvent : IEvent
+{
+    public Guid RequestId { get; init; }
+    public RequestStatus Status { get; init; }
+    public string? FileAccessUrl { get; init; }
+    public string? ErrorMessage { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Events/NovelCreatedEvent.cs

@@ -1,9 +1,8 @@
 using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
 
-namespace FictionArchive.Service.NovelService.Models.IntegrationEvents;
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 
-public class NovelCreatedEvent : IIntegrationEvent
+public record NovelCreatedEvent : IEvent
 {
     public required uint NovelId { get; init; }
     public required string Title { get; init; }

FictionArchive.Service.Shared/MassTransit/Contracts/Events/TranslationCompletedEvent.cs

@@ -0,0 +1,7 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+
+public record TranslationCompletedEvent : IEvent
+{
+    public Guid TranslationRequestId { get; init; }
+    public required string TranslatedText { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/Events/UserInvitedEvent.cs

@@ -0,0 +1,13 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+
+public record UserInvitedEvent : IEvent
+{
+    public Guid InvitedUserId { get; init; }
+    public required string InvitedUsername { get; init; }
+    public required string InvitedEmail { get; init; }
+    public required string InvitedOAuthProviderId { get; init; }
+
+    public Guid InviterId { get; init; }
+    public required string InviterUsername { get; init; }
+    public required string InviterOAuthProviderId { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/Contracts/ICommand.cs

@@ -0,0 +1,6 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts;
+
+/// <summary>
+/// Marker interface for commands (do something, single consumer)
+/// </summary>
+public interface ICommand { }

FictionArchive.Service.Shared/MassTransit/Contracts/IEvent.cs

@@ -0,0 +1,6 @@
+namespace FictionArchive.Service.Shared.MassTransit.Contracts;
+
+/// <summary>
+/// Marker interface for events (something happened, multiple subscribers)
+/// </summary>
+public interface IEvent { }

FictionArchive.Service.Shared/MassTransit/Contracts/JobStateChangedEvent.cs

@@ -0,0 +1,18 @@
+using NodaTime;
+
+namespace FictionArchive.Service.Shared.MassTransit.Contracts;
+
+/// <summary>
+/// Published by sagas on state transitions for centralized job tracking
+/// </summary>
+public record JobStateChangedEvent : IEvent
+{
+    public Guid JobId { get; init; }
+    public required string JobType { get; init; }
+    public required string FromState { get; init; }
+    public required string ToState { get; init; }
+    public string? Message { get; init; }
+    public string? Error { get; init; }
+    public Instant Timestamp { get; init; }
+    public Dictionary<string, object>? Metadata { get; init; }
+}

FictionArchive.Service.Shared/MassTransit/MassTransitExtensions.cs

@@ -0,0 +1,103 @@
+using FictionArchive.Service.Shared.MassTransit.Configuration;
+using MassTransit;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace FictionArchive.Service.Shared.MassTransit;
+
+public static class MassTransitExtensions
+{
+    /// <summary>
+    /// Adds MassTransit with RabbitMQ and Entity Framework outbox
+    /// </summary>
+    public static IServiceCollection AddFictionArchiveMassTransit<TDbContext>(
+        this IServiceCollection services,
+        IConfiguration configuration,
+        Action<IBusRegistrationConfigurator>? configureConsumers = null)
+        where TDbContext : DbContext
+    {
+        services.AddMassTransit(x =>
+        {
+            configureConsumers?.Invoke(x);
+
+            x.AddEntityFrameworkOutbox<TDbContext>(o =>
+            {
+                o.UsePostgres();
+                o.UseBusOutbox();
+            });
+
+            x.UsingRabbitMq((context, cfg) =>
+            {
+                var options = configuration.GetSection("RabbitMQ").Get<MassTransitOptions>()
+                    ?? new MassTransitOptions();
+
+                cfg.Host(options.Host, options.VirtualHost, h =>
+                {
+                    h.Username(options.Username);
+                    h.Password(options.Password);
+                });
+
+                // Immediate retries for transient failures
+                cfg.UseMessageRetry(r => r.Intervals(
+                    TimeSpan.FromSeconds(1),
+                    TimeSpan.FromSeconds(1),
+                    TimeSpan.FromSeconds(1)));
+
+                // Delayed redelivery for longer outages
+                cfg.UseDelayedRedelivery(r => r.Intervals(
+                    TimeSpan.FromSeconds(5),
+                    TimeSpan.FromSeconds(30),
+                    TimeSpan.FromMinutes(2),
+                    TimeSpan.FromMinutes(10),
+                    TimeSpan.FromMinutes(30)));
+
+                cfg.ConfigureEndpoints(context);
+            });
+        });
+
+        return services;
+    }
+
+    /// <summary>
+    /// Adds MassTransit with RabbitMQ without outbox (for services without EF)
+    /// </summary>
+    public static IServiceCollection AddFictionArchiveMassTransit(
+        this IServiceCollection services,
+        IConfiguration configuration,
+        Action<IBusRegistrationConfigurator>? configureConsumers = null)
+    {
+        services.AddMassTransit(x =>
+        {
+            configureConsumers?.Invoke(x);
+
+            x.UsingRabbitMq((context, cfg) =>
+            {
+                var options = configuration.GetSection("RabbitMQ").Get<MassTransitOptions>()
+                    ?? new MassTransitOptions();
+
+                cfg.Host(options.Host, options.VirtualHost, h =>
+                {
+                    h.Username(options.Username);
+                    h.Password(options.Password);
+                });
+
+                cfg.UseMessageRetry(r => r.Intervals(
+                    TimeSpan.FromSeconds(1),
+                    TimeSpan.FromSeconds(1),
+                    TimeSpan.FromSeconds(1)));
+
+                cfg.UseDelayedRedelivery(r => r.Intervals(
+                    TimeSpan.FromSeconds(5),
+                    TimeSpan.FromSeconds(30),
+                    TimeSpan.FromMinutes(2),
+                    TimeSpan.FromMinutes(10),
+                    TimeSpan.FromMinutes(30)));
+
+                cfg.ConfigureEndpoints(context);
+            });
+        });
+
+        return services;
+    }
+}

FictionArchive.Service.Shared/Services/EventBus/EventBusBuilder.cs

@@ -1,25 +0,0 @@
-using Microsoft.Extensions.DependencyInjection;
-
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public class EventBusBuilder<TEventBus> where TEventBus : class, IEventBus
-{
-    private readonly IServiceCollection _services;
-    private readonly SubscriptionManager _subscriptionManager;
-
-    public EventBusBuilder(IServiceCollection services)
-    {
-        _services = services;
-        _services.AddSingleton<IEventBus, TEventBus>();
-        
-        _subscriptionManager = new SubscriptionManager();
-        _services.AddSingleton<SubscriptionManager>(_subscriptionManager);
-    }
-
-    public EventBusBuilder<TEventBus> Subscribe<TEvent, TEventHandler>() where TEvent : IIntegrationEvent where TEventHandler : class, IIntegrationEventHandler<TEvent>
-    {
-        _services.AddKeyedTransient<IIntegrationEventHandler, TEventHandler>(typeof(TEvent).Name);
-        _subscriptionManager.RegisterSubscription<TEvent>();
-        return this;
-    }
-}

FictionArchive.Service.Shared/Services/EventBus/EventBusExtensions.cs

@@ -1,12 +0,0 @@
-using Microsoft.Extensions.DependencyInjection;
-
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public static class EventBusExtensions
-{
-    public static EventBusBuilder<TEventBus> AddEventBus<TEventBus>(this IServiceCollection services)
-        where TEventBus : class, IEventBus
-    {
-        return new EventBusBuilder<TEventBus>(services);
-    }
-}

FictionArchive.Service.Shared/Services/EventBus/IEventBus.cs

@@ -1,7 +0,0 @@
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public interface IEventBus
-{
-    Task Publish<TEvent>(TEvent integrationEvent) where TEvent : IIntegrationEvent;
-    Task Publish(object integrationEvent, string eventType);
-}

FictionArchive.Service.Shared/Services/EventBus/IIntegrationEvent.cs

@@ -1,7 +0,0 @@
-using NodaTime;
-
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public interface IIntegrationEvent
-{
-}

FictionArchive.Service.Shared/Services/EventBus/IIntegrationEventHandler.cs

@@ -1,12 +0,0 @@
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public interface IIntegrationEventHandler<in TEvent> : IIntegrationEventHandler where TEvent : IIntegrationEvent
-{
-    Task Handle(TEvent @event);
-    Task IIntegrationEventHandler.Handle(IIntegrationEvent @event) => Handle((TEvent)@event);
-}
-
-public interface IIntegrationEventHandler
-{
-    Task Handle(IIntegrationEvent @event);
-}

FictionArchive.Service.Shared/Services/EventBus/Implementations/RabbitMQConnectionProvider.cs

@@ -1,35 +0,0 @@
-using RabbitMQ.Client;
-
-namespace FictionArchive.Service.Shared.Services.EventBus.Implementations;
-
-public class RabbitMQConnectionProvider
-{
-    private readonly IConnectionFactory _connectionFactory;
-
-    private IConnection Connection { get; set; }
-    private IChannel DefaultChannel { get; set; }
-
-    public RabbitMQConnectionProvider(IConnectionFactory connectionFactory)
-    {
-        _connectionFactory = connectionFactory;
-    }
-
-    public async Task<IConnection> GetConnectionAsync()
-    {
-        if (Connection == null)
-        {
-            Connection = await _connectionFactory.CreateConnectionAsync();
-        }
-
-        return Connection;
-    }
-    
-    public async Task<IChannel> GetDefaultChannelAsync()
-    {
-        if (DefaultChannel == null)
-        {
-            DefaultChannel = await (await GetConnectionAsync()).CreateChannelAsync();
-        }
-        return DefaultChannel;
-    }
-}

FictionArchive.Service.Shared/Services/EventBus/Implementations/RabbitMQEventBus.cs

@@ -1,137 +0,0 @@
-using System.Text;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using Microsoft.Extensions.Options;
-using Newtonsoft.Json;
-using NodaTime;
-using NodaTime.Serialization.JsonNet;
-using RabbitMQ.Client;
-using RabbitMQ.Client.Events;
-
-namespace FictionArchive.Service.Shared.Services.EventBus.Implementations;
-
-public class RabbitMQEventBus : IEventBus, IHostedService
-{
-    private readonly IServiceScopeFactory _serviceScopeFactory;
-    private readonly RabbitMQConnectionProvider _connectionProvider;
-    private readonly RabbitMQOptions _options;
-    private readonly SubscriptionManager _subscriptionManager;
-    private readonly ILogger<RabbitMQEventBus> _logger;
-    
-    private readonly JsonSerializerSettings _jsonSerializerSettings;
-
-    private const string ExchangeName = "fiction-archive-event-bus";
-    private const string CreatedAtHeader = "X-Created-At";
-    private const string EventIdHeader = "X-Event-Id";
-
-    public RabbitMQEventBus(IServiceScopeFactory serviceScopeFactory, RabbitMQConnectionProvider connectionProvider, IOptions<RabbitMQOptions> options, SubscriptionManager subscriptionManager, ILogger<RabbitMQEventBus> logger)
-    {
-        _serviceScopeFactory = serviceScopeFactory;
-        _connectionProvider = connectionProvider;
-        _subscriptionManager = subscriptionManager;
-        _logger = logger;
-        _options = options.Value;
-        _jsonSerializerSettings = new JsonSerializerSettings().ConfigureForNodaTime(DateTimeZoneProviders.Tzdb);
-    }
-
-    public async Task Publish<TEvent>(TEvent integrationEvent) where TEvent : IIntegrationEvent
-    {
-        var routingKey = typeof(TEvent).Name;
-        
-        await Publish(integrationEvent, routingKey);
-    }
-
-    public async Task Publish(object integrationEvent, string eventType)
-    {
-        var channel = await _connectionProvider.GetDefaultChannelAsync();
-        var body = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(integrationEvent));
-        
-        // headers
-        var props = new BasicProperties();
-        props.Headers = new Dictionary<string, object?>()
-        {
-            { CreatedAtHeader, Instant.FromDateTimeUtc(DateTime.UtcNow).ToString() },
-            { EventIdHeader, Guid.NewGuid().ToString() }
-        };
-        
-        await channel.BasicPublishAsync(ExchangeName, eventType, true, props, body);
-        _logger.LogInformation("Published event {EventName}", eventType);
-    }
-
-    public async Task StartAsync(CancellationToken cancellationToken)
-    {
-        _ = Task.Factory.StartNew(async () =>
-        {
-            try
-            {
-                var channel = await _connectionProvider.GetDefaultChannelAsync();
-                await channel.ExchangeDeclareAsync(ExchangeName, ExchangeType.Direct,
-                    cancellationToken: cancellationToken);
-
-                await channel.BasicQosAsync(prefetchSize: 0, prefetchCount: 1, global: false, cancellationToken: cancellationToken);
-                await channel.QueueDeclareAsync(_options.ClientIdentifier, true, false, false,
-                    cancellationToken: cancellationToken);
-                var consumer = new AsyncEventingBasicConsumer(channel);
-                consumer.ReceivedAsync += (sender, @event) =>
-                {
-                    return OnReceivedEvent(sender, @event, channel);
-                };
-                
-                await channel.BasicConsumeAsync(_options.ClientIdentifier, false, consumer, cancellationToken: cancellationToken);
-                
-                foreach (var subscription in _subscriptionManager.Subscriptions)
-                {
-                    await channel.QueueBindAsync(_options.ClientIdentifier, ExchangeName, subscription.Key,
-                        cancellationToken: cancellationToken);
-                    _logger.LogInformation("Subscribed to {SubscriptionKey}", subscription.Key);
-                }
-
-                _logger.LogInformation("RabbitMQ EventBus started.");
-            }
-            catch (Exception e)
-            {
-                _logger.LogError(e, "An error occurred while starting the RabbitMQ EventBus");
-            }
-        }, cancellationToken);
-    }
-
-    public Task StopAsync(CancellationToken cancellationToken)
-    {
-        return Task.CompletedTask;
-    }
-    
-    private async Task OnReceivedEvent(object sender, BasicDeliverEventArgs @event, IChannel channel)
-    {
-        var eventName = @event.RoutingKey;
-        _logger.LogInformation("Received event {EventName}", eventName);
-        try
-        {
-            if (!_subscriptionManager.Subscriptions.ContainsKey(eventName))
-            {
-                _logger.LogWarning("Received event without subscription entry.");
-                return;
-            }
-            
-            var eventBody = Encoding.UTF8.GetString(@event.Body.Span);
-            var eventObject = JsonConvert.DeserializeObject(eventBody, _subscriptionManager.Subscriptions[eventName], _jsonSerializerSettings) as IIntegrationEvent;
-            
-            using var scope = _serviceScopeFactory.CreateScope();
-
-            foreach (var service in scope.ServiceProvider.GetKeyedServices<IIntegrationEventHandler>(eventName))
-            {
-                await service.Handle(eventObject);
-            }
-            _logger.LogInformation("Finished handling event with name {EventName}", eventName);
-        }
-        catch (Exception e)
-        {
-            _logger.LogError(e, "An error occurred while handling an event.");
-        }
-        finally
-        {
-            await channel.BasicAckAsync(@event.DeliveryTag, false);
-        }
-
-    }
-}

FictionArchive.Service.Shared/Services/EventBus/Implementations/RabbitMQExtensions.cs

@@ -1,24 +0,0 @@
-using Microsoft.Extensions.Configuration;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Options;
-using RabbitMQ.Client;
-
-namespace FictionArchive.Service.Shared.Services.EventBus.Implementations;
-
-public static class RabbitMQExtensions
-{
-    public static EventBusBuilder<RabbitMQEventBus> AddRabbitMQ(this IServiceCollection services, Action<RabbitMQOptions> configure)
-    {
-        services.Configure(configure);
-        services.AddSingleton<IConnectionFactory, ConnectionFactory>(provider =>
-        {
-            var options = provider.GetService<IOptions<RabbitMQOptions>>();
-            ConnectionFactory factory = new ConnectionFactory();
-            factory.Uri = new Uri(options.Value.ConnectionString);
-            return factory;
-        });
-        services.AddSingleton<RabbitMQConnectionProvider>();
-        services.AddHostedService<RabbitMQEventBus>();
-        return services.AddEventBus<RabbitMQEventBus>();
-    }
-}

FictionArchive.Service.Shared/Services/EventBus/Implementations/RabbitMQOptions.cs

@@ -1,7 +0,0 @@
-namespace FictionArchive.Service.Shared.Services.EventBus.Implementations;
-
-public class RabbitMQOptions
-{
-    public string ConnectionString { get; set; }
-    public string ClientIdentifier { get; set; }
-}

FictionArchive.Service.Shared/Services/EventBus/SubscriptionManager.cs

@@ -1,11 +0,0 @@
-namespace FictionArchive.Service.Shared.Services.EventBus;
-
-public class SubscriptionManager
-{
-    public Dictionary<string, Type> Subscriptions { get; } = new Dictionary<string, Type>();
-
-    public void RegisterSubscription<TEvent>()
-    {
-        Subscriptions.Add(typeof(TEvent).Name, typeof(TEvent));
-    }
-}

FictionArchive.Service.TranslationService/FictionArchive.Service.TranslationService.csproj

@@ -23,6 +23,7 @@
         <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
         <PackageReference Include="DeepL.net" Version="1.17.0" />
         <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2"/>
+        <PackageReference Include="MassTransit" Version="8.4.0" />
     </ItemGroup>
 
     <ItemGroup>

FictionArchive.Service.TranslationService/Models/IntegrationEvents/TranslationRequestCompletedEvent.cs

@@ -1,18 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-using FictionArchive.Service.TranslationService.Models.Enums;
-
-namespace FictionArchive.Service.TranslationService.Models.IntegrationEvents;
-
-public class TranslationRequestCompletedEvent : IIntegrationEvent
-{
-    /// <summary>
-    /// Maps this event back to a triggering request.
-    /// </summary>
-    public Guid? TranslationRequestId { get; set; }
-    
-    /// <summary>
-    /// The resulting text.
-    /// </summary>
-    public string? TranslatedText { get; set; }
-}

FictionArchive.Service.TranslationService/Models/IntegrationEvents/TranslationRequestCreatedEvent.cs

@@ -1,13 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.TranslationService.Models.IntegrationEvents;
-
-public class TranslationRequestCreatedEvent : IIntegrationEvent
-{
-    public Guid TranslationRequestId { get; set; }
-    public Language From { get; set; }
-    public Language To { get; set; }
-    public string Body { get; set; }
-    public string TranslationEngineKey { get; set; }
-}

FictionArchive.Service.TranslationService/Program.cs

@@ -2,16 +2,14 @@ using DeepL;
 using FictionArchive.Common.Extensions;
 using FictionArchive.Service.Shared;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using FictionArchive.Service.Shared.Services.GraphQL;
 using FictionArchive.Service.TranslationService.GraphQL;
-using FictionArchive.Service.TranslationService.Models.IntegrationEvents;
 using FictionArchive.Service.TranslationService.Services;
 using FictionArchive.Service.TranslationService.Services.Database;
 using FictionArchive.Service.TranslationService.Services.EventHandlers;
 using FictionArchive.Service.TranslationService.Services.TranslationEngines;
 using FictionArchive.Service.TranslationService.Services.TranslationEngines.DeepLTranslate;
-using RabbitMQ.Client;
 
 namespace FictionArchive.Service.TranslationService;
 
@@ -26,15 +24,16 @@ public class Program
 
         builder.Services.AddHealthChecks();
         
-        #region Event Bus
+        #region MassTransit
 
         if (!isSchemaExport)
         {
-            builder.Services.AddRabbitMQ(opt =>
-            {
-                builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-            })
-            .Subscribe<TranslationRequestCreatedEvent, TranslationRequestCreatedEventHandler>();
+            builder.Services.AddFictionArchiveMassTransit<TranslationServiceDbContext>(
+                builder.Configuration,
+                x =>
+                {
+                    x.AddConsumer<TranslateTextCommandConsumer>();
+                });
         }
 
         #endregion

FictionArchive.Service.TranslationService/Services/EventHandlers/TranslateTextCommandConsumer.cs

@@ -0,0 +1,40 @@
+using FictionArchive.Service.Shared.MassTransit.Contracts.Commands;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
+using FictionArchive.Service.TranslationService.Models.Enums;
+using MassTransit;
+
+namespace FictionArchive.Service.TranslationService.Services.EventHandlers;
+
+public class TranslateTextCommandConsumer : IConsumer<TranslateTextCommand>
+{
+    private readonly ILogger<TranslateTextCommandConsumer> _logger;
+    private readonly TranslationEngineService _translationEngineService;
+
+    public TranslateTextCommandConsumer(
+        ILogger<TranslateTextCommandConsumer> logger,
+        TranslationEngineService translationEngineService)
+    {
+        _logger = logger;
+        _translationEngineService = translationEngineService;
+    }
+
+    public async Task Consume(ConsumeContext<TranslateTextCommand> context)
+    {
+        var command = context.Message;
+
+        var result = await _translationEngineService.Translate(
+            command.From,
+            command.To,
+            command.Body,
+            command.TranslationEngineKey);
+
+        if (result.Status == TranslationRequestStatus.Success)
+        {
+            await context.Publish(new TranslationCompletedEvent
+            {
+                TranslatedText = result.TranslatedText!,
+                TranslationRequestId = command.TranslationRequestId,
+            });
+        }
+    }
+}

FictionArchive.Service.TranslationService/Services/EventHandlers/TranslationRequestCreatedEventHandler.cs

@@ -1,31 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-using FictionArchive.Service.TranslationService.Models.Enums;
-using FictionArchive.Service.TranslationService.Models.IntegrationEvents;
-
-namespace FictionArchive.Service.TranslationService.Services.EventHandlers;
-
-public class TranslationRequestCreatedEventHandler : IIntegrationEventHandler<TranslationRequestCreatedEvent>
-{
-    private readonly ILogger<TranslationRequestCreatedEventHandler> _logger;
-    private readonly TranslationEngineService _translationEngineService;
-    private readonly IEventBus _eventBus;
-
-    public TranslationRequestCreatedEventHandler(ILogger<TranslationRequestCreatedEventHandler> logger, TranslationEngineService translationEngineService)
-    {
-        _logger = logger;
-        _translationEngineService = translationEngineService;
-    }
-
-    public async Task Handle(TranslationRequestCreatedEvent @event)
-    {
-        var result = await _translationEngineService.Translate(@event.From, @event.To, @event.Body, @event.TranslationEngineKey);
-        if (result.Status == TranslationRequestStatus.Success)
-        {
-            await _eventBus.Publish(new TranslationRequestCompletedEvent()
-            {
-                TranslatedText = result.TranslatedText,
-                TranslationRequestId = @event.TranslationRequestId,
-            });
-        }
-    }
-}

FictionArchive.Service.TranslationService/Services/TranslationEngineService.cs

@@ -1,28 +1,21 @@
-using System.Text;
 using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
 using FictionArchive.Service.TranslationService.Models;
 using FictionArchive.Service.TranslationService.Models.Database;
 using FictionArchive.Service.TranslationService.Models.Enums;
-using FictionArchive.Service.TranslationService.Models.IntegrationEvents;
 using FictionArchive.Service.TranslationService.Services.Database;
 using FictionArchive.Service.TranslationService.Services.TranslationEngines;
-using RabbitMQ.Client;
 
 namespace FictionArchive.Service.TranslationService.Services;
 
 public class TranslationEngineService
 {
     private readonly IEnumerable<ITranslationEngine> _translationEngines;
-    private readonly IEventBus _eventBus;
     private readonly TranslationServiceDbContext _dbContext;
 
-    public TranslationEngineService(IEnumerable<ITranslationEngine> translationEngines, TranslationServiceDbContext dbContext, IEventBus eventBus)
+    public TranslationEngineService(IEnumerable<ITranslationEngine> translationEngines, TranslationServiceDbContext dbContext)
     {
         _translationEngines = translationEngines;
         _dbContext = dbContext;
-        _eventBus = eventBus;
     }
 
     public async Task<TranslationResult> Translate(Language from, Language to, string text, string translationEngineKey)

FictionArchive.Service.TranslationService/appsettings.json

@@ -12,8 +12,10 @@
     "DefaultConnection": "Host=localhost;Database=FictionArchive_NovelService;Username=postgres;password=postgres"
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "TranslationService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "AllowedHosts": "*",
   "OIDC": {

FictionArchive.Service.UserNovelDataService/Models/IntegrationEvents/ChapterCreatedEvent.cs

@@ -1,13 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
-
-public class ChapterCreatedEvent : IIntegrationEvent
-{
-    public required uint ChapterId { get; init; }
-    public required uint NovelId { get; init; }
-    public required uint VolumeId { get; init; }
-    public required int VolumeOrder { get; init; }
-    public required uint ChapterOrder { get; init; }
-    public required string ChapterTitle { get; init; }
-}

FictionArchive.Service.UserNovelDataService/Models/IntegrationEvents/NovelCreatedEvent.cs

@@ -1,13 +0,0 @@
-using FictionArchive.Common.Enums;
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
-
-public class NovelCreatedEvent : IIntegrationEvent
-{
-    public required uint NovelId { get; init; }
-    public required string Title { get; init; }
-    public required Language OriginalLanguage { get; init; }
-    public required string Source { get; init; }
-    public required string AuthorName { get; init; }
-}

FictionArchive.Service.UserNovelDataService/Models/IntegrationEvents/UserInvitedEvent.cs

@@ -1,15 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
-
-public class UserInvitedEvent : IIntegrationEvent
-{
-    public Guid InvitedUserId { get; set; }
-    public required string InvitedUsername { get; set; }
-    public required string InvitedEmail { get; set; }
-    public required string InvitedOAuthProviderId { get; set; }
-
-    public Guid InviterId { get; set; }
-    public required string InviterUsername { get; set; }
-    public required string InviterOAuthProviderId { get; set; }
-}

FictionArchive.Service.UserNovelDataService/Program.cs

@@ -1,9 +1,8 @@
 using FictionArchive.Common.Extensions;
 using FictionArchive.Service.Shared;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using FictionArchive.Service.UserNovelDataService.GraphQL;
-using FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
 using FictionArchive.Service.UserNovelDataService.Services;
 using FictionArchive.Service.UserNovelDataService.Services.EventHandlers;
 
@@ -22,17 +21,18 @@ public class Program
         builder.Services.AddMemoryCache();
         builder.Services.AddHealthChecks();
         
-        #region Event Bus
+        #region MassTransit
 
         if (!isSchemaExport)
         {
-            builder.Services.AddRabbitMQ(opt =>
-            {
-                builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-            })
-                .Subscribe<NovelCreatedEvent, NovelCreatedEventHandler>()
-                .Subscribe<ChapterCreatedEvent, ChapterCreatedEventHandler>()
-                .Subscribe<UserInvitedEvent, UserInvitedEventHandler>();
+            builder.Services.AddFictionArchiveMassTransit<UserNovelDataServiceDbContext>(
+                builder.Configuration,
+                x =>
+                {
+                    x.AddConsumer<NovelCreatedEventConsumer>();
+                    x.AddConsumer<ChapterCreatedEventConsumer>();
+                    x.AddConsumer<UserInvitedEventConsumer>();
+                });
         }
 
         #endregion

FictionArchive.Service.UserNovelDataService/Services/EventHandlers/ChapterCreatedEventConsumer.cs

@@ -1,25 +1,27 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 using FictionArchive.Service.UserNovelDataService.Models.Database;
-using FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 
 namespace FictionArchive.Service.UserNovelDataService.Services.EventHandlers;
 
-public class ChapterCreatedEventHandler : IIntegrationEventHandler<ChapterCreatedEvent>
+public class ChapterCreatedEventConsumer : IConsumer<ChapterCreatedEvent>
 {
     private readonly UserNovelDataServiceDbContext _dbContext;
-    private readonly ILogger<ChapterCreatedEventHandler> _logger;
+    private readonly ILogger<ChapterCreatedEventConsumer> _logger;
 
-    public ChapterCreatedEventHandler(
+    public ChapterCreatedEventConsumer(
         UserNovelDataServiceDbContext dbContext,
-        ILogger<ChapterCreatedEventHandler> logger)
+        ILogger<ChapterCreatedEventConsumer> logger)
     {
         _dbContext = dbContext;
         _logger = logger;
     }
 
-    public async Task Handle(ChapterCreatedEvent @event)
+    public async Task Consume(ConsumeContext<ChapterCreatedEvent> context)
     {
+        var @event = context.Message;
+
         // Ensure novel exists
         var novelExists = await _dbContext.Novels.AnyAsync(n => n.Id == @event.NovelId);
         if (!novelExists)

FictionArchive.Service.UserNovelDataService/Services/EventHandlers/NovelCreatedEventConsumer.cs

@@ -1,25 +1,27 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 using FictionArchive.Service.UserNovelDataService.Models.Database;
-using FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 
 namespace FictionArchive.Service.UserNovelDataService.Services.EventHandlers;
 
-public class NovelCreatedEventHandler : IIntegrationEventHandler<NovelCreatedEvent>
+public class NovelCreatedEventConsumer : IConsumer<NovelCreatedEvent>
 {
     private readonly UserNovelDataServiceDbContext _dbContext;
-    private readonly ILogger<NovelCreatedEventHandler> _logger;
+    private readonly ILogger<NovelCreatedEventConsumer> _logger;
 
-    public NovelCreatedEventHandler(
+    public NovelCreatedEventConsumer(
         UserNovelDataServiceDbContext dbContext,
-        ILogger<NovelCreatedEventHandler> logger)
+        ILogger<NovelCreatedEventConsumer> logger)
     {
         _dbContext = dbContext;
         _logger = logger;
     }
 
-    public async Task Handle(NovelCreatedEvent @event)
+    public async Task Consume(ConsumeContext<NovelCreatedEvent> context)
     {
+        var @event = context.Message;
+
         var exists = await _dbContext.Novels.AnyAsync(n => n.Id == @event.NovelId);
         if (exists)
         {

FictionArchive.Service.UserNovelDataService/Services/EventHandlers/UserInvitedEventConsumer.cs

@@ -1,25 +1,27 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 using FictionArchive.Service.UserNovelDataService.Models.Database;
-using FictionArchive.Service.UserNovelDataService.Models.IntegrationEvents;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 
 namespace FictionArchive.Service.UserNovelDataService.Services.EventHandlers;
 
-public class UserInvitedEventHandler : IIntegrationEventHandler<UserInvitedEvent>
+public class UserInvitedEventConsumer : IConsumer<UserInvitedEvent>
 {
     private readonly UserNovelDataServiceDbContext _dbContext;
-    private readonly ILogger<UserInvitedEventHandler> _logger;
+    private readonly ILogger<UserInvitedEventConsumer> _logger;
 
-    public UserInvitedEventHandler(
+    public UserInvitedEventConsumer(
         UserNovelDataServiceDbContext dbContext,
-        ILogger<UserInvitedEventHandler> logger)
+        ILogger<UserInvitedEventConsumer> logger)
     {
         _dbContext = dbContext;
         _logger = logger;
     }
 
-    public async Task Handle(UserInvitedEvent @event)
+    public async Task Consume(ConsumeContext<UserInvitedEvent> context)
     {
+        var @event = context.Message;
+
         var exists = await _dbContext.Users.AnyAsync(u => u.Id == @event.InvitedUserId);
         if (exists)
         {

FictionArchive.Service.UserNovelDataService/appsettings.json

@@ -9,8 +9,10 @@
     "DefaultConnection": "Host=localhost;Database=FictionArchive_UserNovelDataService;Username=postgres;password=postgres"
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "UserNovelDataService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "OIDC": {
     "Authority": "https://auth.orfl.xyz/application/o/fiction-archive/",

FictionArchive.Service.UserService.Tests/UserManagementServiceTests.cs

@@ -1,9 +1,9 @@
-using FictionArchive.Service.Shared.Services.EventBus;
 using FictionArchive.Service.UserService.Models.Database;
 using FictionArchive.Service.UserService.Services;
 using FictionArchive.Service.UserService.Services.AuthenticationClient;
 using FictionArchive.Service.UserService.Services.AuthenticationClient.Authentik;
 using FluentAssertions;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging.Abstractions;
 using NSubstitute;
@@ -27,13 +27,13 @@ public class UserManagementServiceTests
     private static UserManagementService CreateService(
         UserServiceDbContext dbContext,
         IAuthenticationServiceClient authClient,
-        IEventBus? eventBus = null)
+        IPublishEndpoint? publishEndpoint = null)
     {
         return new UserManagementService(
             dbContext,
             NullLogger<UserManagementService>.Instance,
             authClient,
-            eventBus ?? Substitute.For<IEventBus>());
+            publishEndpoint ?? Substitute.For<IPublishEndpoint>());
     }
 
     private static User CreateTestUser(string username, string email, int availableInvites = 5)

FictionArchive.Service.UserService/Models/IntegrationEvents/UserInvitedEvent.cs

@@ -1,17 +0,0 @@
-using FictionArchive.Service.Shared.Services.EventBus;
-
-namespace FictionArchive.Service.UserService.Models.IntegrationEvents;
-
-public class UserInvitedEvent : IIntegrationEvent
-{
-    // Invited user info
-    public Guid InvitedUserId { get; set; }
-    public required string InvitedUsername { get; set; }
-    public required string InvitedEmail { get; set; }
-    public required string InvitedOAuthProviderId { get; set; }
-
-    // Inviter info
-    public Guid InviterId { get; set; }
-    public required string InviterUsername { get; set; }
-    public required string InviterOAuthProviderId { get; set; }
-}

FictionArchive.Service.UserService/Program.cs

@@ -2,7 +2,7 @@ using System.Net.Http.Headers;
 using FictionArchive.Common.Extensions;
 using FictionArchive.Service.Shared;
 using FictionArchive.Service.Shared.Extensions;
-using FictionArchive.Service.Shared.Services.EventBus.Implementations;
+using FictionArchive.Service.Shared.MassTransit;
 using FictionArchive.Service.UserService.GraphQL;
 using FictionArchive.Service.UserService.Services;
 using FictionArchive.Service.UserService.Services.AuthenticationClient;
@@ -19,14 +19,11 @@ public class Program
         var builder = WebApplication.CreateBuilder(args);
         builder.AddLocalAppsettings();
 
-        #region Event Bus
+        #region MassTransit
 
         if (!isSchemaExport)
         {
-            builder.Services.AddRabbitMQ(opt =>
-            {
-                builder.Configuration.GetSection("RabbitMQ").Bind(opt);
-            });
+            builder.Services.AddFictionArchiveMassTransit<UserServiceDbContext>(builder.Configuration);
         }
 
         #endregion

FictionArchive.Service.UserService/Services/UserManagementService.cs

@@ -1,7 +1,7 @@
-using FictionArchive.Service.Shared.Services.EventBus;
+using FictionArchive.Service.Shared.MassTransit.Contracts.Events;
 using FictionArchive.Service.UserService.Models.Database;
-using FictionArchive.Service.UserService.Models.IntegrationEvents;
 using FictionArchive.Service.UserService.Services.AuthenticationClient;
+using MassTransit;
 using Microsoft.EntityFrameworkCore;
 
 namespace FictionArchive.Service.UserService.Services;
@@ -11,18 +11,18 @@ public class UserManagementService
     private readonly ILogger<UserManagementService> _logger;
     private readonly UserServiceDbContext _dbContext;
     private readonly IAuthenticationServiceClient _authClient;
-    private readonly IEventBus _eventBus;
+    private readonly IPublishEndpoint _publishEndpoint;
 
     public UserManagementService(
         UserServiceDbContext dbContext,
         ILogger<UserManagementService> logger,
         IAuthenticationServiceClient authClient,
-        IEventBus eventBus)
+        IPublishEndpoint publishEndpoint)
     {
         _dbContext = dbContext;
         _logger = logger;
         _authClient = authClient;
-        _eventBus = eventBus;
+        _publishEndpoint = publishEndpoint;
     }
 
     /// <summary>
@@ -99,7 +99,7 @@ public class UserManagementService
 
         await _dbContext.SaveChangesAsync();
 
-        await _eventBus.Publish(new UserInvitedEvent
+        await _publishEndpoint.Publish(new UserInvitedEvent
         {
             InvitedUserId = newUser.Id,
             InvitedUsername = newUser.Username,

FictionArchive.Service.UserService/appsettings.json

@@ -9,8 +9,10 @@
     "DefaultConnection": "Host=localhost;Database=FictionArchive_UserService;Username=postgres;password=postgres"
   },
   "RabbitMQ": {
-    "ConnectionString": "amqp://localhost",
-    "ClientIdentifier": "UserService"
+    "Host": "localhost",
+    "VirtualHost": "/",
+    "Username": "guest",
+    "Password": "guest"
   },
   "Authentik": {
     "BaseUrl": "https://auth.orfl.xyz",

FictionArchive.sln

@@ -1,6 +1,6 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
-#
+# 
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FictionArchive.Common", "FictionArchive.Common\FictionArchive.Common.csproj", "{ABF1BA10-9E76-45BE-9947-E20445A68147}"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FictionArchive.API", "FictionArchive.API\FictionArchive.API.csproj", "{420CC1A1-9DBC-40EC-B9E3-D4B25D71B9A9}"
@@ -23,6 +23,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FictionArchive.Service.User
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FictionArchive.Service.UserNovelDataService", "FictionArchive.Service.UserNovelDataService\FictionArchive.Service.UserNovelDataService.csproj", "{A278565B-D440-4AB9-B2E2-41BA3B3AD82A}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FictionArchive.Service.ReportingService", "FictionArchive.Service.ReportingService\FictionArchive.Service.ReportingService.csproj", "{24C8871B-1ECA-47A0-92DC-AD155C17EDF0}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -73,5 +75,9 @@ Global
 		{A278565B-D440-4AB9-B2E2-41BA3B3AD82A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{A278565B-D440-4AB9-B2E2-41BA3B3AD82A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{A278565B-D440-4AB9-B2E2-41BA3B3AD82A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{24C8871B-1ECA-47A0-92DC-AD155C17EDF0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{24C8871B-1ECA-47A0-92DC-AD155C17EDF0}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{24C8871B-1ECA-47A0-92DC-AD155C17EDF0}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{24C8871B-1ECA-47A0-92DC-AD155C17EDF0}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal

docker-compose.yml

@@ -136,6 +136,22 @@ services:
         condition: service_healthy
     restart: unless-stopped
 
+  reporting-service:
+    build:
+      context: .
+      dockerfile: FictionArchive.Service.ReportingService/Dockerfile
+    networks:
+      - fictionarchive
+    environment:
+      ConnectionStrings__DefaultConnection: Host=postgres;Database=FictionArchive_ReportingService;Username=${POSTGRES_USER:-postgres};Password=${POSTGRES_PASSWORD:-postgres}
+      RabbitMQ__ConnectionString: amqp://${RABBITMQ_USER:-guest}:${RABBITMQ_PASSWORD:-guest}@rabbitmq
+    depends_on:
+      postgres:
+        condition: service_healthy
+      rabbitmq:
+        condition: service_healthy
+    restart: unless-stopped
+
   file-service:
     image: git.orfl.xyz/conco/fictionarchive-file-service:latest
     networks: