Function Run

pkg/cli/runner.go:82–326

Run executes an agent in non-TUI mode, handling user input and runtime events. userMessages contains the user messages to send. If a single message is "-", input is read from stdin. If empty, an interactive prompt loop is started.

(ctx context.Context, out *Printer, cfg Config, rt runtime.Runtime, sess *session.Session, userMessages []string)

// userMessages contains the user messages to send. If a single message is "-",
// input is read from stdin. If empty, an interactive prompt loop is started.
func Run(ctx context.Context, out *Printer, cfg Config, rt runtime.Runtime, sess *session.Session, userMessages []string) error {
	// Create a cancellable context for this agentic loop and wire Ctrl+C to cancel it
	ctx, cancel := context.WithCancel(ctx)
	defer cancel()

	// Ensure telemetry is initialized and add to context so runtime can access it
	telemetry.EnsureGlobalTelemetryInitialized(ctx)
	if telemetryClient := telemetry.GetGlobalTelemetryClient(ctx); telemetryClient != nil {
		ctx = telemetry.WithClient(ctx, telemetryClient)
	}

	sess.Title = "Running agent"
	// If the last received event was an error, return it. That way the exit code
	// will be non-zero if the agent failed.
	var lastErr error

	oneLoop := func(text string, rd io.Reader) error {
		autoExtensions := 0

		userInput := strings.TrimSpace(text)
		if userInput == "" {
			return nil
		}

		userMsg, attachedPath, err := PrepareUserMessage(ctx, rt, userInput, cfg.AttachmentPath)
		if err != nil {
			return fmt.Errorf("failed to prepare message: %w", err)
		}
		if userMsg == nil {
			// Agent-only command with no content - agent switched but no message to send
			return nil
		}
		sess.AddMessage(userMsg)
		sess.AddAttachedFile(attachedPath)

		if cfg.OutputJSON {
			for event := range rt.RunStream(ctx, sess) {
				switch e := event.(type) {
				case *runtime.ToolCallConfirmationEvent:
					// JSON mode has no user at stdin — reject unconditionally.
					// A confirmation event under AutoApprove means a
					// preempt-yolo hook overrode --yolo; the safe answer is
					// still Reject (the hook said Ask, not Approve).
					rt.Resume(ctx, runtime.ResumeReject(""))
				case *runtime.ElicitationRequestEvent:
					_ = rt.ResumeElicitation(ctx, "decline", nil)
				case *runtime.MaxIterationsReachedEvent:
					switch handleMaxIterationsAutoApprove(cfg.AutoApprove, &autoExtensions, e.MaxIterations) {
					case maxIterContinue:
						rt.Resume(ctx, runtime.ResumeApprove())
					default: // maxIterStop or maxIterPrompt (no interactive prompt in JSON mode)
						rt.Resume(ctx, runtime.ResumeReject(""))
						return nil
					}
				case *runtime.ErrorEvent:
					return fmt.Errorf("%s", e.Error)
				}