From 5321bafae0916861e270b692a42b3b699a96d339 Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Mon, 4 Jun 2018 21:43:36 +0200 Subject: task index / queue translation --- app/server/bridge.js | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) (limited to 'app/server/bridge.js') diff --git a/app/server/bridge.js b/app/server/bridge.js index bbe0e26..ef586ac 100644 --- a/app/server/bridge.js +++ b/app/server/bridge.js @@ -1,5 +1,6 @@ import { server, io } from './site' import * as proxy from './proxy' +import * as db from './db' let relay_connected = false @@ -27,15 +28,18 @@ function bind_relay(socket) { relay_connected = true client.emit('system_res', { type: 'relay_connected' }) + // responses from a live process socket.on('res', data => { // console.log('Received response', data.cmd) client.emit('res', data) }) + // status messages from a live process socket.on('status', data => { client.emit('status', data) }) + // responses to system calls socket.on('system_res', data => { if (process.env.CACHE_SYSCALLS) { const id = make_server_id(data) @@ -44,10 +48,31 @@ function bind_relay(socket) { client.emit('system_res', data) }) + // messages related to queuing and tasks socket.on('task_res', data => { client.emit('task_res', data) }) + // // data responses from the server, telling us that files, folders, etc were created + // socket.on('data_res', data => { + // if (EXPRESS_CONNECTS_TO_RELAY) return + // switch (data.type) { + // case 'file_create': + // // certain files should be persisted in the database... + // db.models.file.create(data.data).then(file => { + // client.emit('data_res', { + // type: 'file_create', + // data: file, + // }) + // }) + // break + // default: + // client.emit('data_res', data) + // break + // } + // }) + + // image frames generated by pix2pix socket.on('frame', (data) => { client.volatile.emit('frame', data) }) -- cgit v1.2.3-70-g09d2