matrix/matrix-js-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-js-sdk.git synced 2025-11-25 05:23:13 +03:00
Code Activity

Merge pull request #1873 from SimonBrandner/feature/call-timer/18566

Browse Source 
Give `MatrixCall` the capability to emit `LengthChanged` events
This commit is contained in:
Travis Ralston
2021-09-02 22:12:31 -06:00
committed by GitHub
parent 37736184a0 f107d63fab
commit 324f9e58ea
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/webrtc/call.ts
View File

@@ -127,6 +127,8 @@ export enum CallEvent {
FeedsChanged = 'feeds_changed', FeedsChanged = 'feeds_changed',
AssertedIdentityChanged = 'asserted_identity_changed', AssertedIdentityChanged = 'asserted_identity_changed',
LengthChanged = 'length_changed'
} }
export enum CallErrorCode { export enum CallErrorCode {
@@ -323,6 +325,9 @@ export class MatrixCall extends EventEmitter {
private remoteSDPStreamMetadata: SDPStreamMetadata; private remoteSDPStreamMetadata: SDPStreamMetadata;
private callLengthInterval: number;
private callLength = 0;
constructor(opts: CallOpts) { constructor(opts: CallOpts) {
super(); super();
this.roomId = opts.roomId; this.roomId = opts.roomId;
@@ -1479,6 +1484,10 @@ export class MatrixCall extends EventEmitter {
// chrome doesn't implement any of the 'onstarted' events yet // chrome doesn't implement any of the 'onstarted' events yet
if (this.peerConn.iceConnectionState == 'connected') { if (this.peerConn.iceConnectionState == 'connected') {
this.setState(CallState.Connected); this.setState(CallState.Connected);
this.callLengthInterval = setInterval(() => {
this.callLength++;
this.emit(CallEvent.LengthChanged, this.callLength);
}, 1000);
} else if (this.peerConn.iceConnectionState == 'failed') { } else if (this.peerConn.iceConnectionState == 'failed') {
this.hangup(CallErrorCode.IceFailed, false); this.hangup(CallErrorCode.IceFailed, false);
} }
@@ -1729,6 +1738,10 @@ export class MatrixCall extends EventEmitter {
clearTimeout(this.inviteTimeout); clearTimeout(this.inviteTimeout);
this.inviteTimeout = null; this.inviteTimeout = null;
} }
if (this.callLengthInterval) {
clearInterval(this.callLengthInterval);
this.callLengthInterval = null;
}
// Order is important here: first we stopAllMedia() and only then we can deleteAllFeeds() // Order is important here: first we stopAllMedia() and only then we can deleteAllFeeds()
// We don't stop media if the call was replaced as we want to re-use streams in the successor // We don't stop media if the call was replaced as we want to re-use streams in the successor