유저간 채팅기능 만들기 01:10 부분에 로그인했을때

[서영석]

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const MongoClient = require('mongodb').MongoClient;

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

app.use('/public', express.static('public'));

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

var db;
MongoClient.connect('mongodb+srv://scott:scott@cluster0.eeagm.mongodb.net/perfumeapp?retryWrites=true&w=majority', function(에러, client){
    if (에러) return console.log(에러);
    db = client.db('perfumeapp');
    app.listen('8080', function(){
      console.log('listening on 8080')
    });
  })

  app.get('/sub', function(요청, 응답){
    응답.render('sub.ejs')
  });

  app.get('/write',function(요청, 응답){
    응답.render('write.ejs')
  });
 
  app.get('/', function(요청, 응답){
    응답.render('index.ejs')
  });

  app.get('/chat', function(요청, 응답){
    응답.render('chat.ejs')
  });

  app.get('/mypage', function(요청, 응답){
    응답.render('mypage.ejs')
  });

  app.get('/logout', function(요청, 응답){
    응답.render('logout.ejs')
  });

  app.get('/join', function(요청, 응답){
    응답.render('join.ejs')
  });

  app.post('/add', function(요청, 응답){
    응답.send('전송완료');
    db.collection('notecounter').findOne({name : '작성물갯수'}, function(에러, 결과){
      console.log(결과.totalNote)
      var 총작성물갯수 = 결과.totalNote;
 
      db.collection('note').insertOne( { _id : 총작성물갯수 + 1,제목: 요청.body.title, 금액:요청.body.problem} , function(에러,결과){
        console.log('저장완료');
       
        db.collection('notecounter').updateOne({name:'작성물갯수'},{ $inc :{totalNote:1}},function(에러,결과){
          // db.collection('accounter').updateOne({name:'상품갯수'},{$inc :{AllProduct:1}})
          if(에러){return console.log(에러)}
        })
       
      });
    });
   
  });
  app.get('/list',function(요청,응답){
      db.collection('note').find().toArray(function(에러,결과){
      console.log(결과)
      응답.render('list.ejs',{notes:결과});    
    });
     
  });

  app.post('/register', function (요청, 응답) {
    db.collection('user').insertOne({ uid: 요청.body.uid, pw1: 요청.body.pw1, pw2: 요청.body.pw2, 이름: 요청.body.name,  성별: 요청.body.gender, 휴대폰번호:요청.body.ph,주소:요청.body.addr}, function (에러, 결과) {
      응답.redirect('/')
    })
  })

  const passport = require('passport');
  const LocalStrategy = require('passport-local').Strategy;
  const session = require('express-session');
 
  app.use(session({secret : '비밀코드', resave : true, saveUninitialized: false}));
  app.use(passport.initialize());
  app.use(passport.session());

  app.get('/login', function(요청, 응답){
    응답.render('login.ejs')
  });

  app.post('/logout',function(요청, 응답){
    요청.logout();
    응답.redirect('/');
  });

  app.post('/login', passport.authenticate('local', {failureRedirect : '/fail'}), function(요청,응답){
    응답.redirect('/sub')
  });
 
  app.get('/pen',로그인했니,function(요청,응답){
    응답.render('pen.ejs');
  });

  function 로그인했니(요청,응답,next){
    if(요청.user){
      next()
    } else {
      응답.send('로그인안하셨는데요')
    }
  }

  app.get('/chat', 로그인했니, function(요청, 응답){

    db.collection('chatroom').find({ member : 요청.user._id }).toArray().then((결과)=>{
      console.log(결과);
      응답.render('chat.ejs', {data : 결과})
    })
 
  });

 

  passport.use(new LocalStrategy({
    usernameField: 'uid',
    passwordField: 'pw1',
    session: true,
    passReqToCallback: false,
  }, function (입력한아이디, 입력한비번, done) {
    //console.log(입력한아이디, 입력한비번);
    db.collection('user').findOne({ uid: 입력한아이디 }, function (에러, 결과) {
      if (에러) return done(에러)
 
      if (!결과) return done(null, false, { message: '존재하지않는 아이디요' })
      if (입력한비번 == 결과.pw1) {
        return done(null, 결과)
      } else {
        return done(null, false, { message: '비번틀렸어요' })
      }
    })
  }));

  passport.serializeUser(function (user, done) {
    done(null, user.uid)
  });
 
  passport.deserializeUser(function (아이디, done) {
    db.collection('user').findOne({uid : 아이디}, function(에러, 결과){
      done(null, 결과)    
    })    
  });

  app.get('/pen',로그인했니,function(요청,응답){
    응답.render('pen.ejs');
  });

  function 로그인했니(요청,응답,next){
    if(요청.user){
      next()
    } else {
      응답.send('로그인안하셨는데요')
    }
  }
  app.post('/chatroom',로그인했니,function(요청,응답){

    var 저장할거 = {
      title : '무슨무슨채팅방',
      member : [요청.body.당한사람id, 요청.user._id],
      date : new Date()
    }

    db.collection('chatroom').insertOne(저장할거).then((결과)=>{

    })
  })
 
  app.get('/chat', 로그인했니, function(요청, 응답){

    db.collection('chatroom').find({ member : 요청.user._id }).toArray().then((결과)=>{
      console.log(결과);
      응답.render('chat.ejs', {data : 결과})
    })
 
  });

 

write로 게시물을 추가했습니다. 하지만 강사님과 다르게 저는 작성자가 저장이 안되더라고 왜그런지 알수있을까요?

[codingapple]

서버파일에 app.get('/chat', 이 코드가 아직도 2개나 있군요 

[서영석]

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const MongoClient = require('mongodb').MongoClient;

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

app.use('/public', express.static('public'));

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

var db;
MongoClient.connect('mongodb+srv://scott:scott@cluster0.eeagm.mongodb.net/perfumeapp?retryWrites=true&w=majority', function(에러, client){
    if (에러) return console.log(에러);
    db = client.db('perfumeapp');
    app.listen('8080', function(){
      console.log('listening on 8080')
    });
  })

  app.get('/sub', function(요청, 응답){
    응답.render('sub.ejs')
  });

  app.get('/write',function(요청, 응답){
    응답.render('write.ejs')
  });
 
  app.get('/', function(요청, 응답){
    응답.render('index.ejs')
  });

  app.get('/mypage', function(요청, 응답){
    응답.render('mypage.ejs')
  });

  app.get('/logout', function(요청, 응답){
    응답.render('logout.ejs')
  });

  app.get('/join', function(요청, 응답){
    응답.render('join.ejs')
  });

  app.post('/add', function(요청, 응답){
    응답.send('전송완료');
    db.collection('notecounter').findOne({name : '작성물갯수'}, function(에러, 결과){
      console.log(결과.totalNote)
      var 총작성물갯수 = 결과.totalNote;
 
      db.collection('note').insertOne( { _id : 총작성물갯수 + 1,제목: 요청.body.title, 금액:요청.body.problem} , function(에러,결과){
        console.log('저장완료');
       
        db.collection('notecounter').updateOne({name:'작성물갯수'},{ $inc :{totalNote:1}},function(에러,결과){
          // db.collection('accounter').updateOne({name:'상품갯수'},{$inc :{AllProduct:1}})
          if(에러){return console.log(에러)}
        })
       
      });
    });
   
  });
  app.get('/list',function(요청,응답){
      db.collection('note').find().toArray(function(에러,결과){
      console.log(결과)
      응답.render('list.ejs',{notes:결과});    
    });
     
  });

  app.post('/register', function (요청, 응답) {
    db.collection('user').insertOne({ uid: 요청.body.uid, pw1: 요청.body.pw1, pw2: 요청.body.pw2, 이름: 요청.body.name,  성별: 요청.body.gender, 휴대폰번호:요청.body.ph,주소:요청.body.addr}, function (에러, 결과) {
      응답.redirect('/')
    })
  })

  const passport = require('passport');
  const LocalStrategy = require('passport-local').Strategy;
  const session = require('express-session');
 
  app.use(session({secret : '비밀코드', resave : true, saveUninitialized: false}));
  app.use(passport.initialize());
  app.use(passport.session());

  app.get('/login', function(요청, 응답){
    응답.render('login.ejs')
  });

  app.post('/logout',function(요청, 응답){
    요청.logout();
    응답.redirect('/');
  });

  app.post('/login', passport.authenticate('local', {failureRedirect : '/fail'}), function(요청,응답){
    응답.redirect('/sub')
  });
 
  function 로그인했니(요청,응답,next){
    if(요청.user){
      next()
    } else {
      응답.send('로그인안하셨는데요')
    }
  }

 

  passport.use(new LocalStrategy({
    usernameField: 'uid',
    passwordField: 'pw1',
    session: true,
    passReqToCallback: false,
  }, function (입력한아이디, 입력한비번, done) {
    //console.log(입력한아이디, 입력한비번);
    db.collection('user').findOne({ uid: 입력한아이디 }, function (에러, 결과) {
      if (에러) return done(에러)
 
      if (!결과) return done(null, false, { message: '존재하지않는 아이디요' })
      if (입력한비번 == 결과.pw1) {
        return done(null, 결과)
      } else {
        return done(null, false, { message: '비번틀렸어요' })
      }
    })
  }));

  passport.serializeUser(function (user, done) {
    done(null, user.uid)
  });
 
  passport.deserializeUser(function (아이디, done) {
    db.collection('user').findOne({uid : 아이디}, function(에러, 결과){
      done(null, 결과)    
    })    
  });

  app.get('/pen',로그인했니,function(요청,응답){
    응답.render('pen.ejs');
  });

  function 로그인했니(요청,응답,next){
    if(요청.user){
      next()
    } else {
      응답.send('로그인안하셨는데요')
    }
  }
  app.post('/chatroom',로그인했니,function(요청,응답){

    var 저장할거 = {
      title : '무슨무슨채팅방',
      member : [요청.body.당한사람id, 요청.user._id],
      date : new Date()
    }

    db.collection('chatroom').insertOne(저장할거).then((결과)=>{

    })
  })
 
  app.get('/chat', 로그인했니, function(요청, 응답){

    db.collection('chatroom').find({ member : 요청.user._id }).toArray().then((결과)=>{
      console.log(결과);
      응답.render('chat.ejs', {data:결과})
    })
 
  });
 
  app.post('/message', 로그인했니, function(요청, 응답){
    var 저장할거 = {
      parent : 요청.body.parent,
      userid : 요청.user._id,
      content : 요청.body.content,
      date : new Date(),
    }
    db.collection('message').insertOne(저장할거)
    .then((결과)=>{
      응답.send(결과);
    })
  });
 
  app.get('/pen',로그인했니,function(요청,응답){
    응답.render('pen.ejs');
  });

  function 로그인했니(요청,응답,next){
    if(요청.user){
      next()
    } else {
      응답.send('로그인안하셨는데요')
    }

 

하나로 만들었습니다  유저정보가 원래 자동으로 저장 되는게 맞는건가요?

 

[codingapple]

로그인되어있으면 서버에서 요청.user 이런게 항상 있습니다

passport.deserializeUser(function (아이디, done) {
    db.collection('user').findOne({uid : 아이디},

여기서 uid가 아니라 id 일 수도 있습니다 

[글쓴이]

글