Connect-pg-просто не сохраняет сеанс в базу данных - PullRequest
Новая
       19

Connect-pg-просто не сохраняет сеанс в базу данных

3 голосов
/ 07 июля 2019

Я пытаюсь реализовать простую аутентификацию с помощью Node, Express, Express-Session и Passport.js. В качестве промежуточного программного обеспечения для хранения данных я использую connect-pg-simple , так как я использую pg-обещание в своем проекте.

Мне удалось настроить паспорт для работы с маршрутизаторами, но по какой-то причине сеансы не были сохранены в моей базе данных. Ни один из плагинов не возвращает никаких ошибок, кажется, все работает нормально, но моя таблица сессий пуста.

Что я могу делать не так? connect-pg-simple подключается к серверу, passport.js проводит сеансы и экспресс-сеанс назначает настроенный maxAge для файлов cookie.

server.js 

const express = require('express');
const db = require('./database.js');
const cors = require('cors');
const helmet = require('helmet');
const session = require('express-session');
const passport = require('passport');

const port = process.env.PORT || 3000;
const app = express();

const pgSession = require('connect-pg-simple')(session);
const pgStoreConfig = {
  pgPromise: db.conn
};

app.set('trust proxy', 1);

app.use(express.json());
app.use(express.urlencoded({ extended: true }));

app.use(
  session({
    secret: REDACTED, // need to change it later to some proper hash
    store: new pgSession(pgStoreConfig),
    resave: true,
    cookie: {
      maxAge: 30 * 24 * 60 * 60 * 1000, // 30 days ;)
      secure: app.get('env') === 'production'
    },
    saveUninitialized: false
  })
);

app.use(passport.initialize());
app.use(passport.session());

app.use(cors());
app.use(helmet());

app.get('/', (req, res) => {
  if (req.session.views) {
    req.session.views++;
  } else {
    req.session.views = 1;
  }
  //res.send(`Views: ${req.session.views}`);
  res.json(req.session);
});

const userRouter = require('./routes/user.js');

app.use(userRouter);

конфиг / passport.js 

const passport = require('passport');
const local = require('passport-local');
const db = require('../database.js');
const statements = require('../routes/statements/user.js');
const cryptoUtils = require('../utils/crypto.js');

passport.serializeUser((user, done) => {
  done(null, user.id);
});

passport.deserializeUser(async (id, done) => {
  try {
    let result = await db.conn.one(statements.getUserByIdStatement, [id]);
    done(null, result);
  } catch (error) {
    console.log(`Error while deserializing user: ${error}`);
    return done(error);
  }
});

passport.use(
  new local.Strategy(
    { usernameField: 'email', passwordField: 'password' },
    async (username, password, done) => {
      try {
        let user = await db.conn.one(statements.loginUserStatement, [username]);

        if (user == null) {
          console.log(`Couldn't find user!`);
          return done(null, false);
        } else {
          let passwordCheck = cryptoUtils.comparePasswords(
            password,
            user.password,
            user.salt
          );

          if (passwordCheck) {
            delete user.password;
            delete user.salt;
            console.log(`Successfuly logged in!`);
            return done(null, user);
          } else {
            console.log(`Wrong password!`);
            return done(null, false);
          }
        }
      } catch (error) {
        console.log(`Error during local strategy authentication: ${error}`);
        return done(null, false);
      }
    }
  )
);

module.exports = passport;

маршруты / user.js 

router.post('/user/login', (req, res, next) => {
  console.log('Authenticating');
  passport.authenticate('local', (err, user, info) => {
    if (err) {
      res.status(500).json({ status: err });
    }
    if (!user) {
      res.status(404).json({ status: 'User not found' });
    }
    if (user) {
      req.logIn(user, function(err) {
        if (err) {
          res.status(500).json({ status: 'Error while logging in' });
        }
        res.redirect('/');
      });
    }
  })(req, res, next);
});

router.get('/user/logout', userUtils.loginRequired, (req, res, next) => {
  req.logout();
  res.status(200).json({ status: 'Logged out' });
});

database.js 

const pgp = require('pg-promise')(initOptions);
const conn = pgp(connectionConfig);

module.exports = {
  pgp,
  conn
};

Любая помощь будет принята с благодарностью.

...