Primus Client / Server

admin-client.js

const Primus = require('primus')
const Socket = Primus.createSocket({ parser: 'binary' })
const client = new Socket('http://localhost:3030', { transport: { headers: { 'admin': 'true' } } })

client.on('open', () => {
  console.log('opened!')
  client.on('data', data => {
    console.log(data)
  })
  client.write('Hello')
})

server.js

const Primus = require('primus')
const server = require('http').createServer()
const primus = new Primus(server, { transformer: 'websockets', parser: 'binary' })

primus.authorize((req, done) => {
  if (req.headers.admin) {
    req.isAdmin = true
  }
  done()
})

primus.on('connection', spark => {
  console.log('connect')
  spark.on('data', data => {
    const isAdmin = spark.request.isAdmin
    console.log('I AM ADMIN?', isAdmin)
    console.log(data)
    if (isAdmin) {
      spark.write('Hello Back')
    }
  })
})

primus.on('disconnection', spark => {
  console.log('disconnect')
})

server.listen(3030)