brainy/src/utils/metadataIndexCache.ts
David Snelling 2231f90913 feat: v0.49 - Filter discovery API, remove deprecated methods, improve performance
BREAKING CHANGES:
- Removed deprecated getAllNouns() and getAllVerbs() methods
- All internal usage migrated to pagination-based methods

New Features:
- Filter Discovery API:
  - getFilterValues(field): Get all available values for a field
  - getFilterFields(): Get all filterable fields
  - Enables dynamic filter UI generation with O(1) field discovery
- Hybrid metadata indexing with field-level indexes
- Adaptive auto-flush for optimal performance
- LRU caching for metadata indexes

Improvements:
- Fixed ENAMETOOLONG errors from vector-based filenames
- Safe filename generation using hash-based approach
- Scalable chunked value storage for millions of entries
- Performance optimization with adaptive flush thresholds
- Added support for $includes operator in metadata filters

Technical:
- Replaced vector-based filenames with safe hash approach
- Implemented MetadataIndexCache with existing SearchCache pattern
- Field indexes enable O(1) filter discovery
- Adaptive flush based on performance metrics (20-200 entries)
- All tests passing with improved metadata filtering
2025-08-06 14:39:33 -07:00

151 lines
No EOL
3.6 KiB
TypeScript

/**
* MetadataIndexCache - Caches metadata index data for improved performance
* Reuses the same pattern as SearchCache for consistency
*/
export interface MetadataCacheEntry {
data: any // Field index or value chunk data
timestamp: number
hits: number
}
export interface MetadataIndexCacheConfig {
maxAge?: number // Maximum age in milliseconds (default: 5 minutes)
maxSize?: number // Maximum number of cached entries (default: 500)
enabled?: boolean // Whether caching is enabled (default: true)
hitCountWeight?: number // Weight for hit count in eviction policy (default: 0.3)
}
export class MetadataIndexCache {
private cache = new Map<string, MetadataCacheEntry>()
private maxAge: number
private maxSize: number
private enabled: boolean
private hitCountWeight: number
// Cache statistics
private hits = 0
private misses = 0
private evictions = 0
constructor(config: MetadataIndexCacheConfig = {}) {
this.maxAge = config.maxAge ?? 5 * 60 * 1000 // 5 minutes
this.maxSize = config.maxSize ?? 500 // More entries than SearchCache since indexes are smaller
this.enabled = config.enabled ?? true
this.hitCountWeight = config.hitCountWeight ?? 0.3
}
/**
* Get cached entry
*/
get(key: string): any | undefined {
if (!this.enabled) return undefined
const entry = this.cache.get(key)
if (!entry) {
this.misses++
return undefined
}
// Check if entry is expired
if (Date.now() - entry.timestamp > this.maxAge) {
this.cache.delete(key)
this.misses++
return undefined
}
// Update hit count
entry.hits++
this.hits++
return entry.data
}
/**
* Set cache entry
*/
set(key: string, data: any): void {
if (!this.enabled) return
// Evict entries if at max size
if (this.cache.size >= this.maxSize) {
this.evictLeastValuable()
}
this.cache.set(key, {
data,
timestamp: Date.now(),
hits: 0
})
}
/**
* Evict least valuable entry based on age and hit count
*/
private evictLeastValuable(): void {
let leastValuableKey: string | null = null
let lowestScore = Infinity
for (const [key, entry] of this.cache.entries()) {
const age = Date.now() - entry.timestamp
const ageScore = age / this.maxAge
const hitScore = entry.hits * this.hitCountWeight
const score = hitScore - ageScore
if (score < lowestScore) {
lowestScore = score
leastValuableKey = key
}
}
if (leastValuableKey) {
this.cache.delete(leastValuableKey)
this.evictions++
}
}
/**
* Invalidate cache entries matching a pattern
*/
invalidatePattern(pattern: string): void {
const keysToDelete: string[] = []
for (const key of this.cache.keys()) {
if (key.includes(pattern)) {
keysToDelete.push(key)
}
}
keysToDelete.forEach(key => this.cache.delete(key))
}
/**
* Clear all cache entries
*/
clear(): void {
this.cache.clear()
}
/**
* Get cache statistics
*/
getStats() {
return {
size: this.cache.size,
hits: this.hits,
misses: this.misses,
hitRate: this.hits / (this.hits + this.misses) || 0,
evictions: this.evictions
}
}
/**
* Get estimated memory usage
*/
getMemoryUsage(): number {
// Rough estimate: 100 bytes per entry + data size
let totalSize = 0
for (const entry of this.cache.values()) {
totalSize += 100 // Base overhead
totalSize += JSON.stringify(entry.data).length * 2 // Unicode chars
}
return totalSize
}
}