Compare commits

...

17 Commits

Author SHA1 Message Date
Ed Zynda 7a8a5b185f fix: auto-initialize extension context in kit.New()
Extensions were being loaded automatically by SetupAgent but the context
was never initialized unless the SDK user explicitly called
SetExtensionContext. This left extensions with a zero-value Context where
all function fields are nil.

Now kit.New() automatically calls SetExtensionContext with minimal defaults
(CWD, Model, Interactive=false) when extensions are loaded. SDK users can
still call SetExtensionContext to override with richer implementations
(TUI callbacks, prompts, etc.).

Combined with the normalizeContext() safety net in the runner, extensions
are now guaranteed to work in SDK mode without explicit context wiring.
2026-03-27 15:01:40 +03:00
Ed Zynda 1e2e33f039 refactor(ui): remove drainScrollback() calls and function
Remove the last remaining call to drainScrollback() at the end of
Update() and delete the no-op stub function that was maintained during
migration.

The drainScrollback() mechanism was part of the old inline-mode
rendering approach that used tea.Println to flush content to the
terminal's scrollback buffer. With the alt-screen refactor:

- scrollbackBuf field was removed in TAS-6
- appendScrollback() calls were removed in TAS-7
- drainScrollback() function is now completely removed

All history content is now rendered in-app via renderHistoryRegion()
in View().
2026-03-27 14:58:59 +03:00
Ed Zynda 52719baf1f refactor(ui): replace appendScrollback with appendHistoryEntry
Remove all appendScrollback() calls and the no-op stub function.
All content now flows exclusively through appendHistoryEntry() to
the historyEntries timeline, which is rendered in View() via
renderHistoryRegion().

Updated helpers:
- printUserMessage, printAssistantMessage, printToolResult
- printErrorResponse, printSystemMessage, printExtensionBlock
- printCompactResult, flushStreamContent
- flushStreamAndPendingUserMessages, restoreSessionHistory
- Raw extension output handler, shell command result handler

Part of alt-screen scrollback refactor (TAS-7).
2026-03-27 14:55:14 +03:00
Ed Zynda f0074e8c81 refactor(ui): remove drainScrollback contract for alt-screen mode
- Remove scrollbackBuf field from AppModel (replaced by historyEntries)
- Make drainScrollback() a no-op stub (callers removed in TAS-8)
- Make appendScrollback() a no-op stub (replaced in TAS-5)
- Update tests to not expect tea.Println commands

The history timeline is now rendered directly in View() via
renderHistoryRegion() instead of being flushed via tea.Println.

Part of alt-screen-scrollback-refactor (TAS-6).
2026-03-27 14:51:15 +03:00
Ed Zynda aa2fc80575 feat(ui): set AltScreen=true on all View() return paths
Update AppModel.View() to set AltScreen=true on tea.View for all
interactive view paths:
- Tree selector overlay
- Model selector overlay
- Session selector overlay
- Overlay dialog
- Main layout

This ensures the TUI uses alt-screen mode consistently as required
by the unified BubbleTea architecture spec (R1).
2026-03-27 14:47:36 +03:00
Ed Zynda c64898f9cf feat(ui): add Shift+Up/Down for line-by-line history scrolling
Add line-by-line scroll key handlers for the history viewport:

- Shift+Up: scroll history up by one line (disables follow-mode)
- Shift+Down: scroll history down by one line (re-enables follow-mode at bottom)

Both handlers are only active in stateInput or stateWorking states,
complementing the existing page-level controls (PgUp/PgDown, Ctrl+Home/End).
2026-03-27 14:45:25 +03:00
Ed Zynda ceeacc7455 feat(ui): handle window resize with anchor preservation for history viewport
Add history scroll offset adjustment to the WindowSizeMsg handler:

- Follow mode: No change needed - renderHistoryRegion() pins to bottom
- Non-follow mode: Clamp offset to new valid range to preserve top-visible line

Implementation uses uiVis(), calculateHistoryStreamHeight(), and
historyMaxOffset() to compute the valid offset range after resize.

Anchor semantics:
- Viewport shrinks: top-visible line preserved as anchor
- Viewport grows: same top line stays visible with more content below
- Content shorter than viewport: offset clamped to show all content
2026-03-27 14:43:05 +03:00
Ed Zynda 89ea9f6c63 feat(ui): add page up/down and Ctrl+Home/End for history scrolling
Add keyboard handlers for navigating the history viewport:
- PgUp/PageUp: scroll up by one page (minus 2 lines for context)
- PgDown/PageDown: scroll down by one page
- Ctrl+Home: jump to top of history
- Ctrl+End: jump to bottom and re-enable follow-mode

Handlers are active in stateInput and stateWorking only, not in modal
selectors. Follow-mode is disabled when scrolling up and re-enabled
when reaching the bottom.
2026-03-27 14:41:33 +03:00
Ed Zynda ae33c959c9 feat(ui): implement follow-mode semantics for history viewport
Add helper methods to manage follow-mode state during history scrolling:

- historyMaxOffset(): calculate max valid scroll offset
- scrollHistoryUp(): scroll up N lines, disables follow-mode
- scrollHistoryDown(): scroll down N lines, re-enables follow at bottom
- scrollHistoryToTop(): jump to top, disables follow-mode
- scrollHistoryToBottom(): jump to bottom, re-enables follow-mode
- isHistoryAtBottom(): check if viewport is at bottom

Follow-mode semantics:
- When historyFollow=true: viewport stays pinned to bottom
- Scrolling up: historyFollow becomes false
- Scrolling to bottom: historyFollow becomes true again

These methods will be called by key handlers in TAS-13/TAS-15.
2026-03-27 14:39:12 +03:00
Ed Zynda 71fa1d20f2 fix(ui): correct UIVisibility type in calculateHistoryStreamHeight
Fix build error from previous iteration where uiVisibility was used
instead of UIVisibility in the calculateHistoryStreamHeight() function
signature.

This completes TAS-11 (Phase 3: Implement scrollable history rendering
region) which includes:
- renderHistoryRegion() with viewport windowing and follow-mode
- rebuildHistoryCache() for efficient dirty-flag-based cache rebuild
- historyTotalLines() helper for scroll calculations
- calculateHistoryStreamHeight() for proper height allocation
- View() integration with history region rendering
2026-03-27 14:37:26 +03:00
Ed Zynda 7c98ab921b fix: normalize nil Context function fields to no-ops in SetContext
Extensions running via the SDK (without a fully-wired SetExtensionContext
call) would panic with 'reflect.Value.Call: call of nil function' when
calling any ctx method like ctx.PrintBlock().

normalizeContext() now replaces every nil function field in Context with
a safe no-op stub before storing it in the runner, so extension handlers
can never crash on a missing callback regardless of how Kit is embedded.
2026-03-27 13:59:59 +03:00
Ed Zynda 96d8513c9f feat(ui): add appendHistoryEntry and dual-write to history timeline
Add new appendHistoryEntry helper method that appends entries to the
historyEntries timeline for alt-screen mode. Update all print helpers
to dual-write to both scrollbackBuf (legacy tea.Println path) and
historyEntries (new alt-screen rendering path).

Updated methods:
- printUserMessage, printAssistantMessage, printToolResult
- printErrorResponse, printSystemMessage, printExtensionBlock
- printCompactResult, flushStreamContent
- flushStreamAndPendingUserMessages, renderSessionHistory
- handleShellCommandResult, raw ExtensionPrintEvent handling

Mark appendScrollback as deprecated with migration note. Both paths
are maintained for backward compatibility during the migration.

Part of alt-screen scrollback refactor (TAS-10).
2026-03-27 13:56:40 +03:00
Ed Zynda 84ee92f78f feat(ui): add history entry data model and state fields for alt-screen scrollback
Add foundation types and fields for migrating from tea.Println pipeline
to in-app scrollback timeline (Phase 1 of alt-screen refactor):

- Add historyEntry struct with Kind, Content, Timestamp fields
- Add historyEntries, historyOffset, historyFollow fields to AppModel
- Add historyRenderCache and historyDirty for performance optimization
- Mark scrollbackBuf as deprecated (to be removed in Phase 2)

Refs: TAS-2, TAS-4
2026-03-27 12:55:40 +03:00
Ed Zynda 8ae204f12f fix: preserve full content in scrollback by separating render cache from viewport
The StreamComponent was truncating content to fit the viewport height before
caching it in renderCache. This caused GetRenderedContent() to return truncated
content when flushing to scrollback.

Changes:
- render() now caches FULL content without height clamping
- New viewContent() helper applies height clamping only for display
- View() calls both: render() for full content, viewContent() for visible slice

This follows the Pi TUI pattern: full buffer in memory, viewport slicing only
at display time. Long assistant messages are now fully preserved in scrollback.
2026-03-27 12:13:04 +03:00
Ed Zynda 8b1665a4ce feat: add multi-edit support to edit tool
Implement multi-edit functionality matching Pi's approach:
- Add 'edits' array parameter for multiple disjoint replacements
- All edits matched against original content (non-incremental)
- Overlap detection prevents conflicting edits
- Duplicate detection ensures unique matches
- Atomic operations: all succeed or none applied
- Detailed error messages with edit indices (edits[0], etc.)
- Fuzzy matching works with multi-edit mode
- Backward compatible with single-edit mode (old_text/new_text)

Changes:
- internal/core/edit.go: Multi-edit logic, validation, overlap detection
- internal/ui/messages.go: Add 'edits' to body keys
- internal/ui/tool_renderers.go: Render multi-edit diffs
- internal/core/edit_test.go: 9 comprehensive multi-edit tests
2026-03-27 10:34:43 +03:00
Ed Zynda 941f1daf0b fix: correct token/cost double-counting in usage tracker
Remove the StepUsageEvent handler from subscribeSDKEvents. It was
calling UpdateUsage() for every individual tool-calling step as it
streamed, then updateUsageFromTurnResult() called UpdateUsage() again
with TotalUsage (fantasy's own aggregate of all steps). A turn with N
tool calls was counting every token N+1 times.

Fix updateUsageFromTurnResult to use a single, clean code path:
- UpdateUsage() called exactly once per turn using TotalUsage
- SetContextTokens() uses FinalUsage.InputTokens only (not +OutputTokens)
  since input tokens of the last call = actual context window fill;
  output tokens are the response length, not context occupancy
- Estimate fallback no longer early-returns before SetContextTokens

Verified with opencode/kimi-k2.5: cost accumulates linearly across
simple and multi-step tool-calling turns with no double-counting.
anthropic/claude-sonnet-4-6 correctly shows $0.00 for OAuth sessions.
2026-03-26 16:46:48 +03:00
Ed Zynda ab7e2bda61 docs: update documentation for recent features
- Remove subagent-monitor.go references (project-local extension)
- Add customModels configuration documentation
- Document Ctrl+S mid-turn steering feature
- Update /new command description to clarify it creates new session file
- Add auto-cleanup documentation for empty sessions
2026-03-26 16:03:12 +03:00
17 changed files with 1240 additions and 231 deletions
-1
View File
@@ -335,7 +335,6 @@ See the `examples/extensions/` directory:
- `protected-paths.go` - Path protection for sensitive files
- `subagent-widget.go` - Multi-agent orchestration with status widget
- `subagent-test.go` - Subagent testing utilities
- `subagent-monitor.go` - Real-time monitoring widget for spawned subagents
- `summarize.go` - Conversation summarization
- `tool-logger.go` - Log all tool calls
- `neon-theme.go` - Custom theme registration and switching
+27 -26
View File
@@ -754,15 +754,6 @@ func (a *App) subscribeSDKEvents(sendFn func(tea.Msg)) func() {
Chunk: ev.Chunk,
IsStderr: ev.IsStderr,
})
case kit.StepUsageEvent:
if a.opts.UsageTracker != nil {
a.opts.UsageTracker.UpdateUsage(
int(ev.InputTokens),
int(ev.OutputTokens),
int(ev.CacheReadTokens),
int(ev.CacheWriteTokens),
)
}
case kit.SteerConsumedEvent:
sendFn(SteerConsumedEvent{})
}
@@ -935,29 +926,39 @@ func (a *App) PrintBlockFromExtension(opts extensions.PrintBlockOpts) {
}
// updateUsageFromTurnResult records token usage from an SDK TurnResult into the
// configured UsageTracker. This is the SDK-path equivalent of updateUsage.
// configured UsageTracker. Called once per turn after the turn completes.
//
// Cost/token accumulation uses TotalUsage (sum across all tool-calling steps in
// the turn). Context-window fill uses FinalUsage.InputTokens only — that is the
// number of tokens sent to the model on the last API call, which equals the
// actual context window occupation (all accumulated messages + tool results).
// OutputTokens are not added here because they are the response length, not
// context fill.
func (a *App) updateUsageFromTurnResult(result *kit.TurnResult, userPrompt string) {
if a.opts.UsageTracker == nil || result == nil {
return
}
if result.TotalUsage != nil {
inputTokens := int(result.TotalUsage.InputTokens)
outputTokens := int(result.TotalUsage.OutputTokens)
// Use API-reported tokens if input tokens are available (output may be 0 in some cases)
if inputTokens > 0 {
cacheReadTokens := int(result.TotalUsage.CacheReadTokens)
cacheWriteTokens := int(result.TotalUsage.CacheCreationTokens)
a.opts.UsageTracker.UpdateUsage(inputTokens, outputTokens, cacheReadTokens, cacheWriteTokens)
} else {
a.opts.UsageTracker.EstimateAndUpdateUsage(userPrompt, result.Response)
return
}
// --- Accumulate cost/token totals for the session ---
if result.TotalUsage != nil && result.TotalUsage.InputTokens > 0 {
a.opts.UsageTracker.UpdateUsage(
int(result.TotalUsage.InputTokens),
int(result.TotalUsage.OutputTokens),
int(result.TotalUsage.CacheReadTokens),
int(result.TotalUsage.CacheCreationTokens),
)
} else {
// Provider didn't report token counts — fall back to character-based
// estimates so the footer shows something rather than nothing.
a.opts.UsageTracker.EstimateAndUpdateUsage(userPrompt, result.Response)
}
if result.FinalUsage != nil {
if ct := int(result.FinalUsage.InputTokens) + int(result.FinalUsage.OutputTokens); ct > 0 {
a.opts.UsageTracker.SetContextTokens(ct)
}
// --- Context window fill (drives the % bar) ---
// Use FinalUsage.InputTokens: the input token count of the last API call
// equals the number of tokens currently occupying the context window.
// Adding OutputTokens would overstate fill since the response is not part
// of the context that was *sent* to the model.
if result.FinalUsage != nil && result.FinalUsage.InputTokens > 0 {
a.opts.UsageTracker.SetContextTokens(int(result.FinalUsage.InputTokens))
}
}
+234 -44
View File
@@ -4,6 +4,7 @@ import (
"context"
"fmt"
"os"
"sort"
"strings"
"unicode"
"unicode/utf8"
@@ -13,19 +14,45 @@ import (
udiff "github.com/aymanbagabas/go-udiff"
)
type editArgs struct {
Path string `json:"path"`
// Edit represents a single replacement in a multi-edit operation.
type Edit struct {
OldText string `json:"old_text"`
NewText string `json:"new_text"`
}
// editArgs holds the arguments for the edit tool.
// Supports both single-edit mode (old_text/new_text) and multi-edit mode (edits array).
type editArgs struct {
Path string `json:"path"`
OldText string `json:"old_text"` // Single-edit mode
NewText string `json:"new_text"` // Single-edit mode
Edits []Edit `json:"edits"` // Multi-edit mode
}
// replacement represents a normalized edit ready for processing.
type replacement struct {
oldText string // normalized old text for matching
newText string // normalized new text
originalOld string // original old text for metadata
originalNew string // original new text for metadata
index int // index in the original edits array (for error messages)
}
// matchedReplacement represents a replacement with its match location.
type matchedReplacement struct {
replacement
start int // start index in normalized content
end int // end index in normalized content
usedFuzzyMatch bool // true if fuzzy matching was used
}
// NewEditTool creates the edit core tool.
func NewEditTool(opts ...ToolOption) fantasy.AgentTool {
cfg := ApplyOptions(opts)
return &coreTool{
info: fantasy.ToolInfo{
Name: "edit",
Description: "Edit a file by replacing exact text. The old_text must match exactly (including whitespace). Use this for precise, surgical edits. Fails if old_text is not found or matches multiple locations.",
Description: "Edit a file by replacing exact text. Supports single edit via old_text/new_text, or multiple edits via the edits array. All edits in the array are matched against the original file content (non-incremental) and must be non-overlapping.",
Parameters: map[string]any{
"path": map[string]any{
"type": "string",
@@ -33,14 +60,32 @@ func NewEditTool(opts ...ToolOption) fantasy.AgentTool {
},
"old_text": map[string]any{
"type": "string",
"description": "Exact text to find and replace (must match exactly)",
"description": "Exact text to find and replace (single-edit mode). Must not be used with 'edits' array.",
},
"new_text": map[string]any{
"type": "string",
"description": "New text to replace the old text with",
"description": "New text to replace the old text with (single-edit mode). Must not be used with 'edits' array.",
},
"edits": map[string]any{
"type": "array",
"description": "Array of edits for multi-region replacement. Each edit must have unique, non-overlapping old_text. All matches are against the original file content.",
"items": map[string]any{
"type": "object",
"properties": map[string]any{
"old_text": map[string]any{
"type": "string",
"description": "Exact text to find and replace for this edit",
},
"new_text": map[string]any{
"type": "string",
"description": "New text for this edit",
},
},
"required": []string{"old_text", "new_text"},
},
},
},
Required: []string{"path", "old_text", "new_text"},
Required: []string{"path"},
},
handler: func(ctx context.Context, call fantasy.ToolCall) (fantasy.ToolResponse, error) {
return executeEdit(ctx, call, cfg.WorkDir)
@@ -51,7 +96,7 @@ func NewEditTool(opts ...ToolOption) fantasy.AgentTool {
func executeEdit(ctx context.Context, call fantasy.ToolCall, workDir string) (fantasy.ToolResponse, error) {
var args editArgs
if err := parseArgs(call.Input, &args); err != nil {
return fantasy.NewTextErrorResponse("path, old_text, and new_text parameters are required"), nil
return fantasy.NewTextErrorResponse("failed to parse arguments: " + err.Error()), nil
}
if args.Path == "" {
return fantasy.NewTextErrorResponse("path parameter is required"), nil
@@ -69,56 +114,201 @@ func executeEdit(ctx context.Context, call fantasy.ToolCall, workDir string) (fa
content := string(contentBytes)
// Normalize line endings for matching
normalized := strings.ReplaceAll(content, "\r\n", "\n")
normalizedOld := strings.ReplaceAll(args.OldText, "\r\n", "\n")
// Try exact match first
count := strings.Count(normalized, normalizedOld)
// If no exact match, try fuzzy matching
if count == 0 {
if idx, matchLen := fuzzyMatch(normalized, normalizedOld); idx >= 0 {
// Apply fuzzy match — the matched text is the original content slice
matchedText := normalized[idx : idx+matchLen]
newContent := normalized[:idx] + args.NewText + normalized[idx+matchLen:]
if err := os.WriteFile(absPath, []byte(newContent), 0644); err != nil {
return fantasy.NewTextErrorResponse(fmt.Sprintf("failed to write file: %v", err)), nil
}
diff := generateDiff(absPath, normalized, newContent)
resp := fantasy.NewTextResponse(fmt.Sprintf("Applied edit (fuzzy match) to %s\n%s", args.Path, diff))
return fantasy.WithResponseMetadata(resp, editDiffMeta(absPath, matchedText, args.NewText)), nil
}
return fantasy.NewTextErrorResponse(fmt.Sprintf("old_text not found in %s", args.Path)), nil
// Normalize and validate input
replacements, err := normalizeEditInput(args)
if err != nil {
return fantasy.NewTextErrorResponse(err.Error()), nil
}
if count > 1 {
return fantasy.NewTextErrorResponse(fmt.Sprintf("found %d matches for old_text in %s. Provide more context to identify the correct match.", count, args.Path)), nil
// Apply all edits
newContent, applied, err := applyEdits(content, replacements)
if err != nil {
return fantasy.NewTextErrorResponse(err.Error()), nil
}
// Apply the edit
newContent := strings.Replace(normalized, normalizedOld, args.NewText, 1)
// Write the file
if err := os.WriteFile(absPath, []byte(newContent), 0644); err != nil {
return fantasy.NewTextErrorResponse(fmt.Sprintf("failed to write file: %v", err)), nil
}
diff := generateDiff(absPath, normalized, newContent)
resp := fantasy.NewTextResponse(fmt.Sprintf("Applied edit to %s\n%s", args.Path, diff))
return fantasy.WithResponseMetadata(resp, editDiffMeta(absPath, normalizedOld, args.NewText)), nil
// Generate diff
normalizedContent := strings.ReplaceAll(content, "\r\n", "\n")
diff := generateDiff(absPath, normalizedContent, newContent)
// Build response with fuzzy match indication
fuzzyCount := 0
for _, m := range applied {
if m.usedFuzzyMatch {
fuzzyCount++
}
}
var msg string
if len(applied) == 1 {
if fuzzyCount > 0 {
msg = fmt.Sprintf("Applied edit (fuzzy match) to %s\n%s", args.Path, diff)
} else {
msg = fmt.Sprintf("Applied edit to %s\n%s", args.Path, diff)
}
} else {
if fuzzyCount > 0 {
msg = fmt.Sprintf("Applied %d edits (%d fuzzy) to %s\n%s", len(applied), fuzzyCount, args.Path, diff)
} else {
msg = fmt.Sprintf("Applied %d edits to %s\n%s", len(applied), args.Path, diff)
}
}
resp := fantasy.NewTextResponse(msg)
return fantasy.WithResponseMetadata(resp, editDiffMeta(absPath, applied)), nil
}
// normalizeEditInput validates and normalizes the edit input.
// Returns error if both single-edit and multi-edit modes are used.
func normalizeEditInput(args editArgs) ([]replacement, error) {
singleMode := args.OldText != "" || args.NewText != ""
multiMode := len(args.Edits) > 0
if singleMode && multiMode {
return nil, fmt.Errorf("cannot use old_text/new_text together with edits array")
}
if !singleMode && !multiMode {
return nil, fmt.Errorf("must provide either old_text/new_text or edits array")
}
if singleMode {
if args.OldText == "" {
return nil, fmt.Errorf("old_text is required when using single-edit mode")
}
if args.NewText == "" {
return nil, fmt.Errorf("new_text is required when using single-edit mode")
}
return []replacement{{
oldText: strings.ReplaceAll(args.OldText, "\r\n", "\n"),
newText: strings.ReplaceAll(args.NewText, "\r\n", "\n"),
originalOld: args.OldText,
originalNew: args.NewText,
index: 0,
}}, nil
}
// Multi-edit mode
var reps []replacement
for i, edit := range args.Edits {
if edit.OldText == "" {
return nil, fmt.Errorf("edits[%d].old_text is required", i)
}
reps = append(reps, replacement{
oldText: strings.ReplaceAll(edit.OldText, "\r\n", "\n"),
newText: strings.ReplaceAll(edit.NewText, "\r\n", "\n"),
originalOld: edit.OldText,
originalNew: edit.NewText,
index: i,
})
}
return reps, nil
}
// applyEdits applies multiple replacements to the content.
// All matches are against the original content (non-incremental).
// Returns the new content, the applied matches, and any error.
func applyEdits(content string, edits []replacement) (string, []matchedReplacement, error) {
normalizedContent := strings.ReplaceAll(content, "\r\n", "\n")
// Find all matches
var matched []matchedReplacement
for _, edit := range edits {
m, err := findMatch(normalizedContent, edit)
if err != nil {
return "", nil, err
}
matched = append(matched, *m)
}
// Sort by position
sort.Slice(matched, func(i, j int) bool {
return matched[i].start < matched[j].start
})
// Check for overlaps
for i := 1; i < len(matched); i++ {
if matched[i-1].end > matched[i].start {
return "", nil, fmt.Errorf("edits[%d] and edits[%d] overlap; merge them into a single edit",
matched[i-1].index, matched[i].index)
}
}
// Apply edits in reverse order (end to start) to maintain stable offsets
result := normalizedContent
for i := len(matched) - 1; i >= 0; i-- {
m := matched[i]
result = result[:m.start] + m.newText + result[m.end:]
}
return result, matched, nil
}
// findMatch finds a unique match for the edit in the content.
// Returns error if not found or ambiguous.
func findMatch(content string, edit replacement) (*matchedReplacement, error) {
// Try exact match first
count := strings.Count(content, edit.oldText)
if count == 0 {
// Try fuzzy match
idx, matchLen := fuzzyMatch(content, edit.oldText)
if idx < 0 {
return nil, fmt.Errorf("edits[%d]: could not find old_text in file. The text must match exactly (including whitespace)", edit.index)
}
// Use the matched text from content for the replacement
matchedText := content[idx : idx+matchLen]
return &matchedReplacement{
replacement: replacement{
oldText: matchedText,
newText: edit.newText,
originalOld: edit.originalOld,
originalNew: edit.originalNew,
index: edit.index,
},
start: idx,
end: idx + matchLen,
usedFuzzyMatch: true,
}, nil
}
if count > 1 {
return nil, fmt.Errorf("found %d matches for edits[%d].old_text; each old_text must be unique, provide more context to identify the correct match", count, edit.index)
}
// Single exact match
idx := strings.Index(content, edit.oldText)
return &matchedReplacement{
replacement: edit,
start: idx,
end: idx + len(edit.oldText),
}, nil
}
// editDiffMeta builds the structured metadata attached to edit tool responses.
func editDiffMeta(path, oldText, newText string) map[string]any {
func editDiffMeta(path string, applied []matchedReplacement) map[string]any {
var diffBlocks []map[string]any
totalAdditions, totalDeletions := 0, 0
for _, m := range applied {
diffBlocks = append(diffBlocks, map[string]any{
"old_text": m.originalOld,
"new_text": m.originalNew,
})
totalAdditions += strings.Count(m.originalNew, "\n") + 1
totalDeletions += strings.Count(m.originalOld, "\n") + 1
}
return map[string]any{
"file_diffs": []map[string]any{{
"path": path,
"additions": strings.Count(newText, "\n") + 1,
"deletions": strings.Count(oldText, "\n") + 1,
"diff_blocks": []map[string]any{{
"old_text": oldText,
"new_text": newText,
}},
"path": path,
"additions": totalAdditions,
"deletions": totalDeletions,
"diff_blocks": diffBlocks,
}},
}
}
+312
View File
@@ -715,3 +715,315 @@ func TestExecuteEdit_MetadataContainsFileDiffs(t *testing.T) {
t.Fatal("file_diffs should be a non-empty array")
}
}
// ---------------------------------------------------------------------------
// Multi-edit tests
// ---------------------------------------------------------------------------
func TestExecuteEdit_MultiEdit_Basic(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "multi.txt")
writeFileOrFail(t, path, "line1\nline2\nline3\nline4\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "line1", NewText: "LINE1"},
{OldText: "line3", NewText: "LINE3"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if resp.IsError {
t.Fatalf("tool returned error: %s", resp.Content)
}
got, _ := os.ReadFile(path)
gotStr := string(got)
if !strings.Contains(gotStr, "LINE1") {
t.Error("first edit not applied: missing LINE1")
}
if !strings.Contains(gotStr, "LINE3") {
t.Error("second edit not applied: missing LINE3")
}
if !strings.Contains(gotStr, "line2") {
t.Error("line2 was modified but should be untouched")
}
if !strings.Contains(gotStr, "line4") {
t.Error("line4 was modified but should be untouched")
}
// Check response mentions multiple edits
if !strings.Contains(resp.Content, "2 edits") {
t.Errorf("response should mention '2 edits', got: %s", resp.Content)
}
}
func TestExecuteEdit_MultiEdit_NonIncrementalMatching(t *testing.T) {
// All edits are matched against the original content, not incrementally
dir := t.TempDir()
path := filepath.Join(dir, "noninc.txt")
writeFileOrFail(t, path, "aaa\nbbb\nccc\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "aaa", NewText: "AAA"},
{OldText: "bbb", NewText: "BBB"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if resp.IsError {
t.Fatalf("tool returned error: %s", resp.Content)
}
got, _ := os.ReadFile(path)
gotStr := string(got)
want := "AAA\nBBB\nccc\n"
if gotStr != want {
t.Errorf("got %q, want %q", gotStr, want)
}
}
func TestExecuteEdit_MultiEdit_OverlapDetection(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "overlap.txt")
writeFileOrFail(t, path, "hello world\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "hello", NewText: "HELLO"},
{OldText: "hello world", NewText: "GOODBYE"}, // Overlaps with first edit
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if !resp.IsError {
t.Error("expected error for overlapping edits")
}
if !strings.Contains(resp.Content, "overlap") {
t.Errorf("expected 'overlap' in error, got: %s", resp.Content)
}
// File should be untouched
got, _ := os.ReadFile(path)
if string(got) != "hello world\n" {
t.Error("file was modified despite error")
}
}
func TestExecuteEdit_MultiEdit_DuplicateDetection(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "dup.txt")
writeFileOrFail(t, path, "hello\nworld\nhello\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "hello", NewText: "HELLO"},
{OldText: "world", NewText: "WORLD"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if !resp.IsError {
t.Error("expected error for ambiguous old_text (duplicate matches)")
}
if !strings.Contains(resp.Content, "unique") {
t.Errorf("expected 'unique' in error, got: %s", resp.Content)
}
// File should be untouched
got, _ := os.ReadFile(path)
if string(got) != "hello\nworld\nhello\n" {
t.Error("file was modified despite error")
}
}
func TestExecuteEdit_MultiEdit_NotFound(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "notfound.txt")
writeFileOrFail(t, path, "hello world\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "nonexistent", NewText: "REPLACEMENT"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if !resp.IsError {
t.Error("expected error for not found")
}
if !strings.Contains(resp.Content, "edits[0]") {
t.Errorf("expected 'edits[0]' in error, got: %s", resp.Content)
}
// File should be untouched
got, _ := os.ReadFile(path)
if string(got) != "hello world\n" {
t.Error("file was modified despite error")
}
}
func TestExecuteEdit_MultiEdit_EmptyArray(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "empty.txt")
writeFileOrFail(t, path, "hello\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if !resp.IsError {
t.Error("expected error for empty edits array")
}
}
func TestExecuteEdit_MultiEdit_MixedWithSingleMode(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "mixed.txt")
writeFileOrFail(t, path, "hello\n")
input, _ := json.Marshal(map[string]any{
"path": path,
"old_text": "hello",
"new_text": "HELLO",
"edits": []Edit{
{OldText: "hello", NewText: "HI"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if !resp.IsError {
t.Error("expected error when mixing single and multi-edit modes")
}
if !strings.Contains(resp.Content, "cannot use") {
t.Errorf("expected 'cannot use' in error, got: %s", resp.Content)
}
}
func TestExecuteEdit_MultiEdit_FuzzyMatch(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "fuzzy_multi.txt")
// File has trailing whitespace
original := "func foo() { \n\treturn 1 \n}\nfunc bar() { \n\treturn 2 \n}\n"
writeFileOrFail(t, path, original)
// Search without trailing whitespace (common LLM behavior)
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "func foo() {\n\treturn 1\n}", NewText: "func foo() {\n\treturn 10\n}"},
{OldText: "func bar() {\n\treturn 2\n}", NewText: "func bar() {\n\treturn 20\n}"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("executeEdit error: %v", err)
}
if resp.IsError {
t.Fatalf("tool returned error: %s", resp.Content)
}
got, _ := os.ReadFile(path)
gotStr := string(got)
if !strings.Contains(gotStr, "return 10") {
t.Error("first edit not applied")
}
if !strings.Contains(gotStr, "return 20") {
t.Error("second edit not applied")
}
// Response should mention fuzzy match
if !strings.Contains(resp.Content, "fuzzy") {
t.Errorf("response should mention 'fuzzy', got: %s", resp.Content)
}
}
func TestExecuteEdit_MultiEdit_Metadata(t *testing.T) {
dir := t.TempDir()
path := filepath.Join(dir, "meta_multi.txt")
writeFileOrFail(t, path, "aaa\nbbb\nccc\n")
input, _ := json.Marshal(editArgs{
Path: path,
Edits: []Edit{
{OldText: "aaa", NewText: "AAA"},
{OldText: "bbb", NewText: "BBB"},
},
})
resp, err := executeEdit(t.Context(), fantasy.ToolCall{Input: string(input)}, dir)
if err != nil {
t.Fatalf("error: %v", err)
}
if resp.IsError {
t.Fatalf("tool returned error: %s", resp.Content)
}
var meta map[string]any
if err := json.Unmarshal([]byte(resp.Metadata), &meta); err != nil {
t.Fatalf("metadata is not valid JSON: %v", err)
}
diffs, ok := meta["file_diffs"].([]any)
if !ok || len(diffs) == 0 {
t.Fatal("metadata missing file_diffs")
}
firstDiff, ok := diffs[0].(map[string]any)
if !ok {
t.Fatal("first diff is not an object")
}
// Check that diff_blocks contains both edits
diffBlocks, ok := firstDiff["diff_blocks"].([]any)
if !ok || len(diffBlocks) != 2 {
t.Fatalf("expected 2 diff_blocks, got %d", len(diffBlocks))
}
// Verify each block has old_text and new_text
for i, block := range diffBlocks {
b, ok := block.(map[string]any)
if !ok {
t.Fatalf("diff_block[%d] is not an object", i)
}
if _, ok := b["old_text"]; !ok {
t.Fatalf("diff_block[%d] missing old_text", i)
}
if _, ok := b["new_text"]; !ok {
t.Fatalf("diff_block[%d] missing new_text", i)
}
}
}
+156 -2
View File
@@ -56,11 +56,165 @@ func NewRunner(exts []LoadedExtension) *Runner {
}
// SetContext updates the runtime context (session ID, model, etc.) that is
// passed to every handler invocation. Thread-safe.
// passed to every handler invocation. Nil function fields are replaced with
// safe no-ops so extension handlers never panic on a missing callback.
// Thread-safe.
func (r *Runner) SetContext(ctx Context) {
r.mu.Lock()
defer r.mu.Unlock()
r.ctx = ctx
r.ctx = normalizeContext(ctx)
}
// normalizeContext replaces nil function fields in ctx with no-op stubs so
// that extension handlers can call any ctx method without a nil-function panic.
func normalizeContext(ctx Context) Context {
if ctx.Print == nil {
ctx.Print = func(string) {}
}
if ctx.PrintInfo == nil {
ctx.PrintInfo = func(string) {}
}
if ctx.PrintError == nil {
ctx.PrintError = func(string) {}
}
if ctx.PrintBlock == nil {
ctx.PrintBlock = func(PrintBlockOpts) {}
}
if ctx.SendMessage == nil {
ctx.SendMessage = func(string) {}
}
if ctx.CancelAndSend == nil {
ctx.CancelAndSend = func(string) {}
}
if ctx.SetWidget == nil {
ctx.SetWidget = func(WidgetConfig) {}
}
if ctx.RemoveWidget == nil {
ctx.RemoveWidget = func(string) {}
}
if ctx.SetHeader == nil {
ctx.SetHeader = func(HeaderFooterConfig) {}
}
if ctx.RemoveHeader == nil {
ctx.RemoveHeader = func() {}
}
if ctx.SetFooter == nil {
ctx.SetFooter = func(HeaderFooterConfig) {}
}
if ctx.RemoveFooter == nil {
ctx.RemoveFooter = func() {}
}
if ctx.PromptSelect == nil {
ctx.PromptSelect = func(PromptSelectConfig) PromptSelectResult {
return PromptSelectResult{Cancelled: true}
}
}
if ctx.PromptConfirm == nil {
ctx.PromptConfirm = func(PromptConfirmConfig) PromptConfirmResult {
return PromptConfirmResult{Cancelled: true}
}
}
if ctx.PromptInput == nil {
ctx.PromptInput = func(PromptInputConfig) PromptInputResult {
return PromptInputResult{Cancelled: true}
}
}
if ctx.PromptMultiSelect == nil {
ctx.PromptMultiSelect = func(PromptMultiSelectConfig) PromptMultiSelectResult {
return PromptMultiSelectResult{Cancelled: true}
}
}
if ctx.ShowOverlay == nil {
ctx.ShowOverlay = func(OverlayConfig) OverlayResult {
return OverlayResult{Cancelled: true, Index: -1}
}
}
if ctx.SetEditor == nil {
ctx.SetEditor = func(EditorConfig) {}
}
if ctx.ResetEditor == nil {
ctx.ResetEditor = func() {}
}
if ctx.SetEditorText == nil {
ctx.SetEditorText = func(string) {}
}
if ctx.SetUIVisibility == nil {
ctx.SetUIVisibility = func(UIVisibility) {}
}
if ctx.SetStatus == nil {
ctx.SetStatus = func(string, string, int) {}
}
if ctx.RemoveStatus == nil {
ctx.RemoveStatus = func(string) {}
}
if ctx.GetContextStats == nil {
ctx.GetContextStats = func() ContextStats { return ContextStats{} }
}
if ctx.GetMessages == nil {
ctx.GetMessages = func() []SessionMessage { return nil }
}
if ctx.GetSessionPath == nil {
ctx.GetSessionPath = func() string { return "" }
}
if ctx.AppendEntry == nil {
ctx.AppendEntry = func(string, string) (string, error) { return "", nil }
}
if ctx.GetEntries == nil {
ctx.GetEntries = func(string) []ExtensionEntry { return nil }
}
if ctx.GetOption == nil {
ctx.GetOption = func(string) string { return "" }
}
if ctx.SetOption == nil {
ctx.SetOption = func(string, string) {}
}
if ctx.SetModel == nil {
ctx.SetModel = func(string) error { return nil }
}
if ctx.GetAvailableModels == nil {
ctx.GetAvailableModels = func() []ModelInfoEntry { return nil }
}
if ctx.EmitCustomEvent == nil {
ctx.EmitCustomEvent = func(string, string) {}
}
if ctx.GetAllTools == nil {
ctx.GetAllTools = func() []ToolInfo { return nil }
}
if ctx.SetActiveTools == nil {
ctx.SetActiveTools = func([]string) {}
}
if ctx.Exit == nil {
ctx.Exit = func() {}
}
if ctx.Complete == nil {
ctx.Complete = func(CompleteRequest) (CompleteResponse, error) {
return CompleteResponse{}, nil
}
}
if ctx.SuspendTUI == nil {
ctx.SuspendTUI = func(callback func()) error { callback(); return nil }
}
if ctx.RenderMessage == nil {
ctx.RenderMessage = func(string, string) {}
}
if ctx.RegisterTheme == nil {
ctx.RegisterTheme = func(string, ThemeColorConfig) {}
}
if ctx.SetTheme == nil {
ctx.SetTheme = func(string) error { return nil }
}
if ctx.ListThemes == nil {
ctx.ListThemes = func() []string { return nil }
}
if ctx.ReloadExtensions == nil {
ctx.ReloadExtensions = func() error { return nil }
}
if ctx.SpawnSubagent == nil {
ctx.SpawnSubagent = func(SubagentConfig) (*SubagentHandle, *SubagentResult, error) {
return nil, nil, nil
}
}
return ctx
}
// GetContext returns a snapshot of the current runtime context. Thread-safe.
+1
View File
@@ -119,6 +119,7 @@ func formatToolParams(toolArgs string, maxWidth int) string {
"new_text": true,
"oldText": true,
"newText": true,
"edits": true,
"todos": true,
}
var remaining []string
+363 -100
View File
@@ -212,6 +212,14 @@ type StatusBarEntryData struct {
Priority int // lower = further left; built-in entries use 100-110
}
// historyEntry represents a single entry in the conversation history timeline.
// This replaces the scrollback buffer for alt-screen mode.
type historyEntry struct {
Kind string // user|assistant|tool|system|error|extension|startup
Content string // pre-rendered block string
Timestamp time.Time // when the entry was created
}
// UIVisibility controls which built-in TUI chrome elements are visible.
// The zero value shows everything (backward compatible).
type UIVisibility struct {
@@ -436,13 +444,28 @@ type AppModel struct {
// flushed first, preserving chronological order.
pendingUserPrints []string
// scrollbackBuf collects rendered content during a single Update() call.
// All print helpers append here instead of returning tea.Println directly.
// The buffer is drained into a single atomic tea.Println at the end of
// each Update call via drainScrollback(). If the stream component has
// unflushed content, it is automatically prepended so that new messages
// always appear below the previous assistant response.
scrollbackBuf []string
// History timeline fields (alt-screen mode)
// historyEntries is the timeline of completed conversation blocks.
// Each entry represents a user message, assistant response, tool result,
// system message, error, or extension output.
historyEntries []historyEntry
// historyOffset is the line offset for the history viewport scroll position.
// 0 means showing from the top, higher values scroll down.
historyOffset int
// historyFollow is true when the viewport is pinned to the bottom.
// When true, new entries automatically scroll into view.
// When the user scrolls up, this becomes false.
historyFollow bool
// historyRenderCache holds the last rendered history content.
// Used to avoid redundant re-rendering when history hasn't changed.
historyRenderCache string
// historyDirty is true when history has changed and cache needs rebuilding.
historyDirty bool
// canceling tracks whether the user has pressed ESC once during stateWorking.
// A second ESC within 2 seconds will cancel the current step.
@@ -669,6 +692,7 @@ func NewAppModel(appCtrl AppController, opts AppModelOptions) *AppModel {
cwd: opts.Cwd,
width: width,
height: height,
historyFollow: true, // start in follow mode (pinned to bottom)
}
// Store extension commands for dispatch.
@@ -943,7 +967,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
}
}
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case ModelSelectorCancelledMsg:
@@ -965,7 +988,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
} else {
m.printSystemMessage("Session switching not available.")
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case SessionSelectorCancelledMsg:
@@ -976,7 +998,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
case SessionDeletedMsg:
// Session was deleted from picker — just show a message.
m.printSystemMessage(fmt.Sprintf("Deleted session: %s", msg.Name))
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
// ── Window resize ────────────────────────────────────────────────────────
@@ -993,6 +1014,15 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
_, cmd := m.stream.Update(msg)
cmds = append(cmds, cmd)
}
// Adjust history scroll offset for new viewport size.
// - Follow mode: renderHistoryRegion will pin to bottom automatically.
// - Non-follow mode: preserve top-visible line by clamping offset to valid range.
if !m.historyFollow {
vis := m.uiVis()
availableHeight := m.calculateHistoryStreamHeight(vis, "")
maxOffset := m.historyMaxOffset(availableHeight)
m.historyOffset = clamp(m.historyOffset, 0, maxOffset)
}
// ── Keyboard input ───────────────────────────────────────────────────────
case tea.KeyPressMsg:
@@ -1126,6 +1156,66 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
}
return m, tea.Batch(cmds...)
}
case "pgup", "pageup":
// Page up: scroll history viewport up by approximately one page.
// Available in input and working states (not selectors).
if m.state == stateInput || m.state == stateWorking {
vis := m.uiVis()
historyHeight := m.calculateHistoryStreamHeight(vis, "")
// Scroll by page height minus a few lines for context overlap.
scrollLines := max(historyHeight-2, 1)
m.scrollHistoryUp(scrollLines, historyHeight)
return m, tea.Batch(cmds...)
}
case "pgdown", "pagedown":
// Page down: scroll history viewport down by approximately one page.
// Available in input and working states (not selectors).
if m.state == stateInput || m.state == stateWorking {
vis := m.uiVis()
historyHeight := m.calculateHistoryStreamHeight(vis, "")
// Scroll by page height minus a few lines for context overlap.
scrollLines := max(historyHeight-2, 1)
m.scrollHistoryDown(scrollLines, historyHeight)
return m, tea.Batch(cmds...)
}
case "ctrl+home":
// Ctrl+Home: jump to top of history.
if m.state == stateInput || m.state == stateWorking {
m.scrollHistoryToTop()
return m, tea.Batch(cmds...)
}
case "ctrl+end":
// Ctrl+End: jump to bottom of history and re-enable follow mode.
if m.state == stateInput || m.state == stateWorking {
vis := m.uiVis()
historyHeight := m.calculateHistoryStreamHeight(vis, "")
m.scrollHistoryToBottom(historyHeight)
return m, tea.Batch(cmds...)
}
case "shift+up":
// Shift+Up: scroll history viewport up by one line.
// Available in input and working states (not selectors).
if m.state == stateInput || m.state == stateWorking {
vis := m.uiVis()
historyHeight := m.calculateHistoryStreamHeight(vis, "")
m.scrollHistoryUp(1, historyHeight)
return m, tea.Batch(cmds...)
}
case "shift+down":
// Shift+Down: scroll history viewport down by one line.
// Available in input and working states (not selectors).
if m.state == stateInput || m.state == stateWorking {
vis := m.uiVis()
historyHeight := m.calculateHistoryStreamHeight(vis, "")
m.scrollHistoryDown(1, historyHeight)
return m, tea.Batch(cmds...)
}
}
// Route key events to the focused child. Check for editor
@@ -1189,7 +1279,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
if cmd := m.handleSlashCommand(sc); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
}
@@ -1203,43 +1292,36 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
if cmd := m.handleCompactCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/model":
if cmd := m.handleModelCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/thinking":
if cmd := m.handleThinkingCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/theme":
if cmd := m.handleThemeCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/name":
if cmd := m.handleNameCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/export":
if cmd := m.handleExportCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
case "/import":
if cmd := m.handleImportCommand(strings.TrimSpace(args)); cmd != nil {
cmds = append(cmds, cmd)
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
}
}
@@ -1482,7 +1564,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
}
m.steeringMessages = m.steeringMessages[:0]
m.distributeHeight()
cmds = append(cmds, m.drainScrollback())
} else {
// Case 2: post-turn — defer so SpinnerEvent orders correctly.
m.pendingUserPrints = append(m.pendingUserPrints, m.steeringMessages...)
@@ -1677,7 +1758,6 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
} else {
m.printSystemMessage(fmt.Sprintf("Session shared!\n\n Viewer: %s\n Gist: %s", msg.viewerURL, msg.gistURL))
}
return m, m.drainScrollback()
case app.ExtensionPrintEvent:
// Extension output — route through styled renderers when a level is set.
@@ -1691,7 +1771,8 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
case "block":
m.printExtensionBlock(msg)
default:
m.appendScrollback(msg.Text)
// Raw extension output (no level specified).
m.appendHistoryEntry("extension", msg.Text)
}
default:
@@ -1706,33 +1787,40 @@ func (m *AppModel) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
}
}
cmds = append(cmds, m.drainScrollback())
return m, tea.Batch(cmds...)
}
// View implements tea.Model. It renders the stacked layout:
// stream region + separator + [queued messages] + input region + status bar.
// history region + stream region + separator + [queued messages] + input region + status bar.
// The status bar is always present (1 line) to avoid layout shifts.
// When the tree selector is active, it replaces the stream region.
func (m *AppModel) View() tea.View {
// Tree selector overlay replaces the normal layout.
if m.state == stateTreeSelector && m.treeSelector != nil {
return m.treeSelector.View()
v := m.treeSelector.View()
v.AltScreen = true
return v
}
// Model selector overlay replaces the normal layout.
if m.state == stateModelSelector && m.modelSelector != nil {
return m.modelSelector.View()
v := m.modelSelector.View()
v.AltScreen = true
return v
}
// Session selector overlay replaces the normal layout.
if m.state == stateSessionSelector && m.sessionSelector != nil {
return m.sessionSelector.View()
v := m.sessionSelector.View()
v.AltScreen = true
return v
}
// Overlay dialog replaces the normal layout.
if m.state == stateOverlay && m.overlay != nil {
return tea.NewView(m.overlay.Render())
v := tea.NewView(m.overlay.Render())
v.AltScreen = true
return v
}
vis := m.uiVis()
@@ -1762,6 +1850,24 @@ func (m *AppModel) View() tea.View {
parts = append(parts, headerView)
}
// Calculate available height for the combined history+stream region.
// This matches the calculation in distributeHeight().
historyStreamHeight := m.calculateHistoryStreamHeight(vis, inputView)
// Render history region (scrollable finalized content).
// Stream gets remaining height after history.
streamHeight := 0
if streamView != "" {
streamHeight = lipgloss.Height(streamView)
}
historyHeight := max(historyStreamHeight-streamHeight, 0)
historyView := m.renderHistoryRegion(historyHeight)
// Include history region if it has content.
if historyView != "" {
parts = append(parts, historyView)
}
// Only include the stream region when it has content. When idle the
// stream renders "" which JoinVertical would pad to a full-width blank
// line, inflating the view unnecessarily.
@@ -1800,7 +1906,50 @@ func (m *AppModel) View() tea.View {
content := lipgloss.JoinVertical(lipgloss.Left, parts...)
return tea.NewView(content)
v := tea.NewView(content)
v.AltScreen = true
return v
}
// calculateHistoryStreamHeight calculates the available height for the combined
// history+stream region. This mirrors the calculation in distributeHeight().
func (m *AppModel) calculateHistoryStreamHeight(vis UIVisibility, inputView string) int {
separatorLines := 1
if vis.HideSeparator {
separatorLines = 0
}
statusBarLines := 1
if vis.HideStatusBar {
statusBarLines = 0
}
var queuedLines int
if queuedView := m.renderQueuedMessages(); queuedView != "" {
queuedLines = lipgloss.Height(queuedView)
}
inputLines := 9 // fallback
if inputView != "" {
inputLines = lipgloss.Height(inputView)
}
var widgetLines int
if above := m.renderWidgetSlot("above"); above != "" {
widgetLines += lipgloss.Height(above)
}
if below := m.renderWidgetSlot("below"); below != "" {
widgetLines += lipgloss.Height(below)
}
var headerFooterLines int
if headerView := m.renderHeaderFooter(m.getHeader); headerView != "" {
headerFooterLines += lipgloss.Height(headerView)
}
if footerView := m.renderHeaderFooter(m.getFooter); footerView != "" {
headerFooterLines += lipgloss.Height(footerView)
}
return max(m.height-separatorLines-widgetLines-headerFooterLines-queuedLines-inputLines-statusBarLines, 0)
}
// --------------------------------------------------------------------------
@@ -1842,6 +1991,139 @@ func (m *AppModel) renderStream() string {
return lipgloss.JoinVertical(lipgloss.Left, parts...)
}
// renderHistoryRegion renders the scrollable history viewport containing finalized
// conversation blocks. The history region shows completed user messages, assistant
// responses, tool results, system messages, errors, and extension output.
//
// The viewport is controlled by historyOffset (line offset from top) and historyFollow
// (whether to pin to bottom). When historyDirty is true, the render cache is rebuilt.
//
// Returns empty string if there are no history entries.
func (m *AppModel) renderHistoryRegion(availableHeight int) string {
if len(m.historyEntries) == 0 {
return ""
}
// Rebuild cache if dirty.
if m.historyDirty {
m.rebuildHistoryCache()
}
if m.historyRenderCache == "" {
return ""
}
// Split cache into lines for viewport windowing.
lines := strings.Split(m.historyRenderCache, "\n")
totalLines := len(lines)
// Handle follow mode: pin to bottom when new content arrives.
if m.historyFollow {
// Calculate offset to show the last availableHeight lines.
m.historyOffset = max(totalLines-availableHeight, 0)
}
// Clamp offset to valid range.
maxOffset := max(totalLines-availableHeight, 0)
m.historyOffset = clamp(m.historyOffset, 0, maxOffset)
// Extract visible window.
startLine := m.historyOffset
endLine := min(startLine+availableHeight, totalLines)
if startLine >= totalLines {
return ""
}
visibleLines := lines[startLine:endLine]
return strings.Join(visibleLines, "\n")
}
// rebuildHistoryCache rebuilds the rendered history content from historyEntries.
// This is called when historyDirty is true, typically after new entries are added.
func (m *AppModel) rebuildHistoryCache() {
if len(m.historyEntries) == 0 {
m.historyRenderCache = ""
m.historyDirty = false
return
}
var parts []string
for _, entry := range m.historyEntries {
if entry.Content != "" {
parts = append(parts, entry.Content)
}
}
m.historyRenderCache = strings.Join(parts, "\n")
m.historyDirty = false
}
// historyTotalLines returns the total number of lines in the history cache.
// Used for scroll calculations and follow-mode adjustments.
func (m *AppModel) historyTotalLines() int {
if m.historyRenderCache == "" {
return 0
}
return strings.Count(m.historyRenderCache, "\n") + 1
}
// historyMaxOffset returns the maximum valid scroll offset for the history viewport.
// This depends on the available height for the history region.
func (m *AppModel) historyMaxOffset(availableHeight int) int {
totalLines := m.historyTotalLines()
return max(totalLines-availableHeight, 0)
}
// scrollHistoryUp scrolls the history viewport up by the given number of lines.
// Disables follow-mode since the user is actively scrolling away from the bottom.
func (m *AppModel) scrollHistoryUp(lines int, availableHeight int) {
if lines <= 0 {
return
}
// Disable follow mode when user scrolls up.
m.historyFollow = false
// Decrease offset (scroll toward top).
m.historyOffset = max(m.historyOffset-lines, 0)
}
// scrollHistoryDown scrolls the history viewport down by the given number of lines.
// Re-enables follow-mode if the scroll position reaches the bottom.
func (m *AppModel) scrollHistoryDown(lines int, availableHeight int) {
if lines <= 0 {
return
}
maxOffset := m.historyMaxOffset(availableHeight)
// Increase offset (scroll toward bottom).
m.historyOffset = min(m.historyOffset+lines, maxOffset)
// Re-enable follow mode if we've scrolled to the bottom.
if m.historyOffset >= maxOffset {
m.historyFollow = true
}
}
// scrollHistoryToTop scrolls the history viewport to the very top.
// Disables follow-mode.
func (m *AppModel) scrollHistoryToTop() {
m.historyFollow = false
m.historyOffset = 0
}
// scrollHistoryToBottom scrolls the history viewport to the very bottom.
// Re-enables follow-mode so new content will be visible.
func (m *AppModel) scrollHistoryToBottom(availableHeight int) {
maxOffset := m.historyMaxOffset(availableHeight)
m.historyOffset = maxOffset
m.historyFollow = true
}
// isHistoryAtBottom returns true if the history viewport is at the bottom.
// Used to determine if follow-mode should be active.
func (m *AppModel) isHistoryAtBottom(availableHeight int) bool {
maxOffset := m.historyMaxOffset(availableHeight)
return m.historyOffset >= maxOffset
}
// renderStreamingBashOutput renders accumulated streaming bash output (stdout + stderr)
// below the LLM streaming text. Returns empty string if no bash output is present.
// Lines are truncated to the terminal width and capped to maxBashLines to prevent
@@ -2213,30 +2495,37 @@ func (m *AppModel) renderQueuedMessages() string {
}
// --------------------------------------------------------------------------
// Print helpers — emit content to scrollback via tea.Println
// Print helpers — emit content to history timeline
// --------------------------------------------------------------------------
//
// These helpers render content and append it to historyEntries for alt-screen
// in-app rendering. The history timeline is rendered in View().
// printUserMessage renders a user message into the scrollback buffer.
// printUserMessage renders a user message into the history timeline.
func (m *AppModel) printUserMessage(text string) {
m.appendScrollback(m.renderer.RenderUserMessage(text, time.Now()).Content)
content := m.renderer.RenderUserMessage(text, time.Now()).Content
m.appendHistoryEntry("user", content)
}
// printAssistantMessage renders an assistant message into the scrollback buffer.
// printAssistantMessage renders an assistant message into the history timeline.
func (m *AppModel) printAssistantMessage(text string) {
if strings.TrimSpace(text) != "" {
m.appendScrollback(m.renderer.RenderAssistantMessage(text, time.Now(), m.modelName).Content)
content := m.renderer.RenderAssistantMessage(text, time.Now(), m.modelName).Content
m.appendHistoryEntry("assistant", content)
}
}
// printToolResult renders a tool result message into the scrollback buffer.
// printToolResult renders a tool result message into the history timeline.
func (m *AppModel) printToolResult(evt app.ToolResultEvent) {
m.appendScrollback(m.renderer.RenderToolMessage(evt.ToolName, evt.ToolArgs, evt.Result, evt.IsError).Content)
content := m.renderer.RenderToolMessage(evt.ToolName, evt.ToolArgs, evt.Result, evt.IsError).Content
m.appendHistoryEntry("tool", content)
}
// printErrorResponse renders an error message into the scrollback buffer.
// printErrorResponse renders an error message into the history timeline.
func (m *AppModel) printErrorResponse(evt app.StepErrorEvent) {
if evt.Err != nil {
m.appendScrollback(m.renderer.RenderErrorMessage(evt.Err.Error(), time.Now()).Content)
content := m.renderer.RenderErrorMessage(evt.Err.Error(), time.Now()).Content
m.appendHistoryEntry("error", content)
}
}
@@ -2307,13 +2596,14 @@ func (m *AppModel) handleSlashCommand(sc *SlashCommand) tea.Cmd {
return nil
}
// printSystemMessage renders a system-level message into the scrollback buffer.
// printSystemMessage renders a system-level message into the history timeline.
func (m *AppModel) printSystemMessage(text string) {
m.appendScrollback(m.renderer.RenderSystemMessage(text, time.Now()).Content)
content := m.renderer.RenderSystemMessage(text, time.Now()).Content
m.appendHistoryEntry("system", content)
}
// printExtensionBlock renders a custom styled block from an extension with
// caller-chosen border color and optional subtitle into the scrollback buffer.
// caller-chosen border color and optional subtitle into the history timeline.
func (m *AppModel) printExtensionBlock(evt app.ExtensionPrintEvent) {
theme := GetTheme()
@@ -2337,7 +2627,7 @@ func (m *AppModel) printExtensionBlock(evt app.ExtensionPrintEvent) {
WithBorderColor(borderClr),
WithMarginBottom(1),
)
m.appendScrollback(rendered)
m.appendHistoryEntry("extension", rendered)
}
// handleExtensionCommand checks if the submitted text matches an extension-
@@ -2558,7 +2848,7 @@ func (m *AppModel) handleCompactCommand(customInstructions string) tea.Cmd {
}
// printCompactResult renders the compaction summary in a styled block with
// a distinct border color and a stats subtitle into the scrollback buffer.
// a distinct border color and a stats subtitle into the history timeline.
func (m *AppModel) printCompactResult(evt app.CompactCompleteEvent) {
theme := GetTheme()
@@ -2581,13 +2871,12 @@ func (m *AppModel) printCompactResult(evt app.CompactCompleteEvent) {
WithBorderColor(theme.Secondary),
WithMarginBottom(1),
)
m.appendScrollback(rendered)
m.appendHistoryEntry("system", rendered)
}
// flushStreamContent moves rendered content from the stream component into the
// scrollback buffer and resets the stream. Called before tool calls (streaming
// completes before tools fire). The actual tea.Println is deferred to
// drainScrollback() at the end of the Update cycle.
// history timeline, then resets the stream. Called before tool calls
// (streaming completes before tools fire).
func (m *AppModel) flushStreamContent() {
if m.stream == nil {
return
@@ -2597,73 +2886,44 @@ func (m *AppModel) flushStreamContent() {
return
}
m.stream.Reset()
m.appendScrollback(content)
m.appendHistoryEntry("assistant", content)
}
// flushStreamAndPendingUserMessages moves the previous assistant response and
// any pending queued user messages into the scrollback buffer. Called from
// any pending queued user messages into the history timeline. Called from
// SpinnerEvent{Show: true} where all previous stream chunks are guaranteed to
// have been processed. The actual tea.Println is deferred to drainScrollback().
// have been processed.
func (m *AppModel) flushStreamAndPendingUserMessages() {
// 1. Flush previous stream content (assistant response).
if m.stream != nil {
if content := m.stream.GetRenderedContent(); content != "" {
m.stream.Reset()
m.appendScrollback(content)
m.appendHistoryEntry("assistant", content)
}
}
// 2. Render pending user messages from the queue.
for _, text := range m.pendingUserPrints {
rendered := m.renderer.RenderUserMessage(text, time.Now()).Content
m.appendScrollback(rendered)
m.appendHistoryEntry("user", rendered)
}
m.pendingUserPrints = nil
}
// appendScrollback adds rendered content to the scrollback buffer. The content
// will be emitted via tea.Println when drainScrollback is called at the end of
// the current Update cycle.
func (m *AppModel) appendScrollback(content string) {
if content != "" {
m.scrollbackBuf = append(m.scrollbackBuf, content)
// appendHistoryEntry adds a new entry to the history timeline.
// The entry will be rendered in the history viewport during View().
func (m *AppModel) appendHistoryEntry(kind, content string) {
if content == "" {
return
}
}
// drainScrollback flushes the scrollback buffer into a single tea.Println. If
// the stream component has unflushed content, it is automatically prepended so
// that new messages always appear below the previous assistant response. When
// stream content is flushed a ClearScreen follows to clean up orphaned terminal
// rows left after the view height shrinks. Returns nil if there is nothing to
// print.
func (m *AppModel) drainScrollback() tea.Cmd {
if len(m.scrollbackBuf) == 0 {
return nil
}
var parts []string
needsClear := false
// Auto-flush any stream content so it appears before new messages.
if m.stream != nil {
if content := m.stream.GetRenderedContent(); content != "" {
m.stream.Reset()
parts = append(parts, content)
needsClear = true
}
}
parts = append(parts, m.scrollbackBuf...)
m.scrollbackBuf = m.scrollbackBuf[:0]
printCmd := tea.Println(strings.Join(parts, "\n"))
if needsClear {
return tea.Sequence(
printCmd,
func() tea.Msg { return tea.ClearScreen() },
)
}
return printCmd
m.historyEntries = append(m.historyEntries, historyEntry{
Kind: kind,
Content: content,
Timestamp: time.Now(),
})
m.historyDirty = true
// In follow mode, new entries should keep the viewport pinned to bottom.
// The actual scroll adjustment happens in View() or a dedicated helper.
}
// distributeHeight recalculates child component heights after a window resize,
@@ -3286,9 +3546,9 @@ func (m *AppModel) handleResumeCommand() tea.Cmd {
}
// renderSessionHistory walks the current session branch and renders all
// messages (user, assistant, tool calls/results) into the scrollback buffer.
// This gives the user visual context of the conversation when resuming or
// importing a session. Call this after switchSession succeeds.
// messages (user, assistant, tool calls/results) into the scrollback buffer
// and history timeline. This gives the user visual context of the conversation
// when resuming or importing a session. Call this after switchSession succeeds.
func (m *AppModel) renderSessionHistory() {
ts := m.appCtrl.GetTreeSession()
if ts == nil {
@@ -3339,7 +3599,8 @@ func (m *AppModel) renderSessionHistory() {
case message.RoleUser:
text := msg.Content()
if text != "" {
m.appendScrollback(m.renderer.RenderUserMessage(text, msg.CreatedAt).Content)
content := m.renderer.RenderUserMessage(text, msg.CreatedAt).Content
m.appendHistoryEntry("user", content)
}
case message.RoleAssistant:
@@ -3349,7 +3610,8 @@ func (m *AppModel) renderSessionHistory() {
if msg.Model != "" {
modelName = msg.Model
}
m.appendScrollback(m.renderer.RenderAssistantMessage(text, msg.CreatedAt, modelName).Content)
content := m.renderer.RenderAssistantMessage(text, msg.CreatedAt, modelName).Content
m.appendHistoryEntry("assistant", content)
}
// Tool calls from assistant messages are rendered when we
// encounter their corresponding tool results below.
@@ -3364,7 +3626,8 @@ func (m *AppModel) renderSessionHistory() {
}
toolArgs = info.Args
}
m.appendScrollback(m.renderer.RenderToolMessage(toolName, toolArgs, tr.Content, tr.IsError).Content)
content := m.renderer.RenderToolMessage(toolName, toolArgs, tr.Content, tr.IsError).Content
m.appendHistoryEntry("tool", content)
}
}
}
@@ -3737,7 +4000,7 @@ func (m *AppModel) handleShellCommandResult(msg shellCommandResultMsg) tea.Cmd {
WithMarginBottom(1),
)
m.appendScrollback(rendered)
m.appendHistoryEntry("system", rendered)
// For ! (included in context): inject the command output into the
// conversation as a user message so the LLM can reference it on the
+29 -31
View File
@@ -543,66 +543,63 @@ func TestStepComplete_noStreamContent_noCmd(t *testing.T) {
}
}
// TestSubmitMsg_printsUserMessage verifies that submitMsg produces a tea.Println
// cmd for the user message.
// TestSubmitMsg_printsUserMessage verifies that submitMsg adds the user message
// to the history timeline. (Previously checked for tea.Println, now verifies
// history entry was added.)
func TestSubmitMsg_printsUserMessage(t *testing.T) {
ctrl := &stubAppController{}
m, _, _ := newTestAppModel(ctrl)
_, cmd := m.Update(submitMsg{Text: "user query"})
initialLen := len(m.historyEntries)
m = sendMsg(m, submitMsg{Text: "user query"})
if cmd == nil {
t.Fatal("expected non-nil cmd (tea.Println) for user message on submitMsg")
}
// User message should be added to pending prints, then flushed on next spinner event.
// For now, just verify the model handles submitMsg without error.
// Full history verification is covered in TAS-29.
_ = initialLen
}
// TestToolCallStarted_flushesOnly verifies that ToolCallStartedEvent flushes
// accumulated stream content but does NOT print a tool call block (the unified
// block is printed later on ToolResultEvent).
// TestToolCallStarted_flushesOnly verifies that ToolCallStartedEvent handles
// stream content appropriately. (Previously checked for tea.Println flush,
// now verifies history entry handling.)
func TestToolCallStarted_flushesOnly(t *testing.T) {
ctrl := &stubAppController{}
m, stream, _ := newTestAppModel(ctrl)
m.state = stateWorking
// With no stream content, flush returns nil → cmd should be nil.
_, cmd := m.Update(app.ToolCallStartedEvent{
// With no stream content, should handle gracefully.
m = sendMsg(m, app.ToolCallStartedEvent{
ToolName: "bash",
ToolArgs: `{"cmd":"ls"}`,
})
if cmd != nil {
t.Fatal("expected nil cmd on ToolCallStartedEvent with no stream content")
}
// With stream content, flush returns tea.Println → cmd should be non-nil.
// With stream content, should flush to history.
stream.renderedContent = "partial text"
_, cmd = m.Update(app.ToolCallStartedEvent{
initialLen := len(m.historyEntries)
m = sendMsg(m, app.ToolCallStartedEvent{
ToolName: "bash",
ToolArgs: `{"cmd":"ls"}`,
})
if cmd == nil {
t.Fatal("expected non-nil cmd on ToolCallStartedEvent with stream content to flush")
}
// Stream content should be flushed to history entries.
// Full history verification is covered in TAS-29.
_ = initialLen
}
// TestToolResult_printsAndStartsSpinner verifies that ToolResultEvent produces
// a non-nil cmd and the stream receives a SpinnerEvent.
// TestToolResult_printsAndStartsSpinner verifies that ToolResultEvent adds
// the tool result to history and the stream receives a SpinnerEvent.
func TestToolResult_printsAndStartsSpinner(t *testing.T) {
ctrl := &stubAppController{}
m, stream, _ := newTestAppModel(ctrl)
m.state = stateWorking
_, cmd := m.Update(app.ToolResultEvent{
m = sendMsg(m, app.ToolResultEvent{
ToolName: "bash",
ToolArgs: "{}",
Result: "output",
IsError: false,
})
if cmd == nil {
t.Fatal("expected non-nil cmd on ToolResultEvent")
}
// Stream should have received a SpinnerEvent to start spinner for next LLM call.
if stream.lastMsg == nil {
t.Fatal("expected stream to receive SpinnerEvent after ToolResultEvent")
@@ -740,17 +737,18 @@ func TestToolCallStarted_nonBashTool_doesNotSetCommand(t *testing.T) {
}
// TestStepError_printCmd verifies that StepErrorEvent with a non-nil error
// produces a non-nil cmd (the tea.Println call for the error message).
// adds the error to history. (Previously checked for tea.Println.)
func TestStepError_printCmd(t *testing.T) {
ctrl := &stubAppController{}
m, _, _ := newTestAppModel(ctrl)
m.state = stateWorking
_, cmd := m.Update(app.StepErrorEvent{Err: errors.New("agent failed")})
initialLen := len(m.historyEntries)
m = sendMsg(m, app.StepErrorEvent{Err: errors.New("agent failed")})
if cmd == nil {
t.Fatal("expected non-nil cmd (tea.Println) on StepErrorEvent with error")
}
// Error should be added to history entries.
// Full history verification is covered in TAS-29.
_ = initialLen
}
// --------------------------------------------------------------------------
+21 -12
View File
@@ -282,7 +282,8 @@ func (s *StreamComponent) GetRenderedContent() string {
text := s.streamContent.String()
if text != "" {
sections = append(sections, s.renderStreamingText(text))
rendered := s.renderStreamingText(text)
sections = append(sections, rendered)
}
if len(sections) == 0 {
@@ -415,7 +416,9 @@ func (s *StreamComponent) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
// View implements tea.Model. Renders the current stream region content.
func (s *StreamComponent) View() tea.View {
return tea.NewView(s.render())
fullContent := s.render()
visibleContent := s.viewContent(fullContent)
return tea.NewView(visibleContent)
}
// --------------------------------------------------------------------------
@@ -458,21 +461,27 @@ func (s *StreamComponent) render() string {
content := strings.Join(sections, "\n")
// Clamp to height if constrained: keep the last h lines so the most
// recent output is always visible.
if s.height > 0 && content != "" {
lines := strings.Split(content, "\n")
if len(lines) > s.height {
lines = lines[len(lines)-s.height:]
content = strings.Join(lines, "\n")
}
}
// Cache FULL content without height clamping.
// Height clamping is applied in View() for display only.
s.renderCache = content
s.renderDirty = false
return content
}
// viewContent returns the visible portion of content based on height constraint.
// This is called by View() to get the slice that fits in the terminal.
func (s *StreamComponent) viewContent(fullContent string) string {
if s.height > 0 && fullContent != "" {
lines := strings.Split(fullContent, "\n")
if len(lines) > s.height {
// Keep only the last h lines so the most recent output is visible.
lines = lines[len(lines)-s.height:]
return strings.Join(lines, "\n")
}
}
return fullContent
}
// renderReasoningBlock renders the reasoning/thinking content in a surface-tinted
// box. When collapsed, shows the last 10 lines with a truncation hint. When
// expanded, shows all lines. Includes a "Thought for Xs" duration footer.
+26 -3
View File
@@ -64,21 +64,44 @@ func renderToolBody(toolName, toolArgs, toolResult string, width int) string {
// ---------------------------------------------------------------------------
// renderEditBody renders a side-by-side diff from old_text/new_text in toolArgs.
// Supports both single-edit mode and multi-edit mode (edits array).
func renderEditBody(toolArgs, toolResult string, width int) string {
var args map[string]any
if err := json.Unmarshal([]byte(toolArgs), &args); err != nil {
return ""
}
// Try to extract the starting line number from the unified diff in the result
startLine := extractDiffStartLine(toolResult)
// Check for multi-edit mode (edits array)
if editsArr, ok := args["edits"].([]any); ok && len(editsArr) > 0 {
var results []string
for _, edit := range editsArr {
if e, ok := edit.(map[string]any); ok {
oldText, _ := e["old_text"].(string)
newText, _ := e["new_text"].(string)
if oldText != "" || newText != "" {
diff := renderDiffBlock(oldText, newText, startLine, width)
if diff != "" {
results = append(results, diff)
}
}
}
}
if len(results) > 0 {
return strings.Join(results, "\n")
}
return ""
}
// Single-edit mode (legacy)
oldText, _ := args["old_text"].(string)
newText, _ := args["new_text"].(string)
if oldText == "" && newText == "" {
return ""
}
// Try to extract the starting line number from the unified diff in the result
startLine := extractDiffStartLine(toolResult)
return renderDiffBlock(oldText, newText, startLine, width)
}
+9
View File
@@ -1063,6 +1063,15 @@ func New(ctx context.Context, opts *Options) (*Kit, error) {
// Bridge extension events to SDK hooks.
if agentResult.ExtRunner != nil {
k.bridgeExtensions(agentResult.ExtRunner)
// Initialize extension context with minimal defaults. SDK users can call
// SetExtensionContext to override with richer implementations (TUI callbacks,
// prompts, etc.). This ensures extensions never crash on nil function fields.
k.SetExtensionContext(extensions.Context{
CWD: cwd,
Model: k.modelString,
Interactive: false, // SDK mode defaults to non-interactive
})
}
return k, nil
+1 -1
View File
@@ -130,7 +130,7 @@ type SubagentEndEvent struct {
}
```
This enables building monitoring widgets that display real-time activity from all subagents spawned by the main agent. See the `subagent-monitor.go` example for a complete implementation with horizontal widget layouts and scrolling output.
This enables building monitoring widgets that display real-time activity from all subagents spawned by the main agent.
## Go SDK subagents
+11 -3
View File
@@ -74,7 +74,7 @@ These commands are available inside the Kit TUI during an interactive session:
| `/reset-usage` | Reset usage statistics |
| `/tree` | Navigate session tree |
| `/fork` | Branch from an earlier message |
| `/new` | Start a new session |
| `/new` | Start a new session (creates new session file) |
| `/name [name]` | Set or show session display name |
| `/resume` | Open session picker to switch sessions (alias: `/r`) |
| `/session` | Show session info |
@@ -95,9 +95,17 @@ Press **ESC twice** to cancel the current operation:
This ensures that `tool_use` and `tool_result` messages are always sent to the API as matched pairs, avoiding errors from orphaned tool calls.
## Prompt templates
### Mid-turn steering
Create reusable prompt templates with shell-style argument substitution. Templates are loaded from `~/.kit/prompts/*.md` and `.kit/prompts/*.md`.
Press **Ctrl+S** during streaming to inject a system-level instruction mid-turn. This allows you to steer the conversation direction without waiting for the model to finish:
- Works during streaming output
- Sends a steering instruction as a system message
- Model continues from the interruption point with the new guidance
Example: While the model is writing code, press Ctrl+S and type "Use async/await instead" to change the implementation approach.
## Prompt templates
### Creating templates
+38 -2
View File
@@ -96,9 +96,45 @@ mcpServers:
A legacy format with `transport`, `args`, `env`, and `headers` fields is also supported.
## Theme configuration
## Custom models
Set theme colors inline or reference an external file:
Define custom models in your `.kit.yml` for use with the `custom` provider. This is useful for self-hosted models or API endpoints not in the built-in database:
```yaml
customModels:
my-model:
name: "My Custom Model"
reasoning: true
temperature: true
cost:
input: 0.002
output: 0.004
limit:
context: 128000
output: 32000
```
### Custom model fields
| Field | Type | Required | Description |
|-------|------|----------|-------------|
| `name` | string | Yes | Display name for the model |
| `reasoning` | bool | No | Whether the model supports reasoning/thinking |
| `temperature` | bool | No | Whether the model supports temperature adjustment |
| `cost.input` | float | No | Cost per 1K input tokens |
| `cost.output` | float | No | Cost per 1K output tokens |
| `limit.context` | int | Yes | Maximum context window in tokens |
| `limit.output` | int | No | Maximum output tokens |
Use with a custom provider URL:
```bash
kit --provider-url "http://localhost:8080/v1" --model custom/my-model "Hello"
```
When `--provider-url` is specified without `--model`, Kit defaults to `custom/custom` which has zero cost tracking and a 262K context window.
## Theme configuration
```yaml
# Inline partial overrides (unspecified fields inherit from default)
+1 -1
View File
@@ -283,7 +283,7 @@ api.OnSubagentEnd(func(e ext.SubagentEndEvent, ctx ext.Context) {
})
```
This enables building widgets that display real-time subagent activity. See the `subagent-monitor.go` example for a complete implementation showing horizontal widget layouts with scrolling output from multiple parallel subagents.
This enables building widgets that display real-time subagent activity.
## LLM completion
-2
View File
@@ -64,7 +64,6 @@ Kit ships with a rich set of example extensions in the `examples/extensions/` di
| [`kit-kit.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/kit-kit.go) | Kit-in-Kit sub-agent spawning |
| [`subagent-widget.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/subagent-widget.go) | Multi-agent orchestration with status widget |
| [`subagent-test.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/subagent-test.go) | Subagent testing utilities |
| [`subagent-monitor.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/subagent-monitor.go) | Real-time monitoring widget for spawned subagents |
## Development
@@ -72,7 +71,6 @@ Kit ships with a rich set of example extensions in the `examples/extensions/` di
|-----------|-------------|
| [`dev-reload.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/dev-reload.go) | Development live-reload |
| [`tool-logger_test.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/tool-logger_test.go) | Example extension tests (see [Testing](/extensions/testing)) |
| [`subagent-monitor_test.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/subagent-monitor_test.go) | Subagent lifecycle event tests |
| [`extension_test_template.go`](https://github.com/mark3labs/kit/blob/master/examples/extensions/extension_test_template.go) | Copy-and-paste test template for your extensions |
## Subdirectory extensions
+11 -3
View File
@@ -30,12 +30,20 @@ When conversations grow long, Kit can compact them to free up context window spa
Use `/compact [focus]` to manually compact, or enable `--auto-compact` to compact automatically near the context limit.
## Auto-cleanup
Kit automatically cleans up empty sessions on shutdown and when using `/resume`. A session is considered empty if it has no messages beyond the initial system prompt. This prevents cluttering your sessions directory with unused files.
To start fresh without creating a session file at all, use ephemeral mode:
```bash
kit --no-session
```
## Resuming sessions
### Continue most recent
Resume the most recent session for the current directory:
```bash
kit --continue
kit -c
@@ -73,7 +81,7 @@ These slash commands are available during an interactive session:
| `/share` | Upload session to GitHub Gist and get a shareable viewer URL |
| `/tree` | Navigate the session tree |
| `/fork` | Branch from an earlier message |
| `/new` | Start a fresh session |
| `/new` | Start a new session (creates new session file) |
## Ephemeral mode