server/src/Core/Services/Implementations/AzureQueueReferenceEventService.cs

using System.Text;
using System.Text.Json;
using Azure.Storage.Queues;
using Bit.Core.Models.Business;
using Bit.Core.Settings;
using Bit.Core.Utilities;

namespace Bit.Core.Services;

public class AzureQueueReferenceEventService : IReferenceEventService
{
    private const string _queueName = "reference-events";

    private readonly QueueClient _queueClient;
    private readonly GlobalSettings _globalSettings;

    public AzureQueueReferenceEventService(
        GlobalSettings globalSettings)
    {
        _queueClient = new QueueClient(globalSettings.Events.ConnectionString, _queueName);
        _globalSettings = globalSettings;
    }

    public async Task RaiseEventAsync(ReferenceEvent referenceEvent)
    {
        await SendMessageAsync(referenceEvent);
    }

    private async Task SendMessageAsync(ReferenceEvent referenceEvent)
    {
        if (_globalSettings.SelfHosted)
        {
            // Ignore for self-hosted
            return;
        }
        try
        {
            var message = JsonSerializer.Serialize(referenceEvent, JsonHelpers.IgnoreWritingNullAndCamelCase);
            // Messages need to be base64 encoded
            var encodedMessage = Convert.ToBase64String(Encoding.UTF8.GetBytes(message));
            await _queueClient.SendMessageAsync(encodedMessage);
        }
        catch
        {
            // Ignore failure
        }
    }
}