Merge pull request 'Moved Dockerfile, fixed RabbitMq connection fail in constructor' (#2) from feature/rabbit-mq into master

Reviewed-on: #2

Birdmap.API/Controllers/ServicesController.cs

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

Birdmap.API/Startup.cs

@@ -12,7 +12,6 @@ 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
@@ -72,7 +71,7 @@ namespace Birdmap.API
             {
                 opt.Title = "Birdmap";
                 opt.OperationProcessors.Add(new OperationSecurityScopeProcessor("Jwt Token"));
-                opt.AddSecurity("Jwt Token", Array.Empty<string>(),
+                opt.AddSecurity("Jwt Token", new string[] { },
                     new NSwag.OpenApiSecurityScheme
                     {
                         Type = NSwag.OpenApiSecuritySchemeType.ApiKey,
@@ -96,9 +95,11 @@ namespace Birdmap.API
             app.UseOpenApi();
             app.UseSwaggerUi3();
 
+            app.UseHttpsRedirection();
             app.UseStaticFiles();
             app.UseSpaStaticFiles();
 
+
             app.UseAuthentication();
             app.UseRouting();
             app.UseAuthorization();

Birdmap.API/appsettings.json

@@ -27,25 +27,10 @@
   "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.BLL/Options/RabbitMqClientOptions.cs

@@ -1,11 +1,4 @@
 namespace Birdmap.BLL.Options
 {
-    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);
+    public record RabbitMqClientOptions(string Hostname, int Port, string Username, string Password, string Topic);
 }

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

@@ -17,14 +17,14 @@ namespace Birdmap.BLL.Services.CommunationServices.RabbitMq
         private IConnection _connection;
         private IModel _channel;
         private readonly IConnectionFactory _factory;
-        private readonly RabbitMqClientOptions _options;
+        private readonly string _topic;
 
-        public override bool IsConnected => _connection.IsOpen;
+        public override bool IsConnected => throw new NotImplementedException();
 
         public RabbitMqClientService(RabbitMqClientOptions options, ILogger<RabbitMqClientService> logger, IInputService inputService, IHubContext<DevicesHub, IDevicesHubClient> hubContext)
             : base(logger, inputService, hubContext)
         {
-            _options = options;
+            _topic = options.Topic;
             _factory = new ConnectionFactory()
             {
                 HostName = options.Hostname,
@@ -85,26 +85,17 @@ namespace Birdmap.BLL.Services.CommunationServices.RabbitMq
             _connection = _factory.CreateConnection();
             _channel = _connection.CreateModel();
 
-            _channel.ExchangeDeclare(
-                exchange: _options.ExchangeName,
-                type: _options.ExchangeType,
-                durable: _options.ExchangeDurable,
-                autoDelete: _options.ExchangeAutoDelete);
+            _channel.ExchangeDeclare(exchange: "topic_logs", type: "topic");
+            var queueName = _channel.QueueDeclare().QueueName;
 
-            _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);
+            _channel.QueueBind(queue: queueName,
+                                  exchange: "topic_logs",
+                                  routingKey: _topic);
 
             var consumer = new AsyncEventingBasicConsumer(_channel);
             consumer.Received += OnRecieved;
 
-            _channel.BasicConsume(queue: _options.QueueName,
+            _channel.BasicConsume(queue: queueName,
                                  autoAck: true,
                                  consumer: consumer);
 

Birdmap.BLL/Startup.cs

@@ -61,25 +61,6 @@ 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"))
@@ -87,17 +68,8 @@ 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

docker-compose.yml

@@ -41,15 +41,6 @@ services:
             - 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