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

asd

Browse Source
This commit is contained in:
bangae1
2025-10-21 14:35:33 +09:00
parent c63d71828c
commit 890d6ce077
1 changed files with 36 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
server.js
View File

@@ -55,14 +55,26 @@ io.on('connection', (socket) => {
}
});
// 3. WebRTC 시그널링 (SDP, ICE)
socket.on('webrtcSignal', (data) => {
// const targetSocketId = employeeSockets.get(data.targetId);
console.log('webrtcSignal', data);
if (data.targetId) {
io.to(data.targetId).emit('webrtcSignal', data);
// 3. WebRTC 시그널링 (ICE)
socket.on('icecandidate', (data) => {
if(data.server === 'agent') {
if (data.targetId && data.candidate) {
console.log('icecandidate agent', data);
const to = io.to(data.targetId)
data.targetId = socket.id;
to.emit('icecandidate', data);
}
} else {
const targetSocketId = employeeSockets.get(data.targetId);
if (targetSocketId && data.candidate) {
console.log('icecandidate client', data);
const to = io.to(targetSocketId)
data.targetId = socket.id;
to.emit('icecandidate', data);
}
}
});
// 4. 입력 이벤트 전달 (관리자 → 직원)
@@ -89,21 +101,31 @@ io.on('connection', (socket) => {
}
});
socket.on('offer', (data) => {
console.log('offer', employeeSockets, data.targetId);
if(data.targetId) {
const to = io.to(data.targetId)
socket.on('requestOffer', (data) => {
const targetSocketId = employeeSockets.get(data.targetId);
console.log('requestOffer', employeeSockets, targetSocketId);
if(targetSocketId) {
const to = io.to(targetSocketId)
data.targetId = socket.id
to.emit('offer', data);
to.emit('responseOffer', data);
}
})
socket.on('answer', (data) => {
console.log('answer', employeeSockets, data.targetId);
socket.on('requestAnswer', (data) => {
console.log('requestAnswer', employeeSockets, data.targetId);
if(data.targetId) {
const to = io.to(data.targetId)
data.targetId = socket.id
to.emit('answer', data);
to.emit('responseAnswer', data);
}
})
socket.on('start', (data) => {
console.log('start', employeeSockets, data);
if(data.targetId) {
const to = io.to(data.targetId)
data.targetId = socket.id
to.emit('start', data);
}
})
});