rtc-remote/server
1
0
Fork 0
mirror of https://git.hmsn.ink/rtc-remote/server.git synced 2026-03-20 00:12:17 +09:00
Code Issues Packages Projects Releases Wiki Activity

asdf

Browse Source
This commit is contained in:
bangae1
2025-10-20 23:01:59 +09:00
parent 7a327f2d76
commit c63d71828c
1 changed files with 23 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
server.js
View File

@@ -31,12 +31,12 @@ io.on('connection', (socket) => {
}); });
// 2. 관리자가 연결 요청 // 2. 관리자가 연결 요청
socket.on('requestControl', ({ targetId, offer, displayId }) => { socket.on('requestControl', ({ displayId, targetId }) => {
console.log('requestControl', targetId, displayId);
const targetSocketId = employeeSockets.get(targetId); const targetSocketId = employeeSockets.get(targetId);
if (targetSocketId) { if (targetSocketId) {
io.to(targetSocketId).emit('controlRequest', { io.to(targetSocketId).emit('responseControl', {
from: socket.id, targetId: socket.id,
offer,
displayId // 선택된 디스플레이 ID 전달 displayId // 선택된 디스플레이 ID 전달
}); });
} else { } else {
@@ -47,11 +47,9 @@ io.on('connection', (socket) => {
// 2.5. 관리자가 디스플레이 목록 요청 // 2.5. 관리자가 디스플레이 목록 요청
socket.on('requestDisplays', (employeeId) => { socket.on('requestDisplays', (employeeId) => {
console.log('requestDisplays', employeeId);
const displays = employeeDisplays.get(employeeId); const displays = employeeDisplays.get(employeeId);
console.log('requestDisplays', displays);
if (displays) { if (displays) {
socket.emit('availableDisplays', displays); socket.emit('responseDisplays', {displays});
} else { } else {
socket.emit('error', `직원 ${employeeId}의 디스플레이 정보가 없습니다.`); socket.emit('error', `직원 ${employeeId}의 디스플레이 정보가 없습니다.`);
} }
@@ -90,6 +88,24 @@ io.on('connection', (socket) => {
console.log(`디스플레이 목록 저장됨: ${socket.employeeId}`, displays); console.log(`디스플레이 목록 저장됨: ${socket.employeeId}`, displays);
} }
}); });
socket.on('offer', (data) => {
console.log('offer', employeeSockets, data.targetId);
if(data.targetId) {
const to = io.to(data.targetId)
data.targetId = socket.id
to.emit('offer', data);
}
})
socket.on('answer', (data) => {
console.log('answer', employeeSockets, data.targetId);
if(data.targetId) {
const to = io.to(data.targetId)
data.targetId = socket.id
to.emit('answer', data);
}
})
}); });
const PORT = process.env.PORT || 3001; const PORT = process.env.PORT || 3001;