Initial Commit

Author: AbdulRKB

.env

@@ -0,0 +1 @@
+PORT=8080

.replit

@@ -0,0 +1,59 @@
+language = "nodejs"
+run = "npm run start"
+
+[env]
+XDG_CONFIG_HOME = "/home/runner/.config"
+PATH = "/home/runner/$REPL_SLUG/.config/npm/node_global/bin:/home/runner/$REPL_SLUG/node_modules/.bin"
+npm_config_prefix = "/home/runner/$REPL_SLUG/.config/npm/node_global"
+
+[nix]
+channel = "stable-22_05"
+
+[packager]
+language = "nodejs"
+
+[packager.features]
+packageSearch = true
+guessImports = true
+enabledForHosting = false
+
+[debugger]
+support = true
+
+[debugger.interactive]
+transport = "localhost:0"
+startCommand = ["dap-node"]
+
+[debugger.interactive.initializeMessage]
+command = "initialize"
+type = "request"
+
+[debugger.interactive.initializeMessage.arguments]
+clientID = "replit"
+clientName = "replit.com"
+columnsStartAt1 = true
+linesStartAt1 = true
+locale = "en-us"
+pathFormat = "path"
+supportsInvalidatedEvent = true
+supportsProgressReporting = true
+supportsRunInTerminalRequest = true
+supportsVariablePaging = true
+supportsVariableType = true
+
+[debugger.interactive.launchMessage]
+command = "launch"
+type = "request"
+
+[debugger.interactive.launchMessage.arguments]
+console = "externalTerminal"
+cwd = "."
+pauseForSourceMap = false
+program = "./index.js"
+request = "launch"
+sourceMaps = true
+stopOnEntry = false
+type = "pwa-node"
+
+[unitTest]
+language = "nodejs"

Dockerfile

@@ -0,0 +1,14 @@
+# syntax=docker/dockerfile:1
+
+FROM node:19-bullseye
+ENV NODE_ENV=production
+
+WORKDIR /app
+
+COPY ["package.json", "package-lock.json*", "./"]
+
+RUN npm install
+
+COPY . .
+
+CMD [ "node", "index.js" ]

app.json

@@ -0,0 +1,7 @@
+{
+    "name": "P45",
+    "description": "P45",
+    "repository": "https://github.com/cybertitus/tn",
+    "logo": "",
+    "keywords": ["P45", "proxy", "www"]
+  }

index.js

@@ -0,0 +1,101 @@
+import cluster from "cluster";
+import os from "os";
+import express from "express";
+import http from "node:http";
+import createBareServer from "@tomphttp/bare-server-node";
+import path from "node:path";
+import * as dotenv from "dotenv";
+dotenv.config();
+
+const __dirname = process.cwd();
+
+// Increase max sockets to 1000
+http.globalAgent.maxSockets = 1000;
+
+if (cluster.isMaster) {
+  const numCPUs = os.cpus().length;
+  console.log(`Master process running with PID ${process.pid}`);
+
+  // Fork worker processes
+  for (let i = 0; i < numCPUs; i++) {
+    cluster.fork();
+  }
+
+  // Handle worker exit events
+  cluster.on("exit", (worker, code, signal) => {
+    console.log(
+      `Worker ${worker.process.pid} died with code ${code} and signal ${signal}`
+    );
+    console.log("Forking a new worker...");
+    cluster.fork();
+  });
+} else {
+  const server = http.createServer();
+  const app = express(server);
+  const bareServer = createBareServer("/bare/");
+
+  // Serve static files with caching
+  const staticOptions = {
+    maxAge: "1d",
+    setHeaders: (res, path) => {
+      if (path.endsWith(".html")) {
+        res.setHeader("Cache-Control", "no-cache");
+      } else {
+        res.setHeader("Cache-Control", "public, max-age=86400");
+      }
+    },
+  };
+  app.use(express.static(path.join(__dirname, "static"), staticOptions));
+
+  app.use(express.json());
+  app.use(
+    express.urlencoded({
+      extended: true,
+    })
+  );
+
+  // Define routes
+  const routes = [
+    { path: "/", file: "web.html" },
+    // { path: "/web", file: "web.html" },
+    // { path: "/apps", file: "apps.html" },
+    { path: "/go", file: "go.html" },
+    // { path: "/settings", file: "settings.html" },
+    { path: "/404", file: "404.html" },
+  ];
+
+  // Define routes using the routes array
+  routes.forEach((route) => {
+    app.get(route.path, (req, res) => {
+      res.sendFile(path.join(__dirname, "static", route.file));
+    });
+  });
+
+  // Catch-all route
+  app.get("/*", (req, res) => {
+    res.redirect("/404");
+  });
+
+  // Bare Server
+  server.on("request", (req, res) => {
+    if (bareServer.shouldRoute(req)) {
+      bareServer.routeRequest(req, res);
+    } else {
+      app(req, res);
+    }
+  });
+
+  server.on("upgrade", (req, socket, head) => {
+    if (bareServer.shouldRoute(req)) {
+      bareServer.routeUpgrade(req, socket, head);
+    } else {
+      socket.end();
+    }
+  });
+
+  server.listen({
+    port: process.env.PORT,
+  });
+
+  console.log(`Worker process running with PID ${process.pid}`);
+}