42 lines
1.2 KiB
JavaScript
42 lines
1.2 KiB
JavaScript
import { Server } from 'socket.io'
|
|
|
|
export default (_, nuxt) => {
|
|
nuxt.hook('listen', server => {
|
|
const io = new Server(server)
|
|
|
|
nuxt.hook('close', () => io.close())
|
|
|
|
io.on('connection', (socket) => {
|
|
console.log('Connection', socket.id)
|
|
})
|
|
|
|
io.on('connect', (socket) => {
|
|
socket.emit('message', `welcome ${socket.id}`)
|
|
socket.broadcast.emit('message', `${socket.id} joined`)
|
|
|
|
socket.on('joinRoom', (room) => {
|
|
socket.join(room)
|
|
socket.emit('message', `joinRoom ${room}`)
|
|
socket.broadcast.to(room).emit('message', `${socket.id} joined ${room}`)
|
|
})
|
|
|
|
socket.on('newComment',
|
|
function comment(message, room) {
|
|
console.log('new comment received: %s', message)
|
|
socket.broadcast.to(room).emit('newComment', { message })
|
|
})
|
|
|
|
socket.on('message',
|
|
function message(data) {
|
|
console.log('message received: %s', data)
|
|
socket.broadcast.emit('message', { data })
|
|
})
|
|
|
|
socket.on('disconnecting',
|
|
() => {
|
|
console.log('disconnected', socket.id)
|
|
socket.broadcast.emit('message', `${socket.id} left`)
|
|
})
|
|
})
|
|
})
|
|
}
|