|
|
|
@ -230,13 +230,13 @@ const startWorker = (workerId) => { |
|
|
|
|
const FALSE_VALUES = [ |
|
|
|
|
false, |
|
|
|
|
0, |
|
|
|
|
"0", |
|
|
|
|
"f", |
|
|
|
|
"F", |
|
|
|
|
"false", |
|
|
|
|
"FALSE", |
|
|
|
|
"off", |
|
|
|
|
"OFF" |
|
|
|
|
'0', |
|
|
|
|
'f', |
|
|
|
|
'F', |
|
|
|
|
'false', |
|
|
|
|
'FALSE', |
|
|
|
|
'off', |
|
|
|
|
'OFF', |
|
|
|
|
]; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
@ -377,6 +377,8 @@ const startWorker = (workerId) => { |
|
|
|
|
return 'direct'; |
|
|
|
|
case '/api/v1/streaming/list': |
|
|
|
|
return 'list'; |
|
|
|
|
default: |
|
|
|
|
return undefined; |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
@ -475,7 +477,7 @@ const startWorker = (workerId) => { |
|
|
|
|
log.verbose(req.requestId, `Closing connection for ${req.accountId} due to expired access token`); |
|
|
|
|
eventHandlers.onKill(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
@ -530,7 +532,8 @@ const startWorker = (workerId) => { |
|
|
|
|
log.error(req.requestId, err.toString()); |
|
|
|
|
|
|
|
|
|
if (res.headersSent) { |
|
|
|
|
return next(err); |
|
|
|
|
next(err); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
res.writeHead(err.status || 500, { 'Content-Type': 'application/json' }); |
|
|
|
@ -1032,7 +1035,7 @@ const startWorker = (workerId) => { |
|
|
|
|
if (type === 'subscribe') { |
|
|
|
|
subscribeWebsocketToChannel(session, firstParam(stream), params); |
|
|
|
|
} else if (type === 'unsubscribe') { |
|
|
|
|
unsubscribeWebsocketFromChannel(session, firstParam(stream), params) |
|
|
|
|
unsubscribeWebsocketFromChannel(session, firstParam(stream), params); |
|
|
|
|
} else { |
|
|
|
|
// Unknown action type
|
|
|
|
|
} |
|
|
|
|