/** * @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 axios from "axios"; import CryptoJS from "crypto-js"; import _ from "lodash"; import { azureHeadersPagedCustom, consoleLogger, getToken, } from "../../../actions"; const WORDKEY = process.env.HASHKEY; const WEBAPI_URL = process.env.RELAY_ROOT || "https://dev-pedw-ns.servicebus.windows.net/dev-pedw-hc/"; const hashAPIPath = (queryPath) => { var hashlink = CryptoJS.HmacSHA256( queryPath, CryptoJS.enc.Hex.parse(WORDKEY) ); hashlink = hashlink.toString(CryptoJS.enc.Hex); //return "&hash=" + hashlink; return (queryPath.indexOf("?") > -1 ? "&hash=" : "?hash=") + hashlink; }; export default async function ApiProxy(req, res) { var searchString = req.query.searchstring; var pageNumber = req.query.pageNumber; var token = await getToken(); var orderby = req.query.orderby; var fieldSort = req.query.fieldSort; var showNumberOfRecords = req.query.showNumberOfRecords; searchString = _.isEmpty(searchString) ? searchString : JSON.parse(decodeURI(searchString)); var queryString = ""; searchString.q = searchString.q.replace(/\'/g, "''"); queryString += _.has(searchString, "q") && searchString.q != null ? "(contains(title, '" + searchString.q + "') or contains(ticketnumber,'" + searchString.q + "')) and" : ""; queryString += _.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=modifiedon,description,numberofchildincidents,_accountid_value,_customerid_value,_pinswg_associatedlpa_value,_ownerid_value,pinswg_appealcasetype,statuscode,ticketnumber,title,_primarycontactid_value,pinswg_lpareference&$expand=primarycontactid($select=fullname)&$filter=" + queryString + " pinswg_appealcasetype ne null and pinswg_publishtoweb eq true&$orderby=" + orderby + " " + fieldSort + "&$count=true" + (typeof pageNumber != "undefined" ? "&$skiptoken=" + ('') : ""); //console.log("adv qu: ", queryUrl); var apiResponse = _.isEmpty(searchString) ? res.status(400).json() : axios .get( WEBAPI_URL + queryUrl + hashAPIPath(queryUrl), azureHeadersPagedCustom( token.access_token, showNumberOfRecords ) ) .then(({ data }) => { var dataStr; _.has(data, "@odata.nextLink") == true && ((dataStr = JSON.stringify(data["@odata.nextLink"])), (data["@odata.nextLink"] = dataStr.split("/v8.2/")[1])); res.status(200).json(data); }) .catch((error) => { consoleLogger(error); res.status(400).json(error); }); return apiResponse; }