import * as React from 'react';
import { mount, configure } from 'enzyme';
import '@reactivex/rxjs'
import { X, x } from '../index';
import * as createClass from 'create-react-class'
import * as rx from '../xs/rx'
const compose = (f, g) => x => f(g(x));
import { Stream } from '../xs'
import * as Adapter from 'enzyme-adapter-react-16';

configure({ adapter: new Adapter() });

const CounterView: React.SFC<any> = props => (
  <div className="counter-view">
    <span className="count">{props.count}</span>
  </div>
)

CounterView.defaultProps = { count: 0, overwritedProps: 'inner' }
interface Intent {
  type: string
  value?: any
}

const xcountable = x<Stream, Intent, any>((intent$) => {
  return {
    update$: intent$.map((intent) => {
      switch (intent.type) {
        case 'inc':
          return state => ({ count: state.count + 1 })
        case 'dec':
          intent$.next({ type: 'changeDefaultProps', value: -3 })
          intent$.next({ type: 'abs' })
          return state => ({ count: state.count - 1 })
        case 'abs':
          return state => ({ count: Math.abs(state.count) })
        case 'changeWrapperProps':
          return state => ({
            wrapperProps: intent.value,
            overwritedProps: intent.value
          })
        case 'changeDefaultProps':
          return state => ({ count: intent.value })
        case 'exception':
          throw new Error('exception!!!')
        default:
          return state => state
      }
    }),
    actions: {
      inc: () => ({ type: 'inc' }),
      dec: () => ({ type: 'dec' }),
      exception: () => ({ type: 'exception' }),
      changeWrapperProps: (value) => ({ type: 'changeWrapperProps', value }),
      changeDefaultProps: (value) => ({ type: 'changeDefaultProps', value }),
    }
  }
})

let Counter = xcountable(CounterView);
const Xs = ['most', 'rx']
for (let name of Xs) {
  describe('X=' + name, () => {
    let engine, Xtest, mountx
    beforeEach(() => {
      engine = require(`../xs/${name}`)
      Xtest = require(`../xtests/`)[name]
      mountx = compose(mount, y => React.createFactory(X)({}, y))
    })
    describe('actions', () => {
      let counterWrapper, counter, t, counterView, actions
      beforeEach(() => {
        counterWrapper = mountx(<Counter />)
        counter = counterWrapper.find(Counter).instance()
        counterView = counterWrapper.find(CounterView)
        actions = counterView.prop('actions')
        t = new Xtest(counterView.props());
      })
      it.only('add intent to intent$ and go through sink$', () => {
        return t
          .do([
            actions.inc,
            actions.inc,
            actions.inc,
          ])
          .collect(counter)
          .then(x => expect(x.count).toBe(3))
      })

      it('async action', () => {
        return t
          .do([
            actions.inc,
            () => actions.fromEvent({ type: 'inc' }),
            () => actions.fromPromise(Promise.resolve({ type: 'inc' })),
          ])
          .collect(counter)
          .then(state => expect(state.count).toBe(3))
      })

      it('update can also generate new intent', () => {
        return t
          .do([
            counter.machine.actions.dec,
          ]).collect(counter)
          .then(state => expect(state.count).toBe(2))
      })
    });

    describe('props', () => {
      let counterWrapper, counter, t, counterView, actions
      beforeEach(() => {
        counterWrapper = mountx(
          <Counter count={9} />
        )
        counter = counterWrapper.find(Counter).getNode()
        counterView = counterWrapper.find(CounterView)
        actions = counterView.prop('actions')
        t = new Xtest(counterView.props());
      })
      it('wrappers props will overwirte components default props', () => {
        return t
          .do([
            counter.machine.actions.inc,
          ]).collect(counter)
          .then(state => expect(state.count).toBe(10))
      })
    })

    describe('scope', () => {
      let counterWrapper, counter, t, counterView, actions
      beforeEach(() => {
        counterWrapper = mountx(
          <Counter count={0} wrapperProps={0} overwritedProps={0} />
        )
        counter = counterWrapper.find(Counter)
        counterView = counterWrapper.find(CounterView)
        actions = counterView.prop('actions')
        t = new Xtest(counterView.props());
      })
      it('like scope in function, outter component change overwrited props wont works', () => {
        return t.plan(1)
          .do([
            () => actions.changeDefaultProps(19),
            () => counterWrapper.setProps({ wrapperProps: 1, overwritedProps: 1, count: 9 }),
          ]).collect(counter.getNode())
          .then(() => expect(counterView.prop('wrapperProps')).toBe(0))
          .then(() => expect(counterView.prop('overwritedProps')).toBe('inner'))
          .then(() => expect(counterView.prop('count')).toBe(19))
      })
    })

    describe('composable', () => {
      let counterWrapper, counter, t, counterView, actions
      const xxcountable = x<Stream, Intent, any>((intent$) => {
        return {
          update$: intent$.map(intent => {
            switch (intent.type) {
              case 'inc2':
                return state => ({ count: state.count + 2 })
              case 'dec2':
                return state => ({ count: state.count - 2 })
              default:
                return state => state
            }
          }),
          actions: {
            inc2: () => ({ type: 'inc2' }),
            dec2: () => ({ type: 'dec2' }),
          }
        }
      })
      let xxxcoutable = compose(xxcountable, xcountable)
      beforeEach(() => {
        Counter = xxxcoutable(CounterView)
        counterWrapper = mountx(
          <Counter />
        )
        counter = counterWrapper.find(Counter).getNode()
        counterView = counterWrapper.find(CounterView)
        actions = counterView.prop('actions')
        t = new Xtest(counterView.props());
      })
      it('compose xxcountable will provide actions inc2, dec2', () => {
        return t
          .do([
            actions.inc,
            actions.inc2,
            actions.dec2,
          ]).collect(counter)
          .then(state => expect(state.count).toBe(1))
      })
    })

    describe('ERROR', () => {
      let counterWrapper, counter, t, counterView, actions
      beforeEach(() => {
        spyOn(console, 'error')
        counterWrapper = mountx(
          <Counter />
        )
        counter = counterWrapper.find(Counter).getNode()
        counterView = counterWrapper.find(CounterView)
        actions = counterView.prop('actions')
        t = new Xtest(counterView.props());
      })

      it('should recover to identity stream and log exception', () => {
        return t
          .do([
            actions.inc,
            actions.exception,
            actions.inc,
          ]).collect(counter)
          .then(state => expect(state.count).toBe(2))
          .then(() => expect(console.error).toBeCalled)

      })
    })

    describe('unsubscribe when component unmounted', () => {
      it('unsubscribe', (done) => {
        const Counter = x<Stream, Intent, any>((intent$) => {
          return {
            update$: intent$.map(intent => {
              switch (intent.type) {
                case 'inc':
                  return state => ({ count: state.count + 1 })
                default:
                  return state => state
              }
            }),
            actions: {
              inc: () => ({ type: 'inc' })
            }
          }
        })(CounterView)

        const TogglableMount = createClass({
          getInitialState() {
            return {
              mount: true
            }
          },
          render() {
            return this.state.mount && <Counter />
          }
        })
        spyOn(console, 'error')
        let counterWrapper = mountx(
          <TogglableMount />
        )
        let toggle = counterWrapper.find(TogglableMount).getNode()
        let counter = counterWrapper.find(Counter).getNode()
        setTimeout(() => done(), 3)
        new Xtest()
          .do([
            () => toggle.setState({ mount: false }),
            counter.machine.actions.inc,
            counter.machine.actions.inc,
          ]).collect(counter)
          .then(done.fail)

      })
    })
  })
}