122 lines
3.3 KiB
TypeScript
122 lines
3.3 KiB
TypeScript
/**
|
|
* each endpoint will be something like
|
|
* /api/datamart/{name}?{criteria}
|
|
*
|
|
* when getting the current queries we will need to map through the available queries we currently have and send back.
|
|
* example
|
|
*{
|
|
* "name": "getopenorders",
|
|
* "endpoint": "/api/datamart/getopenorders",
|
|
* "description": "Returns open orders based on day count sent over, sDay 15 days in the past eDay 5 days in the future, can be left empty for this default days",
|
|
* "options": "sDay,eDay"
|
|
* },
|
|
*
|
|
* when a criteria is password over we will handle it by counting how many were passed up to 3 then deal with each one respectively
|
|
*/
|
|
import { prodQuery } from "../prodSql/prodSqlQuery.controller.js";
|
|
import {
|
|
type SqlQuery,
|
|
sqlQuerySelector,
|
|
} from "../prodSql/prodSqlQuerySelector.utils.js";
|
|
import { returnFunc } from "../utils/returnHelper.utils.js";
|
|
import { tryCatch } from "../utils/trycatch.utils.js";
|
|
import { datamartData } from "./datamartData.utlis.js";
|
|
|
|
type Options = {
|
|
name: string;
|
|
value: string;
|
|
};
|
|
type Data = {
|
|
name: string;
|
|
options: Options;
|
|
optionsRequired?: boolean;
|
|
howManyOptionsRequired?: number;
|
|
};
|
|
|
|
export const runDatamartQuery = async (data: Data) => {
|
|
// search the query db for the query by name
|
|
const sqlQuery = sqlQuerySelector(`${data.name}`) as SqlQuery;
|
|
|
|
const getDataMartInfo = datamartData.filter((x) => x.endpoint === data.name);
|
|
|
|
// const optionsMissing =
|
|
// !data.options || Object.keys(data.options).length === 0;
|
|
|
|
const optionCount =
|
|
Object.keys(data.options).length ===
|
|
getDataMartInfo[0]?.howManyOptionsRequired;
|
|
|
|
if (getDataMartInfo[0]?.optionsRequired && !optionCount) {
|
|
return returnFunc({
|
|
success: false,
|
|
level: "error",
|
|
module: "datamart",
|
|
subModule: "query",
|
|
message: `This query is required to have the ${getDataMartInfo[0]?.howManyOptionsRequired} options set in order use it.`,
|
|
data: [getDataMartInfo[0].options],
|
|
notify: false,
|
|
});
|
|
}
|
|
|
|
if (!sqlQuery.success) {
|
|
return returnFunc({
|
|
success: false,
|
|
level: "error",
|
|
module: "datamart",
|
|
subModule: "query",
|
|
message: `Error getting ${data.name} info`,
|
|
data: [sqlQuery.message],
|
|
notify: false,
|
|
});
|
|
}
|
|
|
|
// create the query with no changed just to have it here
|
|
let datamartQuery = sqlQuery?.query || "";
|
|
|
|
// split the criteria by "," then and then update the query
|
|
if (data.options) {
|
|
Object.entries(data.options ?? {}).forEach(([key, value]) => {
|
|
const pattern = new RegExp(`\\[${key.trim()}\\]`, "g");
|
|
datamartQuery = datamartQuery.replace(pattern, String(value).trim());
|
|
});
|
|
}
|
|
|
|
const { data: queryRun, error } = await tryCatch(
|
|
prodQuery(datamartQuery, `Running datamart query: ${data.name}`),
|
|
);
|
|
|
|
if (error) {
|
|
return returnFunc({
|
|
success: false,
|
|
level: "error",
|
|
module: "datamart",
|
|
subModule: "query",
|
|
message: `Data for: ${data.name} encountered an error while trying to get it`,
|
|
data: [error],
|
|
notify: false,
|
|
});
|
|
}
|
|
|
|
if (!queryRun.success) {
|
|
return returnFunc({
|
|
success: false,
|
|
level: "error",
|
|
module: "datamart",
|
|
subModule: "query",
|
|
message: queryRun.message,
|
|
data: queryRun.data,
|
|
notify: false,
|
|
});
|
|
}
|
|
|
|
return returnFunc({
|
|
success: true,
|
|
level: "info",
|
|
module: "datamart",
|
|
subModule: "query",
|
|
message: `Data for: ${data.name}`,
|
|
data: queryRun.data,
|
|
notify: false,
|
|
});
|
|
};
|