Updates

package-shared/functions/backend/db/runQuery.js

@@ -11,6 +11,7 @@
 
 const fs = require("fs");
 
+const LOCAL_DB_HANDLER = require("../../../utils/backend/global-db/LOCAL_DB_HANDLER");
 const fullAccessDbHandler = require("../fullAccessDbHandler");
 const varReadOnlyDatabaseDbHandler = require("../varReadOnlyDatabaseDbHandler");
 const serverError = require("../serverError");
@@ -18,7 +19,6 @@ const serverError = require("../serverError");
 const addDbEntry = require("./addDbEntry");
 const updateDbEntry = require("./updateDbEntry");
 const deleteDbEntry = require("./deleteDbEntry");
-const DB_HANDLER = require("../../../utils/backend/global-db/DB_HANDLER");
 const parseDbResults = require("../parseDbResults");
 
 /** ****************************************************************************** */
@@ -90,7 +90,10 @@ async function runQuery({
     try {
         if (typeof query === "string") {
             if (local) {
-                const rawResults = await DB_HANDLER(query, queryValuesArray);
+                const rawResults = await LOCAL_DB_HANDLER(
+                    query,
+                    queryValuesArray
+                );
                 result = tableSchema
                     ? parseDbResults({
                           unparsedResults: rawResults,

package-shared/utils/backend/global-db/LOCAL_DB_HANDLER.js

@@ -0,0 +1,72 @@
+// @ts-check
+
+const mysql = require("serverless-mysql");
+const grabDbSSL = require("../grabDbSSL");
+
+// const mariadb = require("mariadb");
+// const pool = mariadb.createPool({
+//     host: process.env.DSQL_DB_HOST,
+//     user: process.env.DSQL_DB_USERNAME,
+//     password: process.env.DSQL_DB_PASSWORD,
+//     database: process.env.DSQL_DB_NAME,
+//     port: process.env.DSQL_DB_PORT
+//         ? Number(process.env.DSQL_DB_PORT)
+//         : undefined,
+//     charset: "utf8mb4",
+//     ssl: true,
+// });
+
+const MASTER = mysql({
+    config: {
+        host: process.env.DSQL_DB_HOST,
+        user: process.env.DSQL_DB_USERNAME,
+        password: process.env.DSQL_DB_PASSWORD,
+        database: process.env.DSQL_DB_NAME,
+        port: process.env.DSQL_DB_PORT
+            ? Number(process.env.DSQL_DB_PORT)
+            : undefined,
+        charset: "utf8mb4",
+        ssl: grabDbSSL(),
+        timeout: 1000,
+        connectTimeout: 1000,
+    },
+});
+
+/**
+ * DSQL user read-only DB handler
+ * @param {object} params
+ * @param {string} params.paradigm
+ * @param {string} params.database
+ * @param {string} params.queryString
+ * @param {string[]} [params.queryValues]
+ */
+async function LOCAL_DB_HANDLER(/** @type {any[]} */ ...args) {
+    MASTER.config({
+        host: process.env.DSQL_DB_HOST,
+        user: process.env.DSQL_DB_USERNAME,
+        password: process.env.DSQL_DB_PASSWORD,
+        database: process.env.DSQL_DB_NAME,
+        port: process.env.DSQL_DB_PORT
+            ? Number(process.env.DSQL_DB_PORT)
+            : undefined,
+        charset: "utf8mb4",
+        ssl: grabDbSSL(),
+        timeout: 1000,
+        connectTimeout: 1000,
+    });
+
+    try {
+        const results = await MASTER.query(...args);
+        await MASTER.end();
+
+        return JSON.parse(JSON.stringify(results));
+    } catch (/** @type {any} */ error) {
+        console.log("DB Error =>", error);
+        return {
+            success: false,
+            error: error.message,
+        };
+    }
+}
+
+module.exports = LOCAL_DB_HANDLER;