@@ -24,7 +24,7 @@ module.exports = (client, message) => {
const handleTransmission = (client, message) => {
transmissionHandler(client, {
type: message.type,
- src: client.getId(),
+ src: message.src,
dst: message.dst,
payload: message.payload
});
@@ -130,6 +130,8 @@ class WebSocketServer extends EventEmitter {
try {
const message = JSON.parse(data);
+ message.src = client.getId();
+
this.emit('message', client, message);
} catch (e) {
logger.error('Invalid message', data);