using Dpz.Core.MessageQueue.Abstractions;
using Dpz.Core.MessageQueue.Models;

namespace Dpz.Core.MessageQueue.RabbitMQ;

public sealed class NullMessageOutboxStore : IMessageOutboxStore
{
    public static readonly Lazy<NullMessageOutboxStore> Instance = new(() =>
        new NullMessageOutboxStore()
    );

    public Task CreateAsync(
        string messageId,
        string messageType,
        string exchange,
        string routingKey,
        string payload,
        string? source,
        CancellationToken cancellationToken = default
    ) => Task.CompletedTask;

    public Task MarkSentAsync(string messageId, CancellationToken cancellationToken = default) =>
        Task.CompletedTask;

    public Task MarkPublishFailedAsync(
        string messageId,
        string error,
        CancellationToken cancellationToken = default
    ) => Task.CompletedTask;

    public Task MarkConsumedAsync(
        string messageId,
        CancellationToken cancellationToken = default
    ) => Task.CompletedTask;

    public Task MarkConsumeFailedAsync(
        string messageId,
        string error,
        CancellationToken cancellationToken = default
    ) => Task.CompletedTask;

    public Task<IReadOnlyList<MessageOutboxEntry>> GetPendingPublishRetryAsync(
        int batchSize,
        CancellationToken cancellationToken = default
    ) => Task.FromResult<IReadOnlyList<MessageOutboxEntry>>([]);

    public Task<IReadOnlyList<MessageOutboxEntry>> GetPendingConsumeRetryAsync(
        int batchSize,
        CancellationToken cancellationToken = default
    ) => Task.FromResult<IReadOnlyList<MessageOutboxEntry>>([]);
}