task index / queue translation

1 files changed, 25 insertions, 0 deletions

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)
   })