Add planner schema

Author: honganh1206

README.md

@@ -33,6 +33,38 @@ To add MCP servers to clue:
 clue mcp --server-cmd "my-server:npx @modelcontextprotocol/server-everything"
 ```
 
+## Breaking Changes
+
+> **⚠️ WARNING**: If you have a running clue daemon from a previous version, you must purge it before installing the new version:
+
+1. Disable the systemd service:
+
+```bash
+sudo systemctl disable clue
+sudo systemctl stop clue
+```
+
+2. Identify the clue process:
+
+```bash
+ps aux | grep clue
+```
+
+3. Kill the process entirely (replace `<PID>` with the actual process ID):
+
+```bash
+kill -9 <PID>
+```
+
+4. Remove the service file:
+
+```bash
+sudo rm /etc/systemd/system/clue.service
+sudo systemctl daemon-reload
+```
+
+5. Move the existing `conversation.db` from `~/.local/.clue` to `~/.clue` and rename the database to `clue.db`
+
 ## Development
 
 ```bash
@@ -41,3 +73,4 @@ make # Run the agent
 ```
 
 [References](./docs/References.md)
+

agent/agent.go

@@ -195,13 +195,16 @@ func (a *Agent) executeLocalTool(id, name string, input json.RawMessage) message
 	if toolDef.IsSubTool {
 		// Make the subagent invoke tools
 		toolResultMsg, err := a.runSubagent(id, name, toolDef.Description, input)
+		// TODO: Exceed limit of 200k tool result. Trying truncation
+		// 25k is best practice from Anthropic
+		truncatedResult := a.Sub.llm.TruncateMessage(toolResultMsg, 25000)
 		if err != nil {
 			return message.NewToolResultBlock(id, name, err.Error(), true)
 		}
 
 		var final strings.Builder
 		// Iterating over block type is quite tiring?
-		for _, content := range toolResultMsg.Content {
+		for _, content := range truncatedResult.Content {
 			switch blk := content.(type) {
 			case message.TextBlock:
 				final.WriteString(blk.Text)

api/client.go

@@ -137,3 +137,4 @@ func (c *Client) GetLatestConversationID() (string, error) {
 
 	return conversations[0].ID, nil
 }
+

cmd/interactive.go

@@ -54,7 +54,6 @@ func interactive(ctx context.Context, convID string, llmClient, llmClientSub inf
 	}
 
 	subllm, err := inference.Init(ctx, llmClientSub)
-
 	if err != nil {
 		return fmt.Errorf("failed to initialize sub-agent LLM: %w", err)
 	}

cmd/tui.go

@@ -20,14 +20,17 @@ import (
 )
 
 func tui(ctx context.Context, agent *agent.Agent, conv *conversation.Conversation) error {
+	ctx, cancel := context.WithCancel(ctx)
+	defer cancel()
+
 	app := tview.NewApplication()
 
 	conversationView := tview.NewTextView().
 		SetDynamicColors(true).
 		SetWordWrap(true).
 		SetChangedFunc(func() {
 			app.Draw()
-		})
+		}).ScrollToEnd()
 
 	isFirstInput := len(conv.Messages) == 0
 	if isFirstInput {
@@ -36,14 +39,19 @@ func tui(ctx context.Context, agent *agent.Agent, conv *conversation.Conversatio
 	} else {
 		displayConversationHistory(conversationView, conv)
 	}
-
 	relPath := displayRelativePath()
 
 	questionInput := tview.NewTextArea()
 	questionInput.SetTitle("[blue::]Enter to send (ESC to focus conversation)").
 		SetTitleAlign(tview.AlignLeft).
 		SetBorder(true).
 		SetDrawFunc(renderRelativePath(relPath))
+	questionInput.SetFocusFunc(func() {
+		questionInput.SetBorderColor(tcell.ColorGreen)
+	})
+	questionInput.SetBlurFunc(func() {
+		questionInput.SetBorderColor(tcell.ColorWhite)
+	})
 
 	spinnerView := tview.NewTextView().
 		SetDynamicColors(true).
@@ -94,6 +102,8 @@ func tui(ctx context.Context, agent *agent.Agent, conv *conversation.Conversatio
 				defer ticker.Stop()
 				for {
 					select {
+					case <-ctx.Done():
+						return
 					case stop := <-spinCh:
 						if stop {
 							// Clear the spinner text to hide it from the UI when the agent finishes processing
@@ -151,7 +161,11 @@ func tui(ctx context.Context, agent *agent.Agent, conv *conversation.Conversatio
 		return event
 	})
 
-	return app.SetRoot(mainLayout, true).SetFocus(questionInput).Run()
+	if err := app.SetRoot(mainLayout, true).EnableMouse(true).SetFocus(questionInput).Run(); err != nil {
+		panic(err)
+	}
+
+	return nil
 }
 
 func formatMessage(msg *message.Message) string {