cosette/modules/socket.js

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`)
            })
        })
    })
}