Method RunSubmitMessage

ui/runtime.go:180–249

(ctx context.Context, userInput string, state *agent.AgentState, sessionID string)

}

func (r *UiRuntime) RunSubmitMessage(ctx context.Context, userInput string, state *agent.AgentState, sessionID string) []agent.StreamEvent {
	r.CurrentState = state
	if refresher, ok := r.Engine.(interface{ RefreshRuntimeConfig() }); ok {
		refresher.RefreshRuntimeConfig()
	}
	taskRuntime := r.taskRuntime()
	if taskRuntime != nil {
		taskRuntime.SetTaskEventSink(r.TaskSink)
		defer taskRuntime.SetTaskEventSink(nil)
	}
	r.appendTranscriptEntry("user", userInput)
	r.Frame.InputEnabled = false
	r.Frame.InputMode = "normal"
	r.Frame.InputPlaceholder = "Agent is responding..."
	r.refreshContextWindowFrame()
	if preparer, ok := r.UI.(RuntimePreparer); ok {
		preparer.PrepareRuntime()
	}
	if r.UI != nil && !r.Mounted {
		r.UI.Mount(r.Frame)
		r.Mounted = true
	}
	r.markDirty()
	r.Flush(true)
	submitter, ok := r.Engine.(interface {
		SubmitMessage(context.Context, string, *agent.AgentState, ...string) <-chan agent.StreamEvent
	})
	if !ok {
		if r.Dirty {
			r.Flush(true)
		}
		return nil
	}
	var events []agent.StreamEvent
	eventCh := submitter.SubmitMessage(ctx, userInput, state, sessionID)
	ticker := time.NewTicker(uiAnimationInterval)
	defer ticker.Stop()
	for eventCh != nil {
		select {
		case event, open := <-eventCh:
			if !open {
				eventCh = nil
				continue
			}
			uiEvent := r.ToUIEvent(event)
			if uiEvent.Type == "permission_requested" {
				r.HandlePermissionEvent(uiEvent)
			} else {
				r.ApplyUIEvent(uiEvent)
				r.MaybeRenderEvent(event)
				r.FlushIfDue()
			}
			r.DrainTaskEvents()
			events = append(events, event)
		case <-ticker.C:
			r.advanceAnimationFrame()
			r.DrainTaskEvents()
			r.Flush(true)