fix(sqlserver): if we already have a connection just return we dont want to try a second time
This commit is contained in:
@@ -1,111 +1,198 @@
|
|||||||
import sql from "mssql";
|
import sql from "mssql";
|
||||||
import {prodSqlConfig} from "./utils/prodServerConfig.js";
|
import { prodSqlConfig } from "./utils/prodServerConfig.js";
|
||||||
import {createLog} from "../logger/logger.js";
|
import { createLog } from "../logger/logger.js";
|
||||||
import {db} from "../../../database/dbclient.js";
|
import { db } from "../../../database/dbclient.js";
|
||||||
import {settings} from "../../../database/schema/settings.js";
|
import { settings } from "../../../database/schema/settings.js";
|
||||||
import {eq} from "drizzle-orm";
|
import { eq } from "drizzle-orm";
|
||||||
import {installed} from "../../index.js";
|
import { installed } from "../../index.js";
|
||||||
import {checkHostnamePort} from "../../globalUtils/pingServer.js";
|
import { checkHostnamePort } from "../../globalUtils/pingServer.js";
|
||||||
|
|
||||||
let pool: any;
|
let pool: any;
|
||||||
let connected: boolean = false;
|
let connected: boolean = false;
|
||||||
export const initializeProdPool = async () => {
|
export const initializeProdPool = async () => {
|
||||||
if (!installed) {
|
if (!installed) {
|
||||||
createLog("info", "lst", "sqlProd", "The server was not installed will reconnect in 5 seconds");
|
createLog(
|
||||||
setTimeout(() => {
|
"info",
|
||||||
initializeProdPool();
|
"lst",
|
||||||
}, 5 * 1000);
|
"sqlProd",
|
||||||
|
"The server was not installed will reconnect in 5 seconds"
|
||||||
|
);
|
||||||
|
setTimeout(() => {
|
||||||
|
initializeProdPool();
|
||||||
|
}, 5 * 1000);
|
||||||
|
|
||||||
return {success: false, message: "The server is not installed."};
|
return { success: false, message: "The server is not installed." };
|
||||||
}
|
}
|
||||||
const dbServer = await db.select().from(settings).where(eq(settings.name, "dbServer"));
|
const dbServer = await db
|
||||||
const serverUp = await checkHostnamePort(`${dbServer[0].value}:1433`);
|
.select()
|
||||||
|
.from(settings)
|
||||||
|
.where(eq(settings.name, "dbServer"));
|
||||||
|
const serverUp = await checkHostnamePort(`${dbServer[0].value}:1433`);
|
||||||
|
|
||||||
if (!serverUp) {
|
if (!serverUp) {
|
||||||
createLog("error", "lst", "server", `The sql ${dbServer[0].value} is not reachable`);
|
createLog(
|
||||||
return {success: false, message: `The sql ${dbServer[0].value} is not reachable`};
|
"error",
|
||||||
}
|
"lst",
|
||||||
|
"server",
|
||||||
|
`The sql ${dbServer[0].value} is not reachable`
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: `The sql ${dbServer[0].value} is not reachable`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
// make sure the server is not set to localhost this will prevent some weird issues later but can be localhost on the dev
|
// make sure the server is not set to localhost this will prevent some weird issues later but can be localhost on the dev
|
||||||
const serverLoc = await db.select().from(settings).where(eq(settings.name, "dbServer"));
|
const serverLoc = await db
|
||||||
if (serverLoc[0].value === "localhost" && process.env.NODE_ENV !== "development") {
|
.select()
|
||||||
createLog("error", "lst", "sqlProd", "The server is set to localhost, and you are not in development mode.");
|
.from(settings)
|
||||||
return {success: false, message: "The server is set to localhost, and you are not in development mode."};
|
.where(eq(settings.name, "dbServer"));
|
||||||
}
|
if (
|
||||||
|
serverLoc[0].value === "localhost" &&
|
||||||
|
process.env.NODE_ENV !== "development"
|
||||||
|
) {
|
||||||
|
createLog(
|
||||||
|
"error",
|
||||||
|
"lst",
|
||||||
|
"sqlProd",
|
||||||
|
"The server is set to localhost, and you are not in development mode."
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message:
|
||||||
|
"The server is set to localhost, and you are not in development mode.",
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
// if you were restarting from the endpoint you get this lovely error
|
// if you were restarting from the endpoint you get this lovely error
|
||||||
if (connected) {
|
if (connected) {
|
||||||
createLog("error", "lst", "sqlProd", "There is already a connection.");
|
createLog("error", "lst", "sqlProd", "There is already a connection.");
|
||||||
return {success: false, message: "There is already a connection."};
|
return { success: false, message: "There is already a connection." };
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
const config = await prodSqlConfig();
|
const config = await prodSqlConfig();
|
||||||
pool = await sql.connect(config!);
|
pool = await sql.connect(config!);
|
||||||
|
|
||||||
createLog("info", "lst", "sqlProd", `Connected to ${config?.server}, and looking at ${config?.database}`);
|
createLog(
|
||||||
connected = true;
|
"info",
|
||||||
return {success: true, message: "The sql server connection has been closed"};
|
"lst",
|
||||||
} catch (error) {
|
"sqlProd",
|
||||||
createLog("error", "lst", "sqlProd", `${JSON.stringify(error)}, "There was an error connecting to the pool."`);
|
`Connected to ${config?.server}, and looking at ${config?.database}`
|
||||||
throw new Error("There was an error closing the sql connection");
|
);
|
||||||
}
|
connected = true;
|
||||||
|
return {
|
||||||
|
success: true,
|
||||||
|
message: "The sql server connection has been closed",
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
createLog(
|
||||||
|
"error",
|
||||||
|
"lst",
|
||||||
|
"sqlProd",
|
||||||
|
`${JSON.stringify(error)}, "There was an error connecting to the pool."`
|
||||||
|
);
|
||||||
|
throw new Error("There was an error closing the sql connection");
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
export const closePool = async () => {
|
export const closePool = async () => {
|
||||||
try {
|
if (!connected) {
|
||||||
await pool.close();
|
createLog(
|
||||||
createLog("info", "lst", "sqlProd", "Connection pool closed");
|
"error",
|
||||||
connected = false;
|
"lst",
|
||||||
return {success: true, message: "The sql server connection has been closed"};
|
"sqlProd",
|
||||||
} catch (error) {
|
"There is no connection a connection."
|
||||||
createLog(
|
);
|
||||||
"error",
|
return { success: false, message: "There is already a connection." };
|
||||||
"lst",
|
}
|
||||||
"sqlProd",
|
try {
|
||||||
`${JSON.stringify(error)}, "There was an error closing the sql connection"`
|
await pool.close();
|
||||||
);
|
createLog("info", "lst", "sqlProd", "Connection pool closed");
|
||||||
throw new Error("There was an error closing the sql connection");
|
connected = false;
|
||||||
}
|
return {
|
||||||
|
success: true,
|
||||||
|
message: "The sql server connection has been closed",
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
createLog(
|
||||||
|
"error",
|
||||||
|
"lst",
|
||||||
|
"sqlProd",
|
||||||
|
`${JSON.stringify(
|
||||||
|
error
|
||||||
|
)}, "There was an error closing the sql connection"`
|
||||||
|
);
|
||||||
|
throw new Error("There was an error closing the sql connection");
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
export async function query(queryToRun: string, name: string) {
|
export async function query(queryToRun: string, name: string) {
|
||||||
/**
|
/**
|
||||||
* Just an extra catch incase someone tried to run a query while we were not connected to the server or sql server
|
* Just an extra catch incase someone tried to run a query while we were not connected to the server or sql server
|
||||||
*/
|
*/
|
||||||
const dbServer = await db.select().from(settings).where(eq(settings.name, "dbServer"));
|
const dbServer = await db
|
||||||
const serverUp = await checkHostnamePort(`${dbServer[0].value}:1433`);
|
.select()
|
||||||
|
.from(settings)
|
||||||
|
.where(eq(settings.name, "dbServer"));
|
||||||
|
const serverUp = await checkHostnamePort(`${dbServer[0].value}:1433`);
|
||||||
|
|
||||||
if (!serverUp) {
|
if (!serverUp) {
|
||||||
createLog("error", "lst", "server", `The sql ${dbServer[0].value} is not reachable`);
|
createLog(
|
||||||
return {success: false, message: `The sql ${dbServer[0].value} is not reachable`};
|
"error",
|
||||||
|
"lst",
|
||||||
|
"server",
|
||||||
|
`The sql ${dbServer[0].value} is not reachable`
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: `The sql ${dbServer[0].value} is not reachable`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!connected) {
|
||||||
|
createLog(
|
||||||
|
"error",
|
||||||
|
"lst",
|
||||||
|
"server",
|
||||||
|
`The sql ${dbServer[0].value} is not connected`
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
success: false,
|
||||||
|
message: `The sql ${dbServer[0].value} is not not connected`,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* We no longer need to send over the plant token change as we do it inside the query function.
|
||||||
|
*/
|
||||||
|
const plantToken = await db
|
||||||
|
.select()
|
||||||
|
.from(settings)
|
||||||
|
.where(eq(settings.name, "plantToken"));
|
||||||
|
const query = queryToRun.replaceAll("test1", plantToken[0].value);
|
||||||
|
|
||||||
|
try {
|
||||||
|
const result = await pool.request().query(query);
|
||||||
|
|
||||||
|
return result.recordset;
|
||||||
|
} catch (error: any) {
|
||||||
|
if (error.code === "ETIMEOUT") {
|
||||||
|
createLog(
|
||||||
|
"error",
|
||||||
|
"lst",
|
||||||
|
"sqlProd",
|
||||||
|
`${JSON.stringify(error)}, ${name} did not run due to a timeout.`
|
||||||
|
);
|
||||||
|
throw new Error(`${name} query did not run due to a timeout.`);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!connected) {
|
if (error.code === "EREQUEST") {
|
||||||
createLog("error", "lst", "server", `The sql ${dbServer[0].value} is not connected`);
|
throw new Error(
|
||||||
return {success: false, message: `The sql ${dbServer[0].value} is not not connected`};
|
`${name} encoutnered an error ${error.originalError.info.message}`
|
||||||
|
);
|
||||||
}
|
}
|
||||||
/**
|
|
||||||
* We no longer need to send over the plant token change as we do it inside the query function.
|
|
||||||
*/
|
|
||||||
const plantToken = await db.select().from(settings).where(eq(settings.name, "plantToken"));
|
|
||||||
const query = queryToRun.replaceAll("test1", plantToken[0].value);
|
|
||||||
|
|
||||||
try {
|
//console.log(error.originalError.info.message);
|
||||||
const result = await pool.request().query(query);
|
//EREQUEST
|
||||||
|
//throw new Error(`${name} encoutnered an error ${error.code}`);
|
||||||
return result.recordset;
|
}
|
||||||
} catch (error: any) {
|
|
||||||
if (error.code === "ETIMEOUT") {
|
|
||||||
createLog("error", "lst", "sqlProd", `${JSON.stringify(error)}, ${name} did not run due to a timeout.`);
|
|
||||||
throw new Error(`${name} query did not run due to a timeout.`);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (error.code === "EREQUEST") {
|
|
||||||
throw new Error(`${name} encoutnered an error ${error.originalError.info.message}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
//console.log(error.originalError.info.message);
|
|
||||||
//EREQUEST
|
|
||||||
//throw new Error(`${name} encoutnered an error ${error.code}`);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user