jakob/PairDrop
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add connection state handler

Browse source
This commit is contained in:
RobinLinus 2018-09-21 19:24:01 +02:00
parent e573d57419
commit 31e5f635d1
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
client/scripts/network.js
View file

@ -18,7 +18,7 @@ class ServerConnection {
clearTimeout(this._reconnectTimer); clearTimeout(this._reconnectTimer);
} }
_isConnected(){ _isConnected() {
return this._socket && this._socket.readyState === this._socket.OPEN; return this._socket && this._socket.readyState === this._socket.OPEN;
} }
@ -230,7 +230,7 @@ class RTCPeer extends Peer {
this._peerId = peerId; this._peerId = peerId;
this._peer = new RTCPeerConnection(RTCPeer.config); this._peer = new RTCPeerConnection(RTCPeer.config);
this._peer.onicecandidate = e => this._onIceCandidate(e); this._peer.onicecandidate = e => this._onIceCandidate(e);
this._peer.onconnectionstatechange = e => console.log('RTC: state changed:', this._peer.connectionState); this._peer.onconnectionstatechange = e => this._onConnectionStateChange(e);
} }
if (isCaller) { if (isCaller) {
@ -288,11 +288,19 @@ class RTCPeer extends Peer {
} }
_onChannelClosed() { _onChannelClosed() {
console.log('RTC: channel closed ', this._peerId); console.log('RTC: channel closed', this._peerId);
if (!this.isCaller) return; if (!this.isCaller) return;
this._start(this._peerId, true); // reopen the channel this._start(this._peerId, true); // reopen the channel
} }
_onConnectionStateChange(e) {
console.log('RTC: state changed:', this._peer.connectionState);
switch (this._peer.connectionState) {
'disconnected': this._onChannelClosed();
break;
}
}
_send(message) { _send(message) {
this._channel.send(message); this._channel.send(message);
} }