Add initial redux-trigger implementation example.

This code adds the redux-trigger implementation to the
simple example code.

Author: coderkevin

examples/simple/actions/primes.js

@@ -1,12 +1,34 @@
 
 export const ADD_PRIME = 'ADD_PRIME';
 export const ADD_NON_PRIME = 'ADD_PRIME';
-export const QUEUE_NUMBER = 'QUEUE_NUMBER';
+export const ADD_QUEUE_NUMBER = 'ADD_QUEUE_NUMBER';
+export const REMOVE_QUEUE_NUMBER = 'REMOVE_QUEUE_NUMBER';
 
-export function addNumber( number ) {
+export function addQueueNumber( number ) {
 	return {
-		type: QUEUE_NUMBER,
+		type: ADD_QUEUE_NUMBER,
 		number
 	};
 }
 
+export function removeQueueNumber( number ) {
+	return {
+		type: REMOVE_QUEUE_NUMBER,
+		number
+	};
+}
+
+export function addPrime( number ) {
+  return {
+    type: ADD_PRIME,
+    number
+  };
+}
+
+export function addNonPrime( number ) {
+  return {
+    type: ADD_NON_PRIME,
+    number
+  };
+}
+

examples/simple/containers/App.jsx

@@ -4,7 +4,7 @@ import NumberPicker from '../components/NumberPicker';
 import NumberList from '../components/NumberList';
 import WorkingMessage from '../components/WorkingMessage';
 import { setNumberEntry } from '../actions/numberentry';
-import { addNumber } from '../actions/primes';
+import { addQueueNumber } from '../actions/primes';
 
 class App extends Component {
 	constructor( props ) {
@@ -22,7 +22,7 @@ class App extends Component {
 
 		const { numberEntry } = this.props;
 		this.props.dispatch( setNumberEntry( '' ) );
-		this.props.dispatch( addNumber( numberEntry ) );
+		this.props.dispatch( addQueueNumber( numberEntry ) );
 	}
 
 	render() {

examples/simple/index.jsx

@@ -4,8 +4,10 @@ import { render } from 'react-dom';
 import { Provider } from 'react-redux';
 import App from './containers/App';
 import configureStore from './store/configureStore';
+import { addQueueTrigger } from './triggers/primeStateTriggers';
 
 const store = configureStore();
+store.dispatch( addQueueTrigger() );
 
 const rootComponent =
   <Provider store={ store }>

examples/simple/middleware/primesMiddleware.js

@@ -0,0 +1,58 @@
+import { removeQueueNumber, addPrime, addNonPrime } from '../actions/primes';
+
+export const CHECK_NEXT_PRIME = 'CHECK_NEXT_PRIME';
+
+function createPrimesMiddleware() {
+	return ( store ) => ( next ) => ( action ) => {
+		switch ( action.type ) {
+			case CHECK_NEXT_PRIME:
+				const { queue } = store.getState().primeState;
+				checkNextPrime( queue, store.dispatch );
+				return true;
+			default:
+				return next( action );
+		}
+	};
+}
+
+function checkNextPrime( queue, dispatch ) {
+	if ( queue.length > 0 ) {
+		const number = queue[0];
+		console.log( 'checking next number ' + number );
+		checkPrime( number ).then(
+			( isPrime ) => {
+				if ( isPrime ) {
+					console.log( 'number ' + number + ' is prime!' );
+					dispatch( addPrime( number ) );
+				} else {
+					console.log( 'number ' + number + ' is not prime!' );
+					dispatch( addNonPrime( number ) );
+				}
+				dispatch( removeQueueNumber( number ) );
+			}
+		);
+	}
+}
+
+function checkPrime( number ) {
+	return new Promise(
+		( resolve, reject ) => {
+
+			for ( let i = 0; i < number; i++ ) {
+				if ( Number.isInteger( number / i ) ) {
+					resolve( true );
+				}
+			}
+
+			// No numbers below this one divided cleanly, it's prime.
+			resolve( false );
+		}
+	);
+}
+
+export function checkNextPrimeAction() {
+	return { type: CHECK_NEXT_PRIME };
+}
+
+export default createPrimesMiddleware;
+

examples/simple/package.json

@@ -31,7 +31,8 @@
     "react-dom": "^0.14.3",
     "react-redux": "^4.0.5",
     "redux": "^3.0.5",
-    "redux-logger": "^2.3.1"
+    "redux-logger": "^2.3.1",
+    "redux-multi": "^0.1.10"
   },
   "devDependencies": {
     "babel": "^5.8.29",

examples/simple/reducers/index.js

@@ -5,7 +5,8 @@ import {
 import {
 	ADD_PRIME,
 	ADD_NON_PRIME,
-	QUEUE_NUMBER
+	ADD_QUEUE_NUMBER,
+	REMOVE_QUEUE_NUMBER
 } from '../actions/primes';
 
 function numberEntry( state = '', action ) {
@@ -35,22 +36,32 @@ const primesInitialState = {
 function primeState( state = primesInitialState, action ) {
 	switch ( action.type ) {
 		case ADD_PRIME:
-			const primes = [ ...state.primes, action.prime ];
+			const primes = [ ...state.primes, action.number ];
 
 			return Object.assign( {}, state, {
 				primes
 			} );
 		case ADD_NON_PRIME:
-			const nonPrimes = [ ...state.nonPrimes, action.nonPrime ];
+			const nonPrimes = [ ...state.nonPrimes, action.number ];
 
 			return Object.assign( {}, state, {
 				nonPrimes
 			} );
-		case QUEUE_NUMBER:
-			const queue = [ ...state.queue, action.number ];
+		case ADD_QUEUE_NUMBER:
+			console.log("queueing number: " + action.number);
+			const addedQueue = [ ...state.queue, action.number ];
 
 			return Object.assign( {}, state, {
-				queue
+				queue: addedQueue
+			} );
+		case REMOVE_QUEUE_NUMBER:
+			console.log("unqueuing number: " + action.number);
+			const removedQueue = state.queue.filter(
+				( num ) => { return num != action.number }
+			);
+
+			return Object.assign( {}, state, {
+				queue: removedQueue
 			} );
 		default:
 			return state;

examples/simple/store/configureStore.js

@@ -1,8 +1,15 @@
 import { createStore, applyMiddleware } from 'redux';
 import createLogger from 'redux-logger';
+// TODO: Move this import to a proper module after it's build.
+import createTrigger from '../../../src';
+import multi from 'redux-multi';
+import createPrimesMiddleware from '../middleware/primesMiddleware';
 import rootReducer from '../reducers';
 
 const createStoreWithMiddleware = applyMiddleware(
+	multi,
+	createTrigger(),
+	createPrimesMiddleware(),
 	createLogger()
 )( createStore );
 

examples/simple/triggers/primeStateTriggers.js

@@ -0,0 +1,25 @@
+// TODO: Switch this out with a proper import from the module when it's ready.
+import { createTrigger, addTrigger } from '../../../src';
+import { checkNextPrimeAction } from '../middleware/primesMiddleware';
+
+const REMOVE_FROM_QUEUE = 'REMOVE_FROM_QUEUE';
+
+function queueMatcher( state ) {
+	const { queue } = state.primeState;
+	console.log('queue');
+	console.log(queue);
+	return ( queue.length > 0 ? queue : null );
+}
+
+export function addQueueTrigger() {
+	return addTrigger( createTrigger(
+		queueMatcher,
+		( match ) => {
+			return [
+				checkNextPrimeAction(),
+				addQueueTrigger(),
+			];
+		}
+	) );
+}
+

examples/simple/webpack.config.js

@@ -22,7 +22,6 @@ module.exports = {
 			test: /\.jsx?$/,
 			loaders: [ 'babel' ],
 			exclude: /node_modules/,
-			include: __dirname
 		} ]
 	},
 	resolve: {