app.js

const express = require('express')
const app = express()
const passport = require('passport');
const flash = require('express-flash');
const session = require('express-session');
const methodOverride = require('method-override');
const ChatUserDB = require('./DB/Tables/Chat-User')
const { AuthDB, MessageDB } = require('./DB/DB_main')
const bcrypt = require('bcrypt')
const sass = require('node-sass-middleware')
const initializePassport = require('./passport-config');

initializePassport(
    passport,
    FindUserEmail,
    AuthDB.getAuthDataId
)

const users = []


app.set("view engine", "ejs")

app.use(express.urlencoded({ extended: false }));
app.use(flash());
app.use(sass({
    src: __dirname + '/scss',
    dest: __dirname + '/public',
}))
app.use(express.static(__dirname));
app.use(session({
    secret: "aaaaaaa",
    resave: false,
    saveUninitialized: false
}))
app.use(passport.initialize())
app.use(passport.session())
app.use(methodOverride('_method'));


/* /////////////////// Router ///////////////////// */
app.get('/', checkAuthenticated, async (req, res) => {
    res.redirect("/messenger")
});

app.get("/messenger", async (req, res) => {
    let user = await req.user
    if (!user) {
        res.redirect("/login")
        return
    }
    let chatsArr = await GetChats(user.id)
    res.render('messenger.ejs', {
        name: user.name,
        chats: chatsArr,
        id: user.id,
        isChat: false,
    })
}) 

app.get('/messenger/:id', async (req, res) => {
    let user = await req.user
    if (!user) {
        res.redirect("/login")
        return
    }
    let chatsArr = await GetChats(user.id)
    let chatIndex;
    for(let i = 0; i < chatsArr.length; i++) {
        if (chatsArr[i].id == req.params.id) {
            chatIndex = i;
            break;
        }
    }
    res.render('messenger.ejs', {
        name: user.name,
        chats: chatsArr,
        chatIndex: chatIndex,
        id: user.id,
        isChat: true,
        messages: await GetMessages(req.params.id)
    })
})

app.get('/login', checkNotAuthenticated, (req, res) => {
    res.render('login.ejs', {
        test: "test message",
        greeting: "Здравствуйте"
    })
})

app.post('/login', checkNotAuthenticated, passport.authenticate('local', {
    successRedirect: '/',
    failureRedirect: '/login',
    failureFlash: true
}))

app.get('/register', checkNotAuthenticated, (req, res) => {
    res.render('register.ejs', {
        test: "register",
        greeting: "Регистрация"
    })
})

app.post('/register', checkNotAuthenticated, async (req, res) => {
    try {
        const hashedPassword = await bcrypt.hash(req.body.password, 10);
        let newUser = {
            name: req.body.name,
            surname: req.body.surname,
            email: req.body.email,
            phone: req.body.phone_number,
            password: hashedPassword,
            invite_code: req.body.code,
        };
        await AuthDB.register(newUser)
        res.redirect('/login')
    } catch {
        res.redirect('/register')
    }
})

app.delete('/logout', (req, res) => {
    req.logOut()
    res.redirect('/login')
})

function checkAuthenticated(req, res, next) {
    if (req.isAuthenticated()) {
        return next()
    }

    res.redirect('/login')
}

function checkNotAuthenticated(req, res, next) {
    if (req.isAuthenticated()) {
        return res.redirect('/')
    }
    next()
}

async function FindUserEmail(data) {
    let res = await AuthDB.getAuthData({ "data": data })
    if (res["stat"] == 'ERR') {
        return null
    }
    console.log(res)
    return res["data"]
}

async function GetChats(user_id) {
    console.log(user_id)
    let chats = []
    let userchats = await ChatUserDB.get_user_chats({ "user_id": user_id })
    for (let i = 0; i < userchats.length; i++) {
        chats.push((await ChatUserDB.get_chat_info({ "chat_id": userchats[i], "user_id": user_id })))
    }
    return chats
}

async function GetMessages(chat_id) {
    let msgs = await MessageDB.get_all_msgs_for_site(chat_id)
    return msgs
}

mobile_server = app.listen(process.env.PORT || 3000, () => console.log(`Server is running ${process.env.PORT}`)) //! ТАК СДЕЛАТЬ МИШЕ
require('./WS/ws')