Refactor cache and memory utils

mind-agents/src/utils/MemoryManager.ts

@@ -24,23 +24,23 @@ interface LeakDetectionResult {
   recommendations: string[];
 }
 
-interface ManagedResource {
+interface ManagedResource<T = unknown> {
   id: string;
   type: string;
-  resource: any;
+  resource: T;
   cleanup: () => Promise<void> | void;
   createdAt: number;
   lastAccessed: number;
   accessCount: number;
   ttl?: number;
 }
 
-export class MemoryManager extends EventEmitter {
+export class MemoryManager<T = unknown> extends EventEmitter {
   private snapshots: MemorySnapshot[] = [];
   private maxSnapshots = 100;
   private snapshotInterval = 30000; // 30 seconds
-  private resources = new Map<string, ManagedResource>();
-  private weakRefs = new Set<WeakRef<any>>();
+  private resources = new Map<string, ManagedResource<T>>();
+  private weakRefs = new Set<WeakRef<T>>();
   private isMonitoring = false;
   private monitoringTimer?: NodeJS.Timer;
   private cleanupTimer?: NodeJS.Timer;
@@ -131,7 +131,7 @@ export class MemoryManager extends EventEmitter {
    */
   registerResource(
     type: string,
-    resource: any,
+    resource: T,
     cleanup: () => Promise<void> | void,
     options?: {
       ttl?: number;
@@ -140,7 +140,7 @@ export class MemoryManager extends EventEmitter {
   ): string {
     const id = options?.id || this.generateResourceId();
 
-    const managedResource: ManagedResource = {
+    const managedResource: ManagedResource<T> = {
       id,
       type,
       resource,
@@ -185,7 +185,7 @@ export class MemoryManager extends EventEmitter {
   /**
    * Access a registered resource (updates access tracking)
    */
-  accessResource(id: string): any {
+  accessResource(id: string): T | null {
     const resource = this.resources.get(id);
     if (!resource) return null;
 
@@ -476,7 +476,7 @@ export class MemoryManager extends EventEmitter {
 
   private cleanupWeakRefs(): void {
     const initialSize = this.weakRefs.size;
-    const toRemove: WeakRef<any>[] = [];
+    const toRemove: WeakRef<T>[] = [];
 
     for (const weakRef of this.weakRefs) {
       if (weakRef.deref() === undefined) {
@@ -503,4 +503,4 @@ export const memoryManager = new MemoryManager({
 // Auto-start if not in test environment
 if (process.env.NODE_ENV !== 'test') {
   memoryManager.start();
-}
+}

mind-agents/src/utils/context-cache.ts

@@ -17,7 +17,7 @@ export interface CacheEntry<T> {
   hits: number;
   size: number;
   ttl?: number;
-  metadata?: Record<string, any>;
+  metadata?: Record<string, unknown>;
 }
 
 /**
@@ -157,7 +157,7 @@ export class LRUCache<T> {
   /**
    * Estimate size of value
    */
-  private estimateSize(value: any): number {
+  private estimateSize(value: T): number {
     try {
       return JSON.stringify(value).length;
     } catch {
@@ -202,8 +202,8 @@ export class LRUCache<T> {
 /**
  * Multi-level context cache
  */
-export class ContextCache {
-  private l1Cache: LRUCache<any>; // Hot cache - in memory
+export class ContextCache<T = unknown> {
+  private l1Cache: LRUCache<T>; // Hot cache - in memory
   private l2Cache: LRUCache<string>; // Warm cache - compressed
   private cleanupInterval?: NodeJS.Timeout;
 
@@ -229,7 +229,7 @@ export class ContextCache {
   /**
    * Get context from cache
    */
-  async get(key: string): Promise<any | undefined> {
+  async get(key: string): Promise<T | undefined> {
     // Check L1 first
     const l1Result = this.l1Cache.get(key);
     if (l1Result) {
@@ -256,7 +256,11 @@ export class ContextCache {
   /**
    * Set context in cache
    */
-  async set(key: string, value: any, options: { ttl?: number; priority?: 'high' | 'normal' } = {}): Promise<void> {
+  async set(
+    key: string,
+    value: T,
+    options: { ttl?: number; priority?: 'high' | 'normal' } = {}
+  ): Promise<void> {
     // Always set in L1 for immediate access
     this.l1Cache.set(key, value, options.ttl);
 
@@ -379,4 +383,4 @@ export const contextCache = new ContextCache();
 // Cleanup on process exit
 process.on('beforeExit', () => {
   contextCache.stop();
-});
+});