diff --git a/app/src/pkg/prodSql/prodQuery.ts b/app/src/pkg/prodSql/prodQuery.ts index 6980787..d31f4bc 100644 --- a/app/src/pkg/prodSql/prodQuery.ts +++ b/app/src/pkg/prodSql/prodQuery.ts @@ -23,16 +23,15 @@ export async function prodQuery(queryToRun: string, name: string) { }); } const query = queryToRun.replaceAll("test1", env.PROD_PLANT_TOKEN); - try { const result = await pool.request().query(query); - return { success: true, message: `Query results for: ${name}`, data: result.recordset, }; } catch (error: any) { + console.log(error); if (error.code === "ETIMEOUT") { return returnFunc({ success: false, @@ -51,7 +50,7 @@ export async function prodQuery(queryToRun: string, name: string) { module: "prodSql", subModule: "query", level: "error", - message: `${name} encoutnered an error ${error.originalError.info.message}`, + message: `${name} encountered an error ${error.originalError.info.message}`, data: [], }); } diff --git a/app/src/pkg/prodSql/prodSqlConnect.ts b/app/src/pkg/prodSql/prodSqlConnect.ts index bfc7827..7e92b30 100644 --- a/app/src/pkg/prodSql/prodSqlConnect.ts +++ b/app/src/pkg/prodSql/prodSqlConnect.ts @@ -38,7 +38,7 @@ export const initializeProdPool = async () => { }); } try { - pool = sql.connect(sqlConfig); + pool = await sql.connect(sqlConfig); log.info( `Connected to ${sqlConfig?.server}, using DB: ${sqlConfig?.database}`