rewrite vuex gekko event logic

web/routes/baseConfig.js

@@ -19,10 +19,6 @@ config.tradingAdvisor = {
 config.candleWriter = {
   enabled: false
 }
-config.adviceWriter = {
-  enabled: false,
-  muteSoft: true,
-}
 
 config.backtestResultExporter = {
   enabled: false,

web/routes/startGekko.js

@@ -1,7 +1,6 @@
 const _ = require('lodash');
 
 const cache = require('../state/cache');
-const broadcast = cache.get('broadcast');
 const Logger = require('../state/logger');
 const apiKeyManager= cache.get('apiKeyManager');
 const gekkoManager = cache.get('gekkos');
@@ -34,11 +33,6 @@ module.exports = function *() {
   }
 
   const state = gekkoManager.add({config, mode});
-
-  broadcast({
-    type: 'new_gekko',
-    state
-  });
 
   console.log('Gekko', state.id, 'started');
 

web/state/gekkoManager.js

@@ -48,8 +48,10 @@ GekkoManager.prototype.add = function({mode, config}) {
     type,
     logType,
     active: true,
-    initialEvents: {},
-    latestEvents: {},
+    events: {
+      initial: {},
+      latest: {}
+    },
     start: moment()
   }
 
@@ -66,6 +68,12 @@ GekkoManager.prototype.add = function({mode, config}) {
     config.trader.secret = '[REDACTED]';
   }
 
+  broadcast({
+    type: 'new_gekko',
+    id,
+    state
+  });
+
   return state;
 }
 
@@ -91,8 +99,9 @@ GekkoManager.prototype.handleRawEvent = function(id) {
 
 GekkoManager.prototype.handleGekkoEvent = function(id, event) {
   this.gekkos[id] = reduceState(this.gekkos[id], event);
+  console.log(event);
   broadcast({
-    type: 'gekko_update',
+    type: 'gekko_event',
     id,
     event
   });

web/state/reduceState.js

@@ -0,0 +1,35 @@
+// Redux inspired reducer, reduces an event into a gekko state.
+// NOTE: this does mutate.
+// NOTE2: this is used by the backend as well as the frontend.
+
+const moment = require('moment');
+
+const skipInitialEvents = ['marketUpdate'];
+const skipLatestEvents = ['marketStart'];
+const trackAllEvents = ['tradeCompleted', 'advice', 'roundtrip'];
+
+const reduce = (state, event) => {
+  const type = event.type;
+  const payload = event.payload;
+
+  state.latestUpdate = moment();
+
+  if(trackAllEvents.includes(type)) {
+    if(!state.events[type])
+      state.events[type] = [];
+
+    state.events[type].push(payload);
+  }
+
+  if(!state.events.initial[type] && !skipInitialEvents.includes(type)) {
+    state.events.initial[type] = payload;
+  }
+
+  if(!skipLatestEvents.includes(type)) {
+    state.events.latest[type] = payload;
+  }
+
+  return state;
+}
+
+module.exports = reduce;