wooooord

1 files changed, 70 insertions, 11 deletions

diff --git a/public/bundle.js b/public/bundle.js
index 09955f1..8d9b0e7 100644
--- a/public/bundle.js
+++ b/public/bundle.js
@@ -261,6 +261,7 @@ var Select = function (_Component) {
       clearTimeout(this.timeout);
       var new_value = e.target.value;
       this.props.actions.set_param(this.props.name, new_value);
+      this.props.onChange && this.props.onChange(new_value);
     }
   }, {
     key: 'render',
@@ -565,7 +566,7 @@ var app = (0, _preact.h)(
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
-exports.list_sequences = exports.list_epochs = exports.list_checkpoints = exports.set_param = exports.get_params = undefined;
+exports.load_epoch = exports.load_sequence = exports.list_sequences = exports.list_epochs = exports.list_checkpoints = exports.set_param = exports.get_params = undefined;
 
 var _socket = __webpack_require__(/*! ../socket */ "./app/client/socket.js");
 
@@ -599,6 +600,16 @@ var list_sequences = exports.list_sequences = function list_sequences() {
   return { type: 'LOADING_SEQUENCES' };
 };
 
+var load_sequence = exports.load_sequence = function load_sequence(sequence) {
+  socket.load_sequence(sequence);
+  return { type: 'LOADING_SEQUENCE' };
+};
+
+var load_epoch = exports.load_epoch = function load_epoch(checkpoint, epoch) {
+  socket.load_epoch(checkpoint, epoch);
+  return { type: 'LOADING_CHECKPOINT' };
+};
+
 /***/ }),
 
 /***/ "./app/client/live/components/player.component.js":
@@ -702,6 +713,9 @@ var App = function (_Component) {
     props.actions.get_params();
     props.actions.list_checkpoints();
     props.actions.list_sequences();
+    _this.changeCheckpoint = _this.changeCheckpoint.bind(_this);
+    _this.changeEpoch = _this.changeEpoch.bind(_this);
+    _this.changeSequence = _this.changeSequence.bind(_this);
     return _this;
   }
 
@@ -709,11 +723,30 @@ var App = function (_Component) {
     key: 'componentWillUpdate',
     value: function componentWillUpdate(nextProps) {
       console.log('willupdate', nextProps.opt);
-      if (nextProps.opt.checkpoint_name !== this.props.opt.checkpoint_name) {
+      if (!nextProps.epochs || nextProps.opt.checkpoint_name !== this.props.opt.checkpoint_name) {
+        this.props.actions.list_epochs(nextProps.opt.checkpoint_name);
+      }
+      if (!nextProps.epochs || nextProps.opt.checkpoint_name !== this.props.opt.checkpoint_name) {
         this.props.actions.list_epochs(nextProps.opt.checkpoint_name);
       }
     }
   }, {
+    key: 'changeCheckpoint',
+    value: function changeCheckpoint(checkpoint_name) {
+      this.props.actions.load_epoch(checkpoint_name, 'latest');
+    }
+  }, {
+    key: 'changeEpoch',
+    value: function changeEpoch(epoch_name) {
+      this.props.actions.load_epoch(this.props.opt.checkpoint_name, epoch_name);
+    }
+  }, {
+    key: 'changeSequence',
+    value: function changeSequence(sequence) {
+      console.log('got sequence', sequence);
+      this.props.actions.load_sequence(sequence);
+    }
+  }, {
     key: 'render',
     value: function render() {
       return (0, _preact.h)(
@@ -740,17 +773,20 @@ var App = function (_Component) {
               (0, _preact.h)(_select2.default, {
                 name: 'checkpoint_name',
                 title: 'checkpoint',
-                options: this.props.checkpoints
+                options: this.props.checkpoints,
+                onChange: this.changeCheckpoint
               }),
               (0, _preact.h)(_select2.default, {
                 name: 'epoch',
                 title: 'epoch',
-                options: this.props.epochs
+                options: this.props.epochs,
+                onChange: this.changeEpoch
               }),
               (0, _preact.h)(_select2.default, {
                 name: 'sequence_name',
                 title: 'sequence',
-                options: this.props.sequences
+                options: this.props.sequences,
+                onChange: this.changeSequence
               })
             )
           ),
@@ -951,12 +987,19 @@ var liveReducer = function liveReducer() {
 
     case 'LIST_CHECKPOINTS':
       return _extends({}, state, {
-        checkpoints: action.checkpoints
+        checkpoints: action.checkpoints,
+        epochs: []
       });
 
-    case 'LIST_CHECKPOINT_DIR':
+    case 'LIST_EPOCHS':
       return _extends({}, state, {
-        checkpoint_dir: action.checkpoint_dir
+        epochs: action.epochs.map(function (a) {
+          return [a == 'latest' ? Infinity : a, a];
+        }).sort(function (a, b) {
+          return a[0] - b[0];
+        }).map(function (a) {
+          return a[1];
+        })
       });
 
     case 'LIST_SEQUENCES':
@@ -990,6 +1033,8 @@ exports.socket = undefined;
 exports.list_checkpoints = list_checkpoints;
 exports.list_epochs = list_epochs;
 exports.list_sequences = list_sequences;
+exports.load_epoch = load_epoch;
+exports.load_sequence = load_sequence;
 exports.get_params = get_params;
 exports.set_param = set_param;
 
@@ -1030,7 +1075,7 @@ socket.on('res', function (data) {
     case 'list_epochs':
       _store.store.dispatch({
         type: 'LIST_EPOCHS',
-        sequences: data.res
+        epochs: data.res
       });
       break;
     default:
@@ -1059,9 +1104,10 @@ function list_checkpoints() {
     cmd: 'list_checkpoints'
   });
 }
-function list_epochs() {
+function list_epochs(checkpoint_name) {
   socket.emit('cmd', {
-    cmd: 'list_epochs'
+    cmd: 'list_epochs',
+    payload: checkpoint_name
   });
 }
 function list_sequences() {
@@ -1069,6 +1115,19 @@ function list_sequences() {
     cmd: 'list_sequences'
   });
 }
+function load_epoch(checkpoint_name, epoch) {
+  console.log(">> SWITCH CHECKPOINT", checkpoint_name, epoch);
+  socket.emit('cmd', {
+    cmd: 'load_epoch',
+    payload: checkpoint_name + ':' + epoch
+  });
+}
+function load_sequence(sequence) {
+  socket.emit('cmd', {
+    cmd: 'load_sequence',
+    payload: sequence
+  });
+}
 function get_params() {
   socket.emit('cmd', {
     cmd: 'get_params'