import 'mocha'

import * as C from '../../constants'
import EventHandler from './event-handler'

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('the eventHandler routes events correctly', () => {
  let testMocks
  let eventHandler
  let socketWrapper

  beforeEach(() => {
    testMocks = getTestMocks()
    eventHandler = new EventHandler(
      config, services, testMocks.subscriptionRegistry, testMocks.listenerRegistry
    )
    socketWrapper = testMocks.getSocketWrapper().socketWrapper
  })

  afterEach(() => {
    testMocks.subscriptionRegistryMock.verify()
    testMocks.listenerRegistryMock.verify()
  })

  it('subscribes to events', () => {
    const subscriptionMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.SUBSCRIBE,
      names: ['someEvent']
    }
    testMocks.subscriptionRegistryMock
      .expects('subscribeBulk')
      .once()
      .withExactArgs(subscriptionMessage, socketWrapper)

    eventHandler.handle(socketWrapper, subscriptionMessage)
  })

  it('unsubscribes to events', () => {
    const unSubscriptionMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.UNSUBSCRIBE,
      names: ['someEvent']
    }
    testMocks.subscriptionRegistryMock
      .expects('unsubscribeBulk')
      .once()
      .withExactArgs(unSubscriptionMessage, socketWrapper)

    eventHandler.handle(socketWrapper, unSubscriptionMessage)
  })

  it('triggers event without data', () => {
    const eventMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.EMIT,
      name: 'someEvent'
    }
    testMocks.subscriptionRegistryMock
      .expects('sendToSubscribers')
      .once()
      .withExactArgs('someEvent', eventMessage, false, socketWrapper)

    eventHandler.handle(socketWrapper, eventMessage)
  })

  it('triggers event with data', () => {
    const eventMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.EMIT,
      name: 'someEvent',
      data: JSON.stringify({ data: 'payload' })
    }
    testMocks.subscriptionRegistryMock
      .expects('sendToSubscribers')
      .once()
      .withExactArgs('someEvent', eventMessage, false, socketWrapper)

    eventHandler.handle(socketWrapper, eventMessage)
  })

  it('registers a listener', () => {
    const listenMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.LISTEN,
      name: 'event/.*'
    }
    testMocks.listenerRegistryMock
      .expects('handle')
      .once()
      .withExactArgs(socketWrapper, listenMessage)

    eventHandler.handle(socketWrapper, listenMessage)
  })

  it('removes listeners', () => {
    const unlistenMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.UNLISTEN,
      name: 'event/.*'
    }
    testMocks.listenerRegistryMock
      .expects('handle')
      .once()
      .withExactArgs(socketWrapper, unlistenMessage)

    eventHandler.handle(socketWrapper, unlistenMessage)
  })

  it('processes listen accepts', () => {
    const listenAcceptMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.LISTEN_ACCEPT,
      name: 'event/.*',
      subscription: 'event/A'
    }
    testMocks.listenerRegistryMock
      .expects('handle')
      .once()
      .withExactArgs(socketWrapper, listenAcceptMessage)

    eventHandler.handle(socketWrapper, listenAcceptMessage)
  })

  it('processes listen rejects', () => {
    const listenRejectMessage = {
      topic: C.TOPIC.EVENT,
      action: C.EVENT_ACTION.LISTEN_REJECT,
      name: 'event/.*',
      subscription: 'event/A'
    }
    testMocks.listenerRegistryMock
      .expects('handle')
      .once()
      .withExactArgs(socketWrapper, listenRejectMessage)

    eventHandler.handle(socketWrapper, listenRejectMessage)
  })
})