mirror of
https://github.com/openstf/stf
synced 2025-10-05 10:39:25 +02:00
Fix refactoring bug.
This commit is contained in:
parent
7c2bf332e4
commit
6d46132b63
1 changed files with 1 additions and 3 deletions
|
@ -95,8 +95,6 @@ module.exports = function(options) {
|
||||||
user.ip = socket.handshake.query.uip || req.ip
|
user.ip = socket.handshake.query.uip || req.ip
|
||||||
socket.emit('socket.ip', user.ip)
|
socket.emit('socket.ip', user.ip)
|
||||||
|
|
||||||
var messageListener = wirerouter()
|
|
||||||
|
|
||||||
function joinChannel(channel) {
|
function joinChannel(channel) {
|
||||||
channels.push(channel)
|
channels.push(channel)
|
||||||
channelRouter.on(channel, messageListener)
|
channelRouter.on(channel, messageListener)
|
||||||
|
@ -120,7 +118,7 @@ module.exports = function(options) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
messageListener
|
var messageListener = wirerouter()
|
||||||
.on(wire.DeviceLogMessage, function(channel, message) {
|
.on(wire.DeviceLogMessage, function(channel, message) {
|
||||||
socket.emit('device.log', message)
|
socket.emit('device.log', message)
|
||||||
})
|
})
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue