Method applyRollingCache

agent/loop.go:1027–1104

(messages []map[string]any, state *AgentState)

	}
	return query
}

func (e *CoreExecutionEngine) requestSkillShellPermission(ctx context.Context, executor *StreamingToolExecutor, req skills.SkillShellPermissionRequest) bool {
	if e != nil && e.Config.Yolo {
		return true
	}
	ch := make(chan bool, 1)
	e.mu.Lock()
	if e.skillPermissionCh != nil {
		e.mu.Unlock()
		return false
	}
	e.skillPermissionCh = ch
	e.skillPermissionQ = append(e.skillPermissionQ, NewStreamEvent("permission_needed", "", map[string]any{
		"skill_shell_request": req,
		"dangerous":           true,
		"risk":                "high",
	}))
	e.mu.Unlock()
	if executor != nil {
		executor.signalActivity()
	}
	defer func() {
		e.mu.Lock()
		if e.skillPermissionCh == ch {
			e.skillPermissionCh = nil
		}
		e.mu.Unlock()
	}()
	select {
	case granted := <-ch:
		return granted
	case <-ctx.Done():
		return false
	}
}

func (e *CoreExecutionEngine) drainSkillPermissionEvents() []StreamEvent {
	e.mu.Lock()
	defer e.mu.Unlock()
	if len(e.skillPermissionQ) == 0 {
		return nil
	}
	events := append([]StreamEvent(nil), e.skillPermissionQ...)
	e.skillPermissionQ = nil
	return events
}

func (e *CoreExecutionEngine) BuildClient(maxTokens int, model string, thinkingBudgetTokens *int) (api.LLMClient, error) {
	if model == "" {
		model = e.Config.APIModel
	}
	return CreateConfiguredLLMClient(e.Config, model, maxTokens, thinkingBudgetTokens, api.DefaultRetryConfigPtr())
}

func (e *CoreExecutionEngine) PostToolUse(tc coretools.ToolCall, state *AgentState) {
}