using Microsoft.EntityFrameworkCore;
using SameBeat.Application.Interfejsy;
using SameBeat.Domain.Encje;
using SameBeat.Infrastructure.BazaDanych;

namespace SameBeat.Infrastructure.Repozytoria;

public class RepozytoriumWydarzen : IRepozytoriumWydarzen
{
    private readonly KontekstBazyDanych _kontekst;

    public RepozytoriumWydarzen(KontekstBazyDanych kontekst)
    {
        _kontekst = kontekst;
    }

    public Task<Wydarzenie?> PobierzOstatnieAsync(CancellationToken token = default) =>
        _kontekst.Wydarzenia
            .OrderByDescending(w => w.UtworzoneUtc)
            .FirstOrDefaultAsync(token);

    public Task<Wydarzenie?> ZnajdzPoIdAsync(Guid id, CancellationToken token = default) =>
        _kontekst.Wydarzenia.SingleOrDefaultAsync(w => w.Id == id, token);

    public void Dodaj(Wydarzenie wydarzenie) => _kontekst.Wydarzenia.Add(wydarzenie);
}