rabbit library

Author: mehmetozkaya

src/Basket/Basket.API/Basket.API.csproj

@@ -14,5 +14,9 @@
     <PackageReference Include="Swashbuckle.AspNetCore" Version="5.3.1" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\..\Common\EventBusRabbitMQ\EventBusRabbitMQ.csproj" />
+  </ItemGroup>
+
 
 </Project>

src/Basket/Basket.API/Startup.cs

@@ -6,6 +6,7 @@
 using Basket.API.Data.Interfaces;
 using Basket.API.Repositories;
 using Basket.API.Repositories.Interfaces;
+using EventBusRabbitMQ;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
@@ -14,6 +15,7 @@
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using Microsoft.OpenApi.Models;
+using RabbitMQ.Client;
 using StackExchange.Redis;
 
 namespace Basket.API
@@ -30,7 +32,7 @@ public Startup(IConfiguration configuration)
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
         {
-            services.AddControllers();
+            services.AddControllers();            
 
             #region Redis Dependencies
 
@@ -58,6 +60,32 @@ public void ConfigureServices(IServiceCollection services)
             });
 
             #endregion
+
+
+            #region RabbitMQ Dependencies
+
+            services.AddSingleton<IRabbitMQConnection>(sp =>
+            {
+                var factory = new ConnectionFactory()
+                {
+                    HostName = Configuration["EventBusHostName"]
+                };
+
+                if (!string.IsNullOrEmpty(Configuration["EventBusUserName"]))
+                {
+                    factory.UserName = Configuration["EventBusUserName"];
+                }
+
+                if (!string.IsNullOrEmpty(Configuration["EventBusPassword"]))
+                {
+                    factory.Password = Configuration["EventBusPassword"];
+                }
+
+                return new RabbitMQConnection(factory);
+            });
+
+            #endregion            
+
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

src/Common/EventBusRabbitMQ/Common/BasketCheckout.cs

@@ -0,0 +1,20 @@
+using System;
+
+namespace EventBusRabbitMQ.Common
+{
+    public class BasketCheckout
+    {
+        public string City { get; set; }
+        public string Street { get; set; }
+        public string State { get; set; }
+        public string Country { get; set; }
+        public string ZipCode { get; set; }
+        public string CardNumber { get; set; }
+        public string CardHolderName { get; set; }
+        public DateTime CardExpiration { get; set; }
+        public string CardSecurityNumber { get; set; }
+        public int CardTypeId { get; set; }
+        public string Buyer { get; set; }
+        public Guid RequestId { get; set; }
+    }
+}

src/Common/EventBusRabbitMQ/Common/EventBusConstants.cs

@@ -0,0 +1,7 @@
+namespace EventBusRabbitMQ.Common
+{
+    public static class EventBusConstants
+    {
+        public const string BasketCheckoutQueue = "basketCheckoutQueue";
+    }
+}

src/Common/EventBusRabbitMQ/Consumer/EventBusRabbitMQConsumer.cs

@@ -0,0 +1,48 @@
+using EventBusRabbitMQ.Common;
+using Newtonsoft.Json;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using System;
+using System.Text;
+
+namespace EventBusRabbitMQ.Consumer
+{
+    public class EventBusRabbitMQConsumer
+    {
+        private readonly IRabbitMQConnection _connection;
+
+        public EventBusRabbitMQConsumer(IRabbitMQConnection connection)
+        {
+            _connection = connection ?? throw new ArgumentNullException(nameof(connection));
+        }
+
+        public void Consume()
+        {
+            var channel = _connection.CreateModel();
+            channel.QueueDeclare(queue: EventBusConstants.BasketCheckoutQueue, durable: false, exclusive: false, autoDelete: false, arguments: null);
+
+            var consumer = new EventingBasicConsumer(channel);
+
+            //Create event when something receive
+            consumer.Received += ReceivedEvent;
+
+            channel.BasicConsume(queue: EventBusConstants.BasketCheckoutQueue, autoAck: true, consumer: consumer);
+        }
+
+        private void ReceivedEvent(object sender, BasicDeliverEventArgs e)
+        {
+            if (e.RoutingKey == EventBusConstants.BasketCheckoutQueue)
+            {
+                var message = Encoding.UTF8.GetString(e.Body);
+                BasketCheckout basketCheckout = JsonConvert.DeserializeObject<BasketCheckout>(message);
+
+                // TODO : stuff
+            }
+        }
+
+        public void Disconnect()
+        {
+            _connection.Dispose();
+        }
+    }
+}

src/Common/EventBusRabbitMQ/EventBusRabbitMQ.csproj

@@ -5,6 +5,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
     <PackageReference Include="RabbitMQ.Client" Version="5.1.2" />
   </ItemGroup>
 

src/Common/EventBusRabbitMQ/Producer/EventBusRabbitMQProducer.cs

@@ -0,0 +1,43 @@
+using EventBusRabbitMQ.Common;
+using Newtonsoft.Json;
+using RabbitMQ.Client;
+using System;
+using System.Text;
+
+namespace EventBusRabbitMQ.Producer
+{
+    public class EventBusRabbitMQProducer
+    {
+        private readonly IRabbitMQConnection _connection;
+
+        public EventBusRabbitMQProducer(IRabbitMQConnection connection)
+        {
+            _connection = connection ?? throw new ArgumentNullException(nameof(connection));
+        }
+
+        public void PublishBasketCheckout(string queueName, BasketCheckout publishModel)
+        {
+            using (var channel = _connection.CreateModel())
+            {
+                channel.QueueDeclare(queue: queueName, durable: false, exclusive: false, autoDelete: false, arguments: null);
+                var message = JsonConvert.SerializeObject(publishModel);
+                var body = Encoding.UTF8.GetBytes(message);
+
+                IBasicProperties properties = channel.CreateBasicProperties();
+                properties.Persistent = true;
+                properties.DeliveryMode = 2;
+
+                channel.ConfirmSelect();
+                channel.BasicPublish(exchange: "", routingKey: queueName, mandatory: true, basicProperties: properties, body: body);
+                channel.WaitForConfirmsOrDie();
+
+                channel.BasicAcks += (sender, eventArgs) =>
+                {
+                    Console.WriteLine("Sent RabbitMQ");
+                    //implement ack handle
+                };
+                channel.ConfirmSelect();
+            }
+        }
+    }
+}