From 2ea7060eefb0622d3d43ea00d1b714460f926d17 Mon Sep 17 00:00:00 2001
From: Andrija Stevanovic <andrijastev4@gmail.com>
Date: Sat, 14 Feb 2026 00:45:35 +0100
Subject: [PATCH] namespace fix

---
 .../Abstract/{ => MessageBroking}/IMessagePublisher.cs    | 4 +---
 .../Infrastructure/DI/AipsRegistrationExtensions.cs       | 5 +++++
 .../MessageBroking/RabbitMQ/RabbitMqConnection.cs         | 5 +++--
 .../MessageBroking/RabbitMQ/RabbitMqPublisher.cs          | 1 +
 dotnet/AipsWebApi/Controllers/UserController.cs           | 8 ++++++++
 5 files changed, 18 insertions(+), 5 deletions(-)
 rename dotnet/AipsCore/Application/Abstract/{ => MessageBroking}/IMessagePublisher.cs (66%)

diff --git a/dotnet/AipsCore/Application/Abstract/IMessagePublisher.cs b/dotnet/AipsCore/Application/Abstract/MessageBroking/IMessagePublisher.cs
similarity index 66%
rename from dotnet/AipsCore/Application/Abstract/IMessagePublisher.cs
rename to dotnet/AipsCore/Application/Abstract/MessageBroking/IMessagePublisher.cs
index d09651b..30b2998 100644
--- a/dotnet/AipsCore/Application/Abstract/IMessagePublisher.cs
+++ b/dotnet/AipsCore/Application/Abstract/MessageBroking/IMessagePublisher.cs
@@ -1,6 +1,4 @@
-using System.Runtime.Serialization;
-
-namespace AipsCore.Application.Abstract;
+namespace AipsCore.Application.Abstract.MessageBroking;
 
 public interface IMessagePublisher
 {
diff --git a/dotnet/AipsCore/Infrastructure/DI/AipsRegistrationExtensions.cs b/dotnet/AipsCore/Infrastructure/DI/AipsRegistrationExtensions.cs
index 351ea14..49101de 100644
--- a/dotnet/AipsCore/Infrastructure/DI/AipsRegistrationExtensions.cs
+++ b/dotnet/AipsCore/Infrastructure/DI/AipsRegistrationExtensions.cs
@@ -1,5 +1,7 @@
 using AipsCore.Application.Abstract;
+using AipsCore.Application.Abstract.MessageBroking;
 using AipsCore.Application.Common.Dispatcher;
+using AipsCore.Infrastructure.MessageBroking.RabbitMQ;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 
@@ -15,6 +17,9 @@ public static class AipsRegistrationExtensions
         services.AddPersistence(configuration);
 
         services.AddUserContext(configuration);
+
+        services.AddSingleton<IRabbitMqConnection, RabbitMqConnection>();
+        services.AddSingleton<IMessagePublisher, RabbitMqPublisher>();
         
         return services;
     }
diff --git a/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqConnection.cs b/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqConnection.cs
index a07a981..0a41c8d 100644
--- a/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqConnection.cs
+++ b/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqConnection.cs
@@ -18,10 +18,11 @@ public class RabbitMqConnection : IRabbitMqConnection
     {
         if (_connection is null)
         {
-            throw new InvalidOperationException($"RabbitMQ connection not created for {_configuration.GetEnvRabbitMqAmqpUri()}");
+            await CreateConnectionAsync();
+            //throw new InvalidOperationException($"RabbitMQ connection not created for {_configuration.GetEnvRabbitMqAmqpUri()}");
         }
 
-        return await _connection.CreateChannelAsync(null, cancellationToken);
+        return await _connection!.CreateChannelAsync(null, cancellationToken);
     }
 
     public async Task CreateConnectionAsync()
diff --git a/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqPublisher.cs b/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqPublisher.cs
index bf3cc7c..c9cb674 100644
--- a/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqPublisher.cs
+++ b/dotnet/AipsCore/Infrastructure/MessageBroking/RabbitMQ/RabbitMqPublisher.cs
@@ -1,6 +1,7 @@
 using System.Text;
 using System.Text.Json;
 using AipsCore.Application.Abstract;
+using AipsCore.Application.Abstract.MessageBroking;
 using RabbitMQ.Client;
 
 namespace AipsCore.Infrastructure.MessageBroking.RabbitMQ;
diff --git a/dotnet/AipsWebApi/Controllers/UserController.cs b/dotnet/AipsWebApi/Controllers/UserController.cs
index 746887f..2cc97f9 100644
--- a/dotnet/AipsWebApi/Controllers/UserController.cs
+++ b/dotnet/AipsWebApi/Controllers/UserController.cs
@@ -1,4 +1,5 @@
 using AipsCore.Application.Abstract;
+using AipsCore.Application.Abstract.MessageBroking;
 using AipsCore.Application.Common.Authentication;
 using AipsCore.Application.Models.User.Command.LogIn;
 using AipsCore.Application.Models.User.Command.SignUp;
@@ -34,4 +35,11 @@ public class UserController : ControllerBase
         var result = await _dispatcher.Execute(command, cancellationToken);
         return Ok(result.Value);
     }
+
+    [AllowAnonymous]
+    [HttpPost("test")]
+    public async Task Test(IMessagePublisher publisher)
+    {
+        await publisher.PublishAsync("test", "test.test", "Test poruka");
+    }
 }
\ No newline at end of file