sagaInterfaceFactory.js

Table of Contents

  1. appStateFactory.js
  2. createAppDispatcher.js
  3. StateWithSideEffects.js
  4. createChannels.js
  5. createSagas.js
  6. sagaInterfaceFactory.js
  7. Container.js
  8. createContainer.js
  9. createDangerouslySlowContainer.js
  10. index.js
  11. ContainerHelpers.js
  12. assert.js
  13. cast.js
  14. checkUnique.js
  15. isObservable.js
  16. uuid.js
  17. ReduxSaga.js
  18. createReduxReducers.js
  19. reduxChannelName.js
  20. reduxMiddlewareFactory.js
  21. rfluxMessage.js
  22. kefirEmitter.js 
import Kefir from 'kefir'

import kefirEmitter from '../utils/kefirEmitter'
import isObservable from '../internal/isObservable'
import uuid from '../internal/uuid'


export default function sagaInterfaceFactory({AppDispatcher, appStateObservable}) {

  const sideEffects = kefirEmitter()
  const callObservable = sideEffects
    .filter(action => action.action === 'CALL')
    .map(action => action.payload)
    .flatMap(action => {

      const callId = action.callId
      const result = action.fn(...action.args)
      const resultObservable = isObservable(result) ? result : Kefir.constant(result)

      return resultObservable.map(rslt => ({callId, rslt}))
    })
    .onValue(() => undefined)


  function put(action) {

    setTimeout(() => AppDispatcher.emit(action), 0)

    return Kefir.constant(action) // streamified so we can chain together
  }


  function call(fn, ...args) {

    const callId = uuid()

    setTimeout(() => sideEffects.emit({action: 'CALL', payload: {fn, args, callId}}), 0)

    return callObservable.filter(fn => fn.callId === callId).map(fn => fn.rslt).take(1)
  }


  function listen(channel, actionType) {

    return AppDispatcher
      .filter(action => action.channel === channel && action.actionType === actionType)
      .map(action => action.payload)
  }


  function getState() {

    return appStateObservable
  }


  return {
    sideEffects,
    put,
    call,
    listen,
    getState
  }
}
h