namespace Dpz.Core.MessageQueue.Models;

/// <summary>
/// Outbox 后台补发服务记录在缓存中的最近一次运行状态。
/// </summary>
public sealed record MessageOutboxRetryState
{
    /// <summary>
    /// 初始化 Outbox 后台补发运行状态。
    /// </summary>
    /// <param name="startedAtUtc">本轮补发开始时间（UTC）。</param>
    /// <param name="completedAtUtc">本轮补发完成时间（UTC）。</param>
    /// <param name="publishRetryCount">本轮尝试补发发布失败消息的数量。</param>
    /// <param name="publishFailureCount">本轮发布失败消息补发后仍失败的数量。</param>
    /// <param name="consumeRetryCount">本轮尝试重新入队消费失败消息的数量。</param>
    /// <param name="consumeFailureCount">本轮消费失败消息重新入队后仍失败的数量。</param>
    public MessageOutboxRetryState(
        DateTimeOffset startedAtUtc,
        DateTimeOffset completedAtUtc,
        int publishRetryCount,
        int publishFailureCount,
        int consumeRetryCount,
        int consumeFailureCount
    )
    {
        StartedAtUtc = startedAtUtc;
        CompletedAtUtc = completedAtUtc;
        PublishRetryCount = publishRetryCount;
        PublishFailureCount = publishFailureCount;
        ConsumeRetryCount = consumeRetryCount;
        ConsumeFailureCount = consumeFailureCount;
    }

    /// <summary>
    /// 本轮补发开始时间（UTC）。
    /// </summary>
    public DateTimeOffset StartedAtUtc { get; init; }

    /// <summary>
    /// 本轮补发完成时间（UTC）。
    /// </summary>
    public DateTimeOffset CompletedAtUtc { get; init; }

    /// <summary>
    /// 本轮尝试补发发布失败消息的数量。
    /// </summary>
    public int PublishRetryCount { get; init; }

    /// <summary>
    /// 本轮发布失败消息补发后仍失败的数量。
    /// </summary>
    public int PublishFailureCount { get; init; }

    /// <summary>
    /// 本轮尝试重新入队消费失败消息的数量。
    /// </summary>
    public int ConsumeRetryCount { get; init; }

    /// <summary>
    /// 本轮消费失败消息重新入队后仍失败的数量。
    /// </summary>
    public int ConsumeFailureCount { get; init; }
}