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

webrtc update error reporting.

Browse Source
This commit is contained in:
Miroslav Šedivý 2021-12-12 23:40:12 +01:00
parent da3b6df703
commit f12d77f78f
1 changed files with 45 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/component/internal/webrtc.ts
View File

@ -102,7 +102,12 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
} }
this._peer.onconnectionstatechange = () => { this._peer.onconnectionstatechange = () => {
const state = this._peer!.connectionState if (!this._peer) {
this._log.warn(`attempting to call 'onconnectionstatechange' for nonexistent peer`)
return
}
const state = this._peer.connectionState
this._log.info(`peer connection state changed`, { state }) this._log.info(`peer connection state changed`, { state })
switch (state) { switch (state) {
@ -116,7 +121,12 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
} }
this._peer.oniceconnectionstatechange = () => { this._peer.oniceconnectionstatechange = () => {
this._state = this._peer!.iceConnectionState if (!this._peer) {
this._log.warn(`attempting to call 'oniceconnectionstatechange' for nonexistent peer`)
return
}
this._state = this._peer.iceConnectionState
this._log.info(`peer ice connection state changed`, { state: this._state }) this._log.info(`peer ice connection state changed`, { state: this._state })
switch (this._state) { switch (this._state) {
@ -131,7 +141,12 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
} }
this._peer.onsignalingstatechange = () => { this._peer.onsignalingstatechange = () => {
const state = this._peer!.iceConnectionState if (!this._peer) {
this._log.warn(`attempting to call 'onsignalingstatechange' for nonexistent peer`)
return
}
const state = this._peer.iceConnectionState
this._log.info(`peer signaling state changed`, { state }) this._log.info(`peer signaling state changed`, { state })
switch (state) { switch (state) {
@ -145,13 +160,19 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
} }
this._peer.onnegotiationneeded = async () => { this._peer.onnegotiationneeded = async () => {
const offer = await this._peer?.createOffer() if (!this._peer) {
this._log.warn(`attempting to call 'onsignalingstatechange' for nonexistent peer`)
return
}
try {
const offer = await this._peer.createOffer()
// If the connection hasn't yet achieved the "stable" state, // If the connection hasn't yet achieved the "stable" state,
// return to the caller. Another negotiationneeded event // return to the caller. Another negotiationneeded event
// will be fired when the state stabilizes. // will be fired when the state stabilizes.
const state = this._peer!.signalingState const state = this._peer.signalingState
this._log.warn(`negotiation is needed`, { state }) this._log.warn(`negotiation is needed`, { state })
if (state != 'stable') { if (state != 'stable') {
@ -159,13 +180,16 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
return return
} }
this._peer!.setLocalDescription(offer) await this._peer.setLocalDescription(offer)
if (offer) { if (offer) {
this.emit('negotiation', offer) this.emit('negotiation', offer)
} else { } else {
this._log.warn(`negotiatoion offer is empty`) this._log.warn(`negotiatoion offer is empty`)
} }
} catch (error: any) {
this._log.error(`on negotiation needed failed`, { error })
}
} }
this._peer.ontrack = this.onTrack.bind(this) this._peer.ontrack = this.onTrack.bind(this)
@ -177,7 +201,7 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
throw new Error('attempting to set offer for nonexistent peer') throw new Error('attempting to set offer for nonexistent peer')
} }
this._peer.setRemoteDescription({ type: 'offer', sdp }) await this._peer.setRemoteDescription({ type: 'offer', sdp })
if (this._candidates.length > 0) { if (this._candidates.length > 0) {
for (const candidate of this._candidates) { for (const candidate of this._candidates) {
@ -203,7 +227,7 @@ export class NekoWebRTC extends EventEmitter<NekoWebRTCEvents> {
throw new Error('attempting to set answer for nonexistent peer') throw new Error('attempting to set answer for nonexistent peer')
} }
this._peer.setRemoteDescription({ type: 'answer', sdp }) await this._peer.setRemoteDescription({ type: 'answer', sdp })
} }
public addTrack(track: MediaStreamTrack, ...streams: MediaStream[]): RTCRtpSender { public addTrack(track: MediaStreamTrack, ...streams: MediaStream[]): RTCRtpSender {