using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using TCMSDAL.DTO;
using TCMSDAL.Interfaces;
using TCMSDAL.QueryBuilders;

namespace TCMSDAL.Implementations;

public class TCMSTraceabilityDAL : ITCMSTraceabilityDAL
{
    private readonly IQueryExecutor _Qe;

    public TCMSTraceabilityDAL(IQueryExecutor queryExecutor)
        => _Qe = queryExecutor;

    // ── Screen links ──────────────────────────────────────────────────────────

    public async Task<int> InsertScreenLinkAsync(
        TCMSSaveLinkDTO dto, LoginDTO login, CancellationToken ct)
        => await _Qe.ExecuteScalarAsync<int>(
            login,
            TCMSTraceabilityQB.INSERT_SCREEN_LINK,
            new
            {
                dto.TestCaseId, dto.ScreenRoute,
                dto.ScreenTitle, dto.ModuleName,
                CreatedById = login.UserId,
            },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task DeleteScreenLinkAsync(
        int screenLinkId, LoginDTO login, CancellationToken ct)
        => await _Qe.ExecuteAsync(
            login,
            TCMSTraceabilityQB.DELETE_SCREEN_LINK,
            new { ScreenLinkId = screenLinkId },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task<IEnumerable<TCMSScreenLinkDTO>> GetScreenLinksForTestCaseAsync(
        int testCaseId, LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSScreenLinkDTO>(
            login,
            TCMSTraceabilityQB.GET_SCREEN_LINKS_FOR_TESTCASE,
            new { TestCaseId = testCaseId },
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSScreenLinkDTO>();

    // ── API links ─────────────────────────────────────────────────────────────

    public async Task<int> InsertApiLinkAsync(
        TCMSSaveApiLinkDTO dto, LoginDTO login, CancellationToken ct)
        => await _Qe.ExecuteScalarAsync<int>(
            login,
            TCMSTraceabilityQB.INSERT_API_LINK,
            new
            {
                dto.TestCaseId, dto.ApiOperationId,
                dto.ApiPath, dto.HttpMethod,
                CreatedById = login.UserId,
            },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task DeleteApiLinkAsync(
        int apiLinkId, LoginDTO login, CancellationToken ct)
        => await _Qe.ExecuteAsync(
            login,
            TCMSTraceabilityQB.DELETE_API_LINK,
            new { ApiLinkId = apiLinkId },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task<IEnumerable<TCMSApiLinkDTO>> GetApiLinksForTestCaseAsync(
        int testCaseId, LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSApiLinkDTO>(
            login,
            TCMSTraceabilityQB.GET_API_LINKS_FOR_TESTCASE,
            new { TestCaseId = testCaseId },
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSApiLinkDTO>();

    // ── Read queries ──────────────────────────────────────────────────────────

    public async Task<IEnumerable<TCMSTracedTestCaseDTO>> GetTestCasesByScreenAsync(
        string screenRoute, LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSTracedTestCaseDTO>(
            login,
            TCMSTraceabilityQB.GET_TESTCASES_BY_SCREEN,
            new { ScreenRoute = screenRoute },
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSTracedTestCaseDTO>();

    public async Task<IEnumerable<TCMSTracedTestCaseDTO>> GetTestCasesByApiOperationAsync(
        long apiOperationId, LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSTracedTestCaseDTO>(
            login,
            TCMSTraceabilityQB.GET_TESTCASES_BY_API_OPERATION,
            new { ApiOperationId = apiOperationId },
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSTracedTestCaseDTO>();

    public async Task<IEnumerable<TCMSTracedStepDTO>> GetStepsForCasesAsync(
        IEnumerable<int> caseIds, LoginDTO login, CancellationToken ct)
    {
        var csv = string.Join(',', caseIds);
        if (string.IsNullOrEmpty(csv)) return Enumerable.Empty<TCMSTracedStepDTO>();

        return await _Qe.QueryAsync<TCMSTracedStepDTO>(
            login,
            TCMSTraceabilityQB.GET_STEPS_FOR_CASES,
            new { CaseIdsCsv = csv },
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSTracedStepDTO>();
    }

    public async Task<TCMSScreenCoverageDTO?> GetScreenSummaryAsync(
        string screenRoute, LoginDTO login, CancellationToken ct)
    {
        var rows = await _Qe.QueryAsync<TCMSScreenCoverageDTO>(
            login,
            TCMSTraceabilityQB.GET_SCREEN_SUMMARY,
            new { ScreenRoute = screenRoute },
            cancellationToken: ct).ConfigureAwait(false);
        return rows?.FirstOrDefault();
    }

    public async Task<IEnumerable<TCMSScreenTreeNodeDTO>> GetScreenTreeAsync(
        LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSScreenTreeNodeDTO>(
            login,
            TCMSTraceabilityQB.GET_SCREEN_TREE,
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSScreenTreeNodeDTO>();

    // ── Gap detection ─────────────────────────────────────────────────────────

    public async Task<IEnumerable<TCMSCoverageGapDTO>> GetScreenGapsAsync(
        LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSCoverageGapDTO>(
            login,
            TCMSTraceabilityQB.GET_SCREEN_GAPS,
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSCoverageGapDTO>();

    public async Task<IEnumerable<TCMSCoverageGapDTO>> GetApiGapsAsync(
        LoginDTO login, CancellationToken ct)
        => await _Qe.QueryAsync<TCMSCoverageGapDTO>(
            login,
            TCMSTraceabilityQB.GET_API_GAPS,
            cancellationToken: ct).ConfigureAwait(false)
           ?? Enumerable.Empty<TCMSCoverageGapDTO>();
}