Renamed frontend service to Message Queue Service

Birdmap.API/Controllers/ServicesController.cs

@@ -82,7 +82,7 @@ namespace Birdmap.API.Controllers
                 Service = new()
                 {
                     Id = 0,
-                    Name = "Mqtt Client Service",
+                    Name = "Message Queue Service",
                     Uri = "localhost",
                 },
                 Response = $"IsConnected: {_communicationService.IsConnected}",

Birdmap.API/Startup.cs

@@ -12,6 +12,7 @@ using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.IdentityModel.Tokens;
 using NSwag.Generation.Processors.Security;
+using System;
 using System.Text;
 
 namespace Birdmap.API
@@ -71,7 +72,7 @@ namespace Birdmap.API
             {
                 opt.Title = "Birdmap";
                 opt.OperationProcessors.Add(new OperationSecurityScopeProcessor("Jwt Token"));
-                opt.AddSecurity("Jwt Token", new string[] { },
+                opt.AddSecurity("Jwt Token", Array.Empty<string>(),
                     new NSwag.OpenApiSecurityScheme
                     {
                         Type = NSwag.OpenApiSecuritySchemeType.ApiKey,
@@ -95,11 +96,9 @@ namespace Birdmap.API
             app.UseOpenApi();
             app.UseSwaggerUi3();
 
-            app.UseHttpsRedirection();
             app.UseStaticFiles();
             app.UseSpaStaticFiles();
 
-
             app.UseAuthentication();
             app.UseRouting();
             app.UseAuthorization();

Birdmap.API/appsettings.json

@@ -27,10 +27,25 @@
   "UseRabbitMq": false,
   "Mqtt": {
     "BrokerHostSettings": {
+      "VirtualHost": "",
       "Host": "",
       "Port": 1883
     },
 
+    "ExchangeSettings": {
+      "Name": "",
+      "Type": "",
+      "Durable": false,
+      "AutoDelete": false
+    },
+
+    "QueueSettings": {
+      "Name": "",
+      "Durable": false,
+      "Exclusive": false,
+      "AutoDelete": false
+    },
+
     "ClientSettings": {
       "Id": "ASP.NET Core client",
       "Username": "",

Birdmap.API/nlog.config

@@ -35,6 +35,8 @@
 
     <!--Skip non-critical Mqtt logs-->
 	<logger name="*.*Mqtt*.*" minlevel="Trace" maxlevel="Warning" writeTo="mqttFile" final="true"/>
+	<logger name="*.*RabbitMq*.*" minlevel="Trace" maxlevel="Warning" writeTo="mqttFile" final="true"/>
+	<logger name="*.*CommunicationServiceBase*.*" minlevel="Trace" maxlevel="Warning" writeTo="mqttFile" final="true"/>
 
 	<!--Skip non-critical Hub logs-->
 	<logger name="*.*Hubs*.*" minlevel="Trace" maxlevel="Warning" writeTo="hubsFile" final="true"/>

Birdmap.BLL/Interfaces/ICommunicationService.cs

@@ -1,6 +1,8 @@
-namespace Birdmap.BLL.Interfaces
+using Microsoft.Extensions.Hosting;
+
+namespace Birdmap.BLL.Interfaces
 {
-    public interface ICommunicationService
+    public interface ICommunicationService : IHostedService
     {
         public bool IsConnected { get; }
     }

Birdmap.BLL/Interfaces/IMqttClientService.cs

@@ -5,8 +5,7 @@ using MQTTnet.Client.Receiving;
 
 namespace Birdmap.BLL.Interfaces
 {
-    public interface IMqttClientService : IHostedService,
+    public interface IMqttClientService : IMqttClientConnectedHandler,
-                                          IMqttClientConnectedHandler,
                                           IMqttClientDisconnectedHandler,
                                           IMqttApplicationMessageReceivedHandler
     {

Birdmap.BLL/Options/RabbitMqClientOptions.cs

@@ -1,4 +1,11 @@
 namespace Birdmap.BLL.Options
 {
-    public record RabbitMqClientOptions(string Hostname, int Port, string Username, string Password, string Topic);
+    public record RabbitMqClientOptions(
+        string Hostname, int Port, string VirtualHost,
+        string Username, string Password,
+        string ExchangeName, string ExchangeType,
+        bool ExchangeDurable, bool ExchangeAutoDelete,
+        string QueueName,
+        bool QueueDurable, bool QueueAutoDelete, bool QueueExclusive,
+        string Topic);
 }

Birdmap.BLL/Services/CommunationServices/CommunicationServiceBase.cs

@@ -6,6 +6,7 @@ using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Threading;
 using System.Threading.Tasks;
 using Timer = System.Timers.Timer;
 
@@ -83,5 +84,9 @@ namespace Birdmap.BLL.Services.CommunationServices
                 }
             }
         }
+
+        public abstract Task StartAsync(CancellationToken cancellationToken);
+
+        public abstract Task StopAsync(CancellationToken cancellationToken);
     }
 }

Birdmap.BLL/Services/CommunationServices/Mqtt/MqttClientService.cs

@@ -81,7 +81,7 @@ namespace Birdmap.BLL.Services.CommunicationServices.Mqtt
             }
         }
 
-        public async Task StartAsync(CancellationToken cancellationToken)
+        public override async Task StartAsync(CancellationToken cancellationToken)
         {
             try
             {
@@ -97,7 +97,7 @@ namespace Birdmap.BLL.Services.CommunicationServices.Mqtt
             }
         }
 
-        public async Task StopAsync(CancellationToken cancellationToken)
+        public override async Task StopAsync(CancellationToken cancellationToken)
         {
             try
             {

Birdmap.BLL/Services/CommunationServices/RabbitMq/RabbitMqClientService.cs

@@ -7,21 +7,25 @@ using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 using System;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 
 namespace Birdmap.BLL.Services.CommunationServices.RabbitMq
 {
-    internal class RabbitMqClientService : CommunicationServiceBase, IDisposable
+    internal class RabbitMqClientService : CommunicationServiceBase
     {
-        private readonly IConnection _connection;
+        private IConnection _connection;
-        private readonly IModel _channel;
+        private IModel _channel;
+        private readonly IConnectionFactory _factory;
+        private readonly RabbitMqClientOptions _options;
 
-        public override bool IsConnected => throw new NotImplementedException();
+        public override bool IsConnected => _connection.IsOpen;
 
         public RabbitMqClientService(RabbitMqClientOptions options, ILogger<RabbitMqClientService> logger, IInputService inputService, IHubContext<DevicesHub, IDevicesHubClient> hubContext)
             : base(logger, inputService, hubContext)
         {
-            var factory = new ConnectionFactory()
+            _options = options;
+            _factory = new ConnectionFactory()
             {
                 HostName = options.Hostname,
                 Port = options.Port,
@@ -30,25 +34,6 @@ namespace Birdmap.BLL.Services.CommunationServices.RabbitMq
 
                 AutomaticRecoveryEnabled = true,
             };
-
-            _connection = factory.CreateConnection();
-            _channel = _connection.CreateModel();
-
-            _channel.ExchangeDeclare(exchange: "topic_logs", type: "topic");
-            var queueName = _channel.QueueDeclare().QueueName;
-
-            _channel.QueueBind(queue: queueName,
-                                  exchange: "topic_logs",
-                                  routingKey: options.Topic);
-
-            var consumer = new AsyncEventingBasicConsumer(_channel);
-            consumer.Received += OnRecieved;
-
-            _channel.BasicConsume(queue: queueName,
-                                 autoAck: true,
-                                 consumer: consumer);
-
-            StartMessageTimer();
         }
 
         private Task OnRecieved(object sender, BasicDeliverEventArgs eventArgs)
@@ -62,11 +47,68 @@ namespace Birdmap.BLL.Services.CommunationServices.RabbitMq
             return ProcessJsonMessageAsync(body);
         }
 
-        public void Dispose()
+        public override async Task StartAsync(CancellationToken cancellationToken)
+        {
+            try
+            {
+                Connect();
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"Cannot connect. Reconnecting...");
+                await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
+
+                cancellationToken.ThrowIfCancellationRequested();
+                await StartAsync(cancellationToken);
+            }
+        }
+
+        public override Task StopAsync(CancellationToken cancellationToken)
+        {
+            try
             {
                 StopMessageTimer();
-            _channel.Close();
+                _channel?.Close();
-            _connection.Close();
+                _connection?.Close();
+                return Task.CompletedTask;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"Cannot disconnect...");
+                return Task.FromException(ex);
+            }
+        }
+
+        private void Connect()
+        {
+
+            _connection = _factory.CreateConnection();
+            _channel = _connection.CreateModel();
+
+            _channel.ExchangeDeclare(
+                exchange: _options.ExchangeName,
+                type: _options.ExchangeType,
+                durable: _options.ExchangeDurable,
+                autoDelete: _options.ExchangeAutoDelete);
+
+            _channel.QueueDeclare(
+                queue: _options.QueueName,
+                durable: _options.QueueDurable,
+                exclusive: _options.QueueExclusive,
+                autoDelete: _options.QueueAutoDelete);
+
+            _channel.QueueBind(queue: _options.QueueName,
+                                  exchange: _options.ExchangeName,
+                                  routingKey: _options.Topic);
+
+            var consumer = new AsyncEventingBasicConsumer(_channel);
+            consumer.Received += OnRecieved;
+
+            _channel.BasicConsume(queue: _options.QueueName,
+                                 autoAck: true,
+                                 consumer: consumer);
+
+            StartMessageTimer();
         }
     }
 }

Birdmap.BLL/Startup.cs

@@ -61,6 +61,25 @@ namespace Birdmap.BLL
             {
                 Host = brokerHost.GetValue<string>("Host"),
                 Port = brokerHost.GetValue<int>("Port"),
+                VirtualHost = brokerHost.GetValue<string>("VirtualHost"),
+            };
+
+            var exchange = mqtt.GetSection("ExchangeSettings");
+            var exchangeSettings = new
+            {
+                Name = exchange.GetValue<string>("Name"),
+                Type = exchange.GetValue<string>("Type"),
+                Durable = exchange.GetValue<bool>("Durable"),
+                AutoDelete = exchange.GetValue<bool>("AutoDelete"),
+            };
+
+            var queue = mqtt.GetSection("QueueSettings");
+            var queueSettings = new
+            {
+                Name = queue.GetValue<string>("Name"),
+                Durable = exchange.GetValue<bool>("Durable"),
+                Exclusive = exchange.GetValue<bool>("Exclusive"),
+                AutoDelete = exchange.GetValue<bool>("AutoDelete"),
             };
 
             if (configuration.GetValue<bool>("UseRabbitMq"))
@@ -68,8 +87,17 @@ namespace Birdmap.BLL
                 services.AddRabbitMqClientServiceWithConfig(new RabbitMqClientOptions(
                     Hostname: brokerHostSettings.Host,
                     Port: brokerHostSettings.Port,
+                    VirtualHost: brokerHostSettings.VirtualHost,
                     Username: clientSettings.Username,
                     Password: clientSettings.Password,
+                    ExchangeName: exchangeSettings.Name,
+                    ExchangeType: exchangeSettings.Type,
+                    ExchangeDurable: exchangeSettings.Durable,
+                    ExchangeAutoDelete: exchangeSettings.AutoDelete,
+                    QueueName: queueSettings.Name,
+                    QueueDurable: queueSettings.Durable,
+                    QueueExclusive: queueSettings.Exclusive,
+                    QueueAutoDelete: queueSettings.AutoDelete,
                     Topic: clientSettings.Topic));
             }
             else
@@ -111,9 +139,9 @@ namespace Birdmap.BLL
         private static IServiceCollection AddClientServiceWithProvider<T>(this IServiceCollection services) where T : class, ICommunicationService
         {
             services.AddSingleton<T>();
-            services.AddSingleton(serviceProvider =>
+            services.AddSingleton<IHostedService>(serviceProvider =>
             {
-                return (IHostedService)serviceProvider.GetService<T>();
+                return serviceProvider.GetService<T>();
             });
             services.AddSingleton<ICommunicationServiceProvider>(serviceProvider =>
             {

docker-compose.yml

@@ -17,7 +17,7 @@ services:
             - ${APPDATA}/ASP.NET/Https:/root/.aspnet/https:ro
         build:
           context: .
-          dockerfile: Birdmap.API/Dockerfile
+          dockerfile: Dockerfile
         depends_on:
             - db
         environment:
@@ -38,9 +38,18 @@ services:
             - Birdmap_Defaults__Services__KMLabz-Service=https://birb.k8s.kmlabz.com/devices
             - Birdmap_UseDummyServices=true
             - Birdmap_ServicesBaseUrl=https://birb.k8s.kmlabz.com/
-            - Birdmap_UseRabbitMq=true
+            - Birdmap_UseRabbitMq=false
             - Birdmap_Mqtt__BrokerHostSettings__Host=localhost
             - Birdmap_Mqtt__BrokerHostSettings__Port=1883
+            - Birdmap_Mqtt__BrokerHostSettings__VirtualHost=/
+            - Birdmap_Mqtt__ExchangeSettings__Name=birbmapexchange
+            - Birdmap_Mqtt__ExchangeSettings__Type=fanout
+            - Birdmap_Mqtt__ExchangeSettings__Durable=true
+            - Birdmap_Mqtt__ExchangeSettings__AutoDelete=true
+            - Birdmap_Mqtt__QueueSettings__Name=birbmapqueue
+            - Birdmap_Mqtt__QueueSettings__Durable=true
+            - Birdmap_Mqtt__QueueSettings__Exclusive=true
+            - Birdmap_Mqtt__QueueSettings__AutoDelete=true
             - Birdmap_Mqtt__ClientSettings__Id=ASP.NET Core client
             - Birdmap_Mqtt__ClientSettings__Username=username
             - Birdmap_Mqtt__ClientSettings__Password=password