75 lines
2.3 KiB
JavaScript
75 lines
2.3 KiB
JavaScript
const { createServer } = require('http')
|
|
const { parse } = require('url')
|
|
const next = require('next')
|
|
const { Server } = require('socket.io')
|
|
|
|
const dev = process.env.NODE_ENV !== 'production'
|
|
const hostname = process.env.HOSTNAME || '0.0.0.0'
|
|
const port = parseInt(process.env.PORT || '3000', 10)
|
|
|
|
const app = next({ dev, hostname, port })
|
|
const handle = app.getRequestHandler()
|
|
|
|
app.prepare().then(() => {
|
|
const httpServer = createServer(async (req, res) => {
|
|
try {
|
|
const parsedUrl = parse(req.url, true)
|
|
await handle(req, res, parsedUrl)
|
|
} catch (err) {
|
|
console.error('Error occurred handling', req.url, err)
|
|
res.statusCode = 500
|
|
res.end('internal server error')
|
|
}
|
|
})
|
|
|
|
const io = new Server(httpServer, {
|
|
cors: { origin: '*' },
|
|
path: '/socket.io',
|
|
})
|
|
|
|
// Make io globally accessible for API routes
|
|
global.__io = io
|
|
|
|
io.on('connection', (socket) => {
|
|
console.log(`[Socket.io] Client connected: ${socket.id}`)
|
|
|
|
// Client joins a project room
|
|
socket.on('join-project', (projectId) => {
|
|
socket.join(`project:${projectId}`)
|
|
console.log(`[Socket.io] ${socket.id} joined project:${projectId}`)
|
|
})
|
|
|
|
// Client leaves a project room
|
|
socket.on('leave-project', (projectId) => {
|
|
socket.leave(`project:${projectId}`)
|
|
console.log(`[Socket.io] ${socket.id} left project:${projectId}`)
|
|
})
|
|
|
|
// Features updated — broadcast to all others in the project room
|
|
socket.on('features-updated', (data) => {
|
|
const { projectId, features } = data
|
|
socket.to(`project:${projectId}`).emit('features-changed', { features })
|
|
})
|
|
|
|
// Editing lock changed — broadcast to all others in the project room
|
|
socket.on('editing-changed', (data) => {
|
|
const { projectId, editing, editingBy, sessionId } = data
|
|
socket.to(`project:${projectId}`).emit('editing-status', { editing, editingBy, sessionId })
|
|
})
|
|
|
|
// Journal entry added/updated — broadcast to all others
|
|
socket.on('journal-updated', (data) => {
|
|
const { projectId } = data
|
|
socket.to(`project:${projectId}`).emit('journal-changed', { projectId })
|
|
})
|
|
|
|
socket.on('disconnect', () => {
|
|
console.log(`[Socket.io] Client disconnected: ${socket.id}`)
|
|
})
|
|
})
|
|
|
|
httpServer.listen(port, hostname, () => {
|
|
console.log(`> Ready on http://${hostname}:${port}`)
|
|
})
|
|
})
|