(우아한테크캠프 3기) Express 미들웨어 제대로 사용하기 + 로그인 구현하기

app.set('views', './views');
app.set('view engine', 'pug');

extends layout

block content
  h1= title
  p Welcome to #{title}

router.get('/', function(req, res, next) {
  res.render('index', { title: 'Express' });
});

var logger = require('morgan');

// ···

app.use(logger('dev');

var express = require('express')
var morgan = require('morgan')
var path = require('path')
var rfs = require('rotating-file-stream') // version 2.x
 
var app = express()
 
// create a rotating write stream
var accessLogStream = rfs.createStream('access.log', {
  interval: '1d', // rotate daily
  path: path.join(__dirname, 'log')
})

// log only 4xx and 5xx responses to console
app.use(morgan('dev', {
  skip: function (req, res) { return res.statusCode < 400 }
}))
 
// log all requests to access.log
app.use(morgan('common', {
  stream: fs.createWriteStream(path.join(__dirname, 'access.log'), { flags: 'a' })
}))
// ···

var express = require('express')
var session = require('express-session')
 
var app = express()

function logSessionInfo(req) {
  console.log(`req.session : ${req.session}`);
  console.log(`req.sessionID : ${req.sessionID}`);
}

app.use(function(req, res, next) {
  console.log(`express-session 통과 전`);
  console.log(`req.headers.cookie : ${req.session}`);
  logSessionInfo(req);
  next();
})

app.use(session({
  secret: 'keyboard cat',
  resave: false,
  saveUninitialized: true
}));

app.use(function(req, res, next) {
  console.log(`express-session 통과 후`);
  logSessionInfo(req);
  next();
})

// ···

const passport = require('passport')
const localStrategy = require('passport-local').Strategy;

passport.use(new LocalStrategy(
	//verify callback 함수
  function(username, password, done) {
    User.findOne({ username: username }, function (err, user) {
      if (err) { return done(err); }
			// 아이디 없음
      if (!user) {
        return donnull, false, { message: 'Incorrect username.' });
      }
			// 비밀번호 틀림
      if (!user.validPassword(password)) {
        return done(null, false, { message: 'Incorrect password.' });
      }
			// 성공
      return done(null, user);
    });
  }
));

app.post('/login',
  passport.authenticate('local'),
  function(req, res) {
    // If this function gets called, authentication was successful.
    // `req.user` contains the authenticated user.
    res.redirect('/users/' + req.user.username);
  });

app.use(express.session({ secret: 'keyboard cat' }));
app.use(passport.initialize());
app.use(passport.session());

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

passport.deserializeUser(function(id, done) {
  User.findById(id, function(err, user) {
    done(err, user);
  });
});

req.isAuthenticated = function() {
  var property = 'user';
  if (this._passport && this._passport.instance) {
    property = this._passport.instance._userProperty || 'user';
  }
  
  return (this[property]) ? true : false;
}

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

// ···

router.get('/mypage', isAuthenticated, (req, res) => res.render('mypage', { user: req.user }));

const saltRounds = 10;
user.passwordHash = await bcrypt.hash(password, saltRounds);
const match = await bcrypt.compare(password, user.passwordHash);

// ···
if (!user) {
  return done(null, false, { message: 'Incorrect username.' });
}
if (!user.validPassword(password)) {
  return done(null, false, { message: 'Incorrect password.' });
}
// ···

router.get('/login', (req, res) => req.isAuthenticated() 
    ? res.redirect('/mypage') 
    : res.render('login', { failureMsg : req.flash().error })
);

const fs = require('fs');
const path = require('path');

class Model {
    
    static sync = function() {
        if(fs.existsSync(this.fileName)){
            const data = fs.readFileSync(this.fileName, 'utf8');
            this.items = JSON.parse(data);
        }
    }

    static init = (attributesTypes, { tableName, sync }) => {
        this.tableName = tableName;
        this.dirname = path.join(__dirname, `../database`)
        this.fileName = `${this.dirname}/${tableName}.json`;
        this.attributesTypes = attributesTypes;
        this.items = [];
        if(sync) this.sync();
    }

    static write = function() {
        const data = JSON.stringify(this.items);
        if (!fs.existsSync(this.dirname)) fs.mkdirSync(this.dirname);
        fs.writeFileSync(this.fileName, data, 'utf8');
    }

    static validate = function(item) {
        const data = {};
        for (const [key, value] of Object.entries(item)) {
            if(!this.attributesTypes[key] || !value) continue;

            switch(this.attributesTypes[key]){
                case 'date':
                    data[key] = Date(value);
                    break;
                case 'boolean':
                    data[key] = value == 'on' || value == 1;
                    break;
                case typeof(value):
                    data[key] = value;
                    break;
                default:
                    throw new Error('User Input Error'); 
            }
        }
        data.createdAt = Date.now();
        data.updatedAt = Date.now();
        return data;
    }

    static getById = (id) => this.items.find(item => item.id === id);   

    static create = function (item) {
        const validatedItem = this.validate(item);
        this.items.push(validatedItem);
        this.write();
        return validatedItem;
    }

    static update = function (item) {
        const id = this.items.findIndex(item.id);
        item.updatedAt = Date.now();
        this.items[id] = item;
        this.write();
    } 

    static delete = function (item) {
        const id = this.items.findIndex(item.id);
        item.updatedAt = Date.now();
        if(id) this.items[id] = null;
        this.write();
    }
}

module.exports = Model;

const Model = require('./model');

class Users extends Model {
    static init() {
        return super.init({
            id : 'string',
            pw : 'string',
            email : 'string',
            name : 'string',
            phoneNo : 'string',
            address1 : 'string',
            address2 : 'string',
            zipCode : 'string',
            isAdAgreed : 'boolean',
        }, { 
            tableName : 'Users', 
            sync : true 
        });
    } 
}

module.exports = Users;