iridium/neko
2
2
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2024-07-24 14:40:50 +12:00
Code Issues Packages Projects Releases Wiki Activity

forward webrtc sdp for debugging, #15.

Browse Source
This commit is contained in:
Miroslav Šedivý 2021-04-18 22:49:41 +02:00
parent 5f9c565df6
commit 6312ae2cd2
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/component/internal/messages.ts
View File

@ -11,6 +11,8 @@ export interface NekoEvents {
// connection events // connection events
['connection.websocket']: (state: 'connected' | 'connecting' | 'disconnected') => void ['connection.websocket']: (state: 'connected' | 'connecting' | 'disconnected') => void
['connection.webrtc']: (state: 'connected' | 'connecting' | 'disconnected') => void ['connection.webrtc']: (state: 'connected' | 'connecting' | 'disconnected') => void
['connection.webrtc.sdp']: (type: 'local' | 'remote', data: string) => void
['connection.webrtc.sdp.candidate']: (type: 'local' | 'remote', data: RTCIceCandidateInit) => void
['connection.disconnect']: (message: string) => void ['connection.disconnect']: (message: string) => void
// drag and drop events // drag and drop events
@ -106,16 +108,18 @@ export class NekoMessages extends EventEmitter<NekoEvents> {
// Signal Events // Signal Events
///////////////////////////// /////////////////////////////
protected [EVENT.SIGNAL_PROVIDE]({ event, video, videos }: message.SignalProvide) { protected [EVENT.SIGNAL_PROVIDE]({ event, sdp, video, videos }: message.SignalProvide) {
this._log.debug('EVENT.SIGNAL_PROVIDE') this._log.debug('EVENT.SIGNAL_PROVIDE')
Vue.set(this.state.connection.webrtc, 'video', video) Vue.set(this.state.connection.webrtc, 'video', video)
Vue.set(this.state.connection.webrtc, 'videos', videos) Vue.set(this.state.connection.webrtc, 'videos', videos)
// TODO: Handle. // TODO: Handle.
this.emit('connection.webrtc.sdp', 'remote', sdp)
} }
protected [EVENT.SIGNAL_CANDIDATE]({ event, ...candidate }: message.SignalCandidate) { protected [EVENT.SIGNAL_CANDIDATE]({ event, ...candidate }: message.SignalCandidate) {
this._log.debug('EVENT.SIGNAL_CANDIDATE') this._log.debug('EVENT.SIGNAL_CANDIDATE')
// TODO: Handle. // TODO: Handle.
this.emit('connection.webrtc.sdp.candidate', 'remote', candidate)
} }
protected [EVENT.SIGNAL_VIDEO]({ event, video }: message.SignalVideo) { protected [EVENT.SIGNAL_VIDEO]({ event, video }: message.SignalVideo) {

2
src/component/main.vue
View File

@ -369,6 +369,7 @@
try { try {
let sdp = await this.webrtc.connect(payload.sdp, payload.iceservers) let sdp = await this.webrtc.connect(payload.sdp, payload.iceservers)
this.websocket.send(EVENT.SIGNAL_ANSWER, { sdp }) this.websocket.send(EVENT.SIGNAL_ANSWER, { sdp })
this.events.emit('connection.webrtc.sdp', 'local', sdp)
} catch (e) {} } catch (e) {}
break break
case EVENT.SIGNAL_CANDIDATE: case EVENT.SIGNAL_CANDIDATE:
@ -417,6 +418,7 @@
}) })
this.webrtc.on('candidate', (candidate: RTCIceCandidateInit) => { this.webrtc.on('candidate', (candidate: RTCIceCandidateInit) => {
this.websocket.send(EVENT.SIGNAL_CANDIDATE, candidate) this.websocket.send(EVENT.SIGNAL_CANDIDATE, candidate)
this.events.emit('connection.webrtc.sdp.candidate', 'local', candidate)
}) })
let webrtcCongestion: number = 0 let webrtcCongestion: number = 0