From 9a24ba177408dee001efe52bb7ad5bd1396e984d Mon Sep 17 00:00:00 2001
From: robbond <rob@rdbsolutions.co.uk>
Date: Fri, 13 Mar 2026 06:37:24 +0000
Subject: [PATCH] refactor(actions): phase 5 extract portal direct service

---
 actions/services/portalDirectService.js | 333 ++++++++++++++++++++++++
 actions/services/portalService.js       |   2 +-
 2 files changed, 334 insertions(+), 1 deletion(-)
 create mode 100644 actions/services/portalDirectService.js

diff --git a/actions/services/portalDirectService.js b/actions/services/portalDirectService.js
new file mode 100644
index 00000000..c0577505
--- /dev/null
+++ b/actions/services/portalDirectService.js
@@ -0,0 +1,333 @@
+import axios from "axios";
+import { BASE_URL } from "../core/env";
+import { consoleLogger } from "../core/logger";
+import { hashAPIPath } from "../core/hash";
+
+export const getMyCases = (loggedInUserId) => {
+    return axios
+        .get(
+            BASE_URL +
+                "/api/endpoint/getmycases_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getMyInvolvements = async (loggedInUserId) => {
+    try {
+        const res = await axios.get(
+            BASE_URL +
+                "/api/endpoint/getmyinvolvements_api?loggedInUserId=" +
+                loggedInUserId
+        );
+        return res.data;
+    } catch (error) {
+        consoleLogger(error);
+    }
+};
+
+export const getMyLPACases = (lpaid) => {
+    return axios
+        .get(BASE_URL + "/api/endpoint/getmylpacases_api?lpaid=" + lpaid)
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getMyRepresentations = (loggedInUserId) => {
+    return axios
+        .get(
+            BASE_URL +
+                "/api/endpoint/getmyrepresentations_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getMyRepresentationsProxy = (loggedInUserId) => {
+    return axios
+        .get(
+            "/api/endpoint/getmyrepresentationsproxy_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getRepresentations = (incidentID) => {
+    return axios
+        .get("/api/endpoint/getrepresentations_api?incidentID=" + incidentID)
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getRepresentationsProxy = (incidentID) => {
+    return axios
+        .get(
+            "/api/endpoint/getrepresentationsproxy_api?incidentID=" + incidentID
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getWatchedCases = (loggedInUserId) => {
+    return axios
+        .get(
+            BASE_URL +
+                "/api/endpoint/getwatchedcases_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getWatchedCasesProxy = (loggedInUserId) => {
+    return axios
+        .get(
+            "/api/endpoint/getwatchedcasesproxy_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getAwaitingSubmissionProxy = (loggedInUserId) => {
+    return axios
+        .get(
+            "/api/endpoint/getawaitingsubmissionproxy_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => res.data)
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const getAwaitingSubmission = (loggedInUserId) => {
+    return axios
+        .get(
+            BASE_URL +
+                "/api/endpoint/getawaitingsubmission_api?loggedInUserId=" +
+                loggedInUserId
+        )
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const createWatchedCases = async (formValues) => {
+    var data = formValues;
+    var queryUrl = "/api/endpoint/createwatchedcases_api";
+
+    var config = {
+        method: "post",
+        url: queryUrl,
+        data: data
+    };
+
+    try {
+        const res = await axios(config);
+        return res.data;
+    } catch (error) {
+        consoleLogger(error);
+    }
+};
+
+export const deleteMyRepresentations = (myRepresentationsID) => {
+    var queryUrl =
+        "/api/endpoint/deletemyrepresentations_api?myRepresentationsID=" +
+        myRepresentationsID;
+
+    var config = {
+        method: "delete",
+        url: queryUrl + hashAPIPath(queryUrl),
+        headers: {
+            "OData-MaxVersion": "4.0",
+            "OData-Version": "4.0",
+            "Accept": "application/json;odata.metadata=none",
+            "Prefer": 'odata.include-annotations="*",return=representation',
+            "Content-Type": "application/json"
+        }
+    };
+
+    return axios(config)
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const deleteAwaitingSubmissions = (incidentID) => {
+    var queryUrl =
+        "/api/endpoint/deleteawaitingsubmissions_api?incidentID=" + incidentID;
+
+    var config = {
+        method: "delete",
+        url: queryUrl
+    };
+
+    return axios(config)
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const deleteWatchedCases = async (watchedCaseID) => {
+    var queryUrl =
+        "/api/endpoint/deletewatchedcases_api?watchedCaseID=" + watchedCaseID;
+    var config = {
+        method: "delete",
+        url: queryUrl
+    };
+
+    try {
+        const res = await axios(config);
+        return res.data;
+    } catch (error) {
+        consoleLogger(error);
+    }
+};
+
+export const sendCaseCompleteMessage = async (
+    containerID,
+    caseReference,
+    inv
+) => {
+    var queryUrl =
+        "/api/file/createappealcompletemessage_api?container=" +
+        containerID +
+        "&tempcaseref=" +
+        caseReference +
+        "&inv=" +
+        inv;
+
+    var config = {
+        method: "get",
+        url: queryUrl
+    };
+
+    return axios(config)
+        .then((res) => {
+            console.log("sendCaseCompleteMessage: ", res.data);
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const sendCaseCompleteMessageProxy = async (
+    containerID,
+    caseReference
+) => {
+    var queryUrl =
+        "/api/file/createappealcompletemessageproxy_api?container=" +
+        containerID +
+        "&tempcaseref=" +
+        caseReference;
+
+    var config = {
+        method: "get",
+        url: queryUrl
+    };
+
+    return axios(config)
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const sendRepCompleteMessage = async (
+    containerID,
+    caseReference,
+    fileName
+) => {
+    var queryUrl =
+        "/api/file/createrepcompletemessage_api?container=" +
+        containerID +
+        "&tempcaseref=" +
+        caseReference +
+        "&repid=" +
+        fileName;
+
+    var config = {
+        method: "get",
+        url: queryUrl
+    };
+
+    return axios(config)
+        .then((res) => {
+            return res.data;
+        })
+        .catch((error) => {
+            consoleLogger(error);
+        });
+};
+
+export const setRepInvolvment = async (caseid, contactid) => {
+    var queryUrl = "/api/file/createrepinvolvement_api";
+
+    var data = { "incidentid": caseid, "contactid": contactid };
+    var config = {
+        method: "post",
+        url: queryUrl,
+        data: data
+    };
+
+    try {
+        const res = await axios(config);
+        return res.data;
+    } catch (error) {
+        consoleLogger(error);
+    }
+};
+
+export const setCaseInvolvment = async (caseid, contactid) => {
+    var queryUrl = "/api/file/createrepinvolvement_api";
+
+    var data = { "incidentid": caseid, "contactid": contactid };
+    var config = {
+        method: "post",
+        url: queryUrl,
+        data: data
+    };
+
+    try {
+        const res = await axios(config);
+        return res.data;
+    } catch (error) {
+        consoleLogger(error);
+    }
+};
diff --git a/actions/services/portalService.js b/actions/services/portalService.js
index 876a7242..a0b7f31c 100644
--- a/actions/services/portalService.js
+++ b/actions/services/portalService.js
@@ -19,7 +19,7 @@ import {
     sendRepCompleteMessage,
     setRepInvolvment,
     setCaseInvolvment
-} from "./legacyActionsService";
+} from "./portalDirectService";
 
 export {
     getMyCases,