From ed76fe2ab63c6234ba1ac076143d1b8a0a68d85f Mon Sep 17 00:00:00 2001
From: Brant DeBow <125889545+brant-livefront@users.noreply.github.com>
Date: Mon, 15 Dec 2025 08:49:32 -0500
Subject: [PATCH] Refactor configuration for azure queue service for events to
 include queue name (#6724)

* Refactor configuration for azure queue service for events to include queue name

* Address PR feedback

* Add check for queue name before writing to Azure Queue Service

* Fix file encoding (lint error)
---
 dev/secrets.json.example                      |  4 ++++
 ...IntegrationsServiceCollectionExtensions.cs |  3 ++-
 .../AzureQueueEventWriteService.cs            |  2 +-
 src/Core/Settings/GlobalSettings.cs           | 20 ++++++++++++++++++-
 .../AzureQueueHostedService.cs                | 12 ++++++-----
 ...grationServiceCollectionExtensionsTests.cs |  3 ++-
 6 files changed, 35 insertions(+), 9 deletions(-)

diff --git a/dev/secrets.json.example b/dev/secrets.json.example
index c6a16846e9..0d4213aec1 100644
--- a/dev/secrets.json.example
+++ b/dev/secrets.json.example
@@ -33,6 +33,10 @@
       "id": "<your Installation Id>",
       "key": "<your Installation Key>"
     },
+    "events": {
+      "connectionString": "",
+      "queueName": "event"
+    },
     "licenseDirectory": "<full path to license directory>",
     "enableNewDeviceVerification": true,
     "enableEmailVerification": true
diff --git a/src/Core/AdminConsole/EventIntegrations/EventIntegrationsServiceCollectionExtensions.cs b/src/Core/AdminConsole/EventIntegrations/EventIntegrationsServiceCollectionExtensions.cs
index bd8ebf6483..5dce52d907 100644
--- a/src/Core/AdminConsole/EventIntegrations/EventIntegrationsServiceCollectionExtensions.cs
+++ b/src/Core/AdminConsole/EventIntegrations/EventIntegrationsServiceCollectionExtensions.cs
@@ -91,7 +91,8 @@ public static class EventIntegrationsServiceCollectionExtensions
             return services;
         }
 
-        if (CoreHelpers.SettingHasValue(globalSettings.Events.ConnectionString))
+        if (CoreHelpers.SettingHasValue(globalSettings.Events.ConnectionString) &&
+            CoreHelpers.SettingHasValue(globalSettings.Events.QueueName))
         {
             services.TryAddSingleton<IEventWriteService, AzureQueueEventWriteService>();
             return services;
diff --git a/src/Core/AdminConsole/Services/Implementations/AzureQueueEventWriteService.cs b/src/Core/AdminConsole/Services/Implementations/AzureQueueEventWriteService.cs
index f81175f7b5..4f48b64b5a 100644
--- a/src/Core/AdminConsole/Services/Implementations/AzureQueueEventWriteService.cs
+++ b/src/Core/AdminConsole/Services/Implementations/AzureQueueEventWriteService.cs
@@ -8,7 +8,7 @@ namespace Bit.Core.Services;
 public class AzureQueueEventWriteService : AzureQueueService<IEvent>, IEventWriteService
 {
     public AzureQueueEventWriteService(GlobalSettings globalSettings) : base(
-        new QueueClient(globalSettings.Events.ConnectionString, "event"),
+        new QueueClient(globalSettings.Events.ConnectionString, globalSettings.Events.QueueName),
         JsonHelpers.IgnoreWritingNull)
     { }
 
diff --git a/src/Core/Settings/GlobalSettings.cs b/src/Core/Settings/GlobalSettings.cs
index b0d7da05a2..ddc48521e3 100644
--- a/src/Core/Settings/GlobalSettings.cs
+++ b/src/Core/Settings/GlobalSettings.cs
@@ -56,7 +56,7 @@ public class GlobalSettings : IGlobalSettings
     public virtual EventLoggingSettings EventLogging { get; set; } = new EventLoggingSettings();
     public virtual MailSettings Mail { get; set; } = new MailSettings();
     public virtual IConnectionStringSettings Storage { get; set; } = new ConnectionStringSettings();
-    public virtual ConnectionStringSettings Events { get; set; } = new ConnectionStringSettings();
+    public virtual AzureQueueEventSettings Events { get; set; } = new AzureQueueEventSettings();
     public virtual DistributedCacheSettings DistributedCache { get; set; } = new DistributedCacheSettings();
     public virtual NotificationsSettings Notifications { get; set; } = new NotificationsSettings();
     public virtual IFileStorageSettings Attachment { get; set; }
@@ -395,6 +395,24 @@ public class GlobalSettings : IGlobalSettings
         }
     }
 
+    public class AzureQueueEventSettings : IConnectionStringSettings
+    {
+        private string _connectionString;
+        private string _queueName;
+
+        public string ConnectionString
+        {
+            get => _connectionString;
+            set => _connectionString = value?.Trim('"');
+        }
+
+        public string QueueName
+        {
+            get => _queueName;
+            set => _queueName = value?.Trim('"');
+        }
+    }
+
     public class ConnectionStringSettings : IConnectionStringSettings
     {
         private string _connectionString;
diff --git a/src/EventsProcessor/AzureQueueHostedService.cs b/src/EventsProcessor/AzureQueueHostedService.cs
index 8dc0f12c0c..c4c02e32d2 100644
--- a/src/EventsProcessor/AzureQueueHostedService.cs
+++ b/src/EventsProcessor/AzureQueueHostedService.cs
@@ -6,6 +6,7 @@ using Azure.Storage.Queues;
 using Bit.Core;
 using Bit.Core.Models.Data;
 using Bit.Core.Services;
+using Bit.Core.Settings;
 using Bit.Core.Utilities;
 
 namespace Bit.EventsProcessor;
@@ -13,7 +14,7 @@ namespace Bit.EventsProcessor;
 public class AzureQueueHostedService : IHostedService, IDisposable
 {
     private readonly ILogger<AzureQueueHostedService> _logger;
-    private readonly IConfiguration _configuration;
+    private readonly GlobalSettings _globalSettings;
 
     private Task _executingTask;
     private CancellationTokenSource _cts;
@@ -22,10 +23,10 @@ public class AzureQueueHostedService : IHostedService, IDisposable
 
     public AzureQueueHostedService(
         ILogger<AzureQueueHostedService> logger,
-        IConfiguration configuration)
+        GlobalSettings globalSettings)
     {
         _logger = logger;
-        _configuration = configuration;
+        _globalSettings = globalSettings;
     }
 
     public Task StartAsync(CancellationToken cancellationToken)
@@ -56,11 +57,12 @@ public class AzureQueueHostedService : IHostedService, IDisposable
 
     private async Task ExecuteAsync(CancellationToken cancellationToken)
     {
-        var storageConnectionString = _configuration["azureStorageConnectionString"];
-        var queueName = _configuration["azureQueueServiceQueueName"];
+        var storageConnectionString = _globalSettings.Events.ConnectionString;
+        var queueName = _globalSettings.Events.QueueName;
         if (string.IsNullOrWhiteSpace(storageConnectionString) ||
             string.IsNullOrWhiteSpace(queueName))
         {
+            _logger.LogInformation("Azure Queue Hosted Service is disabled. Missing connection string or queue name.");
             return;
         }
 
diff --git a/test/Core.Test/AdminConsole/EventIntegrations/EventIntegrationServiceCollectionExtensionsTests.cs b/test/Core.Test/AdminConsole/EventIntegrations/EventIntegrationServiceCollectionExtensionsTests.cs
index aca783ade2..08fcd23969 100644
--- a/test/Core.Test/AdminConsole/EventIntegrations/EventIntegrationServiceCollectionExtensionsTests.cs
+++ b/test/Core.Test/AdminConsole/EventIntegrations/EventIntegrationServiceCollectionExtensionsTests.cs
@@ -727,7 +727,8 @@ public class EventIntegrationServiceCollectionExtensionsTests
         var services = new ServiceCollection();
         var globalSettings = CreateGlobalSettings(new Dictionary<string, string?>
         {
-            ["GlobalSettings:Events:ConnectionString"] = "DefaultEndpointsProtocol=https;AccountName=test;AccountKey=test;EndpointSuffix=core.windows.net"
+            ["GlobalSettings:Events:ConnectionString"] = "DefaultEndpointsProtocol=https;AccountName=test;AccountKey=test;EndpointSuffix=core.windows.net",
+            ["GlobalSettings:Events:QueueName"] = "event"
         });
 
         services.AddEventWriteServices(globalSettings);