feat: Record the source of the state change

Author: wxnet2013

src/rxloop.js

@@ -31,6 +31,7 @@ export function rxloop( config = {} ) {
       stream[`reducer_${type}$`].pipe(
         map(action => {
           const rtn = this.createReducer(action, reducers[type]);
+          action.__source__ = { reducer: type };
           rtn.__action__ = action;
           return rtn;
         }),
@@ -94,6 +95,7 @@ export function rxloop( config = {} ) {
           });
           const rtn = this.createReducer(action, reducers[reducer]);
           action.type = `${name}/${action.type}`;
+          action.__source__ = { epic: type };
           rtn.__action__ = action;
           return rtn;
         }),

test/plugins.spec.js

@@ -313,21 +313,21 @@ describe('Basic api', () => {
     expect(mockfn.mock.calls.length).toBe(3);
     expect(mockfn.mock.calls[0][0]).toEqual({
       state: { counter: 1 },
-      reducerAction: { type: 'counter/inc' },
+      reducerAction: { type: 'counter/inc', __source__: { reducer: 'inc' } },
       model: 'counter',
       type: 'plugin',
       action: 'onStatePatch',
     });
     expect(mockfn.mock.calls[1][0]).toEqual({
       state: { counter: 2 },
-      reducerAction: { type: 'counter/inc' },
+      reducerAction: { type: 'counter/inc', __source__: { reducer: 'inc' } },
       model: 'counter',
       type: 'plugin',
       action: 'onStatePatch',
     });
     expect(mockfn.mock.calls[2][0]).toEqual({
       state: { counter: 1 },
-      reducerAction: { type: 'counter/dec' },
+      reducerAction: { type: 'counter/dec', __source__: { reducer: 'dec' } },
       model: 'counter',
       type: 'plugin',
       action: 'onStatePatch',