using MessageService.Domain.Entities;

namespace MessageService.Domain.IReposities
{
    public interface IMessageReposity
    {
        Task<Message?> FindByIdAsync(Guid id);
        Task<(IEnumerable<Message> messages, bool hasMore)> GetAsync(string streamKey, long? cusor, int direction, int limit);
        void Create(Message message);
    }
}