using CollabDAL.DTO.CollabEvent;
using CollabDAL.Query.CollabEvent;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace CollabDAL.CustomCode.CollabEvent;

public class CollabEventDAL(IQueryExecutor _qe) : ICollabEventDAL
{
    public async Task InsertEventAsync(CollabSessionEventDTO dto, LoginDTO login, CancellationToken ct)
    {
        await _qe.ExecuteAsync(
            login,
            CollabEventQB.INSERT_EVENT,
            new
            {
                dto.SessionId,
                dto.EventType,
                dto.TriggeredBy,
                dto.Payload,
                dto.DatabaseName,
            }).ConfigureAwait(false);
    }

    public async Task<List<CollabSessionEventDTO>> GetRecentEventsAsync(
        Guid sessionId, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<CollabSessionEventDTO>(
            login,
            CollabEventQB.GET_RECENT_EVENTS,
            new { SessionId = sessionId, login.DatabaseName }).ConfigureAwait(false);
        return result.ToList();
    }
}