Method Run

pkg/app/app.go:456–525

Run one agent loop

(ctx context.Context, cancel context.CancelFunc, message string, attachments []messages.Attachment)

// Run one agent loop
func (a *App) Run(ctx context.Context, cancel context.CancelFunc, message string, attachments []messages.Attachment) {
	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)
		go a.generateTitle(ctx, []string{message})
	}

	go func() {
		if len(attachments) > 0 {
			// Build a single text string with the user's message and inlined text files.
			// Keeping everything in one text block ensures the model sees file content
			// together with the message, rather than as separate content blocks.
			var textBuilder strings.Builder
			textBuilder.WriteString(message)

			// binaryParts holds non-text file parts (images, PDFs, etc.)
			var binaryParts []chat.MessagePart

			for _, att := range attachments {
				switch {
				case att.FilePath != "":
					// File-reference attachment: read and classify from disk.
					// Only remember the path on the session when the file actually
					// exists as a regular file — we don't want sub-agents to inherit
					// dangling references to directories or missing paths. The editor
					// resolves @-mentions to absolute paths before this point.
					if a.processFileAttachment(ctx, att, &textBuilder, &binaryParts) {
						a.session.AddAttachedFile(att.FilePath)
					}
				case att.Content != "":
					// Inline content attachment (e.g. pasted text).
					a.processInlineAttachment(att, &textBuilder)
				default:
					slog.DebugContext(ctx, "skipping attachment with no file path or content", "name", att.Name)
				}
			}

			multiContent := []chat.MessagePart{
				{Type: chat.MessagePartTypeText, Text: textBuilder.String()},
			}
			multiContent = append(multiContent, binaryParts...)

			a.session.AddMessage(session.UserMessage(message, multiContent...))
		} else {
			a.session.AddMessage(session.UserMessage(message))
		}
		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)
				}