const express = require("express");
const db = require("../db");
const fileupload = require("express-fileupload");
const app = express.Router();

app.use(fileupload({}));

app.use("/", express.static(__dirname + "/public/"));

app.get("/api/user/:uid", async (req, res) => {
    const uid = req.params.uid;
    const user = await db.query("SELECT name, middlename, surname FROM users WHERE id = ?", [uid]);
    const questions = await db.query(
        "SELECT q.id, q.question, t.type FROM profile_questions q INNER JOIN profile_input_types t ON t.id = q.question_type",
    );
    const answers = await db.query("SELECT answer, question_id FROM profile_answers WHERE user_id = ?", [uid]);

    for (const answer of answers) {
        const qid = questions.findIndex((question) => question.id === answer.question_id);
        if (qid >= 0) questions[qid].answer = answer.answer;
    }
    res.json({ user: user[0], questions });
});

// Basic API
app.get("/api/questions", async (req, res) => {
    const questions = await db.query(
        "SELECT q.id, q.question, t.type FROM profile_questions q INNER JOIN profile_input_types t ON t.id = q.question_type",
    );
    const answers = await db.query("SELECT answer, question_id FROM profile_answers WHERE user_id = ?", [
        req.session.uid,
    ]);

    for (const answer of answers) {
        const qid = questions.findIndex((question) => question.id === answer.question_id);
        if (qid >= 0) questions[qid].answer = answer.answer;
    }

    const ratios = await db.query("SELECT question_id, x, y FROM profile_image_ratios");
    for (const { question_id, x, y } of ratios) {
        const qid = questions.findIndex((question) => question.id === question_id);
        if (qid >= 0) questions[qid].ratio = { x, y };
    }

    res.json(questions);
});

app.post("/api/answer", async (req, res) => {
    return await answer(req, res, "INSERT INTO profile_answers (answer, question_id, user_id) VALUE (?,?,?)");
});
app.put("/api/answer", async (req, res) => {
    return await answer(req, res, "UPDATE profile_answers SET answer = ? WHERE question_id = ? AND user_id = ?");
});

async function answer(req, res, qs) {
    try {
        for (const qid in req.body) {
            if (!req.body.hasOwnProperty(qid)) continue;
            const answer = req.body[qid];
            const params = [answer, qid, req.session.uid];
            try {
                await db.query(qs, params);
            } catch (e) {
                if (e.code === "ER_DUP_ENTRY") {
                    // Fix strange POST behaviour
                    try {
                        await db.query(
                            "UPDATE profile_answers SET answer = ? WHERE question_id = ? AND user_id = ?",
                            params,
                        );
                    } catch (e) {
                        console.error(e);
                        return res.json({ success: false });
                    }
                } else {
                    console.error(e);
                    return res.json({ success: false });
                }
            }
        }
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        res.json({ success: false });
    }
}

app.post("/api/answerImage", async (req, res) => await answerImage(req, res));

async function answerImage(req, res) {
    try {
        for (const fid in req.files) {
            if (!req.files.hasOwnProperty(fid)) continue;
            const image = req.files[fid];
            const name = `${fid}_${req.session.uid}.jpg`;
            const params = [name, fid, req.session.uid];
            try {
                await image.mv(`${__dirname}/public/uploads/${name}`); // Overwrite anyway
                await db.query("INSERT INTO profile_answers (answer, question_id, user_id) VALUE (?,?,?)", params);
            } catch (e) {
                if (e.code === "ER_DUP_ENTRY") {
                    return res.json({ success: true });
                } else {
                    console.error(e);
                    return res.json({ success: false });
                }
            }
        }
        return res.json({ success: true });
    } catch (e) {
        console.error(e);
        return res.json({ success: false });
    }
}

// Comments API
app.get("/api/comments/:uid", async (req, res) => {
    const uid = req.params.uid;
    const comments = await db.query(
        "SELECT c.id, c.profile_id, c.comment, u.name, u.middlename, u.surname, (user_id = ? OR ?) owner FROM profile_comments c INNER JOIN users u ON user_id=u.id WHERE profile_id = ?",
        [req.session.uid, req.session.isSuperAdmin || false, uid],
    );
    const ret = [];
    comments.forEach((c) => {
        ret.push({
            id: c.id,
            profile_id: c.profile_id,
            user:
                req.session.isSuperAdmin || false ? { name: c.name, middlename: c.middlename, surname: c.surname } : {},
            comment: c.comment,
            owner: c.owner,
        });
    });
    res.json(ret);
});

app.post("/api/comment", async (req, res) => {
    const { pid, comment } = req.body;
    if (!pid || !comment || comment.length > 280) return res.json({ success: false });
    try {
        await db.query("INSERT INTO profile_comments (user_id, profile_id, comment) VALUES (?,?,?)", [
            req.session.uid,
            pid,
            comment,
        ]);
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        return res.json({ success: false });
    }
});

app.put("/api/comment", async (req, res) => {
    const { pid, cid, comment } = req.body;
    if (!pid || !comment || !cid || comment.length > 280) return res.json({ success: false });
    try {
        await db.query(
            "UPDATE profile_comments SET comment = ? WHERE (user_id = ? OR ?) AND profile_id = ? AND id = ?",
            [comment, req.session.uid, req.session.isSuperAdmin || false, pid, cid],
        );
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        return res.json({ success: false });
    }
});

app.delete("/api/comment", async (req, res) => {
    const { pid, cid } = req.body;
    if (!pid || !cid) return res.json({ success: false });
    try {
        await db.query("DELETE FROM profile_comments WHERE (user_id = ? OR ?) AND profile_id = ? AND id = ?", [
            req.session.uid,
            req.session.isSuperAdmin || false,
            pid,
            cid,
        ]);
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        return res.json({ success: false });
    }
});

// Char API
app.get("/api/char/:uid", async (req, res) => {
    const uid = req.params.uid;
    const char = await db.query("SELECT txt FROM profile_char WHERE profile_id = ? AND user_id = ?", [
        uid,
        req.session.uid,
    ]);
    res.json(char.length > 0 ? char[0] : {});
});

app.post("/api/char/:uid", async (req, res) => {
    const uid = req.params.uid;
    const { char } = req.body;
    if (!char || char.length > 255) return res.json({ success: false });
    try {
        await db.query("INSERT INTO profile_char (profile_id, user_id, txt) VALUE (?,?,?)", [
            uid,
            req.session.uid,
            char,
        ]);
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        res.json({ success: false });
    }
});

app.put("/api/char/:uid", async (req, res) => {
    const uid = req.params.uid;
    const { char } = req.body;
    if (!char || char.length > 255) return res.json({ success: false });
    try {
        await db.query("UPDATE profile_char SET txt = ? WHERE profile_id = ? AND user_id = ?", [
            char,
            uid,
            req.session.uid,
        ]);
        res.json({ success: true });
    } catch (e) {
        console.error(e);
        res.json({ success: false });
    }
});

module.exports = app;