housekeeping

app/app.js

@@ -0,0 +1,142 @@
+require("dotenv").config();
+
+const express = require("express");
+const passport = require("passport");
+const session = require("express-session");
+const cookieParser = require("cookie-parser");
+const SQLiteStore = require("connect-sqlite3")(session);
+
+const fs = require("fs");
+const http = require("http");
+const path = require("path");
+
+const authRouter = require("./routes/auth");
+const indexRouter = require("./routes/index");
+
+const db = require("./db").db;
+
+let app = express();
+let server = http.createServer(app);
+let port = normalizePort(process.env.EBPORT || "3000");
+app.set("port", port);
+
+server.listen(port);
+server.on("error", onError);
+server.on("listening", onListening);
+
+function normalizePort(val) {
+	var port = parseInt(val, 10);
+
+	if (isNaN(port)) {
+		// named pipe
+		return val;
+	}
+
+	if (port >= 0) {
+		// port number
+		return port;
+	}
+
+	return false;
+}
+
+function onError(error) {
+	if (error.syscall !== "listen") {
+		throw error;
+	}
+
+	var bind = typeof port === "string"
+		? "Pipe " + port
+		: "Port " + port;
+
+	// handle specific listen errors with friendly messages
+	switch (error.code) {
+	case "EACCES":
+		console.error(bind + " requires elevated privileges");
+		process.exit(1);
+		break;
+	case "EADDRINUSE":
+		console.error(bind + " is already in use");
+		process.exit(1);
+		break;
+	default:
+		throw error;
+	}
+}
+
+function onListening() {
+	var addr = server.address();
+	var bind = typeof addr === "string"
+		? "pipe " + addr
+		: "port " + addr.port;
+	console.log("Listening on " + bind);
+}
+
+app.enable("trust proxy");
+
+// view engine setup
+app.set("views", path.join(__dirname, "views"));
+app.set("view engine", "ejs");
+
+app.use(express.json());
+app.use(express.urlencoded({
+	extended: false
+}));
+app.use(cookieParser());
+app.use(express.static(path.join(__dirname, "public")));
+
+app.use(express.static(path.join(__dirname, "public")));
+app.use(session({
+	secret: process.env.EBSECRET || "pleasechangeme",
+	resave: false,
+	saveUninitialized: false,
+	store: new SQLiteStore({
+		db: "sessions.db",
+		dir: "./var/db"
+	})
+}));
+app.use(passport.authenticate("session"));
+
+app.use("/", indexRouter);
+app.use("/", authRouter);
+
+app.use("/uploads", express.static("uploads"));
+
+function prune () {
+	db.all("SELECT * FROM media", (err, rows) => {
+		console.log("Uploaded files: " + rows.length);
+		console.log(rows);
+	});
+
+	console.log("Vacuuming database...");
+	db.run("VACUUM");
+
+	db.all("SELECT * FROM media WHERE expire < ?", [Date.now()], (err, rows) => {
+		console.log("Expired rows: " + rows);
+		if (err) return console.error(err);
+		rows.forEach((row) => {
+			console.log(`Deleting ${row.path}`);
+			fs.unlink(`uploads/${row.path}`, (err) => {
+				if (err) {
+					if(err.errno == -4058) {
+						console.log("File already deleted");
+						db.all("DELETE FROM media WHERE path = ?", [row.path], (err) => {
+							if (err) return console.error(err);
+						});
+					} else {
+						console.error(err);
+					}
+				} else {
+					db.all("DELETE FROM media WHERE path = ?", [row.path], (err) => {
+						if (err) return console.error(err);
+					});
+				}
+			});
+			console.log(`Deleted ${row.path}`);
+		});
+	});
+}
+
+setInterval(prune, 1000 * 60); //prune every minute
+
+module.exports = app;