@@ -4,16 +4,17 @@ import {
4
4
IssuePayload ,
5
5
IssueReason ,
6
6
IssueType ,
7
- WebRTCStatsParsed
7
+ WebRTCStatsParsed ,
8
8
} from '../types' ;
9
9
import BaseIssueDetector from './BaseIssueDetector' ;
10
10
11
11
interface MissingStreamDetectorParams {
12
12
timeoutMs ?: number ;
13
13
}
14
14
15
- export class MissingStreamDataDetector extends BaseIssueDetector {
15
+ export default class MissingStreamDataDetector extends BaseIssueDetector {
16
16
readonly #lastMarkedAt = new Map < string , number > ( ) ;
17
+
17
18
readonly #timeoutMs: number ;
18
19
19
20
constructor ( params : MissingStreamDetectorParams = { } ) {
@@ -57,11 +58,15 @@ export class MissingStreamDataDetector extends BaseIssueDetector {
57
58
return issues ;
58
59
}
59
60
60
- private detectMissingData ( commonStreamStats : CommonParsedInboundStreamStats [ ] , type : IssueType , reason : IssueReason ) : IssueDetectorResult {
61
+ private detectMissingData (
62
+ commonStreamStats : CommonParsedInboundStreamStats [ ] ,
63
+ type : IssueType ,
64
+ reason : IssueReason ,
65
+ ) : IssueDetectorResult {
61
66
const issues : IssuePayload [ ] = [ ] ;
62
67
63
68
commonStreamStats . forEach ( ( inboundItem ) => {
64
- const trackId = inboundItem . track . trackIdentifier
69
+ const trackId = inboundItem . track . trackIdentifier ;
65
70
66
71
if ( inboundItem . bytesReceived === 0 && ! inboundItem . track . detached && ! inboundItem . track . ended ) {
67
72
const hasIssue = this . markIssue ( trackId ) ;
@@ -87,7 +92,7 @@ export class MissingStreamDataDetector extends BaseIssueDetector {
87
92
}
88
93
} ) ;
89
94
90
- return issues
95
+ return issues ;
91
96
}
92
97
93
98
private markIssue ( trackId : string ) : boolean {
@@ -106,4 +111,3 @@ export class MissingStreamDataDetector extends BaseIssueDetector {
106
111
this . #lastMarkedAt. delete ( trackId ) ;
107
112
}
108
113
}
109
-
0 commit comments