using SameBeat.Domain.Encje;

namespace SameBeat.Application.Interfejsy;

public interface IRepozytoriumCzatu
{
    Task<UczestnikCzatu?> ZnajdzUczestnikaPoIdAsync(Guid id, CancellationToken token = default);

    void DodajUczestnika(UczestnikCzatu uczestnik);

    void DodajWiadomosc(WiadomoscCzatu wiadomosc);

    /// <summary>Ostatnia (najnowsza) wiadomosc danej tozsamosci czatu, niezaleznie od Usunieta -- podstawa rate limitu w SerwisCzatu.</summary>
    Task<WiadomoscCzatu?> PobierzOstatniaWiadomoscUczestnikaAsync(Guid nadawcaTozsamoscId, CancellationToken token = default);

    /// <summary>Ostatnie liczbaWiadomosci wiadomosci NIE usunietych dla wydarzenia, w kolejnosci chronologicznej (od najstarszej).</summary>
    Task<List<WiadomoscCzatu>> PobierzHistorieAsync(Guid wydarzenieId, int liczbaWiadomosci, CancellationToken token = default);

    Task<WiadomoscCzatu?> ZnajdzWiadomoscPoIdAsync(Guid id, CancellationToken token = default);
}