유저간 채팅기능 만들기 5. DB 변동사항 실시간 업데이트

[곽범근]

다른 기능은 다 구현되는데 실시간으로 갱신되지 않습니다.
하루종일 찾아봐도 안 나와서 질문 올려봅니다.

또한 채팅방을 여러번 클릭하면 어느순간부터 빈 채팅방만 보여주는데 왜 그런건가요?

chat.ejs

<hr />

    <script>
    $('#send').click(function(){
      var 채팅내용 = $('#chat-input').val();  
      var 보낼거 = {
        parent: 지금누른채팅방id,
        content: 채팅내용,
      }
      $.post('/message', 보낼거).then((e)=>{  
        console.log(e)
      });
    
    });
    
    var 지금누른채팅방id;
    var eventSource;

    $('.list-group-item').click(function(){
      지금누른채팅방id = this.dataset.id;
      $('.chat-content').html('') //일단 메세지들 전부 비우기

        eventSource = new EventSource('/message/' + 지금누른채팅방id);
        eventSource.addEventListener('test', function (e){
          console.log(e.data);

          var 가져온거 = JSON.parse(e.data);
          가져온거.forEach((a) => {
              $('.chat-content').append(`<li><span class="chat-box">${a.content}</span></li>`)
          });
        });
      
      });
    </script>

server.js

<hr />

app.get('/message/:parentid', 로그인했니, function(req, res){

  res.writeHead(200, {
    "Connection": "keep-alive",
    "Content-Type": "text/event-stream",
    "Cache-Control": "no-cache",
  });

  db.collection('message').find({ parent: req.params.parentid }).toArray()
  .then((rs)=>{
    console.log(rs);
    res.write('event: test\n');
    res.write(`data:${JSON.stringify(rs)}\n\n`);
  });

  const 찾을문서 = [
    { $match: { 'fullDocument.parent': req.params.parentid } }
  ];

  const changeStream = db.collection('message').watch(찾을문서);
  changeStream.on('change', (result) => {
    console.log(result.fullDocument);
    var 추가된문서 = [result.fullDocument];
    res.write(`data:${JSON.stringify(추가된문서)}\n\n`);
  });
});

[codingapple]

res.write(`data: ${JSON.stringify(추가된문서)}\n\n`);
스페이스바 빠진듯요 
채팅방 클릭하면 지금누른채팅방id 같은 변수 출력잘되는지 확인해봅시다 

[곽범근]

다른 질문 게시글보고 해결했습니다
changeStream 에서 res.write('event: test\n');가 빠졌네요
저거 한 줄 입력하니까 정상적으로 메세지가 갱신되네요 감사합니다 !

[글쓴이]

글