refactor: fix lint

Author: BioPhoton

packages/utils/src/lib/profiler/wal-json-trace.ts

@@ -1,5 +1,5 @@
 import { performance } from 'node:perf_hooks';
-import type { WalFormat } from '../wal.js';
+import type { InvalidEntry, WalFormat } from '../wal.js';
 import {
   decodeTraceEvent,
   encodeTraceEvent,
@@ -108,8 +108,14 @@ export const traceEventWalFormat = <
         : `${baseName}${finalExtension}`,
     // eslint-disable-next-line functional/prefer-tacit
     finalizer: (
-      records: UserTimingTraceEvent[],
+      records: (UserTimingTraceEvent | InvalidEntry<string>)[],
       metadata?: Record<string, unknown>,
-    ) => generateTraceContent(records, metadata),
+    ) => {
+      const validRecords = records.filter(
+        (r): r is UserTimingTraceEvent =>
+          !(typeof r === 'object' && r != null && '__invalid' in r),
+      );
+      return generateTraceContent(validRecords, metadata);
+    },
   } satisfies WalFormat<T>;
 };

packages/utils/src/lib/wal.ts

@@ -225,7 +225,10 @@ export type WalFormat<T> = {
   /** Function to generate final merged file path */
   finalPath: () => string;
   /** Finalizer for converting records to a string */
-  finalizer: (records: T[], opt?: Record<string, unknown>) => string;
+  finalizer: (
+    records: (T | InvalidEntry<string>)[],
+    opt?: Record<string, unknown>,
+  ) => string;
 };
 
 export const stringCodec = <
@@ -250,7 +253,7 @@ export const stringCodec = <
  *  - codec defaults to stringCodec<T>()
  *  - shardPath defaults to (id: string) => `${baseName}.${id}${walExtension}`
  *  - finalPath defaults to () => `${baseName}${finalExtension}`
- *  - finalizer defaults to (encodedRecords: T[]) => `${encodedRecords.join('\n')}\n`
+ *  - finalizer defaults to (encodedRecords: (T | InvalidEntry<string>)[]) => `${encodedRecords.join('\n')}\n`
  * @param format - Partial WalFormat configuration
  * @returns Parsed WalFormat with defaults filled in
  */
@@ -264,7 +267,8 @@ export function parseWalFormat<T extends object | string = object>(
     codec = stringCodec<T>(),
     shardPath = (id: string) => `${baseName}.${id}.${walExtension}`,
     finalPath = () => `${baseName}.${finalExtension}`,
-    finalizer = (encodedRecords: T[]) => `${encodedRecords.join('\n')}\n`,
+    finalizer = (encodedRecords: (T | InvalidEntry<string>)[]) =>
+      `${encodedRecords.join('\n')}\n`,
   } = format;
 
   return {