Commit

Author: gvbvdxxalt2

.gitignore

@@ -0,0 +1 @@
+node_modules

package.json

@@ -0,0 +1,25 @@
+{
+  "name": "randomrants-proxy",
+  "version": "1.0.0",
+  "description": "Proxy for random rants +",
+  "homepage": "https://github.com/Random-Rants-Chat/randomrants-proxy#readme",
+  "bugs": {
+    "url": "https://github.com/Random-Rants-Chat/randomrants-proxy/issues"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/Random-Rants-Chat/randomrants-proxy.git"
+  },
+  "license": "MIT",
+  "author": "Gvbvdxx",
+  "type": "commonjs",
+  "main": "index.js",
+  "scripts": {
+    "start": "node src/server.js"
+  },
+  "dependencies": {
+    "https": "^1.0.0",
+    "ws": "^8.19.0",
+    "wss": "^3.3.4"
+  }
+}

src/config.js

@@ -0,0 +1,8 @@
+
+module.exports = {
+    targetHost: "randomrants-plus.onrender.com",
+    targetOrigin: "randomrants-plus.onrender.com",
+    targetWsPath: "wss://randomrants-plus.onrender.com",
+    serverModule: require("https"),
+    wsModule: require("wss")
+};

src/header-blacklist.js

@@ -0,0 +1,12 @@
+module.exports = [
+    "origin",
+    "x-forwarded-for",
+    "x-forwarded-proto",
+    "x-forwarded-host",
+    "proxy-connection",
+    "x-forwarded-port",
+    "x-forwarded-scheme",
+    "x-real-ip",
+    "host",
+    "referer"
+];

src/http/index.js

@@ -0,0 +1,39 @@
+var headerBlacklist = require("../header-blacklist.js");
+var http = require("http");
+var config = require("../config.js");
+var serverModule = config.serverModule;
+var headerBlacklist = require("../header-blacklist.js");
+
+function onHTTPRequest(req,res) {
+    var proxyHeaders = req.headers || {};
+    for (var blockedHeader of headerBlacklist) {
+        proxyHeaders[blockedHeader] = null;
+        delete proxyHeaders[blockedHeader];
+    }
+    proxyHeaders["origin"] = config.targetOrigin;
+    var proxyReq = serverModule.request({
+        host: config.targetHost,
+        method: req.method,
+        path: req.url,
+        headers: proxyHeaders
+    }, (proxyRes) => {
+        var headers = proxyRes.headers || {};
+        for (var blockedHeader of headerBlacklist) {
+            headers[blockedHeader] = null;
+            delete headers[blockedHeader];
+        }
+        for (var header of Object.keys(headers)) {
+            res.setHeader(header, headers[header]);
+        }
+        
+        proxyRes.pipe(res);
+    });
+
+    if (req.method == "POST") {
+        req.pipe(proxyReq);
+    } else {
+        proxyReq.end("");
+    }
+}
+
+module.exports = {onHTTPRequest};

src/server.js

@@ -0,0 +1,11 @@
+process.env['NODE_TLS_REJECT_UNAUTHORIZED'] = 0;
+
+var http = require("http");
+var {onHTTPRequest} = require("./http");
+var {onUpgradeRequest} = require("./ws");
+
+var server = http.createServer(onHTTPRequest);
+
+server.on("upgrade", onUpgradeRequest);
+
+server.listen(8080);

src/ws/anti-ghost.js

@@ -0,0 +1,54 @@
+function terminateGhostSockets(ws) {
+  var isAlive = true;
+  var terminated = false;
+
+  function heartbeat() {
+    isAlive = true;
+  }
+
+  ws.on("pong", heartbeat);
+
+  var interval = setInterval(() => {
+    if (!isAlive) {
+      if (!terminated) {
+        terminated = true;
+        clearInterval(interval);
+        ws.terminate();
+        //ws.emit("close");
+      }
+      return;
+    }
+
+    isAlive = false;
+    try {
+      ws.ping();
+    } catch (err) {
+      if (!terminated) {
+        terminated = true;
+        clearInterval(interval);
+        ws.terminate();
+        //ws.emit("close");
+      }
+    }
+  }, 1500); // Check every 1500 miliseconds.
+
+  ws.on("close", () => {
+    if (!terminated) {
+      terminated = true;
+      clearInterval(interval);
+    }
+  });
+
+  try {
+    ws.ping();
+  } catch (err) {
+    // Socket might already be broken
+    if (!terminated) {
+      terminated = true;
+      clearInterval(interval);
+      ws.terminate();
+    }
+  }
+}
+
+module.exports = {terminateGhostSockets};

src/ws/index.js

@@ -0,0 +1,54 @@
+var headerBlacklist = require("../header-blacklist.js");
+var config = require("../config.js");
+var tls = require('tls');
+var net = require('net');
+
+function onUpgradeRequest(clientRequest, clientSocket, clientHead) {
+    const options = {
+        host: config.targetHost,
+        port: 443,
+        servername: config.targetHost, 
+        rejectUnauthorized: false
+    };
+
+    const targetSocket = tls.connect(options, () => {
+        clientSocket.setTimeout(0);
+        targetSocket.setTimeout(0);
+        clientSocket.setNoDelay(true);
+        targetSocket.setNoDelay(true);
+        let headers = `${clientRequest.method} ${clientRequest.url} HTTP/${clientRequest.httpVersion}\r\n`;
+        for (let i = 0; i < clientRequest.rawHeaders.length; i += 2) {
+            const key = clientRequest.rawHeaders[i];
+            const value = clientRequest.rawHeaders[i + 1];
+            if (headerBlacklist && headerBlacklist.includes(key)) continue;
+            if (key.toLowerCase() === 'host') {
+                headers += `Host: ${config.targetHost}\r\n`;
+            } else if (key.toLowerCase() === 'origin') {
+                headers += `Origin: https://${config.targetHost}\r\n`;
+            } else {
+                headers += `${key}: ${value}\r\n`;
+            }
+        }
+        headers += '\r\n';
+
+        targetSocket.write(headers);
+        targetSocket.write(clientHead);
+
+        clientSocket.pipe(targetSocket).pipe(clientSocket);
+    });
+
+    targetSocket.on('error', (err) => {
+        console.error('Target Socket Error:', err.message);
+        clientSocket.end();
+    });
+
+    clientSocket.on('error', (err) => {
+        console.error('Client Socket Error:', err.message);
+        targetSocket.end();
+    });
+
+    targetSocket.on('end', () => clientSocket.end());
+    clientSocket.on('end', () => targetSocket.end());
+}
+
+module.exports = {onUpgradeRequest};