Add websocket translation script

1 files changed, 45 insertions, 0 deletions

diff --git a/websockets/server.js b/websockets/server.js
new file mode 100755
index 0000000..c6af67f
--- /dev/null
+++ b/websockets/server.js
@@ -0,0 +1,45 @@
+#!/usr/bin/env node
+const net=require("net");
+const WebSocket=require("ws");
+
+const PORT=29546;
+
+const upstream={
+	host: "localhost",
+	port: 29536
+};
+
+
+const server=new WebSocket.Server({port:PORT},()=>{
+	console.log(`Listening for websocket http requests on port ${PORT}`);
+});
+server.on("connection",(sock)=>{
+	let netconn=null;
+	let buffer=[];
+
+	netconn=net.connect(upstream.port,upstream.host,()=>{
+		for(const item of buffer){
+			netconn.write(item);
+		}
+		buffer=[];
+	});
+	netconn.on("close",()=>{
+		sock.close();
+	});
+	netconn.on("data",(data)=>{
+		sock.send(data);
+	});
+
+	sock.on("close",()=>{
+		netconn.end();
+	});
+	sock.on("message",(data)=>{
+		if(netconn.connecting)buffer.push(data);
+		else netconn.write(data);
+	});
+});
+
+process.on("SIGINT",()=>{
+	console.log("Closing websocket server...");
+	server.close();
+});