examples: add sse

examples/sse/server.js

@@ -0,0 +1,55 @@
+const serverRouter = require('server-router')
+const browserify = require('browserify')
+const bankai = require('bankai')
+const http = require('http')
+const SSE = require('sse')
+
+const clients = []
+const PORT = 8080
+
+const server = http.createServer(createRouter())
+server.listen(PORT, () => {
+  process.stdout.write(`listening on port ${PORT}\n`)
+  var sse = new SSE(server)
+
+  // code adapted from: https://github.com/markbrown4/server-sent-events-demo
+  sse.on('connection', (stream) => {
+    clients.push(stream)
+    console.log('Opened connection 🎉')
+
+    var json = JSON.stringify({ message: 'Gotcha' })
+    stream.send(json)
+    console.log('Sent: ' + json)
+
+    stream.on('close', () => {
+      clients.splice(clients.indexOf(stream), 1)
+      console.log('Closed connection 😱')
+    })
+  })
+})
+
+// emit data every 1.5 seconds
+setInterval(() => {
+  var json = JSON.stringify({ message: 'Hello hello!' })
+  clients.forEach((stream) => {
+    stream.send(json)
+    console.log('Sent: ' + json)
+  })
+}, 1500)
+
+function createRouter () {
+  const router = serverRouter('/404')
+
+  const html = bankai.html({ css: false })
+  router.on('/', (req, res) => html(req, res).pipe(res))
+
+  const js = bankai.js(browserify, require.resolve('./client.js'))
+  router.on('/bundle.js', (req, res) => js(req, res).pipe(res))
+
+  router.on('/404', (req, res) => {
+    res.statusCode = 404
+    res.end('{ "message": "the server is confused" }')
+  })
+
+  return router
+}