Unit tests for issue angular-redux#149

Author: Evan Schultz

src/___tests___/components/ng-redux.spec.ts

@@ -6,7 +6,7 @@ import { NgRedux } from '../../components/ng-redux';
 import { select } from '../../decorators/select';
 import * as sinon from 'sinon';
 import * as sinonChai from 'sinon-chai';
-
+import 'rxjs/add/operator/filter';
 use(sinonChai);
 
 function returnPojo() {
@@ -304,3 +304,180 @@ describe('NgRedux Observable Store', () => {
     );
   });
 });
+
+describe('Chained actions in subscriptions', () => {
+  interface IAppState {
+    keyword: string;
+    keywordLength: number;
+  };
+
+  let defaultState: IAppState;
+  let rootReducer;
+  let ngRedux;
+  let doSearch = (word) => {
+    ngRedux.dispatch({ type: 'SEARCH', payload: word });
+  };
+  let doFetch = (word) => {
+    ngRedux.dispatch({ type: 'SEARCH_RESULT', payload: word.length });
+  };
+
+  beforeEach(() => {
+    defaultState = {
+      keyword: '',
+      keywordLength: -1
+
+    };
+
+    rootReducer = (state = defaultState, action) => {
+      switch (action.type) {
+        case 'SEARCH':
+          return Object.assign({}, state, { keyword: action.payload });
+        case 'SEARCH_RESULT':
+          return Object.assign({}, state, { keywordLength: action.payload });
+        default:
+          return state;
+      }
+    };
+
+    ngRedux = new NgRedux<IAppState>();
+    ngRedux.configureStore(rootReducer, defaultState);
+  });
+
+
+  describe('dispatching an action in a keyword$ before length$ happens', () => {
+    it(`length sub should be called twice`, () => {
+
+      let keyword$ = ngRedux.select(n => n.keyword);
+      let keyword = '';
+      let length;
+      let length$ = ngRedux.select(n => n.keywordLength);
+      let lengthSpy = sinon.spy((n) => length = n);
+      let lenSub;
+      let keywordSub;
+      keywordSub = keyword$.
+        filter(n => n !== '')
+        .subscribe(n => {
+          keyword = n;
+          doFetch(n);
+        });
+
+      lenSub = length$.subscribe(lengthSpy);
+
+      expect(keyword).to.equal('');
+      expect(length).to.equal(-1);
+
+      expect(lengthSpy.calledOnce).to.be.equal(true);
+
+      doSearch('test');
+
+      expect(lengthSpy.calledTwice).to.be.equal(true);
+
+      expect(keyword).to.equal('test');
+      expect(length).to.equal(4);
+      keywordSub.unsubscribe();
+      lenSub.sunsubscribe();
+    });
+
+    it(`second sub should get most current state value`, () => {
+
+      let keyword$ = ngRedux.select(n => n.keyword);
+      let keyword = '';
+      let length;
+      let length$ = ngRedux.select(n => n.keywordLength);
+      let lengthSpy = sinon.spy((n) => length = n);
+      let lenSub;
+      let keywordSub;
+      keywordSub = keyword$.
+        filter(n => n !== '')
+        .subscribe(n => {
+          keyword = n;
+          doFetch(n);
+        });
+
+      lenSub = length$.subscribe(lengthSpy);
+
+      expect(keyword).to.equal('');
+      expect(length).to.equal(-1);
+
+      expect(lengthSpy.calledOnce).to.be.equal(true);
+
+      doSearch('test');
+
+      expect(keyword).to.equal('test');
+      expect(length).to.equal(4);
+      keywordSub.unsubscribe();
+      lenSub.sunsubscribe();
+    });
+  });
+
+  describe('dispatching an action in a keyword$ after length$ happens', () => {
+    it(`length sub should be called twice`, () => {
+
+      let keyword$ = ngRedux.select(n => n.keyword);
+      let keyword = '';
+      let length;
+      let length$ = ngRedux.select(n => n.keywordLength);
+      let lengthSpy = sinon.spy((n) => length = n);
+      let lenSub;
+      let keywordSub;
+      
+      lenSub = length$.subscribe(lengthSpy);
+      keywordSub = keyword$.
+        filter(n => n !== '')
+        .subscribe(n => {
+          keyword = n;
+          doFetch(n);
+        });
+
+
+
+      expect(keyword).to.equal('');
+      expect(length).to.equal(-1);
+
+      expect(lengthSpy.calledOnce).to.be.equal(true);
+
+      doSearch('test');
+
+      expect(lengthSpy.calledTwice).to.be.equal(true);
+
+      expect(keyword).to.equal('test');
+      expect(length).to.equal(4);
+      keywordSub.unsubscribe();
+      lenSub.unsubscribe();
+    });
+
+    it(`first sub should get most current state value`, () => {
+
+      let keyword$ = ngRedux.select(n => n.keyword);
+      let keyword = '';
+      let length;
+      let length$ = ngRedux.select(n => n.keywordLength);
+      let lengthSpy = sinon.spy((n) => length = n);
+      let lenSub;
+      let keywordSub;
+      lenSub = length$.subscribe(lengthSpy);
+      keywordSub = keyword$.
+        filter(n => n !== '')
+        .subscribe(n => {
+          keyword = n;
+          doFetch(n);
+        });
+
+      
+
+      expect(keyword).to.equal('');
+      expect(length).to.equal(-1);
+
+      expect(lengthSpy.calledOnce).to.be.equal(true);
+
+      doSearch('test');
+
+      expect(keyword).to.equal('test');
+      expect(length).to.equal(4);
+      keywordSub.unsubscribe();
+      lenSub.unsubscribe();
+    });
+  });
+
+
+});