diff --git a/dist/package-shared/functions/backend/db/addDbEntry.js b/dist/package-shared/functions/backend/db/addDbEntry.js index 1ce6e84..f11cfd0 100644 --- a/dist/package-shared/functions/backend/db/addDbEntry.js +++ b/dist/package-shared/functions/backend/db/addDbEntry.js @@ -184,7 +184,7 @@ function addDbEntry(_a) { label: "queryValuesArray", }); } - const newInsert = yield (0, conn_db_handler_1.default)(DB_CONN, query, queryValuesArray); + const newInsert = yield (0, conn_db_handler_1.default)(DB_CONN, query, queryValuesArray, debug); if (debug) { (0, debug_log_1.default)({ log: newInsert, diff --git a/dist/package-shared/utils/db/conn-db-handler.d.ts b/dist/package-shared/utils/db/conn-db-handler.d.ts index d770791..56577eb 100644 --- a/dist/package-shared/utils/db/conn-db-handler.d.ts +++ b/dist/package-shared/utils/db/conn-db-handler.d.ts @@ -21,5 +21,5 @@ query?: QueryObject["query"] | QueryObject[], /** * Array of Values to Sanitize and Inject */ -values?: QueryObject["values"]): Promise>; +values?: QueryObject["values"], debug?: boolean): Promise>; export {}; diff --git a/dist/package-shared/utils/db/conn-db-handler.js b/dist/package-shared/utils/db/conn-db-handler.js index e68fa13..0d6c9bd 100644 --- a/dist/package-shared/utils/db/conn-db-handler.js +++ b/dist/package-shared/utils/db/conn-db-handler.js @@ -8,8 +8,12 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, ge step((generator = generator.apply(thisArg, _arguments || [])).next()); }); }; +var __importDefault = (this && this.__importDefault) || function (mod) { + return (mod && mod.__esModule) ? mod : { "default": mod }; +}; Object.defineProperty(exports, "__esModule", { value: true }); exports.default = connDbHandler; +const debug_log_1 = __importDefault(require("../logging/debug-log")); /** * # Run Query From MySQL Connection * @description Run a query from a pre-existing MySQL/Mariadb Connection @@ -27,7 +31,7 @@ query, /** * Array of Values to Sanitize and Inject */ -values) { +values, debug) { return __awaiter(this, void 0, void 0, function* () { var _a, _b; try { @@ -37,6 +41,13 @@ values) { throw new Error("Query String Required!"); if (typeof query == "string") { const res = yield conn.query(trimQuery(query), values); + if (debug) { + (0, debug_log_1.default)({ + log: res, + addTime: true, + label: "res", + }); + } return JSON.parse(JSON.stringify(res)); } else if (typeof query == "object") { @@ -45,6 +56,13 @@ values) { try { const queryObj = query[i]; const queryObjRes = yield conn.query(trimQuery(queryObj.query), queryObj.values); + if (debug) { + (0, debug_log_1.default)({ + log: queryObjRes, + addTime: true, + label: "queryObjRes", + }); + } resArray.push(JSON.parse(JSON.stringify(queryObjRes))); } catch (error) { @@ -52,6 +70,13 @@ values) { resArray.push(null); } } + if (debug) { + (0, debug_log_1.default)({ + log: resArray, + addTime: true, + label: "resArray", + }); + } return resArray; } else { diff --git a/package-shared/functions/backend/db/addDbEntry.ts b/package-shared/functions/backend/db/addDbEntry.ts index 569b3c5..e757fab 100644 --- a/package-shared/functions/backend/db/addDbEntry.ts +++ b/package-shared/functions/backend/db/addDbEntry.ts @@ -239,7 +239,12 @@ export default async function addDbEntry({ }); } - const newInsert = await connDbHandler(DB_CONN, query, queryValuesArray); + const newInsert = await connDbHandler( + DB_CONN, + query, + queryValuesArray, + debug + ); if (debug) { debugLog({ diff --git a/package-shared/utils/db/conn-db-handler.ts b/package-shared/utils/db/conn-db-handler.ts index aedfb88..3061196 100644 --- a/package-shared/utils/db/conn-db-handler.ts +++ b/package-shared/utils/db/conn-db-handler.ts @@ -1,4 +1,5 @@ import { ServerlessMysql } from "serverless-mysql"; +import debugLog from "../logging/debug-log"; type QueryObject = { query: string; @@ -24,7 +25,8 @@ export default async function connDbHandler( /** * Array of Values to Sanitize and Inject */ - values?: QueryObject["values"] + values?: QueryObject["values"], + debug?: boolean ): Promise> { try { if (!conn) throw new Error("No Connection Found!"); @@ -32,6 +34,14 @@ export default async function connDbHandler( if (typeof query == "string") { const res = await conn.query(trimQuery(query), values); + + if (debug) { + debugLog({ + log: res, + addTime: true, + label: "res", + }); + } return JSON.parse(JSON.stringify(res)); } else if (typeof query == "object") { const resArray = []; @@ -43,6 +53,15 @@ export default async function connDbHandler( trimQuery(queryObj.query), queryObj.values ); + + if (debug) { + debugLog({ + log: queryObjRes, + addTime: true, + label: "queryObjRes", + }); + } + resArray.push(JSON.parse(JSON.stringify(queryObjRes))); } catch (error: any) { global.ERROR_CALLBACK?.( @@ -53,6 +72,14 @@ export default async function connDbHandler( } } + if (debug) { + debugLog({ + log: resArray, + addTime: true, + label: "resArray", + }); + } + return resArray as any; } else { return null; diff --git a/package.json b/package.json index 7e59be5..9aab264 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@moduletrace/datasquirel", - "version": "4.4.6", + "version": "4.4.7", "description": "Cloud-based SQL data management tool", "main": "dist/index.js", "bin": {