Merge branch 'timestamps'

This commit is contained in:
2022-01-03 08:30:23 +00:00
+6 -6
View File
@@ -35,7 +35,7 @@ const chat = io => {
}); });
//from here, handles all normal messages //from here, handles all normal messages
socket.on('open chat', message => { socket.on('open chat', async message => {
//handle rooms - only in a room if you've opened chat //handle rooms - only in a room if you've opened chat
const newlyOpened = !socket.user.room; const newlyOpened = !socket.user.room;
socket.user.room = socket.user.room || 'general'; //default to general socket.user.room = socket.user.room || 'general'; //default to general
@@ -46,11 +46,8 @@ const chat = io => {
socket.join(socket.user.room); socket.join(socket.user.room);
//broadcast to this room
socket.broadcast.to(socket.user.room).emit('message', { emphasis: true, text: `${socket.user.username} entered chat` });
//log //log
chatlog.create({ const log = await chatlog.create({
notification: true, notification: true,
username: socket.user.username, username: socket.user.username,
text: `${socket.user.username} entered chat`, text: `${socket.user.username} entered chat`,
@@ -58,6 +55,9 @@ const chat = io => {
emphasis: true emphasis: true
}); });
//broadcast to this room
socket.broadcast.to(socket.user.room).emit('message', {timestamp: log.createdAt, emphasis: true, text: `${socket.user.username} entered chat` });
//send backlog to the user //send backlog to the user
chatlog.findAll({ chatlog.findAll({
where: { where: {
@@ -120,7 +120,7 @@ const chat = io => {
socket.broadcast.to(socket.user.room).emit('message', log); socket.broadcast.to(socket.user.room).emit('message', log);
}); });
socket.on('disconnect', reason => { socket.on('disconnect', async reason => {
//broadcast to this room //broadcast to this room
if (!socket.user) { if (!socket.user) {
return; return;