EventSource's response has a MIME type 오류

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const methodOverride = require('method-override');
const passport = require('passport');
const LocalStrategy = require('passport-local').Strategy;
const session = require('express-session');
const { ObjectId } = require('mongodb');

function isLogin(req, res, next){
  if(req.user) {
    next()
  } else {
    res.send("You are not login")
  }
}

require('dotenv').config()

// middleware
app.use(session({ secret : "비밀코드", resave : true, saveUninitialized : false }))
app.use(passport.initialize());
app.use(passport.session());

app.use(bodyParser.urlencoded({extended : true}));
app.use(methodOverride('_method'));

// css middleware연동
app.use(express.static(__dirname + '/public'));

// MongoDB연동
let db;
const MongoClient = require('mongodb').MongoClient;
app.set('view engine', 'ejs');
MongoClient.connect(process.env.DB_URL, function(err, client) {
  if(err) {
    return console.log(err)
  }
  db = client.db('todoapp')

  app.listen(process.env.PORT , function(){
    console.log("listening on 8080");
  });
});

app.get('/list', function(req, res) {
  db.collection('posts').find().toArray(function(err, result) {
    res.render('list.ejs', { posts : result });
  });
});

app.get('/search', function(req, res) {
  const searchCondition = [
    {
      $search : {
        index : 'titleSearch',
        text : {
          query : req.query.value,
          path : "title"
        }
      }
    },
  ]
  db.collection('posts').aggregate(searchCondition).toArray(function(err, result) {
    res.render('search.ejs', { posts : result })
  })
})

app.get('/detail/:id', function(req, res) {
  db.collection('posts').findOne({ _id : parseInt(req.params.id)}, function(err, result) {
    res.render('detail.ejs', { data : result });
    if(result == null) {
      res.send("404 Not Found")
    }
  });
});

app.get('/edit/:id', function(req, res) {
  db.collection('posts').findOne({ _id : parseInt(req.params.id)}, function(err, result) {
    res.render('edit.ejs', { data : result });
    if(result == null) {
      res.send("404 Not Found")
    }
  });
});

app.put('/edit', function(req, res) {
  db.collection('posts').updateOne({ _id : parseInt(req.body.id) }, { $set : { title : req.body.title, date : req.body.date } }, function(err, result){
    console.log("수정완료")
    res.redirect('/list')
  });
});

app.get('/', function(req, res){
  res.render('index.ejs', {})
});

app.get('/write', function(req, res){
  res.render('write.ejs', {})
});

app.get('/login', function(req, res){
  res.render('login.ejs', {})
});

app.post('/login', passport.authenticate('local',{ failureRedirect : '/fail'}), function(req, res){
  res.redirect('/')
});

app.get('/fail', function(req, res){
  res.render('fail.ejs', {})
});

app.get('/mypage', isLogin, function(req, res){
  console.log(req.user)
  res.render('mypage.ejs', { user : req.user })
});

// 아이디, 비번 검증
passport.use(new LocalStrategy({
  usernameField : 'id',
  passwordField : 'pw',
  session : true,
  passReqToCallback : false,
}, function(inputId, inputPw, done) {
  console.log(inputId, inputPw, done);
  db.collection('login').findOne({ id : inputId }, function(err, result){
    if(err) return done(err)
    if(!result) return done(null, false, { message : "존재하지 않는 아이디입니다."})
    if(inputPw == result.pw) {
      return done(null, result)
    } else {
      return done(null, false, { message : "비밀번호가 틀렸습니다."})
    }
  })
}));

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

passport.deserializeUser(function(userId, done){
  db.collection('login').findOne({ id : userId }, function(err, result){
    done(null, result)
  })
})

app.get('/register', function(req, res) {
  res.render('register.ejs', {})
})

app.post('/register', function(req, res) {
  db.collection('login').insertOne({ id : req.body.id, pw : req.body.pw }, function(err, result) {
    res.redirect('/')
  })
})

app.post('/add', function(req, res) {
  res.redirect('/list')
  db.collection('counter').findOne({name : '게시물갯수'}, function(err, result) {
    let totalPost = result.totalPost;
    const saveList = { _id : totalPost + 1, writer : req.user._id, title : req.body.title, date : req.body.date }
    db.collection('posts').insertOne(saveList, function(err, result){
      console.log('저장완료');
      db.collection('counter').updateOne({name : '게시물갯수'},{ $inc : { totalPost : 1} },function(err, result){
        if (err) {
          return console.log(err)
        }
        console.log(result)
      })
    });
  });
});

app.delete('/delete', function(req, res) {
  req.body._id = parseInt(req.body._id)
  const deleteDate = { _id : req.body._id, writer : req.user._id }
  db.collection('posts').deleteOne(deleteDate, function(err, result) {
    if (err) {
      console.log(err)
    }
    res.status(200).send({ message : "success" });
  });
});

app.get('/upload', function(req, res) {
  res.render('upload.ejs', {})
})

const multer = require('multer');
const storage = multer.diskStorage({
  destination : function(req, file, cb) {
    cb(null, './public/image')
  },
  filename : function(req, file, cb) {
    cb(null, file.originalname)
  }
});
const upload = multer({storage : storage});

app.post('/upload', upload.single('profile'), function(req, res) {
  res.send("전송완료")
})

app.get('/image/:imageName', function(req, res) {
  res.sendFile(__dirname + '/public/image/' + req.params.imageName)
})

app.get('/chat',isLogin, function(req, res) {
  db.collection('chatroom').find({ member : req.user._id }).toArray().then((result)=> {
    res.render('chat.ejs', { data : result })
  })
})

app.post('/chatroom', isLogin, function(req, res) {
  const saveList = {
    title : "채팅방방",
    member : [ObjectId(req.body.user_id), req.user._id],
    date : new Date()
  }
  db.collection('chatroom').insertOne(saveList).then((result)=> {
    res.send("채팅방 개설 성공")
  })
})

app.post('/message', isLogin, function(req, res) {
  const saveList = {
    parent : ObjectId(req.body.parent),
    content : req.body.content,
    userid : req.user._id,
    date : new Date(),
  }
  db.collection('message').insertOne(saveList).then(()=> {
    console.log("성공")
    res.send("DB저장 성공")
  }).catch(()=> {
    console.log("실패")
  })
})

app.get('/message/:id', isLogin, function(req, res) {
  res.writeHead(200, {
    "Connection" : "keep-alive",
    "Content-Type" : "text/event-stream; charset=utf-8",
    "Cache-Control" : "no-cache",
  });
  db.collection('message').find({ parent : ObjectId(req.params.id) }).toArray().then( (result)=> {
    res.write(event : test\n);
    res.write(data : ${JSON.stringify(result)}\n\n);
  });
  const pipeline = [
    { $match : { 'fullDocument.parent' : ObjectId(req.params.id) } }
  ];
  const collection = db.collection('message');
  const changeStream = collection.watch(pipeline);
  changeStream.on('change', (result)=> {
    console.log(result.fullDocument)
    res.write(data : ${JSON.stringify([result.fullDocument])} \n\n);
  });
});

// router practice
app.use('/shop', require('./routes/shop.js'));
app.use('/board/sub', require('./routes/board.js'));