using Microsoft.Extensions.Logging;
using SameBeat.Application.DTO;
using SameBeat.Application.Interfejsy;
using SameBeat.Application.Komendy;
using SameBeat.Domain.Encje;
using SameBeat.Domain.Wyjatki;

namespace SameBeat.Application.Serwisy;

/// <summary>
/// Minimalny cykl zycia wydarzenia dla hosta: utworz -> start -> stop. Sama scena/sloty to ETAP 3.
/// </summary>
public sealed class SerwisZarzadzaniaWydarzeniem : ISerwisZarzadzaniaWydarzeniem
{
    private readonly IRepozytoriumWydarzen _repozytoriumWydarzen;
    private readonly IJednostkaPracy _jednostkaPracy;
    private readonly ILogger<SerwisZarzadzaniaWydarzeniem> _logger;

    public SerwisZarzadzaniaWydarzeniem(
        IRepozytoriumWydarzen repozytoriumWydarzen,
        IJednostkaPracy jednostkaPracy,
        ILogger<SerwisZarzadzaniaWydarzeniem> logger)
    {
        _repozytoriumWydarzen = repozytoriumWydarzen;
        _jednostkaPracy = jednostkaPracy;
        _logger = logger;
    }

    public async Task<WynikOperacji<WydarzenieDto>> UtworzAsync(UtworzWydarzenieKomenda komenda, CancellationToken token = default)
    {
        Wydarzenie wydarzenie;
        try
        {
            wydarzenie = Wydarzenie.Utworz(komenda.Nazwa);
        }
        catch (WyjatekDomenowy wyjatek)
        {
            return WynikOperacji<WydarzenieDto>.Niepowodzenie(wyjatek.Message);
        }

        _repozytoriumWydarzen.Dodaj(wydarzenie);
        await _jednostkaPracy.ZapiszZmianyAsync(token);

        _logger.LogInformation("Utworzono wydarzenie {WydarzenieId} ({Nazwa}).", wydarzenie.Id, wydarzenie.Nazwa);

        return WynikOperacji<WydarzenieDto>.Ok(DoDto(wydarzenie));
    }

    public async Task<WynikOperacji<WydarzenieDto>> StartujAsync(Guid wydarzenieId, CancellationToken token = default)
    {
        var wydarzenie = await _repozytoriumWydarzen.ZnajdzPoIdAsync(wydarzenieId, token);
        if (wydarzenie is null)
        {
            return WynikOperacji<WydarzenieDto>.Niepowodzenie("Nie znaleziono wydarzenia o podanym identyfikatorze.");
        }

        wydarzenie.PrzejdzNaLive();
        await _jednostkaPracy.ZapiszZmianyAsync(token);

        _logger.LogInformation("Wydarzenie {WydarzenieId} przeszlo na Live.", wydarzenie.Id);

        return WynikOperacji<WydarzenieDto>.Ok(DoDto(wydarzenie));
    }

    public async Task<WynikOperacji<WydarzenieDto>> ZatrzymajAsync(Guid wydarzenieId, CancellationToken token = default)
    {
        var wydarzenie = await _repozytoriumWydarzen.ZnajdzPoIdAsync(wydarzenieId, token);
        if (wydarzenie is null)
        {
            return WynikOperacji<WydarzenieDto>.Niepowodzenie("Nie znaleziono wydarzenia o podanym identyfikatorze.");
        }

        wydarzenie.PrzejdzNaOffline();
        await _jednostkaPracy.ZapiszZmianyAsync(token);

        _logger.LogInformation("Wydarzenie {WydarzenieId} przeszlo na Offline.", wydarzenie.Id);

        return WynikOperacji<WydarzenieDto>.Ok(DoDto(wydarzenie));
    }

    private static WydarzenieDto DoDto(Wydarzenie wydarzenie) => new(wydarzenie.Id, wydarzenie.Nazwa, wydarzenie.Status);
}