Merge pull request #24 from cyclejs-community/async-example-tests

Add async tests for example autocomplete using @cyclejs/time

Author: lmatteis

example/cycle/test/helpers.js

@@ -0,0 +1,49 @@
+import {mockTimeSource} from '@cycle/time';
+
+export function assertSourcesSinks(sources, sinks, main, done, timeOpts = {}) {
+  const Time = mockTimeSource(timeOpts);
+  const _sources = Object.keys(sources)
+    .reduce((_sources, sourceKey) => {
+      const sourceObj = sources[sourceKey];
+      const diagram = Object.keys(sourceObj)[0];
+      const sourceOpts = sourceObj[diagram];
+
+      let obj = {};
+      let firstKey = Object.keys(sourceOpts)[0];
+      if (typeof sourceOpts[firstKey] === 'function') {
+        obj = {
+          [sourceKey]: {
+            [firstKey]: () => Time.diagram(diagram, sourceOpts[firstKey]())
+          }
+        }
+      } else {
+        obj = {
+          [sourceKey]: Time.diagram(diagram, sourceOpts)
+        }
+      }
+
+      return Object.assign(_sources, obj);
+    }, {})
+
+  const _sinks = Object.keys(sinks)
+    .reduce((_sinks, sinkKey) => {
+      const sinkObj = sinks[sinkKey];
+      const diagram = Object.keys(sinkObj)[0];
+      const sinkOpts = sinkObj[diagram];
+
+      return Object.assign(_sinks, { [sinkKey]: Time.diagram(diagram, sinkOpts) });
+    }, {});
+
+  // always pass Time as a source
+  _sources.Time = Time;
+
+  const _main = main(_sources);
+
+  Object.keys(sinks)
+    .map(sinkKey => Time.assertEqual(_main[sinkKey], _sinks[sinkKey]));
+
+  Time.run(err => {
+    expect(err).toBeFalsy();
+    done();
+  });
+}

example/cycle/test/test.js

@@ -1,63 +1,12 @@
 import assert from 'assert';
 import xs from 'xstream';
-import fromDiagram from 'xstream/extra/fromDiagram';
-import {mockTimeSource} from '@cycle/time';
+
+import { assertSourcesSinks } from './helpers';
 import * as ActionTypes from '../../ActionTypes';
 import * as actions from '../../actions';
 
 import { fetchReposByUser, searchUsers } from '../';
 
-function assertSourcesSinks(sources, sinks, main, done) {
-  const Time = mockTimeSource();
-  const _sources = Object.keys(sources)
-    .reduce((_sources, sourceKey) => {
-      const sourceObj = sources[sourceKey];
-      const diagram = Object.keys(sourceObj)[0];
-      const sourceOpts = sourceObj[diagram];
-
-      let obj = {};
-      if (diagram === 'stream') {
-        obj = {
-          [sourceKey]: sourceOpts
-        }
-      } else {
-        let firstKey = Object.keys(sourceOpts)[0];
-        if (typeof sourceOpts[firstKey] === 'function') {
-          obj = {
-            [sourceKey]: {
-              [firstKey]: () => Time.diagram(diagram, sourceOpts[firstKey]())
-            }
-          }
-        } else {
-          obj = {
-            [sourceKey]: Time.diagram(diagram, sourceOpts)
-          }
-        }
-      }
-
-      return Object.assign(_sources, obj);
-    }, {})
-
-  const _sinks = Object.keys(sinks)
-    .reduce((_sinks, sinkKey) => {
-      const sinkObj = sinks[sinkKey];
-      const diagram = Object.keys(sinkObj)[0];
-      const sinkOpts = sinkObj[diagram];
-
-      return Object.assign(_sinks, { [sinkKey]: Time.diagram(diagram, sinkOpts) });
-    }, {});
-
-  const _main = main(_sources);
-
-  Object.keys(sinks)
-    .map(sinkKey => Time.assertEqual(_main[sinkKey], _sinks[sinkKey]));
-
-  Time.run(err => {
-    expect(err).toBeFalsy();
-    done();
-  });
-}
-
 describe('Cycles', function() {
   describe('fetchReposByUser', function() {
     it('should emit HTTP requests given ACTIONs', function(done) {
@@ -125,31 +74,35 @@ describe('Cycles', function() {
     });
   });
 
-  // describe('searchUsers', () => {
-  //   it('should emit HTTP requests given ACTIONs, in an async fashion', (done) => {
-  //     const actionSource = {
-  //       a: actions.searchUsers('l'),
-  //       b: actions.searchUsers('lu'),
-  //       c: actions.searchUsers('luc')
-  //     };
-  //     const httpSource = {
-  //       select: () => null
-  //     }
-  //     const actionSink = {
-  //       a: {
-  //         url: `https://api.github.com/search/users?q=luc`,
-  //         category: 'query'
-  //       }
-  //     }
-  //
-  //
-  //     assertSourcesSinks({
-  //       ACTION: { '-a-b-c------|': actionSource },
-  //       HTTP:   { '-------|': httpSource },
-  //       Time:   { stream: mockTimeSource() }
-  //     }, {
-  //       HTTP:   { '--a----|': actionSink }
-  //     }, searchUsers, done);
-  //   })
-  // })
+  describe('searchUsers', () => {
+    it('should emit HTTP requests given many debounced ACTIONs, and should emit ACTION given HTTP response', (done) => {
+      const actionSource = {
+        a: actions.searchUsers('l'),
+        b: actions.searchUsers('lu'),
+        c: actions.searchUsers('luc')
+      };
+      const httpSource = {
+        select: () => ({
+          r: xs.of({ body: { items: ['foo'] } })
+        })
+      }
+      const httpSink = {
+        a: {
+          url: `https://api.github.com/search/users?q=luc`,
+          category: 'query'
+        }
+      }
+      const actionSink = {
+        r: actions.receiveUsers(['foo']),
+      }
+
+      assertSourcesSinks({
+        ACTION: { '-a-b-c----|': actionSource },
+        HTTP:   { '---r------|': httpSource },
+      }, {
+        HTTP:   { '---------a|': httpSink },
+        ACTION: { '---r------|': actionSink },
+      }, searchUsers, done, { interval: 200 });
+    })
+  })
 });