From 1a6ae72c46b08c27db0ca5da9fe8f84b38c0f769 Mon Sep 17 00:00:00 2001
From: Jules Laplace <julescarbon@gmail.com>
Date: Sun, 20 May 2018 14:29:32 +0200
Subject: more relay stuff, setting up server

---
 app/server/index.js | 38 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 38 insertions(+)
 create mode 100644 app/server/index.js

(limited to 'app/server/index.js')

diff --git a/app/server/index.js b/app/server/index.js
new file mode 100644
index 0000000..3fcb8ee
--- /dev/null
+++ b/app/server/index.js
@@ -0,0 +1,38 @@
+require('dotenv').config()
+const app = require('express')()
+const server = require('http').createServer(app)
+const io = require('socket.io')(server)
+const ss = require('socket.io-stream')
+
+const client = io.of('/client')
+const relay = io.of('/relay')
+
+client.on('connect', socket => {
+  console.log('client connected')
+  socket.on('cmd', data => {
+    relay.emit('cmd', data)
+  })
+  socket.on('disconnect', () => {
+    console.log("client disconnected")
+  })
+})
+
+relay.on('connect', socket => {
+  console.log('relay connected')
+  socket.on('params', data => {
+    client.emit('params', data)
+  })
+
+  ss(relay).on('frame', (stream, data) => {
+    console.log(data)
+    Object.values(client.connected).map(socket => {
+      ss(socket).emit('frame', stream, data)
+    })
+  })
+
+  socket.on('disconnect', () => {
+    console.log("relay disconnected")
+  })
+})
+
+server.listen(process.env.EXPRESS_PORT)
\ No newline at end of file
-- 
cgit v1.2.3-70-g09d2