Function userMessagePlainText

agent/query_engine.go:401–429

(content any)

	}()

	event := NewStreamEvent("permission_needed", "", map[string]any{
		"skill_shell_request": req,
		"dangerous":           true,
		"risk":                "high",
	})
	if !sendStream(ctx, out, event) {
		return false
	}
	select {
	case granted := <-ch:
		return granted
	case <-ctx.Done():
		return false
	}
}

func (q *QueryEngine) resolvePendingSkillPermission(granted bool) bool {
	q.skillPermissionMu.Lock()
	ch := q.skillPermissionCh
	q.skillPermissionMu.Unlock()
	if ch == nil {
		return false
	}
	select {
	case ch <- granted:
	default:
	}
	return true
}

func (q *QueryEngine) normalizeSkillUserPrompt(skillName, skillArgs string) string {
	if strings.TrimSpace(skillArgs) != "" {