feat(mcp): add local-only MCP server with stdio transport

Author: codevalve

.agents/workflows/prd-mcp.md

@@ -32,3 +32,8 @@ For each triage action:
 ## 4. Work Dispatch
 - [ ] Update `ROADMAP.md` if the issue is high-priority for the next release.
 - [ ] Ask the USER to approve the plan before execution.
+
+## 5. Environment Check
+// turbo
+- [ ] Ensure local git config is correct:
+      `git config user.email "john.lovell@codevalve.com" && git config user.name "codevalve"`

.agents/workflows/setup-mcp.md

@@ -30,14 +30,23 @@ Bridging the gap between local-only and cloud-hosted logs by leveraging private
   - **Clipboard Support**: Robust handling for multi-character pastes in the terminal.
   - **Dynamic Layout**: Constrained collection column width with automatic truncation.
 
-## v2.7.0: Documentation & Onboarding
+## v2.7.2: Security Fix (Released 🔒🚀)
+- **Fixes**:
+  - **esbuild**: Resolved a security vulnerability in `esbuild` using npm overrides in the documentation site.
+
+## v2.7.1: Build & Security (Released 🛠️🚀)
+- **Fixes**:
+  - **CI/CD Align**: Updated Go to 1.25 and Node to 22 in GitHub Actions.
+  - **Security**: Added Dependabot configuration for automated dependency tracking.
+
+## v2.7.0: Documentation & Onboarding (Released 📖🚀)
 The goal is to lower the barrier to entry and ensure Rapide feels accessible to new users while maintaining its professional edge.
 
 - **Infrastructure**: Refined internal documentation and self-documenting CLI help.
 - **Features**:
-  - **Interactive Tutorial**: A guided first-run experience within the TUI.
-  - **The "Context" system**: Enhanced in-app help (press `?`) that explains Rapide's syntax (bullets, margin keys) in real-time.
-  - **Example Collections**: Optionally seed the journal with best-practice templates (e.g., Work, Health, Ideas) on setup.
+  - **`rapide init`**: Interactive setup wizard to seed your journal.
+  - **TUI Help Overlay**: In-app quick reference (press `?`).
+  - **VitePress Documentation**: Dedicated docs site on GitHub Pages.
 
 ## v3.0.0: Rapide MCP (Model Context Protocol)
 Bridging the gap between your logs and AI agents by making Rapide a first-class MCP server.

.agents/workflows/triage-issues.md

@@ -0,0 +1,45 @@
+package cmd
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"os/signal"
+	"rapide/internal/mcp"
+	"rapide/internal/storage"
+	"syscall"
+
+	"github.com/spf13/cobra"
+)
+
+var mcpCmd = &cobra.Command{
+	Use:    "mcp",
+	Short:  "MCP server commands",
+	Hidden: true,
+}
+
+var mcpStartCmd = &cobra.Command{
+	Use:    "start",
+	Short:  "Start the MCP server",
+	Hidden: true,
+	RunE: func(cmd *cobra.Command, args []string) error {
+		s, err := storage.NewStorage()
+		if err != nil {
+			return fmt.Errorf("failed to initialize storage: %w", err)
+		}
+
+		adapter := mcp.NewJournalAdapter(s)
+		server := mcp.NewServer(adapter)
+
+		ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
+		defer stop()
+
+		fmt.Fprintln(os.Stderr, "Starting Rapide MCP server (stdio)...")
+		return server.Start(ctx)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(mcpCmd)
+	mcpCmd.AddCommand(mcpStartCmd)
+}

ROADMAP.md

@@ -0,0 +1,75 @@
+package mcp
+
+import (
+	"context"
+	"rapide/internal/model"
+	"rapide/internal/storage"
+	"strings"
+	"time"
+)
+
+type JournalAdapter interface {
+	AddAgentEntry(ctx context.Context, content string) (*model.Entry, error)
+	SearchAgentEntries(ctx context.Context, query string) ([]model.Entry, error)
+	ListRecentAgentEntries(ctx context.Context, limit int) ([]model.Entry, error)
+}
+
+type storageAdapter struct {
+	storage *storage.Storage
+}
+
+func NewJournalAdapter(s *storage.Storage) JournalAdapter {
+	return &storageAdapter{storage: s}
+}
+
+func (a *storageAdapter) AddAgentEntry(ctx context.Context, content string) (*model.Entry, error) {
+	entry := model.Entry{
+		Timestamp: time.Now(),
+		MarginKey: "AGENT",
+		Bullet:    "•",
+		Content:   content,
+		Priority:  false,
+		Pinned:    false,
+	}
+
+	id, err := a.storage.Append(entry)
+	if err != nil {
+		return nil, err
+	}
+	entry.ID = id
+	return &entry, nil
+}
+
+func (a *storageAdapter) SearchAgentEntries(ctx context.Context, query string) ([]model.Entry, error) {
+	all, err := a.storage.List()
+	if err != nil {
+		return nil, err
+	}
+
+	var results []model.Entry
+	q := strings.ToLower(query)
+	for _, e := range all {
+		if e.MarginKey == "AGENT" && strings.Contains(strings.ToLower(e.Content), q) {
+			results = append(results, e)
+		}
+	}
+	return results, nil
+}
+
+func (a *storageAdapter) ListRecentAgentEntries(ctx context.Context, limit int) ([]model.Entry, error) {
+	all, err := a.storage.List()
+	if err != nil {
+		return nil, err
+	}
+
+	var agentEntries []model.Entry
+	for i := len(all) - 1; i >= 0; i-- {
+		if all[i].MarginKey == "AGENT" {
+			agentEntries = append(agentEntries, all[i])
+			if len(agentEntries) >= limit {
+				break
+			}
+		}
+	}
+	return agentEntries, nil
+}

cmd/mcp.go

@@ -0,0 +1,83 @@
+package mcp
+
+import (
+	"context"
+	"os"
+	"path/filepath"
+	"rapide/internal/storage"
+	"testing"
+)
+
+func setupTestStorage(t *testing.T) (*storage.Storage, func()) {
+	tmpDir, err := os.MkdirTemp("", "rapide-mcp-test-*")
+	if err != nil {
+		t.Fatalf("failed to create temp dir: %v", err)
+	}
+	
+	dbPath := filepath.Join(tmpDir, "entries.jsonl")
+	s := &storage.Storage{FilePath: dbPath}
+	
+	return s, func() {
+		os.RemoveAll(tmpDir)
+	}
+}
+
+func TestAdapter_AddAgentEntry(t *testing.T) {
+	s, cleanup := setupTestStorage(t)
+	defer cleanup()
+	
+	adapter := NewJournalAdapter(s)
+	content := "test mcp entry"
+	
+	entry, err := adapter.AddAgentEntry(context.Background(), content)
+	if err != nil {
+		t.Fatalf("AddAgentEntry failed: %v", err)
+	}
+	
+	if entry.Content != content {
+		t.Errorf("expected content %q, got %q", content, entry.Content)
+	}
+	if entry.MarginKey != "AGENT" {
+		t.Errorf("expected margin key AGENT, got %q", entry.MarginKey)
+	}
+}
+
+func TestAdapter_SearchAgentEntries(t *testing.T) {
+	s, cleanup := setupTestStorage(t)
+	defer cleanup()
+	
+	adapter := NewJournalAdapter(s)
+	adapter.AddAgentEntry(context.Background(), "apple pie")
+	adapter.AddAgentEntry(context.Background(), "banana split")
+	
+	results, err := adapter.SearchAgentEntries(context.Background(), "banana")
+	if err != nil {
+		t.Fatalf("SearchAgentEntries failed: %v", err)
+	}
+	
+	if len(results) != 1 {
+		t.Fatalf("expected 1 result, got %d", len(results))
+	}
+	if results[0].Content != "banana split" {
+		t.Errorf("expected 'banana split', got %q", results[0].Content)
+	}
+}
+
+func TestAdapter_ListRecentAgentEntries(t *testing.T) {
+	s, cleanup := setupTestStorage(t)
+	defer cleanup()
+	
+	adapter := NewJournalAdapter(s)
+	for i := 0; i < 5; i++ {
+		adapter.AddAgentEntry(context.Background(), "entry")
+	}
+	
+	results, err := adapter.ListRecentAgentEntries(context.Background(), 3)
+	if err != nil {
+		t.Fatalf("ListRecentAgentEntries failed: %v", err)
+	}
+	
+	if len(results) != 3 {
+		t.Errorf("expected 3 results, got %d", len(results))
+	}
+}

internal/mcp/adapter.go

@@ -0,0 +1,83 @@
+package mcp
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+)
+
+func (s *Server) toolAddEntry(ctx context.Context, args json.RawMessage) (interface{}, *Error) {
+	var a AddEntryArgs
+	if err := json.Unmarshal(args, &a); err != nil {
+		return nil, &Error{Code: -32602, Message: "Invalid arguments"}
+	}
+
+	if a.Content == "" {
+		return nil, &Error{Code: -32602, Message: "Content is required"}
+	}
+
+	entry, err := s.adapter.AddAgentEntry(ctx, a.Content)
+	if err != nil {
+		return nil, &Error{Code: -32000, Message: fmt.Sprintf("Failed to add entry: %v", err)}
+	}
+
+	return CallToolResult{
+		Content: []TextContent{
+			{
+				Type: "text",
+				Text: fmt.Sprintf("Added entry with ID %s to AGENT collection", entry.ID),
+			},
+		},
+	}, nil
+}
+
+func (s *Server) toolSearchEntries(ctx context.Context, args json.RawMessage) (interface{}, *Error) {
+	var a SearchEntriesArgs
+	if err := json.Unmarshal(args, &a); err != nil {
+		return nil, &Error{Code: -32602, Message: "Invalid arguments"}
+	}
+
+	entries, err := s.adapter.SearchAgentEntries(ctx, a.Query)
+	if err != nil {
+		return nil, &Error{Code: -32000, Message: fmt.Sprintf("Failed to search entries: %v", err)}
+	}
+
+	data, _ := json.MarshalIndent(entries, "", "  ")
+	return CallToolResult{
+		Content: []TextContent{
+			{
+				Type: "text",
+				Text: string(data),
+			},
+		},
+	}, nil
+}
+
+func (s *Server) toolListRecent(ctx context.Context, args json.RawMessage) (interface{}, *Error) {
+	var a ListRecentArgs
+	if err := json.Unmarshal(args, &a); err != nil {
+		// Fallback to default if unmarshal fails (e.g. empty args)
+		a.Limit = 10
+	}
+	if a.Limit <= 0 {
+		a.Limit = 10
+	}
+	if a.Limit > 50 {
+		a.Limit = 50
+	}
+
+	entries, err := s.adapter.ListRecentAgentEntries(ctx, a.Limit)
+	if err != nil {
+		return nil, &Error{Code: -32000, Message: fmt.Sprintf("Failed to list entries: %v", err)}
+	}
+
+	data, _ := json.MarshalIndent(entries, "", "  ")
+	return CallToolResult{
+		Content: []TextContent{
+			{
+				Type: "text",
+				Text: string(data),
+			},
+		},
+	}, nil
+}