Skip to content
Snippets Groups Projects
Commit 2ee167be authored by Jure's avatar Jure
Browse files

Fix style issues

parent 6819eacf
No related branches found
No related tags found
No related merge requests found
const EventEmitter = require('events').EventEmitter const { EventEmitter } = require('events')
class SSE extends EventEmitter { class SSE extends EventEmitter {
constructor () { constructor() {
super() super()
this.connect = this.connect.bind(this) this.connect = this.connect.bind(this)
...@@ -9,9 +9,9 @@ class SSE extends EventEmitter { ...@@ -9,9 +9,9 @@ class SSE extends EventEmitter {
this.pulse() this.pulse()
} }
connect (req, res) { connect(req, res) {
// if (req.header('Accept').indexOf('text/event-stream') === -1) { // if (req.header('Accept').indexOf('text/event-stream') === -1) {
// TODO: throw exception? // TODO: throw exception?
// } // }
req.socket.setTimeout(Number.MAX_SAFE_INTEGER) req.socket.setTimeout(Number.MAX_SAFE_INTEGER)
...@@ -23,19 +23,20 @@ class SSE extends EventEmitter { ...@@ -23,19 +23,20 @@ class SSE extends EventEmitter {
res.set({ res.set({
'Content-Type': 'text/event-stream', 'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache', 'Cache-Control': 'no-cache',
'Connection': 'keep-alive', Connection: 'keep-alive',
'X-Accel-Buffering': 'no' // prevent buffering by nginx 'X-Accel-Buffering': 'no', // prevent buffering by nginx
}) })
this.setMaxListeners(this.getMaxListeners() + 1) this.setMaxListeners(this.getMaxListeners() + 1)
const write = (type, data) => { const write = (type, data) => {
res.write(type + ': ' + data) res.write(`${type}: ${data}`)
res.write('\n') res.write('\n')
} }
const dataListener = data => { const dataListener = data => {
write('id', this.messageId++) this.messageId = this.messageId + 1
write('id', this.messageId)
if (data.event) { if (data.event) {
write('event', data.event) write('event', data.event)
...@@ -56,16 +57,16 @@ class SSE extends EventEmitter { ...@@ -56,16 +57,16 @@ class SSE extends EventEmitter {
}) })
} }
pulse () { pulse() {
const pulseInterval = setInterval(() => { const pulseInterval = setInterval(() => {
this.emit('data', {event: 'pulse', data: Date.now()}) this.emit('data', { event: 'pulse', data: Date.now() })
}, 10000) }, 10000)
pulseInterval.unref() pulseInterval.unref()
} }
send (data, event) { send(data, event) {
this.emit('data', {data, event}) this.emit('data', { data, event })
} }
} }
......
...@@ -16,11 +16,5 @@ ...@@ -16,11 +16,5 @@
}, },
"devDependencies": { "devDependencies": {
"standard": "^10.0.2" "standard": "^10.0.2"
},
"eslintConfig": {
"extends": "standard",
"parserOptions": {
"ecmaVersion": 6
}
} }
} }
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment