import { BASE_URL } from "../core/env";
import { consoleLogger } from "../core/logger";
import { logAndReturnResponse } from "./httpServiceUtils";
import { getJson, requestJson } from "../clients/endpointClient";
import { buildFileQuery, withBaseUrl } from "../clients/fileRouteBuilder";

export const getCaseMessage = (searchString) => {
    const route = buildFileQuery("/api/endpoint/getcasemessage_api", {
        id: searchString
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch(logAndReturnResponse);
};

export const getIncidentbyID = (searchString) => {
    const route = buildFileQuery("/api/endpoint/getincidentbyid_api", {
        searchString
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch(logAndReturnResponse);
};

export const getIsPublishedbyID = (searchString) => {
    const route = buildFileQuery("/api/endpoint/getispublishedbyid_api", {
        searchString
    });

    return getJson(route).catch(logAndReturnResponse);
};

export const getPartSavedAppeal = (searchString) => {
    const route = buildFileQuery("/api/endpoint/getpartsavedappeal_api", {
        searchString
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch(logAndReturnResponse);
};

export const getSIPSEvents = async (caseid) => {
    const route = buildFileQuery("/api/endpoint/getsipsevents_api", {
        caseid
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch(logAndReturnResponse);
};

export const getSIPSMedia = async (caseid) => {
    const route = buildFileQuery("/api/endpoint/getsipsmedia_api", {
        caseid
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch(logAndReturnResponse);
};

export const getAppealID = (
    caseReference,
    updateFormCollection,
    primaryAttribute
) => {
    const route = buildFileQuery("/api/endpoint/getappealid_api", {
        updateFormCollection,
        primaryAttribute,
        caseReference
    });

    return getJson(route)
        .then((data) => {
            const result = Object.entries(data.value[0]).filter(
                ([key]) => !key.startsWith("_")
            )[0][1];
            var appealID = result;
            return appealID;
        })
        .catch((error) => {
            consoleLogger(error);
        });
};

export const createNewCase = (
    appealTypeId,
    lpaID,
    contactid,
    createBody,
    containerName
) => {
    appealTypeId = parseInt(appealTypeId);

    var data = createBody;

    var queryUrl = buildFileQuery("/api/endpoint/createcase_api", {
        appealTypeId,
        lpaID,
        contactid,
        containername: containerName
    });

    var config = {
        method: "post",
        url: withBaseUrl(BASE_URL, queryUrl),
        data: data
    };

    return requestJson(config).catch((error) => {
        consoleLogger(error);
    });
};

export const createNewCaseBlob = (
    appealTypeId,
    lpaID,
    contactid,
    createBody,
    containerName,
    lpaName
) => {
    appealTypeId = parseInt(appealTypeId);

    var data = createBody;

    data.pinswg_lpaname = lpaName;
    data.createdon = new Date();

    var queryUrl = buildFileQuery("/api/file/createcase_api", {
        appealTypeId,
        lpaID,
        contactid,
        containername: containerName
    });

    var config = {
        method: "post",
        url: queryUrl,
        data: data
    };

    return requestJson(config).catch((error) => {
        consoleLogger(error);
    });
};

export const updateCase = async (
    incidentId,
    updateBody,
    updateFormCollection,
    primaryAttribute,
    caseReference
) => {
    var data = updateBody;

    var appealObj = await getAppealID(
        caseReference,
        updateFormCollection,
        primaryAttribute
    );

    var queryUrl = buildFileQuery("/api/endpoint/updatecase_api", {
        updateFormCollection,
        appealObj
    });

    var config = {
        method: "post",
        url: queryUrl,
        data: updateBody
    };

    return requestJson(config).catch((error) => {
        consoleLogger(error);
    });
};

export const updateCaseBlob = async (
    incidentId,
    updateBody,
    updateFormCollection,
    primaryAttribute,
    caseReference
) => {
    var data = updateBody;

    var appealObj = await getAppealID(
        caseReference,
        updateFormCollection,
        primaryAttribute
    );

    var queryUrl = buildFileQuery("/api/file/updatecase_api", {
        updateFormCollection,
        appealObj
    });

    var config = {
        method: "post",
        url: queryUrl,
        data: updateBody
    };

    return requestJson(config).catch((error) => {
        consoleLogger(error);
    });
};

export const patchCase = async (incidentid) => {
    var queryUrl = buildFileQuery("/api/endpoint/patchcase_api", {
        incidentid
    });
    return getJson(queryUrl).catch((error) => {
        //console.log("this error:", error);
    });
};

export const getCase = (incidentID) => {
    const route = buildFileQuery("/api/endpoint/getcase_api", {
        incidentID
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
    });
};

export const getCaseByID = (incidentID) => {
    const route = buildFileQuery("/api/endpoint/getcasebyid_api", {
        incidentID
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
    });
};

export const getAppealPDFDocs = (incidentID) => {
    const route = buildFileQuery("/api/endpoint/getappealpdfdocuments_api", {
        incidentid: incidentID
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
    });
};

export const getAppealPDFDocument = async (incidentid) => {
    const route = buildFileQuery("/api/endpoint/getappealpdfdocuments_api", {
        incidentid
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
        return error.response;
    });
};

export const getPortalModuleDetails = async (appealType, caseReference) => {
    const route = buildFileQuery("/api/endpoint/getportalmoduledetails_api", {
        appealType,
        caseReference: encodeURI(caseReference)
    });

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
    });
};

export const getPortalModuleDetailsProxy = (appealType, caseReference) => {
    const route = buildFileQuery(
        "/api/endpoint/getportalmoduledetailsproxy_api",
        {
            appealType,
            caseReference: caseReference.replace(/\'/g, "''")
        }
    );

    return getJson(route).catch((error) => {
        consoleLogger(error);
    });
};

export const getCaseStatus = async (appealType, caseReference) => {
    const route = buildFileQuery("/api/endpoint/getStatusCounts_api", {});

    return getJson(withBaseUrl(BASE_URL, route)).catch((error) => {
        consoleLogger(error);
    });
};