Merge pull request #4 from oskarhane/store-first

Let actions go to store before sending into Suber

package.json

@@ -32,6 +32,7 @@
     "babel-preset-es2015": "^6.18.0",
     "jest-cli": "^18.1.0",
     "redux": "^3.6.0",
+    "redux-mock-store": "^1.2.2",
     "redux-observable": "^0.12.2",
     "redux-saga": "^0.14.2",
     "rxjs": "^5.0.3",

src/bus.js

@@ -66,8 +66,9 @@ export function applyMiddleware () {
   Array.from(arguments).forEach((arg) => middlewares.push(arg(send)))
 }
 export const createReduxMiddleware = () => () => (next) => (action) => {
+  const res = next(action)
   bus.send(action.type, action, 'redux')
-  return next(action)
+  return res
 }
 export function applyReduxMiddleware () {
   Array.from(arguments).forEach((arg) => {

src/redux-compat.test.js

@@ -5,6 +5,7 @@ import 'rxjs'
 import { createEpicMiddleware } from 'redux-observable'
 import createSagaMiddleware from 'redux-saga'
 import { put, takeLatest } from 'redux-saga/effects'
+import configureMockStore from 'redux-mock-store'
 
 test('can create a redux middleware that repeats all redux actions into bus', () => {
   // Given
@@ -26,6 +27,28 @@ test('can create a redux middleware that repeats all redux actions into bus', ()
   expect(cb).toHaveBeenCalledWith(data)
 })
 
+test('can create a redux middleware that let actions go to redux store before sending to suber', (done) => {
+  // Given
+  const b = getBus()
+  const channel = 'FROM_MOCK_REDUX'
+  const data = {id: 10, type: channel}
+  const mw = createReduxMiddleware()
+  const mockStore = configureMockStore([mw])
+  const store = mockStore({
+    state: {}
+  })
+
+  // When
+  b.take(channel, (action) => {
+    // Then
+    expect(store.getActions()).toEqual([
+      data
+    ])
+    done()
+  })
+  store.dispatch(data)
+})
+
 test('exposes applyReduxMiddleware with same mw signature as redux', () => {
   // Given
   const b = getBus()

yarn.lock

@@ -2575,6 +2575,10 @@ redeyed@~1.0.0:
   dependencies:
     esprima "~3.0.0"
 
+redux-mock-store@^1.2.2:
+  version "1.2.2"
+  resolved "https://registry.yarnpkg.com/redux-mock-store/-/redux-mock-store-1.2.2.tgz#38007dc38f12ca8d965c7521afee5ccacc234d03"
+
 redux-observable@^0.12.2:
   version "0.12.2"
   resolved "https://registry.yarnpkg.com/redux-observable/-/redux-observable-0.12.2.tgz#4bc1657c7eedace577e114b74ffe6f6fb2b36ccf"