refactor: send single message

This commit is contained in:
Barış Soner Uşaklı
2025-06-11 13:16:52 -04:00
parent 84d99a0fc7
commit dc37789b5d
2 changed files with 21 additions and 16 deletions

View File

@@ -173,9 +173,10 @@ module.exports = function (grunt) {
winston.error(err.stack); winston.error(err.stack);
} }
if (worker) { if (worker) {
worker.send({ compiling: compiling }); worker.send({
// Send livereload event via Socket.IO for instant browser refresh compiling: compiling,
worker.send({ livereload: true }); livereload: true, // Send livereload event via Socket.IO for instant browser refresh
});
} }
}); });
}); });

View File

@@ -107,20 +107,24 @@ function addProcessHandlers() {
shutdown(1); shutdown(1);
}); });
process.on('message', (msg) => { process.on('message', (msg) => {
if (msg && Array.isArray(msg.compiling)) { if (msg) {
if (msg.compiling.includes('tpl')) { if (Array.isArray(msg.compiling)) {
const benchpressjs = require('benchpressjs'); if (msg.compiling.includes('tpl')) {
benchpressjs.flush(); const benchpressjs = require('benchpressjs');
} else if (msg.compiling.includes('lang')) { benchpressjs.flush();
const translator = require('./translator'); } else if (msg.compiling.includes('lang')) {
translator.flush(); const translator = require('./translator');
translator.flush();
}
} }
} else if (msg && msg.livereload) {
// Send livereload event to all connected clients via Socket.IO if (msg.livereload) {
const websockets = require('./socket.io'); // Send livereload event to all connected clients via Socket.IO
if (websockets.server) { const websockets = require('./socket.io');
websockets.server.emit('event:livereload'); if (websockets.server) {
winston.info('[livereload] Sent reload event to all clients'); websockets.server.emit('event:livereload');
winston.info('[livereload] Sent reload event to all clients');
}
} }
} }
}); });