namespace Dpz.Core.MessageQueue.Enums;

/// <summary>
/// RabbitMQ Exchange 类型枚举
/// </summary>
public enum ExchangeType
{
    /// <summary>
    /// 直接路由：精确匹配路由键
    /// 用途：点对点消息传递，如订单系统中特定用户的通知
    /// 示例：routing key "order.created" 只发送到绑定了 "order.created" 的队列
    /// </summary>
    Direct,

    /// <summary>
    /// 主题路由：支持通配符匹配路由键
    /// 用途：发布/订阅模式，支持灵活的消息分类
    /// 通配符：
    ///   * (星号) - 匹配一个单词，如 "order.*.created" 匹配 "order.user.created"
    ///   # (井号) - 匹配零个或多个单词，如 "order.#" 匹配 "order.user.created.success"
    /// 示例：
    ///   routing key "news.tech.ai"
    ///   可被 "news.tech.*" 或 "news.#" 的队列接收
    /// </summary>
    Topic,

    /// <summary>
    /// 广播路由：忽略路由键，发送到所有绑定的队列
    /// 用途：消息广播，如系统配置更新、缓存清除通知
    /// 示例：一条消息发送到所有订阅的微服务实例
    /// 性能：最快的路由方式，无需匹配路由键
    /// </summary>
    Fanout,

    /// <summary>
    /// 头部路由：根据消息头（Headers）属性匹配，忽略路由键
    /// 用途：复杂的路由规则，如根据消息优先级、来源、类型等多个维度路由
    /// 匹配模式：
    ///   x-match: all - 所有头部属性都匹配（AND）
    ///   x-match: any - 任一头部属性匹配（OR）
    /// 示例：根据 {"priority": "high", "type": "alert"} 路由消息
    /// 性能：匹配速度慢于其他类型，较少使用
    /// </summary>
    Headers,
}

/// <summary>
/// Exchange 类型扩展方法
/// </summary>
public static class ExchangeTypeExtensions
{
    /// <summary>
    /// 转换为 RabbitMQ 的字符串表示
    /// </summary>
    public static string ToRabbitMQString(this ExchangeType exchangeType)
    {
        return exchangeType switch
        {
            ExchangeType.Direct => "direct",
            ExchangeType.Topic => "topic",
            ExchangeType.Fanout => "fanout",
            ExchangeType.Headers => "headers",
            _ => throw new ArgumentOutOfRangeException(nameof(exchangeType), exchangeType, null),
        };
    }

    /// <summary>
    /// 从字符串解析为枚举
    /// </summary>
    public static ExchangeType FromString(string exchangeType)
    {
        return exchangeType.ToLowerInvariant() switch
        {
            "direct" => ExchangeType.Direct,
            "topic" => ExchangeType.Topic,
            "fanout" => ExchangeType.Fanout,
            "headers" => ExchangeType.Headers,
            _ => throw new ArgumentException(
                $"未知的 Exchange 类型: {exchangeType}",
                nameof(exchangeType)
            ),
        };
    }
}