summaryrefslogtreecommitdiff
path: root/app/client/socket.js
diff options
context:
space:
mode:
Diffstat (limited to 'app/client/socket.js')
-rw-r--r--app/client/socket.js163
1 files changed, 0 insertions, 163 deletions
diff --git a/app/client/socket.js b/app/client/socket.js
deleted file mode 100644
index da70dfc..0000000
--- a/app/client/socket.js
+++ /dev/null
@@ -1,163 +0,0 @@
-import { store } from './store'
-import types from './types'
-import * as player from './live/player'
-
-let socket = io.connect('/client')
-
-// SOCKET ACTIONS
-
-socket.on('connect', () => store.dispatch({ type: types.socket.connect }))
-socket.on('connect_error', (error) => store.dispatch({ type: types.socket.connect_error, error }))
-socket.on('reconnect', (attempt) => store.dispatch({ type: types.socket.reconnect, attempt }))
-socket.on('reconnecting', () => store.dispatch({ type: types.socket.reconnecting }))
-socket.on('reconnect_error', (error) => store.dispatch({ type: types.socket.reconnect_error, error }))
-socket.on('reconnect_failed', (error) => store.dispatch({ type: types.socket.reconnect_failed, error }))
-socket.on('disconnect', () => store.dispatch({ type: types.socket.disconnect }))
-socket.on('error', (error) => store.dispatch({ type: types.socket.error, error }))
-
-socket.on('res', (data) => {
- console.log(data.cmd)
- switch (data.cmd) {
- case 'get_last_frame':
- if (data.res !== 'working') {
- socket.emit('cmd', {
- cmd: 'get_last_frame',
- })
- }
- break
- case 'get_params':
- store.dispatch({
- type: types.socket.load_params,
- opt: data.res,
- })
- break
- case 'list_checkpoints':
- store.dispatch({
- type: types.socket.list_checkpoints,
- checkpoints: data.res,
- })
- break
- case 'list_sequences':
- store.dispatch({
- type: types.socket.list_sequences,
- sequences: data.res,
- })
- break
- case 'list_epochs':
- store.dispatch({
- type: types.socket.list_epochs,
- epochs: data.res,
- })
- break
- default:
- break
- }
- console.log(data)
-})
-
-socket.on('system_res', (data) => {
- console.log('system response', data)
- switch (data.type) {
- case 'relay_connected':
- return store.dispatch({ type: types.system.relay_connected })
- case 'relay_disconnected':
- return store.dispatch({ type: types.system.relay_disconnected })
- case 'rpc_connected':
- return store.dispatch({ type: types.system.rpc_connected, runner: data.runner })
- case 'rpc_disconnected':
- return store.dispatch({ type: types.system.rpc_disconnected })
- case 'relay_status':
- return store.dispatch({ type: data.rpc_connected ? types.system.rpc_connected : types.system.rpc_disconnected, runner: data.runner })
- case 'command_output':
- store.dispatch({
- type: types.system.command_output,
- data: data,
- })
- break
- }
-})
-
-socket.on('frame', player.onFrame)
-
-socket.on('status', (data) => {
- console.log('got status', data.key, data.value)
- store.dispatch({ type: types.socket.status })
- switch (data.key) {
- case 'processing':
- store.dispatch({
- type: 'SET_PARAM',
- ...data,
- })
- break
- default:
- break
- }
-})
-
-export function list_checkpoints() {
- socket.emit('cmd', {
- cmd: 'list_checkpoints',
- })
-}
-export function list_epochs(checkpoint_name) {
- socket.emit('cmd', {
- cmd: 'list_epochs',
- payload: checkpoint_name,
- })
-}
-export function list_sequences() {
- socket.emit('cmd', {
- cmd: 'list_sequences',
- })
-}
-export function load_epoch(checkpoint_name, epoch) {
- console.log(">> SWITCH CHECKPOINT", checkpoint_name, epoch)
- socket.emit('cmd', {
- cmd: 'load_epoch',
- payload: checkpoint_name + ':' + epoch,
- })
-}
-export function load_sequence(sequence) {
- socket.emit('cmd', {
- cmd: 'load_sequence',
- payload: sequence,
- })
-}
-export function seek(frame) {
- socket.emit('cmd', {
- cmd: 'seek',
- payload: frame,
- })
-}
-export function pause(frame) {
- socket.emit('cmd', {
- cmd: 'pause',
- })
-}
-export function play(frame) {
- socket.emit('cmd', {
- cmd: 'play',
- })
-}
-export function get_params() {
- socket.emit('cmd', {
- cmd: 'get_params',
- })
-}
-export function set_param(key, value) {
- socket.emit('cmd', {
- cmd: 'set_param',
- payload: {
- 'key': key,
- 'value': value,
- }
- })
-}
-export function run_system_command(cmd) {
- socket.emit('system', {
- cmd: 'run_system_command',
- payload: cmd,
- })
-}
-
-export { socket }