TASK22211: normalize metadata and linked-case endpoint contracts

pages/api/endpoint/getappealid_api.js

@@ -29,40 +29,78 @@
  */
 
 import axios from "axios";
-import CryptoJS from "crypto-js";
 import { azureHeaders } 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) {
-    var caseReference = req.query.caseReference;
+    const caseReference = req.query.caseReference;
-    var updateFormCollection = req.query.updateFormCollection;
+    const updateFormCollection = req.query.updateFormCollection;
-    var primaryAttribute = req.query.primaryAttribute;
+    const primaryAttribute = req.query.primaryAttribute;
-    var token = await getToken();
 
-    const queryUrl =
+    if (
-        updateFormCollection +
+        typeof caseReference !== "string" ||
-        "?$count=true&$select=_" +
+        caseReference.trim().length === 0
-        primaryAttribute +
+    ) {
-        "s_value&$filter=pinswg_name eq '" +
+        return respondError(res, {
-        caseReference +
+            status: 400,
-        "'";
+            code: "CASE_REFERENCE_REQUIRED",
+            message: "caseReference is required"
+        });
+    }
 
-    return axios
+    if (
-        .get(
+        typeof updateFormCollection !== "string" ||
+        updateFormCollection.trim().length === 0
+    ) {
+        return respondError(res, {
+            status: 400,
+            code: "UPDATE_FORM_COLLECTION_REQUIRED",
+            message: "updateFormCollection is required"
+        });
+    }
+
+    if (
+        typeof primaryAttribute !== "string" ||
+        primaryAttribute.trim().length === 0
+    ) {
+        return respondError(res, {
+            status: 400,
+            code: "PRIMARY_ATTRIBUTE_REQUIRED",
+            message: "primaryAttribute is required"
+        });
+    }
+
+    try {
+        const token = await getToken();
+        const escapedCaseReference = caseReference.split("'").join("''");
+
+        const queryUrl =
+            updateFormCollection +
+            "?$count=true&$select=_" +
+            primaryAttribute +
+            "s_value&$filter=pinswg_name eq '" +
+            escapedCaseReference +
+            "'";
+
+        const { data } = await axios.get(
             WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
             azureHeaders(token.access_token)
-        )
+        );
-        .then(({ data }) => {
+
-            res.status(200).json(data);
+        return respondSuccess(res, data);
-        })
+    } catch (error) {
-        .catch((error) => {
+        consoleLogger(error);
-            consoleLogger(error);
+        return respondError(res, {
-            res.status(400).json(error);
+            status: 400,
+            code: "APPEAL_ID_FETCH_FAILED",
+            message: "Failed to fetch appeal id"
         });
+    }
 }

pages/api/endpoint/getappealtypes_api.js

@@ -10,42 +10,45 @@
  */
 
 import axios from "axios";
-import CryptoJS from "crypto-js";
 import { azureHeaders } 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) {
-    var token = await getToken();
+    try {
+        const token = await getToken();
 
-    var queryUrl =
+        const queryUrl =
-        "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype'  " +
+            "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype'  " +
-        (process.env.SHOWSIPS !== "true"
+            (process.env.SHOWSIPS !== "true"
-            ? "and attributevalue ne 846040002"
+                ? "and attributevalue ne 846040002"
-            : "") +
+                : "") +
-        "&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
+            "&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
 
-    // for sips
+        // for sips
-    // "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
+        // "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
 
-    // "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype' and value ne 'Misc Casework'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
+        // "stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype' and value ne 'Misc Casework'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
-    //"stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype' and value ne 'Developments of National Significance' and value ne 'LDP' and value ne 'Misc Casework'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
+        //"stringmaps?$filter=objecttypecode eq 'incident' and attributename eq 'pinswg_appealcasetype' and value ne 'Developments of National Significance' and value ne 'LDP' and value ne 'Misc Casework'&$count=true&$select=value,stringmapid,organizationid,attributevalue&$orderby=value asc";
 
-    return axios
+        const { data } = await axios.get(
-        .get(
             WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
             azureHeaders(token.access_token)
-        )
+        );
-        .then(({ data }) => {
+
-            res.status(200).json(data);
+        return respondSuccess(res, data);
-        })
+    } catch (error) {
-        .catch((error) => {
+        consoleLogger(error);
-            consoleLogger(error);
+        return respondError(res, {
-            res.status(400).json(error);
+            status: 400,
+            code: "APPEAL_TYPES_FETCH_FAILED",
+            message: "Failed to fetch appeal types"
         });
+    }
 }

pages/api/endpoint/getlinkedcases_api.js

@@ -17,35 +17,50 @@
  */
 
 import axios from "axios";
-import CryptoJS from "crypto-js";
 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) {
-    var parentIncidentid = req.query.parentincidentid;
+    const parentIncidentid = req.query.parentincidentid;
-    var token = await getToken();
 
-    var queryUrl =
+    if (
-        "incidents?$count=true&$filter=_parentcaseid_value eq " +
+        typeof parentIncidentid !== "string" ||
-        parentIncidentid +
+        parentIncidentid.trim().length === 0
-        " and pinswg_appealcasetype ne null and pinswg_publishtoweb eq true &$select=title, incidentid";
+    ) {
+        return respondError(res, {
+            status: 400,
+            code: "PARENT_INCIDENT_ID_REQUIRED",
+            message: "parentincidentid is required"
+        });
+    }
 
-    return axios
+    try {
-        .get(
+        const token = await getToken();
+
+        const queryUrl =
+            "incidents?$count=true&$filter=_parentcaseid_value eq " +
+            parentIncidentid +
+            " and pinswg_appealcasetype ne null and pinswg_publishtoweb eq true &$select=title, incidentid";
+
+        const { data } = await axios.get(
             WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
             azureHeadersPaged(token.access_token)
-        )
+        );
-        .then(({ data }) => {
+
-            res.status(200).json(data);
+        return respondSuccess(res, data);
-        })
+    } catch (error) {
-        .catch((error) => {
+        consoleLogger(error);
-            consoleLogger(error);
+        return respondError(res, {
-            res.status(400).json(error);
+            status: 400,
+            code: "LINKED_CASES_FETCH_FAILED",
+            message: "Failed to fetch linked cases"
         });
+    }
 }

pages/api/endpoint/getlpa_api.js

@@ -13,33 +13,35 @@
  */
 
 import axios from "axios";
-import CryptoJS from "crypto-js";
 import { azureHeaders } 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) {
-    var token = await getToken();
+    try {
+        const token = await getToken();
 
-    var queryUrl =
+        const queryUrl =
-        "accounts?$count=true&$filter=pinswg_isalocalplanningauthorityaccount eq 846040000&$select=name&$orderby=name asc";
+            "accounts?$count=true&$filter=pinswg_isalocalplanningauthorityaccount eq 846040000&$select=name&$orderby=name asc";
 
-    //console.log(WEBAPI_URL + queryUrl + hashAPIPath(queryUrl));
+        const { data } = await axios.get(
-    return axios
-        .get(
             WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
             azureHeaders(token.access_token)
-        )
+        );
-        .then(({ data }) => {
+
-            res.status(200).json(data);
+        return respondSuccess(res, data);
-        })
+    } catch (error) {
-        .catch((error) => {
+        consoleLogger(error);
-            consoleLogger(error);
+        return respondError(res, {
-            res.status(400).json(error);
+            status: 400,
+            code: "LPA_FETCH_FAILED",
+            message: "Failed to fetch local planning authorities"
         });
+    }
 }

pages/api/endpoint/getprojecttypes_api.js

@@ -10,34 +10,35 @@
  */
 
 import axios from "axios";
-import CryptoJS from "crypto-js";
 import { azureHeaders } 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) {
-    var token = await getToken();
+    try {
+        const token = await getToken();
 
-    var queryUrl =
+        const queryUrl =
-        "pinswg_sipsprojecttypes?$select=pinswg_name,pinswg_sipsprojecttypeid&$orderby=pinswg_name asc&$count=true";
+            "pinswg_sipsprojecttypes?$select=pinswg_name,pinswg_sipsprojecttypeid&$orderby=pinswg_name asc&$count=true";
 
-    //console.log(queryUrl);
+        const { data } = await axios.get(
-
-    return axios
-        .get(
             WEBAPI_URL + queryUrl + hashAPIPath(queryUrl),
             azureHeaders(token.access_token)
-        )
+        );
-        .then(({ data }) => {
+
-            res.status(200).json(data);
+        return respondSuccess(res, data);
-        })
+    } catch (error) {
-        .catch((error) => {
+        consoleLogger(error);
-            consoleLogger(error);
+        return respondError(res, {
-            res.status(400).json(error);
+            status: 400,
+            code: "PROJECT_TYPES_FETCH_FAILED",
+            message: "Failed to fetch project types"
         });
+    }
 }

tests/phase21/endpoint-handler-contract.test.cjs

@@ -2552,6 +2552,186 @@ test("deleteawaitingsubmissions catch path returns AWAITING_SUBMISSION_DELETE_FA
     );
 });
 
+test("getlpa catch path returns LPA_FETCH_FAILED", async () => {
+    const mod = loadModule("pages/api/endpoint/getlpa_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeaders: () => ({}),
+        axios: {
+            get: async () => {
+                throw new Error("relay failed");
+            }
+        },
+        consoleLogger: () => {}
+    });
+
+    const req = { query: {} };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(res.state.jsonBody.error.code, "LPA_FETCH_FAILED");
+});
+
+test("getappealid returns CASE_REFERENCE_REQUIRED when caseReference missing", async () => {
+    const mod = loadModule("pages/api/endpoint/getappealid_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeaders: () => ({}),
+        axios: { get: async () => ({ data: { value: [] } }) },
+        consoleLogger: () => {}
+    });
+
+    const req = {
+        query: {
+            updateFormCollection: "pinswg_planningappeals78s",
+            primaryAttribute: "pinswg_planningappeals78id"
+        }
+    };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(
+        res.state.jsonBody.error.code,
+        "CASE_REFERENCE_REQUIRED"
+    );
+});
+
+test("getappealid catch path returns APPEAL_ID_FETCH_FAILED", async () => {
+    const mod = loadModule("pages/api/endpoint/getappealid_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeaders: () => ({}),
+        axios: {
+            get: async () => {
+                throw new Error("relay failed");
+            }
+        },
+        consoleLogger: () => {}
+    });
+
+    const req = {
+        query: {
+            caseReference: "CAS-1",
+            updateFormCollection: "pinswg_planningappeals78s",
+            primaryAttribute: "pinswg_planningappeals78id"
+        }
+    };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(res.state.jsonBody.error.code, "APPEAL_ID_FETCH_FAILED");
+});
+
+test("getprojecttypes catch path returns PROJECT_TYPES_FETCH_FAILED", async () => {
+    const mod = loadModule("pages/api/endpoint/getprojecttypes_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeaders: () => ({}),
+        axios: {
+            get: async () => {
+                throw new Error("relay failed");
+            }
+        },
+        consoleLogger: () => {}
+    });
+
+    const req = { query: {} };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(
+        res.state.jsonBody.error.code,
+        "PROJECT_TYPES_FETCH_FAILED"
+    );
+});
+
+test("getappealtypes catch path returns APPEAL_TYPES_FETCH_FAILED", async () => {
+    const mod = loadModule("pages/api/endpoint/getappealtypes_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeaders: () => ({}),
+        axios: {
+            get: async () => {
+                throw new Error("relay failed");
+            }
+        },
+        consoleLogger: () => {},
+        process: { env: {} }
+    });
+
+    const req = { query: {} };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(
+        res.state.jsonBody.error.code,
+        "APPEAL_TYPES_FETCH_FAILED"
+    );
+});
+
+test("getlinkedcases returns PARENT_INCIDENT_ID_REQUIRED when parentincidentid missing", async () => {
+    const mod = loadModule("pages/api/endpoint/getlinkedcases_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeadersPaged: () => ({}),
+        axios: { get: async () => ({ data: { value: [] } }) },
+        consoleLogger: () => {}
+    });
+
+    const req = { query: {} };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(
+        res.state.jsonBody.error.code,
+        "PARENT_INCIDENT_ID_REQUIRED"
+    );
+});
+
+test("getlinkedcases catch path returns LINKED_CASES_FETCH_FAILED", async () => {
+    const mod = loadModule("pages/api/endpoint/getlinkedcases_api.js", {
+        respondError: respondErrorMock,
+        respondSuccess: respondSuccessMock,
+        getToken: async () => ({ access_token: "token" }),
+        hashAPIPath: () => "&hash=expected",
+        azureHeadersPaged: () => ({}),
+        axios: {
+            get: async () => {
+                throw new Error("relay failed");
+            }
+        },
+        consoleLogger: () => {}
+    });
+
+    const req = { query: { parentincidentid: "i1" } };
+    const res = createRes();
+    await mod.default(req, res);
+
+    assert.strictEqual(res.state.statusCode, 400);
+    assert.strictEqual(
+        res.state.jsonBody.error.code,
+        "LINKED_CASES_FETCH_FAILED"
+    );
+});
+
 const run = async () => {
     let passed = 0;
     for (const currentTest of tests) {