passportConfig.js

const LocalStrategy = require("passport-local").Strategy;

const bcrypt = require("bcrypt");

const { pool } = require("./dbconfig");

function initialize(passport) {
  const authenticateUser = (email, password, done) => {
    pool.query(
      `SELECT * FROM "users" WHERE "email" = $1`,
      [email],
      (err, results) => {
        if (err) {
          console.log(err);
        }

        if (results.rows.length > 0) {
          const user = results.rows[0];

          bcrypt.compare(password, user.password, (err, isMatch) => {
            if (err) {
              console.log("passport :", err);
            }
            if (isMatch) {
              return done(null, user);
            } else {
              return done(null, false, { message: "Password is incorrect" });
            }
          });
        } else {
          return done(null, false, {
            message: "No user with that email address",
          });
        }
      }
    );
  };

  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 "users" WHERE "id" = $1`,
      [id],
      (err, results) => {
        if (err) {
          return done(err);
        }

        return done(null, results.rows[0]);
      }
    );
  });
}

module.exports = initialize;