From c6dbf0450566c40efc4a26f4f0717452b6ef95cd Mon Sep 17 00:00:00 2001
From: Minteck <contact@minteck.org>
Date: Wed, 10 Aug 2022 10:38:44 +0200
Subject: Initial commit

---
 server/hornchat.conversation.js | 74 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 74 insertions(+)
 create mode 100644 server/hornchat.conversation.js

(limited to 'server/hornchat.conversation.js')

diff --git a/server/hornchat.conversation.js b/server/hornchat.conversation.js
new file mode 100644
index 0000000..99baccd
--- /dev/null
+++ b/server/hornchat.conversation.js
@@ -0,0 +1,74 @@
+require('./hornchat.serverlet.sync')
+
+const WebSocket = require('ws');
+const uuid = require('uuid-v4');
+const _auth = require('./hornchat.serverlet.authentication');
+
+const server = new WebSocket.Server({
+    port: 8306
+});
+
+global.data = {};
+
+server.on('connection', function (socket, req) {
+    socket.ip = req.headers['x-forwarded-for'] ? req.headers['x-forwarded-for'].split(',')[0].trim() : req.socket.remoteAddress;
+
+    socket.authenticated = null;
+    socket.id = uuid();
+    console.log("New connection: " + socket.id);
+    data[socket.id] = {};
+    data[socket.id]["socket"] = socket;
+
+    require('./hornchat.serverlet.timeout')(socket);
+
+    socket.on('close', () => {
+        if (socket.id) {
+            delete data[socket.id];
+        }
+    })
+
+    socket.on('message', function (msg) {
+        if (socket.authenticated === null) {
+            _auth(socket, msg);
+        } else {
+            let d;
+            try {
+                d = JSON.parse(msg);
+            } catch (e) {
+                socket.send(JSON.stringify({error:"INVALID_DATA", fatal: false}));
+                console.log("[" + socket.id + "] Received invalid data");
+                return;
+            }
+
+            if (d.type) {
+                switch (d.type) {
+                    case "start":
+                        require('./hornchat.conversation.start')(socket, d);
+                        break;
+
+                    case "typing":
+                        require('./hornchat.conversation.typing')(socket, d);
+                        break;
+
+                    case "message":
+                        require('./hornchat.conversation.message')(socket, d);
+                        break;
+
+                    case "read":
+                        require('./hornchat.conversation.read')(socket, d);
+                        break;
+
+                    default:
+                        socket.send(JSON.stringify({error:"MISSING_OPERAND", fatal: false}));
+                        console.log("[" + socket.id + "] Missing 'type' value");
+                        break;
+                }
+            } else {
+                socket.send(JSON.stringify({error:"MISSING_OPERAND", fatal: false}));
+                console.log("[" + socket.id + "] Missing 'type' value");
+            }
+        }
+    });
+});
+
+console.log("Listening on port 8306");
\ No newline at end of file
-- 
cgit