'use strict'
Channel = require('..').Channel
channel = null
queueName1 = 'test:queue-1'
queueName2 = 'test:queue-2'
expect = (require 'chai').expect
verbose = process.env.VERBOSE

expectedItems1 = [
    'item one',
    'item two',
    'item three',
]

expectedItems2 = [
    'item uno',
    'item dos',
    'item tres',
]

describe '===Channel push/pop===', ->
  @timeout 3000  ## 3 seconds 
  it 'must connect to redis-server', (done) ->
    channel = new Channel
    channel.connect ->
      console.log 'push/pop queue channel ready' if verbose
      expect(channel).to.be.a 'object'
      expect(channel.push).to.be.a 'function'

      channel.on 'error', (error) ->
        console.log '>>>' + error
        throw error if error instanceof Error
        process.exit()
      done()

  it 'must clear test-queues', (done) ->
      queuesToClear = 2
      channel.clear queueName1, ->
        console.log 'Cleared "' + queueName1 + '"' if verbose
        done() unless --queuesToClear
      channel.clear queueName2, ->
        console.log 'Cleared "' + queueName2 + '"' if verbose
        done() unless --queuesToClear

  it 'must retrieve pushed items in correct order', (done) ->
    channel.on 'end', ->
      console.log '>>>End Channel connection'

    for item in expectedItems1
      console.log 'Pushing message "' + item + '" to queue "' + queueName1 + '"' \
        if verbose
      channel.push queueName1, item

    itemCnt = 0
    for item in expectedItems1
      channel.pop queueName1, (data) ->
        console.log 'Received message "' + data +
                    '" in queue "' + queueName1 + '"' if verbose
        expect(data).to.equal expectedItems1[itemCnt++]
        done() if itemCnt is expectedItems1.length

  it 'must be able to monitor two queues for input at the same time', (done) ->
    itemsQueued = 0
    for item in expectedItems1
      console.log 'Pushing message "' + item + '" to queue "' + queueName1 + '"' \
        if verbose
      channel.push queueName1, item
      ++itemsQueued

    for item in expectedItems2
      console.log 'Pushing message "' + item + '" to queue "' + queueName2 + '"' \
        if verbose
      channel.push queueName2, item
      ++itemsQueued
    
    itemCnt1 = itemCnt2 = 0
    consume = ->
      channel.popAny queueName1, queueName2, (queueName, data) ->
        console.log 'Received message "' + data +
                    '" in queue "' + queueName + '"' if verbose
        if queueName is queueName1
          expect(data).to.equal expectedItems1[itemCnt1++]
        if queueName is queueName2
          expect(data).to.equal expectedItems2[itemCnt2++]
        unless --itemsQueued
          done()
        else
          consume()
    consume()

  it 'popTimeout must time out if timeout specified and queue empty', (done) ->
    channel.once 'timeout', (key, cancel) ->
      console.log 'popTimeout timed out, key=' + key if verbose
      expect(key).to.equal queueName1
      cancel() ## prevents another popTimeout
      done()

    channel.popTimeout queueName1, 1, ->
      return

  it 'popAnyTimeout must time out if timeout specified and queue empty', (done) ->
    channel.once 'timeout', (keys, cancel) ->
      console.log 'popAnyTimeout timed out, keys=' + keys if verbose
      expect(keys).to.equal queueName2
      cancel() ## prevents another popAnyTimeout
      done()

    channel.popAnyTimeout queueName2, 1, -> return

  it 'quits cleanly', ->
    console.log 'Ending Channel push/pop test' if verbose
    expect(channel.end()).to.be.a 'object'