| 1 | Redis = require 'ioredis'
|
| 2 | HydrantManager = require '..'
|
| 3 |
|
| 4 | describe 'HydrantManager', ->
|
| 5 | beforeEach (done) ->
|
| 6 | @client = new Redis dropBufferSupport: true
|
| 7 | @uuidAliasResolver = resolve: (uuid, callback) => callback(null, uuid)
|
| 8 | @client.on 'ready', done
|
| 9 |
|
| 10 | beforeEach 'hydrant setup', ->
|
| 11 | hydrantClient = new Redis dropBufferSupport: true
|
| 12 | @sut = new HydrantManager {
|
| 13 | @uuidAliasResolver
|
| 14 | client: hydrantClient
|
| 15 | }
|
| 16 |
|
| 17 | describe 'connect', ->
|
| 18 | beforeEach (done) ->
|
| 19 | @nonce = Date.now()
|
| 20 | @sut.once 'message', (@message) => done()
|
| 21 | @sut.connect uuid: 'some-uuid', =>
|
| 22 | @client.publish 'some-uuid', @nonce, (error) =>
|
| 23 | return done error if error?
|
| 24 |
|
| 25 | it 'should receive a message', ->
|
| 26 | expect(@message).to.equal @nonce
|