Merge branch 'master' of gitea.moe:lamp/qonq

also fixed trust proxy bug

.gitignore

@@ -1,6 +1,9 @@
-files/*
+*
-node_modules
+!/.vscode
-*.log
+!/.gitignore
+!/qonq.js
+!/discord-preloader.js
+!/package.json
+!/package-lock.json
+!/README.md
 !.gitkeep
-ecosystem.config.js
-.env

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+	"files.watcherExclude": {
+		"**/files/**": true
+	}
+}

qonq.js

@@ -1,5 +1,4 @@
 require("dotenv").config();
-process.env.NODE_ENV = "production";
 var colors = require("colors");
 var express = require("express");
 var formidable = require("formidable");
@@ -14,7 +13,10 @@ if (process.env.HOSTNAMES) {
 }
 
 var app = express();
-app.enable('trust proxy', '127.0.0.1');
+app.set("env", "production");
+app.set('trust proxy', '127.0.0.1');
+app.listen(process.env.PORT || 8568, process.env.ADDRESS);
+
 
 app.use((req, res, next)=>{
 	var d = new Date;
@@ -25,53 +27,56 @@ app.use((req, res, next)=>{
 	next();
 });
 
-app.post("/upload", (req, res, next) => {
+
-	if (req.headers.authentication != process.env.AUTH_TOKEN) return res.status(403).send("Unauthorized");
+app.post("*", (req, res, next) => {
+	if (req.headers.authentication != process.env.AUTH_TOKEN) return void res.status(403).send("Unauthorized");
 	var form = new formidable.IncomingForm({
 		maxFileSize: 2**30, // 1 GiB
 		maxFields: 1,
 		uploadDir: process.env.TMP_DIR
 	});
 	form.parse(req, function(err, fields, files) {
-		if (err) return next(err);
+		if (err) return void next(err);
 		var file = files.file;
-		if (!file) return res.sendStatus(400);
+		if (!file) return void res.sendStatus(400);
-		do {
+		(function trymkdir() {
 			var filecode = Math.random().toString(36).slice(2).substring(0,4);
-		} while ( fs.existsSync(path.join(FILES_DIR, filecode)) && !console.log("oof") );
+			var webroot = path.join(FILES_DIR, filecode);
-		try {
+			fs.mkdir(webroot, function (error) {
-			fs.mkdirSync(path.join(FILES_DIR, filecode));
+				if (error) if (error.code == "EEXIST") {
-			fs.renameSync(file.path, path.join(FILES_DIR, filecode, file.name));
+					console.log("oof");
-		} catch(e) {
+					trymkdir();
-			return next(e);
+				} else next(error);
-		}
+				else {
-		let url = `${req.protocol}://${filecode}.${randomHostname?.() || req.hostname}`;
+					fs.rename(file.path, path.join(webroot, file.name), function (error) {
-		res.send(url);
+						if (error) return void next(error);
-		require("./discord-preloader.js")(url);
+						let url = `${req.protocol}://${filecode}.${randomHostname?.() || req.hostname}`;
+						res.send(url);
+						require("./discord-preloader.js")(url);
+					});
+				}
+			});
+		})();
 	});
 });
 
+
 app.get("*", function(req, res, next){
-	let filecode = req.hostname.split('.')[0]; // for home page just create file in directory named as the last level of base hostname
+	var filecode = req.hostname.split('.')[0]; // for webroot of main domain i.e. qonq.gq, mkdir files/qonq
-	let webroot = path.join(FILES_DIR, filecode);
+	var webroot = path.join(FILES_DIR, filecode);
-	let webrootdirlist = fs.readdirSync(webroot);
+	fs.readdir(webroot, function(error, webrootdirlist) {
-	if (webrootdirlist.length > 1) {
+		if (error) return void next(error.code == "ENOENT" ? "route" : error);
-		req.url = path.join(filecode, req.url);
+		if (webrootdirlist.length > 1) {
-		next();
+			req.url = path.join(filecode, req.url);
-	} else if (webrootdirlist.length == 1) {
+			next();
-		res.sendFile(webrootdirlist[0], {
+		} else if (webrootdirlist.length == 1) {
-			root: path.join(process.cwd(), webroot),
+			res.sendFile(webrootdirlist[0], {
-			headers: {"Content-Disposition": `filename=${webrootdirlist[0]}`}
+				root: path.join(process.cwd(), webroot),
-		});
+				headers: {"Content-Disposition": `filename=${webrootdirlist[0]}`}
-	} else {
+			});
-		res.sendStatus(204);
+		} else {
-	}
+			res.sendStatus(204);
-});
+		}
+	});
+}, express.static(FILES_DIR), serveIndex(FILES_DIR, {icons: true}));
 
-app.get("*", express.static(FILES_DIR), serveIndex(FILES_DIR, {icons: true}));
-
-app.use(function (error, req, res, next) {
-	res.status(error.code == "ENOENT" ? 404 : console.error(error.stack) || 500).type("text/plain").send(error.toString());
-});
-
-app.listen(process.env.PORT || 8568, process.env.ADDRESS);