passport-config.js

const LocalStrategy = require('passport-local').Strategy
const { pool } = require('./dbConfig');
const bcrypt = require('bcrypt')

 function initialize(passport, getUserByEmail, getUserById) {
    const authenticateUser = async (email, password, done) => {
    
        pool.query(
            'SELECT * from public.accounts WHERE email = $1', [email], (err, results)=> {
                if(err){
                    throw err;
                } 
                console.log(results.row);
                if (results.rows.length > 0){
                    const user = results.rows[0];

                    bcrypt.compare(password, user.password, (err, isMatch) => {
                        if (err){
                            throw err
                        }
                        if(isMatch) {
                            return done(null, user);
                        } else {
                            return done(null, false, {message: 'Password is not correct'});
                        }
                    });
                } else {
                    return done(null, false, {message: 'Email is not registered'});
                }
            }
        );
    };



passport.use(
    new LocalStrategy({ 
        usernameField: 'email',
        passwordField: 'password'
    }, 
authenticateUser))
passport.serializeUser((user, done) => done(null, user.id));
passport.deserializeUser((id, done) => {
pool.query(
    'SELECT * FROM public.accounts Where id=$1', [id], (err, results)=>{
        if (err) {
            throw err;  
        }
        return done(null, results.rows[0]);
    });
});
}
module.exports = initialize;