DigitalData.MessagingService/tests/DigitalData.MessagingService.Tests/Integration/EmailSenderUrlOverloadTests.cs

using DigitalData.MessagingService.Application.Common.Dto;
using DigitalData.MessagingService.Client;
using DigitalData.MessagingService.Domain.Entities;

namespace DigitalData.MessagingService.Tests.Integration;

/// <summary>
/// Integration tests for the URL-based <see cref="EmailSender.ConnectRabbitMq(string, string, string, OnReconnect)"/>
/// overload. All tests run inside <see cref="EmailSenderCollection"/> so they share the already-established
/// static connection. The URL overload is exercised via <see cref="OnReconnect.Ignore"/> and
/// <see cref="OnReconnect.ThrowException"/> to verify its delegation and guard behavior.
/// </summary>
[Collection(EmailSenderCollection.Name)]
public sealed class EmailSenderUrlOverloadTests
{
    private static readonly string ValidUrl = $"amqp://{RabbitMqTestConfig.HostName}:{RabbitMqTestConfig.Port}";
    private static readonly string ValidUrlWithVHost = $"amqp://{RabbitMqTestConfig.HostName}:{RabbitMqTestConfig.Port}/myvhost";

    [Fact]
    public void ConnectRabbitMq_UrlOverload_WhenAlreadyConnected_WithIgnore_DoesNotThrow()
    {
        var exception = Record.Exception(() =>
            EmailSender.ConnectRabbitMq(
                ValidUrl,
                RabbitMqTestConfig.UserName,
                RabbitMqTestConfig.Password,
                OnReconnect.Ignore));

        Assert.Null(exception);
    }

    [Fact]
    public void ConnectRabbitMq_UrlOverload_WhenAlreadyConnected_WithThrowException_Throws()
    {
        Assert.Throws<InvalidOperationException>(() =>
            EmailSender.ConnectRabbitMq(
                ValidUrl,
                RabbitMqTestConfig.UserName,
                RabbitMqTestConfig.Password,
                OnReconnect.ThrowException));
    }

    [Fact]
    public void ConnectRabbitMq_UrlOverload_WithVHostInPath_WithIgnore_DoesNotThrow()
    {
        var exception = Record.Exception(() =>
            EmailSender.ConnectRabbitMq(
                ValidUrlWithVHost,
                RabbitMqTestConfig.UserName,
                RabbitMqTestConfig.Password,
                OnReconnect.Ignore));

        Assert.Null(exception);
    }

    [Fact]
    public async Task Send_AfterUrlOverloadConnection_DoesNotThrow()
    {
        var email = new EmailContext
        {
            Sender = new EmailAccount { Username = "test@example.com", Password = "password", SmtpServer = "smtp.example.com" },
            Recipients = ["url-overload-test@example.com"],
            Subject = "URL Overload Integration Test",
            Body = "<p>Sent after URL-based connection.</p>",
            IsHtml = true
        };

        // Connection was established via Action<> overload in the fixture;
        // Send should work regardless of which overload was used to connect.
        var exception = await Record.ExceptionAsync(() => EmailSender.Send(email));

        Assert.Null(exception);
    }
}