state updates are now being part of output

maciejzasada · Jul 3, 2017 · 6a1dc44 · 6a1dc44
1 parent 02cf38f
commit 6a1dc44
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/lib/flowchat.js b/lib/flowchat.js
@@ -27,6 +27,7 @@ export class Flowchat {
     this.setInput(new Subject());
     this._state = new Subject();
     this._output = new Subject();
+    this._memStore = {};
     this._activators = [];
     this._paths = [];
     this._reducers = {};
@@ -41,7 +42,8 @@ export class Flowchat {
 
     // Send.
     this._sendSaga = function* sendSaga({ data, sessionId }) {
-      yield self._send(data, sessionId);
+      const state = self._memStore[sessionId];
+      yield self._send(data, state, sessionId);
     }
     this._sendSagaRunner = function* sendSagaRunner() {
       yield takeEvery('send', self._sendSaga);
@@ -224,6 +226,7 @@ export class Flowchat {
 
   _run(flow, data, state, sessionId) {
     const newState = this._reduce(flow, data, state, sessionId);
+    this._memStore[sessionId] = newState;
     const runNext = () => {
       this._store.dispatch({ type: flow, data, state: newState, sessionId });
     }
@@ -247,8 +250,8 @@ export class Flowchat {
     return state;
   }
 
-  _send(data, sessionId) {
-    this._output.onNext({ data, sessionId });
+  _send(data, state, sessionId) {
+    this._output.onNext({ data, state, sessionId });
   }
 
 }

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "flowchat",
   "description": "Modern ES6 reactive framework for building scalable, maintainable and testable chat bots",
-  "version": "0.2.4",
+  "version": "0.3.2",
   "author": "Maciej Zasada <hello@maciejzasada.com>",
   "keywords": [
     "flowchat",