Skip to content

Commit

Permalink
Merge pull request #395 from USEPA/feature/update-server-app-logging
Browse files Browse the repository at this point in the history
Feature/update server app logging
  • Loading branch information
courtneymyers authored Feb 28, 2024
2 parents f9f7389 + 24e5bd5 commit ed093ef
Showing 1 changed file with 18 additions and 18 deletions.
36 changes: 18 additions & 18 deletions app/server/app/utilities/bap.js
Original file line number Diff line number Diff line change
Expand Up @@ -273,9 +273,9 @@ const {

/**
* Sets up the BAP connection and stores it in the Express app's locals object.
* @param {express.Application} app
* @param {express.Request} req
*/
function setupConnection(app) {
function setupConnection(req) {
const bapConnection = new jsforce.Connection({
oauth2: {
clientId: BAP_CLIENT_ID,
Expand All @@ -289,14 +289,14 @@ function setupConnection(app) {
.loginByOAuth2(BAP_USER, BAP_PASSWORD)
.then((userInfo) => {
const logMessage = `Initializing BAP connection: ${userInfo.url}.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** Store bapConnection in global express object using app.locals. */
app.locals.bapConnection = bapConnection;
/** Store bapConnection in global express object using req.app.locals. */
req.app.locals.bapConnection = bapConnection;
})
.catch((err) => {
const logMessage = `Error initializing BAP connection.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

throw err;
});
Expand All @@ -311,7 +311,7 @@ function setupConnection(app) {
*/
async function queryForSamEntities(req, email) {
const logMessage = `Querying the BAP for SAM.gov entities for user with email: '${email}'.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -412,7 +412,7 @@ async function queryForBapFormSubmissionData(
const logMessage =
`Querying the BAP for ${formType.toUpperCase()} submission data ` +
`associated with ${logId}.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -518,7 +518,7 @@ async function queryForBapFormSubmissionsStatuses(req, comboKeys) {
const logMessage =
`Querying the BAP for form submissions statuses associated with ` +
`combokeys: '${comboKeys}'.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -614,7 +614,7 @@ async function queryBapFor2022PRFData(req, frfReviewItemId) {
const logMessage =
`Querying the BAP for 2022 FRF submission associated with ` +
`FRF Review Item ID: '${frfReviewItemId}'.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -778,7 +778,7 @@ async function queryBapFor2023PRFData(req, frfReviewItemId) {
const logMessage =
`Querying the BAP for 2023 FRF submission associated with ` +
`FRF Review Item ID: '${frfReviewItemId}'.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -1035,7 +1035,7 @@ async function queryBapFor2022CRFData(req, frfReviewItemId, prfReviewItemId) {
`FRF Review Item ID: '${frfReviewItemId}' ` +
`and 2022 PRF submission associated with ` +
`PRF Review Item ID: '${prfReviewItemId}'.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

/** @type {jsforce.Connection} */
const { bapConnection } = req.app.locals;
Expand Down Expand Up @@ -1321,21 +1321,21 @@ function verifyBapConnection(req, { name, args }) {

if (!bapConnection) {
const logMessage = `BAP connection has not yet been initialized.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

return setupConnection(req.app).then(() => callback());
return setupConnection(req).then(() => callback());
}

return bapConnection
.identity((err, res) => {
.identity((err, _res) => {
if (err) {
const logMessage = `BAP connection identity error.`;
log({ level: "info", message: logMessage });
log({ level: "info", message: logMessage, req });

return setupConnection(req.app).then(() => callback());
return setupConnection(req).then(() => callback());
}
})
.then((res) => callback());
.then((_res) => callback());
}

/**
Expand Down

0 comments on commit ed093ef

Please sign in to comment.