test.js

var ifError = require('assert').ifError

var request = require('supertest')
var suppose = require('suppose')

var post2sse = require('./index.js')


const EVENTS_SEPARATOR = '\n\n'


it('fail when using an invalid HTTP method', function(done)
{
  request(post2sse())
    .put('/a')
    .expect(405, done)
})

describe('SSE clients', function()
{
  it('fail when not defined ID', function(done)
  {
    request(post2sse())
      .get('/')
      .expect(403, done)
  })

  it('register correctly', function(done)
  {
    request(post2sse())
      .get('/a')
    .pipe(suppose())
      .when(':ok'+EVENTS_SEPARATOR, done)
  })

  it('fail when trying to register same ID twice', function(done)
  {
    var proxy = post2sse()
    request(proxy)
      .get('/a')
      .end()
    request(proxy)
      .get('/a')
      .expect(409, done)
  })
})

describe('POST notifications', function()
{
  it('fail when not defined ID', function(done)
  {
    request(post2sse())
      .post('/')
      .expect(403, done)
  })

  it('fail when ID is not found', function(done)
  {
    request(post2sse())
      .post('/a')
      .expect(404, done)
  })

  it('forward correctly a notification', function(done)
  {
    var data =
    {
      asdf: 'qwerty'
    }

    var proxy = post2sse()

    request(proxy)
      .get('/a')
    .pipe(suppose())
      .when(':ok'+EVENTS_SEPARATOR)
      .when('data: '+JSON.stringify(data)+EVENTS_SEPARATOR, done)

    request(proxy)
      .post('/a')
      .send(data)
      .end(ifError)
  })
})