app.js

require("dotenv").config();
const express = require("express");
const https = require("https");
const http = require("http");
const app = express();
const myKeyPath = process.env.myKey;
const myCertPath = process.env.myCert;
const options = { key: myKeyPath, cert: myCertPath };
const myPort1 = process.env.myPort1;
const myPort2 = process.env.myPort2;
let redirectMiddleware;
try {
    redirectMiddleware = require("./redirectMiddleware");
} catch (error) {
    console.error("Error loading redirectMiddleware:");
}

const { createPool } = require("mysql2/promise");
const pool = createPool({
    host: process.env.DB_HOST,
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    database: process.env.DB_DATABASE,
});

https.createServer(options, app).listen(myPort1, () => {});
http.createServer(app).listen(myPort2, () => {});

app.use(express.static("public"));
app.set("view engine", "ejs");

if (redirectMiddleware) {
    app.use(redirectMiddleware);
} else console.log("no redirect");

app.get(["/", "/index"], async (req, res) => {
    const connection = await pool.getConnection();
    const [main] = await connection.query(
        "SELECT *, DATE_FORMAT(date, '%d %m %Y') AS formatted_date FROM main ORDER BY date DESC"
    );
    connection.release();
    res.render("index", { main });
});

app.get("/loved", async (req, res) => {
    const connection = await pool.getConnection();
    const [loved] = await connection.query(
        "SELECT *, DATE_FORMAT(date, '%d %m %Y') AS formatted_date FROM love ORDER BY id DESC"
    );
    connection.release();
    res.render("loved", { loved });
});

app.get("/archive", async (req, res) => {
    const connection = await pool.getConnection();
    const [archive] = await connection.query(
        "SELECT *, DATE_FORMAT(date, '%d %m %Y') AS formatted_date FROM archive ORDER BY id DESC"
    );
    connection.release();
    res.render("archive", { archive });
});

app.post("/love/:body", async (req, res) => {
    const emailID = req.params.body;
    const connection = await pool.getConnection();
    await connection.beginTransaction();

    const [email] = await connection.query(
        "SELECT id, sender, subject, body, date FROM main WHERE body = ?",
        [emailID]
    );

    if (email.length === 0 || !email[0].id) {
        // Email not found or id is undefined
        connection.release();
        res.redirect("/");
        return;
    }

    const { id, sender, subject, body, date } = email[0];

    await connection.query(
        "INSERT INTO love (sender, subject, body, date) VALUES (?, ?, ?, ?)",
        [sender, subject, body, date]
    );
    await connection.query("DELETE FROM main WHERE body = ?", [emailID]);

    await connection.commit();
    connection.release();

    const lastEmailID = id + 1;

    res.redirect(`/#${lastEmailID}`);
});

app.post("/archive/:body", async (req, res) => {
    const emailID = req.params.body;
    const connection = await pool.getConnection();
    await connection.beginTransaction();

    const [email] = await connection.query(
        "SELECT id FROM main WHERE body = ?",
        [emailID]
    );

    if (email.length === 0 || !email[0].id) {
        // Email not found or id is undefined
        connection.release();
        res.redirect("/");
        return;
    }

    const emailIDInMain = email[0].id;

    await connection.query(
        "INSERT INTO archive (sender, subject, body, date) SELECT sender, subject, body, date FROM main WHERE body = ?",
        [emailID]
    );
    await connection.query("DELETE FROM main WHERE body = ?", [emailID]);
    await connection.query("DELETE FROM love WHERE body = ?", [emailID]);
    await connection.commit();
    connection.release();

    const lastEmailID = emailIDInMain + 1;

    res.redirect(`/#${lastEmailID}`);
});

app.post("/archivee/:archiveBody", async (req, res) => {
    const emailID = req.params.archiveBody;
    const connection = await pool.getConnection();
    await connection.beginTransaction();
    await connection.query(
        "INSERT INTO archive (sender, subject, body, date) SELECT sender, subject, body, date FROM love WHERE body = ?",
        [emailID]
    );
    await connection.query("DELETE FROM love WHERE body = ?", [emailID]);
    await connection.commit();
    connection.release();
    res.redirect("/loved");
});

app.post("/lovee/:loveBody", async (req, res) => {
    const emailID = req.params.loveBody;
    const connection = await pool.getConnection();
    await connection.beginTransaction();
    await connection.query(
        `INSERT INTO love (sender, subject, body, date) SELECT sender, subject, body, date FROM archive WHERE body = ?`,
        [emailID]
    );
    await connection.query("DELETE FROM archive WHERE body = ?", [emailID]);
    await connection.commit();
    connection.release();
    res.redirect("/archive");
});

app.listen(() => {
    console.log(`Server running at http://localhost:3000`);
});