// /**
//  * @swagger
//  * /api/endpoint/getadvancedsearchpaged_api:
//  *   get:
//  *     tags: [Search]
//  *     description: Advanced search paged
//  *     parameters:
//  *       - name: searchstring
//  *         description: search string
//  *         in: query
//  *         required: false
//  *         example: {
//  *                  "q":"cas-",
//  *                  "lpa":"744c69f4-48da-eb11-aac5-00224800be9c",
//  *                  "apt":"846040000",
//  *                  "statuscode":"1"}
//  *         schema:
//  *           type: string
//  *       - name: pageNumber
//  *         in: query
//  *         required: true
//  *         example: 1
//  *         schema:
//  *           type: string
//  *       - name: orderby
//  *         in: query
//  *         required: true
//  *         example: createdon
//  *         schema:
//  *           type: string
//  *       - name: fieldSort
//  *         in: query
//  *         required: true
//  *         description: asc or desc
//  *         example: asc
//  *         schema:
//  *           type: string
//  *       - name: showNumberOfRecords
//  *         in: query
//  *         required: true
//  *         description: number of records to return per page
//  *         example: 10
//  *         schema:
//  *           type: string
//  *     responses:
//  *       200:
//  *         description: Success
//  */

import _ from "lodash";
import { azureHeadersPagedCustom } from "../../../actions/core/headers";
import { respondError } from "../middleware/apiResponse";
import { relayGet } from "../middleware/relayForwarding";

export default async function ApiProxy(req, res) {
    const rawSearchString = req.query.searchstring;
    const pageNumber = req.query.pageNumber;
    const orderby = req.query.orderby;
    const fieldSort = req.query.fieldSort;
    const showNumberOfRecords = req.query.showNumberOfRecords;

    if (
        typeof rawSearchString !== "string" ||
        rawSearchString.trim().length === 0
    ) {
        return respondError(res, {
            status: 400,
            code: "SEARCH_STRING_REQUIRED",
            message: "searchstring is required"
        });
    }
    if (typeof orderby !== "string" || orderby.trim().length === 0) {
        return respondError(res, {
            status: 400,
            code: "ORDER_BY_REQUIRED",
            message: "orderby is required"
        });
    }
    if (typeof fieldSort !== "string" || fieldSort.trim().length === 0) {
        return respondError(res, {
            status: 400,
            code: "FIELD_SORT_REQUIRED",
            message: "fieldSort is required"
        });
    }
    if (
        typeof showNumberOfRecords !== "string" ||
        showNumberOfRecords.trim().length === 0
    ) {
        return respondError(res, {
            status: 400,
            code: "SHOW_NUMBER_OF_RECORDS_REQUIRED",
            message: "showNumberOfRecords is required"
        });
    }

    let searchString;
    try {
        searchString = JSON.parse(decodeURI(rawSearchString));
    } catch (error) {
        return respondError(res, {
            status: 400,
            code: "INVALID_SEARCH_STRING",
            message: "searchstring must be valid encoded JSON"
        });
    }

    var queryString = "";

    queryString +=
        _.has(searchString, "q") && searchString.q != null
            ? "(contains(title, '" +
              searchString.q.replace(/\'/g, "''") +
              "') or contains(ticketnumber,'" +
              searchString.q.replace(/\'/g, "''") +
              "')) and"
            : "";

    queryString +=
        _.has(searchString, "lpaRef") && searchString.lpaRef != null
            ? "(contains(pinswg_lpareference, '" +
              searchString.lpaRef.replace(/\'/g, "''") +
              "')) and"
            : "";

    queryString +=
        (_.has(searchString, "lpa") || _.has(searchString, "LPA")) &&
        searchString.lpa != null
            ? " _pinswg_associatedlpa_value eq " + searchString.lpa + " and"
            : "";

    queryString +=
        _.has(searchString, "apt") && searchString.apt != null
            ? " pinswg_appealcasetype eq " + searchString.apt + " and"
            : "";

    queryString +=
        _.has(searchString, "statuscode") && searchString.statuscode != null
            ? " statuscode eq " + searchString.statuscode + " and"
            : "";

    var queryUrl =
        "incidents?$select=pinswg_environmentalstatementlocation,pinswg_caseaddress,modifiedon,description,numberofchildincidents,_accountid_value,_customerid_value,_pinswg_associatedlpa_value,_ownerid_value,pinswg_appealcasetype,statuscode,ticketnumber,title,_primarycontactid_value,pinswg_lpareference,pinswg_appellantagent,pinswg_appellantfirstname,pinswg_appellantlastname&$expand=primarycontactid($select=fullname)&$filter=" +
        queryString +
        " pinswg_appealcasetype ne null and pinswg_publishtoweb eq true&$orderby=" +
        orderby +
        " " +
        fieldSort +
        "&$count=true" +
        (typeof pageNumber != "undefined"
            ? "&$skiptoken=" + ('<cookie pagenumber="' + pageNumber + '" />')
            : "");

    if (_.has(searchString, "projecttype")) {
        queryUrl =
            "pinswg_sipses?$count=true&$expand=pinswg_sipscase&$filter=_pinswg_projecttype_value eq " +
            searchString.projecttype +
            (searchString.hasOwnProperty("q")
                ? " and contains(pinswg_projectname, '" + searchString.q + "')"
                : "") +
            (searchString.hasOwnProperty("lpa")
                ? " and _pinswg_associatedlpa_value eq " +
                  searchString.lpa +
                  " "
                : "") +
            "&$orderby=" +
            orderby +
            " " +
            fieldSort +
            (typeof pageNumber != "undefined"
                ? "&$skiptoken=" +
                  ('<cookie pagenumber="' + pageNumber + '" />')
                : "");
    }

    return relayGet({
        queryUrl,
        res,
        requestOptionsBuilder: (accessToken) =>
            azureHeadersPagedCustom(accessToken, showNumberOfRecords),
        transformData: (data) => {
            let dataStr;
            _.has(data, "@odata.nextLink") === true &&
                ((dataStr = JSON.stringify(data["@odata.nextLink"])),
                (data["@odata.nextLink"] = dataStr.split("/v8.2/")[1]));

            return data;
        },
        errorResponse: {
            status: 400,
            code: "ADVANCED_SEARCH_PAGED_FETCH_FAILED",
            message: "Failed to fetch advanced search paged results"
        }
    });
}