test sending events

1 files changed, 44 insertions, 19 deletions

diff --git a/public/bundle.js b/public/bundle.js
index 2691c5e..67a30db 100644
--- a/public/bundle.js
+++ b/public/bundle.js
@@ -1534,7 +1534,7 @@ exports.play = exports.pause = exports.seek = exports.load_epoch = exports.load_
 
 var _socket = __webpack_require__(/*! ../socket */ "./app/client/socket/index.js");
 
-var socket = _interopRequireWildcard(_socket);
+var _socket2 = _interopRequireDefault(_socket);
 
 var _types = __webpack_require__(/*! ../types */ "./app/client/types.js");
 
@@ -1542,56 +1542,54 @@ var _types2 = _interopRequireDefault(_types);
 
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
-
 var get_params = exports.get_params = function get_params() {
-  socket.get_params();
+  _socket2.default.live.get_params();
   return { type: _types2.default.player.get_params };
 };
 
 var set_param = exports.set_param = function set_param(key, value) {
   console.log('set param', key, value);
-  socket.set_param(key, value);
+  _socket2.default.live.set_param(key, value);
   return { type: _types2.default.player.set_param, key: key, value: value };
 };
 
 var list_checkpoints = exports.list_checkpoints = function list_checkpoints() {
-  socket.list_checkpoints();
+  _socket2.default.live.list_checkpoints();
   return { type: _types2.default.player.loading_checkpoints };
 };
 
 var list_epochs = exports.list_epochs = function list_epochs(path) {
-  socket.list_epochs(path);
+  _socket2.default.live.list_epochs(path);
   return { type: _types2.default.player.loading_epochs };
 };
 
 var list_sequences = exports.list_sequences = function list_sequences() {
-  socket.list_sequences();
+  _socket2.default.live.list_sequences();
   return { type: _types2.default.player.loading_sequences };
 };
 
 var load_sequence = exports.load_sequence = function load_sequence(sequence) {
-  socket.load_sequence(sequence);
+  _socket2.default.live.load_sequence(sequence);
   return { type: _types2.default.player.loading_sequence };
 };
 
 var load_epoch = exports.load_epoch = function load_epoch(checkpoint, epoch) {
-  socket.load_epoch(checkpoint, epoch);
+  _socket2.default.live.load_epoch(checkpoint, epoch);
   return { type: _types2.default.player.loading_checkpoint };
 };
 
 var seek = exports.seek = function seek(frame) {
-  socket.seek(frame);
+  _socket2.default.live.seek(frame);
   return { type: _types2.default.player.seeking };
 };
 
 var pause = exports.pause = function pause(frame) {
-  socket.pause(pause);
+  _socket2.default.live.pause(pause);
   return { type: _types2.default.player.pausing };
 };
 
 var play = exports.play = function play(frame) {
-  socket.play();
+  _socket2.default.live.play();
   return { type: _types2.default.player.playing };
 };
 
@@ -2923,25 +2921,25 @@ _socket.socket.on('res', function (data) {
       }
       break;
     case 'get_params':
-      store.dispatch({
+      (0, _store.dispatch)({
         type: _types2.default.socket.load_params,
         opt: data.res
       });
       break;
     case 'list_checkpoints':
-      store.dispatch({
+      (0, _store.dispatch)({
         type: _types2.default.socket.list_checkpoints,
         checkpoints: data.res
       });
       break;
     case 'list_sequences':
-      store.dispatch({
+      (0, _store.dispatch)({
         type: _types2.default.socket.list_sequences,
         sequences: data.res
       });
       break;
     case 'list_epochs':
-      store.dispatch({
+      (0, _store.dispatch)({
         type: _types2.default.socket.list_epochs,
         epochs: data.res
       });
@@ -3310,6 +3308,10 @@ var _system = __webpack_require__(/*! ./system.actions */ "./app/client/system/s
 
 var systemActions = _interopRequireWildcard(_system);
 
+var _live = __webpack_require__(/*! ../live/live.actions */ "./app/client/live/live.actions.js");
+
+var liveActions = _interopRequireWildcard(_live);
+
 var _task = __webpack_require__(/*! ../task/task.actions */ "./app/client/task/task.actions.js");
 
 var taskActions = _interopRequireWildcard(_task);
@@ -3345,6 +3347,10 @@ var live_test_task = {
   epochs: 1,
   opt: {}
 };
+var fruits = ["apple", "pear", "banana", "strawberry"];
+function choice(a) {
+  return a[Math.floor(Math.random() * a.length)];
+}
 
 var System = function (_Component) {
   _inherits(System, _Component);
@@ -3530,6 +3536,24 @@ var System = function (_Component) {
                     } },
                   'Stop'
                 )
+              ),
+              (0, _preact.h)(
+                _param2.default,
+                { title: 'Test Live RPC' },
+                (0, _preact.h)(
+                  'button',
+                  { onClick: function onClick() {
+                      return actions.live.get_params();
+                    } },
+                  'Get'
+                ),
+                (0, _preact.h)(
+                  'button',
+                  { onClick: function onClick() {
+                      return actions.live.set_param('fruit', choice(fruits));
+                    } },
+                  'Set'
+                )
               )
             )
           ),
@@ -3597,14 +3621,15 @@ var System = function (_Component) {
 }(_preact.Component);
 
 var mapStateToProps = function mapStateToProps(state) {
-  return _extends({}, state.system);
+  return _extends({}, state.system, state.live);
 };
 
 var mapDispatchToProps = function mapDispatchToProps(dispatch, ownProps) {
   return {
     actions: {
       system: (0, _redux.bindActionCreators)(systemActions, dispatch),
-      task: (0, _redux.bindActionCreators)(taskActions, dispatch)
+      task: (0, _redux.bindActionCreators)(taskActions, dispatch),
+      live: (0, _redux.bindActionCreators)(liveActions, dispatch)
     }
   };
 };