Method RunWithMessage

pkg/app/app.go:682–724

RunWithMessage runs the agent loop with a pre-constructed message. This is used for special cases like image attachments.

(ctx context.Context, cancel context.CancelFunc, msg *session.Message)

// RunWithMessage runs the agent loop with a pre-constructed message.
// This is used for special cases like image attachments.
func (a *App) RunWithMessage(ctx context.Context, cancel context.CancelFunc, msg *session.Message) {
	a.cancel = cancel

	// If this is the first message and no title exists, start local title generation
	if a.session.Title == "" && a.titleGen != nil {
		a.titleGenerating.Store(true)
		// Extract text content from the message for title generation
		userMessage := msg.Message.Content
		if userMessage == "" && len(msg.Message.MultiContent) > 0 {
			for _, part := range msg.Message.MultiContent {
				if part.Type == chat.MessagePartTypeText {
					userMessage = part.Text
					break
				}
			}
		}
		go a.generateTitle(ctx, []string{userMessage})
	}

	go func() {
		a.session.AddMessage(msg)
		for event := range a.runtime.RunStream(ctx, a.session) {
			// If context is cancelled, continue draining but don't forward events
			// — except StreamStoppedEvent, which must always propagate so the
			// supervisor can mark the session as no longer running.
			if ctx.Err() != nil {
				if _, ok := event.(*runtime.StreamStoppedEvent); ok {
					// ctx is cancelled; detach cancellation but keep its trace
					// context so the stop event still reaches subscribers.
					a.sendEvent(context.WithoutCancel(ctx), event)
				}
				continue
			}

			// Clear titleGenerating flag when title is generated (from server for remote runtime)
			if _, ok := event.(*runtime.SessionTitleEvent); ok {
				a.titleGenerating.Store(false)
			}

			a.sendEvent(ctx, event)
		}
	}()
}

func (a *App) RunBangCommand(ctx context.Context, command string) {
	command = strings.TrimSpace(command)