using Dpz.Core.Entity.Base;
using Dpz.Core.MessageQueue.Attributes;
using Dpz.Core.MessageQueue.Enums;
using Dpz.Core.MessageQueue.RabbitMQ;

namespace Dpz.Core.MessageQueue.Test.RabbitMQ;

public class DefaultMessageRoutingConventionTests
{
    [Fact]
    public void ConventionNames_ShouldUseTypeName_WhenNoAttribute()
    {
        var sut = new DefaultMessageRoutingConvention();

        var exchange = sut.GetExchangeName<NewsArticleMessage>();
        var queue = sut.GetQueueName<NewsArticleMessage>();
        var routingKey = sut.GetRoutingKey<NewsArticleMessage>();
        var type = sut.GetExchangeType<NewsArticleMessage>();

        Assert.Equal("dpz.news.exchange", exchange);
        Assert.Equal("dpz.news.article.queue", queue);
        Assert.Equal("news.article.#", routingKey);
        Assert.Equal(ExchangeType.Topic, type);
    }

    [Fact]
    public void ConventionNames_ShouldUseAttributeOverrides_WhenSpecified()
    {
        var sut = new DefaultMessageRoutingConvention();

        var exchange = sut.GetExchangeName<CustomRouteMessage>();
        var queue = sut.GetQueueName<CustomRouteMessage>();
        var routingKey = sut.GetRoutingKey<CustomRouteMessage>();
        var type = sut.GetExchangeType<CustomRouteMessage>();

        Assert.Equal("custom.exchange", exchange);
        Assert.Equal("custom.queue", queue);
        Assert.Equal("custom.route", routingKey);
        Assert.Equal(ExchangeType.Direct, type);
    }

    private sealed class NewsArticleMessage : MessageBase { }

    [MessageRoute(
        ExchangeName = "custom.exchange",
        QueueName = "custom.queue",
        RoutingKey = "custom.route",
        ExchangeType = ExchangeType.Direct
    )]
    private sealed class CustomRouteMessage : MessageBase { }
}