From 04cb18ad6014967e5813e6050ea76b890f2f5e25 Mon Sep 17 00:00:00 2001 From: bangae1 Date: Wed, 22 Oct 2025 14:58:09 +0900 Subject: [PATCH] s --- server.js | 23 ++++++++++++++++++----- 1 file changed, 18 insertions(+), 5 deletions(-) diff --git a/server.js b/server.js index 352a7ac..189d9b0 100644 --- a/server.js +++ b/server.js @@ -78,10 +78,12 @@ io.on('connection', (socket) => { }); // 4. 입력 이벤트 전달 (관리자 → 직원) - socket.on('inputEvent', ({ targetId, ...data }) => { - const targetSocketId = employeeSockets.get(targetId); + socket.on('inputEvent', async (data) => { + console.log('inputEvent', data); + const targetSocketId = employeeSockets.get(data.targetId); if (targetSocketId) { - io.to(targetSocketId).emit('inputEvent', data); + // console.log('inputEvent', data); + await io.to(targetSocketId).emit('inputEvent', data); } }); @@ -89,10 +91,20 @@ io.on('connection', (socket) => { socket.on('disconnect', () => { if (socket.employeeId) { employeeSockets.delete(socket.employeeId); + employeeDisplays.delete(socket.employeeId); socket.broadcast.emit('employeeOffline', socket.employeeId); console.log(`직원 오프라인: ${socket.employeeId}`); } }); + // rtc close + socket.on('forceClose', (data) => { + if(data.server === 'agent') { + + } else if(data.server === 'client') { + const targetSocketId = employeeSockets.get(data.targetId); + io.to(targetSocketId).emit('forceClose', data); + } + }); socket.on('availableDisplays', ({ displays }) => { if (socket.employeeId && displays) { @@ -131,6 +143,7 @@ io.on('connection', (socket) => { }); const PORT = process.env.PORT || 3001; -server.listen(PORT, () => { - console.log(`시그널링 서버 실행 중: http://localhost:${PORT}`); +const ADDR = process.env.ADDR || '0.0.0.0'; +server.listen(PORT, ADDR, () => { + console.log(`시그널링 서버 실행 중: http://${ADDR}:${PORT}`); }); \ No newline at end of file