From 8c9973e55deafafe9f95b2b9b42be72934e912a3 Mon Sep 17 00:00:00 2001
From: Lisoveliy <lisoveliy@proton.me>
Date: Fri, 25 Jul 2025 16:27:27 +0300
Subject: [PATCH] feat: added RabbitMQ queue from back-end to hook auth for
 client

---
 .../Infrastructure/Config/RabbitQueues.cs       |  6 ++++++
 JOBot.Backend/Program.cs                        |  2 +-
 JOBot.Backend/Services/HeadHunterService.cs     | 17 +++++++++++++++--
 JOBot.Backend/Startup.cs                        | 11 ++++++++++-
 4 files changed, 32 insertions(+), 4 deletions(-)
 create mode 100644 JOBot.Backend/Infrastructure/Config/RabbitQueues.cs

diff --git a/JOBot.Backend/Infrastructure/Config/RabbitQueues.cs b/JOBot.Backend/Infrastructure/Config/RabbitQueues.cs
new file mode 100644
index 0000000..cc8de04
--- /dev/null
+++ b/JOBot.Backend/Infrastructure/Config/RabbitQueues.cs
@@ -0,0 +1,6 @@
+namespace JOBot.Backend.Infrastructure.Config;
+
+public static class RabbitQueues
+{
+    public const string AuthQueue = "auth";
+}
\ No newline at end of file
diff --git a/JOBot.Backend/Program.cs b/JOBot.Backend/Program.cs
index 95467a3..6e070ab 100644
--- a/JOBot.Backend/Program.cs
+++ b/JOBot.Backend/Program.cs
@@ -4,7 +4,7 @@ var builder = WebApplication.CreateBuilder(args);
 
 var startup = new Startup(builder.Configuration);
 
-startup.ConfigureServices(builder.Services);
+await startup.ConfigureServices(builder.Services);
 
 var app = builder.Build();
 startup.Configure(app, app.Environment);
diff --git a/JOBot.Backend/Services/HeadHunterService.cs b/JOBot.Backend/Services/HeadHunterService.cs
index e89ce38..3e67879 100644
--- a/JOBot.Backend/Services/HeadHunterService.cs
+++ b/JOBot.Backend/Services/HeadHunterService.cs
@@ -1,14 +1,19 @@
+using System.Text;
 using System.Text.Json;
-using System.Web;
 using JOBot.Backend.DAL.Context;
 using JOBot.Backend.DTOs.HeadHunterHook;
 using JOBot.Backend.Infrastructure.Config;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Options;
+using RabbitMQ.Client;
 
 namespace JOBot.Backend.Services;
 
-public class HeadHunterService(ILogger<HeadHunterService> logger, IOptions<HeadHunterConfig> config, AppDbContext dbContext)
+public class HeadHunterService(
+    IChannel channel, 
+    ILogger<HeadHunterService> logger, 
+    IOptions<HeadHunterConfig> config, 
+    AppDbContext dbContext)
 {
     private readonly HeadHunterConfig _config = config.Value;
 
@@ -88,6 +93,14 @@ public class HeadHunterService(ILogger<HeadHunterService> logger, IOptions<HeadH
         await dbContext.SaveChangesAsync();
         
         logger.LogInformation($"User {userId} auth completed!");
+        
+        await channel.BasicPublishAsync(
+            string.Empty, 
+            RabbitQueues.AuthQueue, 
+            Encoding.UTF8.GetBytes(userId.ToString()));
+        
+        logger.LogInformation($"RabbitMQ event was created");
+
         return Status.Success;
     }
 
diff --git a/JOBot.Backend/Startup.cs b/JOBot.Backend/Startup.cs
index 1295739..d08caed 100644
--- a/JOBot.Backend/Startup.cs
+++ b/JOBot.Backend/Startup.cs
@@ -3,6 +3,7 @@ using JOBot.Backend.Infrastructure.Config;
 using JOBot.Backend.Services;
 using JOBot.Backend.Services.gRPC;
 using Microsoft.EntityFrameworkCore;
+using RabbitMQ.Client;
 
 namespace JOBot.Backend;
 
@@ -10,12 +11,20 @@ public class Startup(IConfiguration configuration)
 {
     private IConfiguration Configuration { get; } = configuration;
 
-    public void ConfigureServices(IServiceCollection services)
+    public async Task ConfigureServices(IServiceCollection services)
     {
         services.AddGrpc(); 
         services.AddGrpcReflection();
         services.AddControllers();
         services.AddLogging();
+
+        await using var rabbitMqConnection = await new ConnectionFactory
+        {
+            HostName = "jobot-rabbitmq"
+        }.CreateConnectionAsync();
+        await using var channel = await rabbitMqConnection.CreateChannelAsync();
+        await channel.QueueDeclareAsync(RabbitQueues.AuthQueue, false, false, autoDelete: false);
+        services.AddSingleton(channel);
         
         services.AddDbContext<AppDbContext>(options =>
             options.UseNpgsql(Configuration.GetConnectionString("PostgreSQL")));