diff --git a/server/ioevent/ioevent.js b/server/ioevent/ioevent.js index 16c5ad63a..b53159918 100644 --- a/server/ioevent/ioevent.js +++ b/server/ioevent/ioevent.js @@ -7,9 +7,11 @@ require("dotenv").config({ path: path.resolve(process.cwd(), `.env.${process.env.NODE_ENV || "development"}`) }); +// Emit this to bodyshop room + exports.default = async (req, res) => { const { useremail, bodyshopid, operationName, variables, env, time, dbevent, user } = req.body; - + const { ioRedis } = req; try { await client.request(queries.INSERT_IOEVENT, { event: { @@ -22,6 +24,12 @@ exports.default = async (req, res) => { useremail } }); + + ioRedis.to(bodyshopid).emit("bodyshop-message", { + operationName, + useremail + }); + res.sendStatus(200); } catch (error) { logger.log("ioevent-error", "trace", user, null, {