test message

Author: Patel230

cmd/iterate/repl.go

@@ -589,6 +589,7 @@ func suggestAtFiles(prompt, repoPath string) {
 	var candidates []string
 	seen := make(map[string]bool)
 	for _, w := range words {
+		// Strip trailing punctuation.
 		w = strings.TrimRight(w, ".,;:!?\"')")
 		if len(w) < minWordLen {
 			continue

cmd/iterate/repl_streaming.go

@@ -387,9 +387,43 @@ func printFinalStats(elapsed, ttft time.Duration, beforeTokens int, requestCostU
 	selector.PrintStatusLine(elapsed, delta)
 	fmt.Println()
 
+	// Proactive context window warnings — shown once per threshold crossing.
+	printContextWarning(sess.InputTokens + sess.OutputTokens)
+
 	slog.Debug("request completed", "elapsed_ms", elapsed.Milliseconds(), "ttft_ms", ttft.Milliseconds(), "response_chars", len(fullContent), "total_tokens", sess.Tokens, "cost_usd", requestCostUSD)
 }
 
+// contextWarnState tracks which threshold warnings have been shown this session.
+var contextWarnState struct {
+	shown70 bool
+	shown85 bool
+	shown95 bool
+}
+
+// printContextWarning prints a one-time advisory when the context crosses 70/85/95%.
+func printContextWarning(usedTokens int) {
+	window := selector.ContextWindow
+	if window <= 0 {
+		window = 200_000
+	}
+	pct := float64(usedTokens) * 100 / float64(window)
+
+	switch {
+	case pct >= 95 && !contextWarnState.shown95:
+		contextWarnState.shown95 = true
+		fmt.Printf("%s⚠  Context at %.0f%% — use /compact or /compact llm to free space%s\n\n",
+			colorRed, pct, colorReset)
+	case pct >= 85 && !contextWarnState.shown85:
+		contextWarnState.shown85 = true
+		fmt.Printf("%s⚠  Context at %.0f%% — approaching limit, consider /compact%s\n\n",
+			colorYellow, pct, colorReset)
+	case pct >= 70 && !contextWarnState.shown70:
+		contextWarnState.shown70 = true
+		fmt.Printf("%s  Context at %.0f%% — use /context to monitor usage%s\n\n",
+			colorDim, pct, colorReset)
+	}
+}
+
 // authErrorHint returns a human-readable fix suggestion for known API error
 // patterns, or an empty string when the error doesn't look auth-related.
 func authErrorHint(errMsg string) string {

internal/commands/mode.go

@@ -1,6 +1,7 @@
 package commands
 
 import (
+	"context"
 	"fmt"
 	"os"
 	"os/exec"
@@ -69,6 +70,13 @@ func registerDisplayCommands(r *Registry) {
 		"/explain", "explain code in path", cmdExplain,
 		"/view", "view file with line numbers", cmdView,
 	)
+	r.Register(Command{
+		Name:        "/chain",
+		Aliases:     []string{},
+		Description: "run prompts sequentially, separated by ;; (e.g. /chain fix tests ;; commit the changes)",
+		Category:    "mode",
+		Handler:     cmdChain,
+	})
 	registerDisplayNavCommands(r)
 }
 
@@ -283,7 +291,7 @@ func cmdSummarize(ctx Context) Result {
 			"what was implemented, and any decisions made. Be brief.\n\n"+
 			"(Conversation has %d messages)", len(msgs))
 	if ctx.REPL.StreamAndPrint != nil {
-		ctx.REPL.StreamAndPrint(nil, ctx.Agent, prompt, ctx.RepoPath)
+		ctx.REPL.StreamAndPrint(context.Background(), ctx.Agent, prompt, ctx.RepoPath)
 	} else {
 		PrintError("agent stream not available")
 	}
@@ -542,3 +550,40 @@ func cmdRender(ctx Context) Result {
 	}
 	return Result{Handled: true}
 }
+
+// cmdChain runs multiple prompts sequentially, separated by ";;".
+// Example: /chain write tests for auth.go ;; run the tests ;; fix any failures
+func cmdChain(ctx Context) Result {
+	if ctx.REPL.StreamAndPrint == nil || ctx.Agent == nil {
+		PrintError("agent not available")
+		return Result{Handled: true}
+	}
+
+	raw := ctx.Args()
+	if raw == "" {
+		fmt.Printf("%sUsage: /chain prompt1 ;; prompt2 ;; prompt3%s\n", ColorDim, ColorReset)
+		fmt.Printf("%sEach step runs after the previous one completes.%s\n\n", ColorDim, ColorReset)
+		return Result{Handled: true}
+	}
+
+	steps := strings.Split(raw, ";;")
+	var prompts []string
+	for _, s := range steps {
+		s = strings.TrimSpace(s)
+		if s != "" {
+			prompts = append(prompts, s)
+		}
+	}
+	if len(prompts) == 0 {
+		PrintError("no prompts found — separate them with ;;")
+		return Result{Handled: true}
+	}
+
+	fmt.Printf("%s── Chain: %d steps ──────────────────────%s\n\n", ColorDim, len(prompts), ColorReset)
+	for i, prompt := range prompts {
+		fmt.Printf("%s[%d/%d]%s  %s%s%s\n\n", ColorDim, i+1, len(prompts), ColorReset, ColorYellow, prompt, ColorReset)
+		ctx.REPL.StreamAndPrint(context.Background(), ctx.Agent, prompt, ctx.RepoPath)
+	}
+	fmt.Printf("%s── Chain complete ───────────────────────%s\n\n", ColorLime, ColorReset)
+	return Result{Handled: true}
+}

internal/evolution/engine.go

@@ -167,9 +167,9 @@ func (e *Engine) loadPRState() {
 	}
 
 	// Validate the PR is still open on GitHub before trusting the state.
-	// This guards against the scenario where the PR was merged/closed/deleted
-	// externally and pr_state.json was not cleared (e.g. a crash in phase 5).
-	if state.PRNumber > 0 && e.repo != "" {
+	// Only done in CI (GITHUB_ACTIONS=true) to avoid hitting the API in tests
+	// or local development where credentials may not be available.
+	if state.PRNumber > 0 && e.repo != "" && os.Getenv("GITHUB_ACTIONS") == "true" {
 		out, ghErr := e.runGHPRState(state.PRNumber)
 		if ghErr != nil || (out != "OPEN" && out != "") {
 			e.logger.Warn("pr_state.json refers to a non-open PR, clearing it",