app.js

const express = require('express');
const app = express();
const http = require('http');
const https = require('https');
const fs = require('fs');
const middleware = require('./middleware')
const path = require('path')
const bodyParser = require("body-parser")
const mongoose = require("./database");
const session = require('express-session');
const sha512 = require('js-sha512').sha512;

const args = process.argv.slice(2);
const isDebugMode = args.includes('--debug');

const port = isDebugMode ? 80 : 443; // Use HTTP on port 80 if in debug mode, otherwise use HTTPS on port 443

const sslKeyPath = './kiwi.social.key';
const sslCertPath = './kiwi.social.pem';

var datetime = new Date();
console.log("app.js started at: " + datetime);
console.log("App started in " + (isDebugMode ? "debug" : "production") + " mode");

// Create http server to ensure users to use secure connection
if (!isDebugMode) {
  const httpApp = express();
  httpApp.get("*", function(req, res, next) {
      res.redirect("https://" + req.headers.host + req.path);
  });

  http.createServer(httpApp).listen(80, function() {
      console.log("HTTP redirect server listening on port 80");
  });
}

const options = !isDebugMode ? {
  key: fs.readFileSync(sslKeyPath),
  cert: fs.readFileSync(sslCertPath),
  ca: [
      fs.readFileSync('./intermediate.cert.pem')
  ],
  maxHeaderSize: 2 * 1024 * 1024 // Set maximum header size to 2 MB
} : {};

const server = isDebugMode ? http.createServer(app) : https.createServer(options, app);

server.listen(port, () => {
  console.log(`Server listening on port ${port}`);
});

const io = require('socket.io')(server, { pingTimeout: 60000 });

app.set("view engine", "pug");
app.set("views", "views");

app.use(bodyParser.urlencoded({ extended: false }));
app.use(express.static(path.join(__dirname, "public")));

app.use(session({
  secret: "17/11/2022 BBC News: 'I haven't ducked difficult decisions, chancellor tells BBC'",
  resave: true,
  saveUninitialized: false
}))

// Routes
const loginRoute = require('./routes/loginRoutes');
const registerRoute = require('./routes/registerRoutes');
const logoutRoute = require('./routes/logout');
const postRoute = require('./routes/postRoutes');
const profileRoute = require('./routes/profileRoutes');
const uploadRoute = require('./routes/uploadRoutes');
const searchRoute = require('./routes/searchRoutes');
const messagesRoute = require('./routes/messagesRoutes');
const notificationsRoute = require('./routes/notificationRoutes');
const settingsRoute = require('./routes/settingsRoutes');
const legalRoute = require('./routes/legalRoutes');
const adminRoute = require('./routes/adminRoutes');
const sslRoute = require('./routes/sslRoutes');
const banRoute = require('./routes/bannedRoutes');
const twoFactorRoute = require('./routes/twoFactorRoutes');
const tokensRoute = require('./routes/tokensRoutes');
const bookmarksRoute = require('./routes/bookmarksRoutes');

// Api routes
const postApiRoute = require('./routes/api/posts');
const usersApiRoute = require('./routes/api/users');
const chatsApiRoute = require('./routes/api/chats');
const messagesApiRoute = require('./routes/api/messages');
const notificationsApiRoute = require('./routes/api/notifications');
const settingsApiRoute = require('./routes/api/settings');
const adminApiRoute = require('./routes/api/admin');
const twoFactorApiRoute = require('./routes/api/twoFactor');
const bookmarksApiRoute = require('./routes/api/bookmarks');

app.use("/login", loginRoute);
app.use("/register", registerRoute);
app.use("/logout", logoutRoute);
app.use("/post", middleware.requireLogin, postRoute);
app.use("/profile", middleware.requireLogin, profileRoute);
app.use("/uploads", uploadRoute);
app.use("/search", middleware.requireLogin, searchRoute);
app.use("/messages", middleware.requireLogin, messagesRoute);
app.use("/notifications", middleware.requireLogin, notificationsRoute);
app.use("/settings", middleware.requireLogin, settingsRoute);
app.use("/twofactor", twoFactorRoute);
app.use("/legal", legalRoute);
app.use("/admin", middleware.requireAdmin, adminRoute);
app.use("/.well-known", sslRoute);
app.use("/banned", banRoute);
app.use("/tokens", tokensRoute);
app.use("/bookmarks", bookmarksRoute);

// Api routes
app.use("/api/posts", postApiRoute);
app.use("/api/users", usersApiRoute);
app.use("/api/chats", chatsApiRoute);
app.use("/api/messages", messagesApiRoute);
app.use("/api/notifications", notificationsApiRoute);
app.use("/api/settings", settingsApiRoute);
app.use("/api/twofactor", twoFactorApiRoute);
app.use("/api/admin", adminApiRoute);
app.use("/api/bookmarks", bookmarksApiRoute);

app.get("/", middleware.requireLogin, (req, res, next) => {

  var payload = {
      pageTitle: "Home",
      userLoggedIn: req.session.user,
      userLoggedInJs: JSON.stringify(req.session.user)
  }

  res.status(200).render("home", payload);
})

app.get("/home/trending", middleware.requireLogin, (req, res, next) => {

  var payload = {
      pageTitle: "Trending",
      userLoggedIn: req.session.user,
      userLoggedInJs: JSON.stringify(req.session.user)
  }

  res.status(200).render("trending", payload);
})

app.use((req, res) => {
  res.redirect('/');
});

io.on("connection", (socket) => {

  socket.on("setup", userData => {
    socket.join(userData._id);
    socket.emit("connected");
  })

  socket.on("join room", room => socket.join(room));
  socket.on("typing", room => socket.in(room).emit("typing"));
  socket.on("stop typing", room => socket.in(room).emit("stop typing"));
  socket.on("notification received", room => socket.in(room).emit("notification received"));

  socket.on("new message", newMessage => {
    var chat = newMessage.chat;

    if(!chat.users) return console.log("Chat.users undefined");

    chat.users.forEach(user => {
      if(user._id == newMessage.sender._id) return;
      socket.in(user._id).emit("message received", newMessage);
    })
  })

});