index.js

if (process.env.NODE_ENV !== 'production') {
	require('dotenv').config()
}
const express = require('express')
const http = require('http')
const WebSocket = require('ws')
const mongoose = require('mongoose')
const { endRoom, createRoom } = require('./controllers/game')
const { socketsConnection } = require('./controllers/sockets')
const Room = require('./models/room')
const User = require('./models/user')
const { broadcastUpdate } = require('./utils/broadcast')
const dbURL = process.env.DB_URL

mongoose.set('strictQuery', true)
mongoose.connect(dbURL)
const db = mongoose.connection
db.on('error', console.error.bind(console, 'connection error:'))
db.on('open', () => {
	console.log('Database connected')
})

const app = express()
const server = http.createServer(app)
const wss = new WebSocket.Server({ server })
app.use(express.urlencoded({ extended: true }))
app.use(express.json())

wss.on('connection', (ws) => {
	socketsConnection(wss, ws)
})

app.get('/health', (req, res) => {
	res.json({ message: 'Server is running' })
})

app.post('/fill-room', async (req, res) => {
	const { gameId } = req.body
	const room = await Room.findOne({ id: gameId })
	await room.populate('players')
	await room.startGame()
	// console.log(room)
	res.json(room)
})

app.post('/join-room', async (req, res) => {
	try {
		const { name, gameId } = req.body
		if (!name || !gameId) {
			res.status(400)
			res.json({ message: 'Invalid request' })
			return;
		}
		let roomExists = await Room.findOne({ id: gameId })
		if (!roomExists) {
			roomExists = await createRoom(gameId)
		}
		let player = await User.findOne({ name })
		if (!player) {
			const playerr = new User({ name, balance: 1000 })
			player = await playerr.save()
		}
		if (roomExists.players.length > 10) {
			res.json({ message: 'Room is full' })
			return
		}
		if (roomExists.isStarted) {
			res.status(403); //	deny
			res.json({ message: 'Game already started' })
			return
		}
		if (!roomExists.players.includes(player._id)) {
			await roomExists.addPlayer(player)
		}
		await roomExists.populate('players')
		const payload = { id: player._id };
		await broadcastUpdate(gameId, roomExists)
		res.json(payload)
	} catch (err) {
		console.log(err)
	}
})

app.post('/end-room', endRoom)

server.listen(3000, () => {
	console.log('Server listening on port 3000')
})