refactor: wip

Author: BioPhoton

packages/utils/eslint.config.js

@@ -13,7 +13,7 @@ export default tseslint.config(
     },
   },
   {
-    files: ['packages/utils/src/lib/**/file-sink*.ts'],
+    files: ['packages/utils/src/lib/**/wal*.ts'],
     rules: {
       'n/no-sync': 'off',
     },

packages/utils/mocks/sink.mock.ts

@@ -1,29 +1,55 @@
-import type { Sink } from '../src/lib/sink-source.type';
+import { WriteAheadLogFile } from '../src/lib/profiler/wal.js';
+import type { Codec } from '../src/lib/types.js';
 
-export class MockFileSink implements Sink<string, string> {
-  setPath: (filePath: string) => void;
-  getPath: () => string;
+export class MockFileSink implements WriteAheadLogFile<string> {
   private writtenItems: string[] = [];
   private closed = false;
 
+  constructor(options?: { file?: string; codec?: Codec<string> }) {
+    const file = options?.file || '/tmp/mock-sink.log';
+    const codec = options?.codec || {
+      encode: (input: string) => input,
+      decode: (data: string) => data,
+    };
+  }
+
+  #fd: number | null = null;
+
+  get path(): string {
+    return '/tmp/mock-sink.log';
+  }
+
+  getPath(): string {
+    return this.path;
+  }
+
   open(): void {
-    this.closed = false;
+    this.#fd = 1; // Mock file descriptor
   }
 
-  write(input: string): void {
-    this.writtenItems.push(input);
+  append(v: string): void {
+    this.writtenItems.push(v);
   }
 
   close(): void {
+    this.#fd = null;
     this.closed = true;
   }
 
   isClosed(): boolean {
-    return this.closed;
+    return this.#fd === null;
+  }
+
+  recover(): any {
+    return {
+      records: this.writtenItems,
+      errors: [],
+      partialTail: null,
+    };
   }
 
-  encode(input: string): string {
-    return `${input}-${this.constructor.name}-encoded`;
+  repack(): void {
+    // Mock implementation - do nothing
   }
 
   getWrittenItems(): string[] {

packages/utils/src/index.ts

@@ -114,6 +114,7 @@ export {
   settlePromise,
 } from './lib/promises.js';
 export { generateRandomId } from './lib/random.js';
+export { profiler } from './lib/profiler/profiler.js';
 export {
   CODE_PUSHUP_DOMAIN,
   CODE_PUSHUP_UNICODE_LOGO,