Method maybeCompressContext

agent/loop.go:1229–1267

(ctx context.Context, state *AgentState)

func (e *CoreExecutionEngine) PinConsumedCacheEdits() {
	e.pinConsumedCacheEdits()
}

func (e *CoreExecutionEngine) RestoreInFlightCacheEdits() {
	e.restoreInFlightCacheEdits()
}

func (e *CoreExecutionEngine) consumeCacheEditsForRequest(visibleToolResultIDs map[string]struct{}) *api.LLMRequestOptions {
	if !strings.HasPrefix(strings.ToLower(e.Config.APIModel), "claude-") {
		e.cacheEditState = RuntimeCacheEditState{}
		return &api.LLMRequestOptions{}
	}
	if !e.Config.AnthropicCacheEditsEnabled {
		return &api.LLMRequestOptions{}
	}

	pinned := filterVisibleCacheEdits(e.cacheEditState.Pinned, visibleToolResultIDs)
	pending := filterVisibleCacheEdits(e.cacheEditState.Pending, visibleToolResultIDs)
	e.cacheEditState.Pinned = pinned
	e.cacheEditState.Pending = nil
	e.cacheEditState.ConsumedInFlight = pending

	edits := make([]api.CacheEdit, 0, len(pinned)+len(pending))
	edits = append(edits, pinned...)
	edits = append(edits, pending...)
	return &api.LLMRequestOptions{AnthropicCacheEdits: edits}
}

func (e *CoreExecutionEngine) pinConsumedCacheEdits() {
	if len(e.cacheEditState.ConsumedInFlight) == 0 {
		return
	}
	existing := map[string]struct{}{}
	for _, edit := range e.cacheEditState.Pinned {
		existing[edit.ToolUseID] = struct{}{}
	}
	for _, edit := range e.cacheEditState.ConsumedInFlight {
		if _, ok := existing[edit.ToolUseID]; ok {
			continue
		}
		e.cacheEditState.Pinned = append(e.cacheEditState.Pinned, edit)
		existing[edit.ToolUseID] = struct{}{}
	}