@@ -97,7 +97,7 @@ interface LogBufferMessage {
97
97
}
98
98
99
99
class LogBuffer {
100
- private messages : Array < LogBufferMessage > = [ ] ;
100
+ private messages : LogBufferMessage [ ] = [ ] ;
101
101
102
102
constructor ( private readonly maxLength : number ) { }
103
103
@@ -108,27 +108,33 @@ class LogBuffer {
108
108
objs : objs . map ( value => structuredClone ( value ) ) ,
109
109
timestamp : performance . now ( )
110
110
} ;
111
- if ( this . messages . length == this . maxLength ) {
111
+ if ( this . messages . length === this . maxLength ) {
112
112
this . messages . shift ( ) ;
113
113
}
114
114
this . messages . push ( message ) ;
115
115
}
116
116
117
117
dump ( ) : void {
118
118
const now = performance . now ( ) ;
119
+ const numBufferedMessages = this . messages . length ;
120
+ const i = 1 ;
119
121
120
- while ( this . messages . length > 0 ) {
121
- const { level, msg, objs, timestamp } = this . messages . shift ( ) ;
122
- const args = obj . map ( argToString ) ;
123
- const messageString = `Firestore BUFFERED (${
124
- now - timestamp
125
- } ms ago): ${ msg } `;
122
+ while ( true ) {
123
+ const message = this . messages . shift ( ) ;
124
+ if ( ! message ) {
125
+ break ;
126
+ }
127
+ const { level, msg, objs, timestamp } = message ;
128
+ const args = objs . map ( argToString ) ;
129
+ const messageString =
130
+ `Firestore BUFFERED ${ i } /${ numBufferedMessages } ` +
131
+ `(${ now - timestamp } ms ago): ${ msg } ` ;
126
132
if ( level === LogLevel . WARN ) {
127
- logClient . warn ( messageString , ...objs ) ;
133
+ logClient . warn ( messageString , ...args ) ;
128
134
} else if ( level === LogLevel . ERROR ) {
129
- logClient . error ( messageString , ...objs ) ;
135
+ logClient . error ( messageString , ...args ) ;
130
136
} else {
131
- logClient . debug ( messageString , ...objs ) ;
137
+ logClient . debug ( messageString , ...args ) ;
132
138
}
133
139
}
134
140
}
0 commit comments