fix: Add guard to handle null decode results; Update log event query to use active event count (fixes #166).

src/services/LogFileManager/index.ts

@@ -366,14 +366,6 @@
         }
     }
 
-    /**
-     * Queries a chunk of log events, sends the results, and schedules the next chunk query if more
-     * log events remain.
-     *
-     * @param queryId
-     * @param chunkBeginIdx
-     * @param queryRegex
-     */
     #queryChunkAndScheduleNext (
         queryId: number,
         chunkBeginIdx: number,
@@ -383,7 +375,17 @@
             // Current task no longer corresponds to the latest query in the LogFileManager.
             return;
         }
-        const chunkEndIdx = Math.min(chunkBeginIdx + QUERY_CHUNK_SIZE, this.#numEvents);
+
+        const filteredLogEventMap = this.#decoder.getFilteredLogEventMap();
+        const numActiveEvents: number = filteredLogEventMap ?
+            filteredLogEventMap.length :
+            this.#numEvents;
+
+        if (0 === numActiveEvents) {
+            return;
+        }
+
+        const chunkEndIdx = Math.min(chunkBeginIdx + QUERY_CHUNK_SIZE, numActiveEvents);
         const results: QueryResults = new Map();
         const decodedEvents = this.#decoder.decodeRange(
             chunkBeginIdx,
@@ -400,13 +402,13 @@
         // The query progress takes the maximum of the progress based on the number of events
         // queried over total log events, and the number of results over the maximum result limit.
         const progress = Math.max(
-            chunkEndIdx / this.#numEvents,
+            chunkEndIdx / numActiveEvents,
             this.#queryCount / MAX_QUERY_RESULT_COUNT
         );
 
         this.#onQueryResults(progress, results);
 
-        if (chunkEndIdx < this.#numEvents && MAX_QUERY_RESULT_COUNT > this.#queryCount) {
+        if (chunkEndIdx < numActiveEvents && MAX_QUERY_RESULT_COUNT > this.#queryCount) {
             defer(() => {
                 this.#queryChunkAndScheduleNext(queryId, chunkEndIdx, queryRegex);
             });
@@ -446,4 +448,4 @@
     }
 }
 
 export default LogFileManager;

src/services/decoders/ClpIrDecoder.ts

@@ -101,9 +101,13 @@
         endIdx: number,
         useFilter: boolean
     ): Nullable<DecodeResult[]> {
-        const results: DecodeResult[] =
+        const results: Nullable<DecodeResult[]> =
             this.#streamReader.decodeRange(beginIdx, endIdx, useFilter);
 
+        if (null === results) {
+            return null;
+        }
+
         if (null === this.#formatter) {
             if (this.#streamType === CLP_IR_STREAM_TYPE.STRUCTURED) {
                 // eslint-disable-next-line no-warning-comments