using Utility.Environment;
using Utility.Queue.Handler;
using Utility.Queue.Subscribers;
using Microsoft.Extensions.Hosting;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Utility.Queue
{
    public class QueueSubscriberService<T, U> : BackgroundService where T : IMessageHandler<U>
    {
        private readonly IServiceProvider ServiceProvider;
        private readonly IEnvironmentRequester EnvironmentRequester;

        public QueueSubscriber(IServiceProvider serviceProvider,
            IEnvironmentRequester environmentRequester)
        {
            ServiceProvider = serviceProvider;
            EnvironmentRequester = environmentRequester;
        }

        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            var subscriber = new SQSSubscriber(EnvironmentRequester, ServiceProvider);

            var nameResolver = new NameResolver(EnvironmentRequester);

            await subscriber.SetQueueName(nameResolver.GetQueueName<U>());

            await subscriber.PollSQS<T, U>(ServiceProvider, stoppingToken);
        }
    }
}