Cleanuparr/code/backend/Cleanuparr.Infrastructure/Features/DownloadRemover/Consumers/DownloadRemoverConsumer.cs

using Cleanuparr.Infrastructure.Features.DownloadRemover.Interfaces;
using Cleanuparr.Infrastructure.Features.DownloadRemover.Models;
using Data.Models.Arr;
using MassTransit;
using Microsoft.Extensions.Logging;

namespace Cleanuparr.Infrastructure.Features.DownloadRemover.Consumers;

public class DownloadRemoverConsumer<T> : IConsumer<QueueItemRemoveRequest<T>>
    where T : SearchItem
{
    private readonly ILogger<DownloadRemoverConsumer<T>> _logger;
    private readonly IQueueItemRemover _queueItemRemover;

    public DownloadRemoverConsumer(
        ILogger<DownloadRemoverConsumer<T>> logger,
        IQueueItemRemover queueItemRemover
    )
    {
        _logger = logger;
        _queueItemRemover = queueItemRemover;
    }

    public async Task Consume(ConsumeContext<QueueItemRemoveRequest<T>> context)
    {
        try
        {
            await _queueItemRemover.RemoveQueueItemAsync(context.Message);
        }
        catch (Exception exception)
        {
            _logger.LogError(exception,
                "failed to remove queue item| {title} | {url}",
                context.Message.Record.Title,
                context.Message.Instance.Url
            );
        }
    }
}