Method Set

internal/cache/cache.go:189–241

Set stores data in the cache.

(key string, data interface{}, ttl time.Duration)

// Set stores data in the cache.
func (c *FileCache) Set(key string, data interface{}, ttl time.Duration) error {
	c.mutex.Lock()
	defer c.mutex.Unlock()

	// Marshal data to JSON once (avoids double marshaling on Get)
	jsonData, err := json.Marshal(data)
	if err != nil {
		return fmt.Errorf("failed to marshal data: %w", err)
	}

	// Create cache item with pre-marshaled JSON
	item := &CacheItem{
		Data:      jsonData,
		Timestamp: time.Now().Unix(),
		TTL:       int64(ttl.Seconds()),
	}

	// Check if item already exists, update it if so
	if element, exists := c.inMemory[key]; exists {
		entry := element.Value.(*lruEntry)
		entry.item = item
		c.lruList.MoveToFront(element)
	} else {
		// Add new item to cache
		entry := &lruEntry{key: key, item: item}
		element := c.lruList.PushFront(entry)
		c.inMemory[key] = element

		// Evict least recently used item if cache is full
		if c.maxSize > 0 && c.lruList.Len() > c.maxSize {
			c.evictLRU()
		}
	}

	// If persisted, write to file
	if c.persisted {
		// Convert to JSON
		bytes, err := json.Marshal(item)
		if err != nil {
			return fmt.Errorf("failed to marshal cache item: %w", err)
		}

		// Write to file
		filePath := filepath.Join(c.dir, key+".json")
		if err := os.WriteFile(filePath, bytes, 0o600); err != nil {
			return fmt.Errorf("failed to write cache file: %w", err)
		}
	}

	getCacheLogger().Debug("Cached item: %s with TTL %v", key, ttl)

	return nil
}

// evictLRU removes the least recently used item from the cache.
// Must be called with mutex held.