Remove obsolete WebSocket logs monitor (#5629)
This never worked in prod (see #1460)
This commit is contained in:
@@ -1,20 +1,7 @@
|
||||
'use strict'
|
||||
|
||||
const config = require('config').util.toObject()
|
||||
const secretIsValid = require('./secret-is-valid')
|
||||
const RateLimit = require('./rate-limit')
|
||||
const log = require('./log')
|
||||
|
||||
function secretInvalid(req, res) {
|
||||
if (!secretIsValid(req.password)) {
|
||||
// An unknown entity tries to connect. Let the connection linger for a minute.
|
||||
setTimeout(() => {
|
||||
res.json({ errors: [{ code: 'invalid_secrets' }] })
|
||||
}, 10000)
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
function setRoutes({ rateLimit }, { server, metricInstance }) {
|
||||
const ipRateLimit = new RateLimit({
|
||||
@@ -29,12 +16,6 @@ function setRoutes({ rateLimit }, { server, metricInstance }) {
|
||||
})
|
||||
|
||||
server.handle((req, res, next) => {
|
||||
if (req.url.startsWith('/sys/')) {
|
||||
if (secretInvalid(req, res)) {
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
if (rateLimit) {
|
||||
const ip =
|
||||
(req.headers['x-forwarded-for'] || '').split(', ')[0] ||
|
||||
@@ -63,23 +44,6 @@ function setRoutes({ rateLimit }, { server, metricInstance }) {
|
||||
res.json({ ips: config.public.shields_ips })
|
||||
})
|
||||
|
||||
server.ws('/sys/logs', socket => {
|
||||
const listener = (...msg) => socket.send(msg.join(' '))
|
||||
socket.on('close', () => log.removeListener(listener))
|
||||
socket.on('message', msg => {
|
||||
let req
|
||||
try {
|
||||
req = JSON.parse(msg)
|
||||
} catch (e) {
|
||||
return
|
||||
}
|
||||
if (!secretIsValid(req.secret)) {
|
||||
return socket.close()
|
||||
}
|
||||
log.addListener(listener)
|
||||
})
|
||||
})
|
||||
|
||||
server.get('/sys/rate-limit', (req, res) => {
|
||||
res.json({
|
||||
ip: ipRateLimit.toJSON(),
|
||||
@@ -95,6 +59,4 @@ function setRoutes({ rateLimit }, { server, metricInstance }) {
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
setRoutes,
|
||||
}
|
||||
module.exports = { setRoutes }
|
||||
|
||||
Reference in New Issue
Block a user