pedwfrontend/pages/api/endpoint/getadvancedsearch_api.js

/**
 * @swagger
 * /api/endpoint/getadvancedsearch_api:
 *   get:
 *     tags: [Search]
 *     description: Advanced search
 *     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
 *     responses:
 *       200:
 *         description: Success
 */

import axios from "axios";
import { azureHeadersPaged } from "../../../actions/core/headers";
import { consoleLogger } from "../../../actions/core/logger";
import { getToken } from "../../../actions/core/token";
import { hashAPIPath } from "../../../actions/core/hash";
import { respondError, respondSuccess } from "../middleware/apiResponse";

const WEBAPI_URL =
    process.env.RELAY_ROOT ||
    "https://dev-pedw-ns.servicebus.windows.net/dev-pedw-hc/";

export default async function ApiProxy(req, res) {
    const encodedSearchString = req.query.searchstring;

    if (
        typeof encodedSearchString !== "string" ||
        encodedSearchString.trim().length === 0
    ) {
        return respondError(res, {
            status: 400,
            code: "SEARCH_STRING_REQUIRED",
            message: "searchstring is required"
        });
    }

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

    if (
        !searchString ||
        typeof searchString !== "object" ||
        Object.keys(searchString).length === 0
    ) {
        return respondError(res, {
            status: 400,
            code: "SEARCH_STRING_REQUIRED",
            message: "searchstring is required"
        });
    }

    const toEscapedString = (value) => String(value).replace(/\'/g, "''");
    let queryString = "";

    queryString +=
        searchString.q != null
            ? "(contains(title, '" +
              toEscapedString(searchString.q) +
              "') or contains(ticketnumber,'" +
              toEscapedString(searchString.q) +
              "')) and"
            : "";

    queryString +=
        searchString.lpaRef != null
            ? "(contains(pinswg_lpareference, '" +
              toEscapedString(searchString.lpaRef) +
              "')) and"
            : "";

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

    queryString +=
        searchString.apt != null
            ? " pinswg_appealcasetype eq " + searchString.apt + " and"
            : "";

    queryString +=
        searchString.statuscode != null
            ? " statuscode eq " + searchString.statuscode + " and"
            : "";

    const 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=createdon desc&$count=true";

    try {
        const token = await getToken();
        const { data } = await axios.get(
            WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
            azureHeadersPaged(token.access_token)
        );

        if (Object.prototype.hasOwnProperty.call(data, "@odata.nextLink")) {
            const dataStr = JSON.stringify(data["@odata.nextLink"]);
            data["@odata.nextLink"] = dataStr.split("/v8.2/")[1];
        }

        if (searchString.projecttype != null) {
            for (let i = 0; i < data.value.length; i++) {
                const item = data.value[i];

                try {
                    const projectTypeQuery =
                        "pinswg_sipses?$filter=_pinswg_sipscase_value eq " +
                        item.incidentid +
                        " and _pinswg_projecttype_value eq " +
                        searchString.projecttype +
                        "&$select=_pinswg_projecttype_value";

                    const response = await axios.get(
                        WEBAPI_URL +
                            projectTypeQuery +
                            hashAPIPath(projectTypeQuery),
                        azureHeadersPaged(token.access_token)
                    );

                    if (
                        response.data.value.length > 0 &&
                        response.data.value[0]._pinswg_projecttype_value != null
                    ) {
                        Object.assign(item, response.data.value[0]);
                    }
                } catch (error) {
                    consoleLogger(error);
                }
            }

            data.value = data.value.filter(
                (item) => item._pinswg_projecttype_value != null
            );

            data["@odata.count"] = data.value.length;
        }

        return respondSuccess(res, data);
    } catch (error) {
        consoleLogger(error);
        return respondError(res, {
            status: 400,
            code: "ADVANCED_SEARCH_FETCH_FAILED",
            message: "Failed to fetch advanced search results"
        });
    }
}