Method loadCacheFiles

internal/cache/cache.go:93–139

loadCacheFiles loads all existing cache files into memory.

()

// loadCacheFiles loads all existing cache files into memory.
func (c *FileCache) loadCacheFiles() error {
	files, err := os.ReadDir(c.dir)
	if err != nil {
		return fmt.Errorf("failed to read cache directory: %w", err)
	}

	for _, file := range files {
		if file.IsDir() || filepath.Ext(file.Name()) != ".json" {
			continue
		}

		key := file.Name()[:len(file.Name())-5] // Remove .json extension

		// Read the file
		data, err := os.ReadFile(filepath.Join(c.dir, file.Name()))
		if err != nil {
			getCacheLogger().Debug("Warning: Failed to read cache file %s: %v", file.Name(), err)

			continue
		}

		// Parse the item
		var item CacheItem
		if err := json.Unmarshal(data, &item); err != nil {
			getCacheLogger().Debug("Warning: Failed to parse cache file %s: %v", file.Name(), err)

			continue
		}

		// Check if the item is expired
		if item.TTL > 0 && time.Now().Unix()-item.Timestamp > item.TTL {
			// Item is expired, remove the file
			if err := os.Remove(filepath.Join(c.dir, file.Name())); err != nil {
				getCacheLogger().Debug("Warning: Failed to remove expired cache file %s: %v", file.Name(), err)
			}

			continue
		}

		// Add to in-memory cache with LRU tracking
		entry := &lruEntry{key: key, item: &item}
		element := c.lruList.PushFront(entry)
		c.inMemory[key] = element
	}

	return nil
}

// Get retrieves data from the cache and updates LRU order.
func (c *FileCache) Get(key string, dest interface{}) (bool, error) {