forked from Github/uno-online
56 lines
1.6 KiB
JavaScript
56 lines
1.6 KiB
JavaScript
const express = require('express')
|
|
const socketio = require('socket.io')
|
|
const http = require('http')
|
|
const cors = require('cors')
|
|
const { addUser, removeUser, getUser, getUsersInRoom } = require('./users')
|
|
|
|
const PORT = process.env.PORT || 5000
|
|
|
|
const app = express()
|
|
const server = http.createServer(app)
|
|
const io = socketio(server)
|
|
|
|
app.use(cors())
|
|
|
|
io.on('connection', socket => {
|
|
socket.on('join', (payload, callback) => {
|
|
let numberOfUsersInRoom = getUsersInRoom(payload.room).length
|
|
|
|
const { error, newUser} = addUser({
|
|
id: socket.id,
|
|
name: numberOfUsersInRoom===0 ? 'Player 1' : 'Player 2',
|
|
room: payload.room
|
|
})
|
|
|
|
if(error)
|
|
return callback(error)
|
|
|
|
socket.join(newUser.room)
|
|
|
|
io.to(newUser.room).emit('roomData', {room: newUser.room, users: getUsersInRoom(newUser.room)})
|
|
socket.emit('currentUserData', {name: newUser.name})
|
|
callback()
|
|
})
|
|
|
|
socket.on('initGameState', gameState => {
|
|
const user = getUser(socket.id)
|
|
if(user)
|
|
io.to(user.room).emit('initGameState', gameState)
|
|
})
|
|
|
|
socket.on('updateGameState', gameState => {
|
|
const user = getUser(socket.id)
|
|
if(user)
|
|
io.to(user.room).emit('updateGameState', gameState)
|
|
})
|
|
|
|
socket.on('disconnect', () => {
|
|
const user = removeUser(socket.id)
|
|
if(user)
|
|
io.to(user.room).emit('roomData', {room: user.room, users: getUsersInRoom(user.room)})
|
|
})
|
|
})
|
|
|
|
server.listen(PORT, () => {
|
|
console.log(`Server running on port ${PORT}`)
|
|
}) |