moved consumers back into the webapp

azure container apps is too slow for now (30 sec polling time is an issue)

src/container_apps/Jordnaer.Chat/Extensions/WebApplicationBuilderExtensions.cs

@@ -8,10 +8,6 @@ public static WebApplicationBuilder AddMassTransit(this WebApplicationBuilder bu
     {
         builder.Services.AddMassTransit(config =>
         {
-            config.AddConsumer<StartChatConsumer>();
-            config.AddConsumer<SendMessageConsumer>();
-            config.AddConsumer<SetChatNameConsumer>();
-
             config.UsingAzureServiceBus((context, azureServiceBus) =>
             {
                 azureServiceBus.Host(builder.Configuration.GetConnectionString("AzureServiceBus"));

src/web/Server/Consumers/README.md

@@ -0,0 +1,14 @@
+# Info
+
+All consumers in this folders should be moved to Azure Container Apps or
+Azure Container App Jobs once Mini Møder's traffic is large enough.
+
+## Criteria
+
+**ChatConsumers:**
+
+- Over 1 message sent every 5 minutes, consistently throughout the day (6-24)
+
+OR
+
+- Over 100 messages sent per hour, consistently throughout the day (6-24)

src/container_apps/Jordnaer.Chat/SendMessageConsumer.cs → src/web/Server/Consumers/SendMessageConsumer.cs

@@ -1,8 +1,9 @@
+using Jordnaer.Server.Database;
 using Jordnaer.Shared;
 using MassTransit;
 using Microsoft.EntityFrameworkCore;
 
-namespace Jordnaer.Chat;
+namespace Jordnaer.Server.Consumers;
 
 public class SendMessageConsumer : IConsumer<SendMessage>
 {

src/container_apps/Jordnaer.Chat/SetChatNameConsumer.cs → src/web/Server/Consumers/SetChatNameConsumer.cs

@@ -1,7 +1,7 @@
 using Jordnaer.Shared;
 using MassTransit;
 
-namespace Jordnaer.Chat;
+namespace Jordnaer.Server.Consumers;
 
 public class SetChatNameConsumer : IConsumer<SetChatName>
 {

src/container_apps/Jordnaer.Chat/StartChatConsumer.cs → src/web/Server/Consumers/StartChatConsumer.cs

@@ -1,7 +1,8 @@
+using Jordnaer.Server.Database;
 using Jordnaer.Shared;
 using MassTransit;
 
-namespace Jordnaer.Chat;
+namespace Jordnaer.Server.Consumers;
 
 public class StartChatConsumer : IConsumer<StartChat>
 {
@@ -16,7 +17,7 @@ public async Task Consume(ConsumeContext<StartChat> consumeContext)
     {
         var chat = consumeContext.Message;
 
-        _context.Chats.Add(new Shared.Chat
+        _context.Chats.Add(new Chat
         {
             LastMessageSentUtc = chat.LastMessageSentUtc,
             Id = chat.Id,

src/web/Server/Extensions/WebApplicationBuilderExtensions.cs

@@ -1,3 +1,4 @@
+using Jordnaer.Server.Consumers;
 using Jordnaer.Server.Database;
 using MassTransit;
 using Microsoft.AspNetCore.ResponseCompression;
@@ -11,6 +12,10 @@ public static WebApplicationBuilder AddMassTransit(this WebApplicationBuilder bu
     {
         builder.Services.AddMassTransit(config =>
         {
+            config.AddConsumer<StartChatConsumer>();
+            config.AddConsumer<SendMessageConsumer>();
+            config.AddConsumer<SetChatNameConsumer>();
+
             config.UsingAzureServiceBus((context, azureServiceBus) =>
             {
                 azureServiceBus.Host(builder.Configuration.GetConnectionString("AzureServiceBus"));