diff --git a/server/job/job-updated.js b/server/job/job-updated.js index 62f63b0e2..89637a6f8 100644 --- a/server/job/job-updated.js +++ b/server/job/job-updated.js @@ -2,7 +2,15 @@ const { isObject } = require("lodash"); const jobUpdated = async (req, res) => { const { ioRedis, logger, ioHelpers } = req; + // Old Way + if (req?.body?.event?.data?.new || isObject(req?.body?.event?.data?.new)) { + const updatedJob = req.body.event.data.new; + const bodyshopID = updatedJob.shopid; + ioRedis.to(ioHelpers.getBodyshopRoom(bodyshopID)).emit("production-job-updated", updatedJob); + return res.json({ message: "Job updated and event emitted" }); + } + // New way if (!req?.body?.data || !isObject(req.body.data)) { logger.log("job-update-error", "ERROR", req.user?.email, null, { message: `Malformed Job Update request sent from Hasura`,