import { store } from './store' import * as player from './live/player' let socket = io.connect('/client') // SOCKET ACTIONS 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('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 { socket }