Add additional logging to OS Handler.

This commit is contained in:
Patrick Fic
2025-02-20 14:37:25 -08:00
parent 5d0500582e
commit 0f32e6ffc7

View File

@@ -25,6 +25,10 @@ async function OpenSearchUpdateHandler(req, res) {
switch (req.body.table.name) { switch (req.body.table.name) {
case "jobs": case "jobs":
logger.log("os-handler-jobs", "DEBUG", req.user.email, null, {
jobid: req.body.event.data.new.id,
bodyshopid: req.body.event.data.new.shopid
});
document = pick(req.body.event.data.new, [ document = pick(req.body.event.data.new, [
"id", "id",
"bodyshopid", "bodyshopid",
@@ -49,6 +53,10 @@ async function OpenSearchUpdateHandler(req, res) {
document.bodyshopid = req.body.event.data.new.shopid; document.bodyshopid = req.body.event.data.new.shopid;
break; break;
case "vehicles": case "vehicles":
logger.log("os-handler-vehicles", "DEBUG", req.user.email, null, {
vehicleid: req.body.event.data.new.id,
bodyshopid: req.body.event.data.new.shopid
});
document = pick(req.body.event.data.new, [ document = pick(req.body.event.data.new, [
"id", "id",
"v_model_yr", "v_model_yr",
@@ -61,6 +69,10 @@ async function OpenSearchUpdateHandler(req, res) {
document.bodyshopid = req.body.event.data.new.shopid; document.bodyshopid = req.body.event.data.new.shopid;
break; break;
case "owners": case "owners":
logger.log("os-handler-owners", "DEBUG", req.user.email, null, {
ownerid: req.body.event.data.new.id,
bodyshopid: req.body.event.data.new.shopid
});
document = pick(req.body.event.data.new, ["id", "ownr_fn", "ownr_ln", "ownr_co_nm", "ownr_ph1", "ownr_ph2"]); document = pick(req.body.event.data.new, ["id", "ownr_fn", "ownr_ln", "ownr_co_nm", "ownr_ph1", "ownr_ph2"]);
document.bodyshopid = req.body.event.data.new.shopid; document.bodyshopid = req.body.event.data.new.shopid;
break; break;
@@ -96,9 +108,15 @@ async function OpenSearchUpdateHandler(req, res) {
...bill.bills_by_pk, ...bill.bills_by_pk,
bodyshopid: bill.bills_by_pk.job.shopid bodyshopid: bill.bills_by_pk.job.shopid
}; };
logger.log("os-handler-bills", "DEBUG", req.user.email, null, {
billid: req.body.event.data.new.id,
bodyshopid: bill.bills_by_pk.job.shopid
});
break; break;
case "payments": case "payments":
//Query to get the job and RO number //Query to get the job and RO number
const payment = await client.request( const payment = await client.request(
`query ADMIN_GET_PAYMENT_BY_ID($paymentId: uuid!) { `query ADMIN_GET_PAYMENT_BY_ID($paymentId: uuid!) {
payments_by_pk(id: $paymentId) { payments_by_pk(id: $paymentId) {
@@ -139,6 +157,10 @@ async function OpenSearchUpdateHandler(req, res) {
...payment.payments_by_pk, ...payment.payments_by_pk,
bodyshopid: payment.payments_by_pk.job.shopid bodyshopid: payment.payments_by_pk.job.shopid
}; };
logger.log("os-handler-payments", "DEBUG", req.user.email, null, {
paymentid: req.body.event.data.new.id,
bodyshopid: payment.payments_by_pk.job.shopid
});
break; break;
} }
const payload = { const payload = {
@@ -166,7 +188,9 @@ async function OpenSearchSearchHandler(req, res) {
} }
logger.log("os-search", "DEBUG", req.user.email, null, { logger.log("os-search", "DEBUG", req.user.email, null, {
search search,
index,
bodyshopid
}); });
const BearerToken = req.BearerToken; const BearerToken = req.BearerToken;