import {spy} from 'sinon'
import {expect} from 'chai'

import MessageDistributor from './message-distributor'
import * as testHelper from '../test/helper/test-helper'
import { getTestMocks } from '../test/helper/test-mocks'

const options = testHelper.getDeepstreamOptions()
const config = options.config
const services = options.services

describe('message connector distributes messages to callbacks', () => {
  let messageDistributor
  let testMocks
  let client
  let testCallback

  beforeEach(() => {
    testMocks = getTestMocks()
    client = testMocks.getSocketWrapper()
    testCallback = spy()

    messageDistributor = new MessageDistributor(config, services)
  })

  afterEach(() => {
    client.socketWrapperMock.verify()
  })

  it('makes remote connection', () => {
    expect(services.clusterNode.lastSubscribedTopic).to.equal(null)

    messageDistributor.registerForTopic('someTopic', testCallback)

    expect(services.clusterNode.lastSubscribedTopic).to.equal('someTopic')
  })

  it('makes local connection', () => {
    messageDistributor.registerForTopic('someTopic', testCallback)

    messageDistributor.distribute(client.socketWrapper, { topic: 'someTopic' })

    expect(testCallback).to.have.callCount(1)
  })

  it.skip('routes messages from the message connector', () => {
    messageDistributor.registerForTopic('topicB', testCallback)

    services.message.simulateIncomingMessage('topicB', { topic: 'topicB' })

    expect(testCallback).to.have.callCount(1)
  })

  it('only routes matching topics', () => {
    messageDistributor.registerForTopic('aTopic', testCallback)
    messageDistributor.registerForTopic('anotherTopic', testCallback)

    messageDistributor.distribute(client.socketWrapper, { topic: 'aTopic' })

    expect(testCallback).to.have.callCount(1)
  })

  it('throws an error for multiple registrations to the same topic', () => {
    let hasErrored = false

    try {
      messageDistributor.registerForTopic('someTopic', testCallback)
      messageDistributor.registerForTopic('someTopic', testCallback)
    } catch (e) {
      hasErrored = true
    }

    expect(hasErrored).to.equal(true)
  })
})