using System.Text;
using System.Text.Json;
using StandManager.Domain.DTO;
using StandManager.Domain.Entita;
using StandManager.Service.Interfaces;
using StandManager.Service.Mail;

namespace StandManager.Service;

public class RegistrazioneMailProcessor : IMailProcessor
{
    private readonly IManagerService _managerService;

    public RegistrazioneMailProcessor(IManagerService managerService)
    {
        _managerService = managerService;
    }

    public MailFrom MailFrom => MailFrom.Registrazione;

    public async Task ProcessAsync(List<MailQueue> mailQueueList, EmailConfig _config, HttpClient httpClient)
    {
        // Default size dei chunck è 20
        var size = _config.RangeSize != 0 ? _config.RangeSize : 20;
        // Estraggo i destinatari
        var to = _config.To.Split(_config.MailSplitCharTo).ToList();

        foreach (var chunk in mailQueueList.Chunk(size))
        {

            string body = string.Join(_config.MailSplitCharBody, chunk.Select(x => x.ToList));

            try
            {
                var email = new Email()
                {
                    From = _config.From,
                    Body = body,
                    Cc = null,
                    Subject = _config.Subject,
                    To = //to
                        new() { "g.vitari@oaservice.it" }
                };

                var messageJson = JsonSerializer.Serialize(email);

                // multipart
                using var form = new MultipartFormDataContent();
                form.Add(new StringContent(messageJson, Encoding.UTF8, "application/json"), "messageJson");

                //Attachments
                /* if (File.Exists(@"C:\temp\test.pdf")) {
                   var fileBytes = await File.ReadAllBytesAsync(@"C:\temp\test.pdf");
                   var fileContent = new ByteArrayContent(fileBytes);
                   fileContent.Headers.ContentType = MediaTypeHeaderValue.Parse("application/pdf");
                   form.Add(fileContent, "attachments", "test.pdf");
                } 
                */

                var response = await httpClient.PostAsync(
                    _config.ServerAddress,
                    form
                );
                response.EnsureSuccessStatusCode();
                Array.ForEach(chunk, item => item.Sent = true);
            }
            catch (Exception e)
            {
                Array.ForEach(chunk, item => item.Sent = false);
                Array.ForEach(chunk, item => item.Error = e.Message);
            }

            // Salvo in blocco le entità
            await _managerService.MailQueueService.Salva(chunk.ToList());
        }
    }
}