#!/usr/bin/env ts-node

import {
  test,
  sinon,
}             from 'tstest'

import {
  PuppetOptions,
}                 from 'wechaty-puppet'
import {
  PuppetMock,
}                 from 'wechaty-puppet-mock'

import {
  PuppetHostie,
  PuppetServer,
  PuppetServerOptions,
}                               from '../src/'

test('integration testing', async (t) => {
  const TOKEN    = 'test_token'
  const ENDPOINT = '0.0.0.0:8788'
  const DING     = 'ding_data'

  /**
   * Puppet in Hostie
   */
  const puppet = new PuppetMock()
  const spyStart = sinon.spy(puppet, 'start')
  const spyOn    = sinon.spy(puppet, 'on')
  const spyDing  = sinon.spy(puppet, 'ding')

  /**
   * Hostie Server
   */
  const serverOptions = {
    endpoint : ENDPOINT,
    puppet   : puppet,
    token    : TOKEN,
  } as PuppetServerOptions

  const hostieServer = new PuppetServer(serverOptions)
  await hostieServer.start()

  /**
   * Puppet Hostie Client
   */
  const puppetOptions = {
    endpoint: ENDPOINT,
    token: TOKEN,
  } as PuppetOptions

  const puppetHostie = new PuppetHostie(puppetOptions)
  await puppetHostie.start()

  t.ok(spyStart.called, 'should called the hostie server start() function')

  const future = new Promise<string>((resolve, reject) => {
    const offError = () => puppetHostie.off('error', reject)

    puppetHostie.once('dong', payload => {
      resolve(payload.data)
      offError()
    })
    puppetHostie.once('error', e => {
      reject(e)
      offError()
    })
  })

  puppetHostie.ding(DING)
  const result = await future

  t.ok(spyOn.called,    'should called the hostie server on() function')
  t.ok(spyDing.called,  'should called the hostie server ding() function')

  t.equal(result, DING, 'should get a successful roundtrip for ding')

  /**
   * Stop
   *  1. Puppet in Hostie
   *  2. Hostie Service
   *  3. Puppet Hostie Client
   *
   */
  await puppetHostie.stop()
  await hostieServer.stop()
})