feat: add performance improvements with filtering options

- Add --max-age flag to filter by file modification time (default: 60 days)
- Add --max-size flag to skip large files (default: 1GB)
- Add --all flag to include everything (no limits)
- Use worker pool pattern (8 workers) instead of semaphore to avoid ulimit issues
- Show version in title bar
- Remove unused timestamp extraction functions
- Add tests for mtime and size filtering

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: brtkwr

AGENTS.md

@@ -16,9 +16,11 @@ go test -v -cover
 ### Run locally
 
 ```bash
-./ccs
-./ccs <query>
-./ccs -- --plan  # pass flags to claude
+./ccs                    # search recent (60 days, <1GB files)
+./ccs <query>            # search with initial query
+./ccs --max-age=7        # last 7 days only
+./ccs --all              # include everything
+./ccs -- --plan          # pass flags to claude
 ```
 
 ## Release Process
@@ -71,8 +73,8 @@ go test -v -cover
 
 ### Key Functions
 
-- `getConversations()` - Loads all conversations from `~/.claude/projects/`
-- `parseConversationFile()` - Parses JSONL conversation files
+- `getConversations(cutoff, maxSize)` - Loads conversations from `~/.claude/projects/` with filters
+- `parseConversationFile(path, cutoff, maxSize)` - Parses JSONL files, skips by mtime/size
 - `buildItems()` - Creates list items with searchable text
 - `initialModel()` - Sets up bubbletea TUI
 - `Update()` - Handles keyboard/mouse input

CLAUDE.md

@@ -0,0 +1,5 @@
+# CCS — Claude Instructions
+
+When updating project memory, update AGENTS.md instead of this file.
+
+@AGENTS.md

README.md

@@ -44,19 +44,33 @@ Download the binary from [releases](https://github.com/agentic-utils/ccs/release
 ## Usage
 
 ```bash
-# Search and resume a conversation
+# Search recent conversations (last 60 days, files <1GB)
 ccs
 
 # Search with initial query
 ccs buyer
 
+# Search last 7 days only
+ccs --max-age=7
+
+# Search everything (all time, all files)
+ccs --all
+
 # Resume with plan mode
 ccs -- --plan
 
 # Combined: search "buyer", resume with plan mode
 ccs buyer -- --plan
 ```
 
+### Flags
+
+| Flag | Default | Description |
+|------|---------|-------------|
+| `--max-age=N` | 60 | Only search files modified in the last N days (0 = no limit) |
+| `--max-size=N` | 1024 | Max file size in MB to include (0 = no limit) |
+| `--all` | - | Include everything (same as `--max-age=0 --max-size=0`) |
+
 ### Keybindings
 
 - `↑/↓` or `Ctrl+P/N` - Navigate list

main.go

@@ -255,13 +255,14 @@ func (m model) View() string {
 	tableWidth := 97
 
 	// Title line with help right-aligned
-	// Display widths: title="ccs · claude code search"=25, help="↑/↓ Enter Ctrl+J/K Esc"=22
-	titlePadding := tableWidth - 2 - 25 - 22 + 1 // 2 for indent, +1 to shift right
+	title := fmt.Sprintf("ccs · claude code search · %s", version)
+	help := "↑/↓ Enter Ctrl+J/K Esc"
+	titlePadding := tableWidth - 2 - len(title) - len(help)
 	if titlePadding < 1 {
 		titlePadding = 1
 	}
-	b.WriteString(fmt.Sprintf("  \033[1;36mccs\033[0m \033[90m· claude code search%s↑/↓ Enter Ctrl+J/K Esc\033[0m\n",
-		strings.Repeat(" ", titlePadding)))
+	b.WriteString(fmt.Sprintf("  \033[1;36mccs\033[0m \033[90m· claude code search · %s%s%s\033[0m\n",
+		version, strings.Repeat(" ", titlePadding), help))
 
 	// Search line with count right-aligned
 	count := fmt.Sprintf("(%d/%d)", len(m.filtered), len(m.items))
@@ -547,7 +548,11 @@ func extractText(content json.RawMessage) string {
 	return ""
 }
 
-func parseConversationFile(path string) (*Conversation, error) {
+
+
+
+
+func parseConversationFile(path string, cutoff time.Time, maxSize int64) (*Conversation, error) {
 	info, err := os.Stat(path)
 	if err != nil {
 		return nil, err
@@ -557,6 +562,16 @@ func parseConversationFile(path string) (*Conversation, error) {
 		return nil, nil
 	}
 
+	// Skip files larger than maxSize (0 means no limit)
+	if maxSize > 0 && info.Size() > maxSize {
+		return nil, nil
+	}
+
+	// Skip files not modified since cutoff (file mtime check)
+	if !cutoff.IsZero() && info.ModTime().Before(cutoff) {
+		return nil, nil
+	}
+
 	sessionID := strings.TrimSuffix(info.Name(), ".jsonl")
 	conv := &Conversation{SessionID: sessionID}
 
@@ -570,8 +585,10 @@ func parseConversationFile(path string) (*Conversation, error) {
 	scanner.Buffer(make([]byte, 1024*1024), 10*1024*1024)
 
 	for scanner.Scan() {
+		lineBytes := scanner.Bytes()
+
 		var raw RawMessage
-		if err := json.Unmarshal(scanner.Bytes(), &raw); err != nil {
+		if err := json.Unmarshal(lineBytes, &raw); err != nil {
 			continue
 		}
 
@@ -615,7 +632,7 @@ func parseConversationFile(path string) (*Conversation, error) {
 	return conv, nil
 }
 
-func getConversations() ([]Conversation, error) {
+func getConversations(cutoff time.Time, maxSize int64) ([]Conversation, error) {
 	projectsDir := getProjectsDir()
 
 	var files []string
@@ -632,24 +649,30 @@ func getConversations() ([]Conversation, error) {
 		return nil, err
 	}
 
-	var wg sync.WaitGroup
+	// Worker pool to limit concurrent file operations
+	const numWorkers = 8
+	jobs := make(chan string, len(files))
 	results := make(chan *Conversation, len(files))
-	sem := make(chan struct{}, 20)
 
-	for _, file := range files {
+	var wg sync.WaitGroup
+	for i := 0; i < numWorkers; i++ {
 		wg.Add(1)
-		go func(path string) {
+		go func() {
 			defer wg.Done()
-			sem <- struct{}{}
-			defer func() { <-sem }()
-
-			conv, err := parseConversationFile(path)
-			if err == nil && conv != nil {
-				results <- conv
+			for path := range jobs {
+				conv, err := parseConversationFile(path, cutoff, maxSize)
+				if err == nil && conv != nil {
+					results <- conv
+				}
 			}
-		}(file)
+		}()
 	}
 
+	for _, file := range files {
+		jobs <- file
+	}
+	close(jobs)
+
 	go func() {
 		wg.Wait()
 		close(results)
@@ -728,12 +751,17 @@ Arguments:
   -- claude-flags  Flags to pass to 'claude --resume' (after --)
 
 Flags:
-  -h, --help      Show this help message
-  -v, --version   Show version
-  --dump [query]  Debug: print all search items (with optional highlighting)
+  -h, --help       Show this help message
+  -v, --version    Show version
+  --max-age=N      Only search last N days (default: 60, 0 = no limit)
+  --max-size=N     Max file size in MB (default: 1024, 0 = no limit)
+  --all            Include everything (same as --max-age=0 --max-size=0)
+  --dump [query]   Debug: print all search items (with optional highlighting)
 
 Examples:
-  ccs                                Search all conversations
+  ccs                                Search last 60 days, files <1GB (default)
+  ccs --max-age=7                    Search last 7 days only
+  ccs --all                          Search everything (all time, all files)
   ccs buyer                          Search with initial query "buyer"
   ccs -- --plan                      Resume with plan mode
   ccs buyer -- --plan                Search "buyer", resume with plan mode
@@ -763,14 +791,39 @@ func main() {
 		}
 	}
 
+	// Parse flags
+	maxAgeDays := 60        // Default to 60 days
+	maxSizeMB := int64(1024) // Default to 1GB
+	for _, arg := range args {
+		if arg == "--all" {
+			maxAgeDays = 0
+			maxSizeMB = 0
+		} else if strings.HasPrefix(arg, "--max-age=") {
+			val := strings.TrimPrefix(arg, "--max-age=")
+			fmt.Sscanf(val, "%d", &maxAgeDays)
+		} else if strings.HasPrefix(arg, "--max-size=") {
+			val := strings.TrimPrefix(arg, "--max-size=")
+			fmt.Sscanf(val, "%d", &maxSizeMB)
+		}
+	}
+
+	// Convert to bytes (0 means no limit)
+	maxSize := maxSizeMB * 1024 * 1024
+
+	// Calculate cutoff time (0 means no limit)
+	var cutoff time.Time
+	if maxAgeDays > 0 {
+		cutoff = time.Now().AddDate(0, 0, -maxAgeDays)
+	}
+
 	// Debug mode - dump search lines
 	for i, arg := range args {
 		if arg == "--dump" {
 			filter := ""
 			if i+1 < len(args) && !strings.HasPrefix(args[i+1], "-") {
 				filter = args[i+1]
 			}
-			conversations, _ := getConversations()
+			conversations, _ := getConversations(cutoff, maxSize)
 			items := buildItems(conversations)
 			for _, item := range items {
 				line := item.searchText
@@ -791,6 +844,10 @@ func main() {
 			claudeFlags = args[i+1:]
 			break
 		}
+		// Skip our flags when looking for filter query
+		if arg == "--all" || strings.HasPrefix(arg, "--max-age=") || strings.HasPrefix(arg, "--max-size=") {
+			continue
+		}
 		if !strings.HasPrefix(arg, "-") && filterQuery == "" {
 			filterQuery = arg
 		}
@@ -804,7 +861,7 @@ func main() {
 	}
 
 	fmt.Fprint(os.Stderr, "Loading conversations...")
-	conversations, err := getConversations()
+	conversations, err := getConversations(cutoff, maxSize)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "\rError loading conversations: %v\n", err)
 		os.Exit(1)

main_test.go

@@ -6,6 +6,7 @@ import (
 	"path/filepath"
 	"strings"
 	"testing"
+	"time"
 )
 
 func TestTruncate(t *testing.T) {
@@ -239,7 +240,7 @@ func TestParseConversationFile(t *testing.T) {
 		t.Fatalf("failed to write test file: %v", err)
 	}
 
-	conv, err := parseConversationFile(testFile)
+	conv, err := parseConversationFile(testFile, time.Time{}, 0) // No cutoff, no size limit
 	if err != nil {
 		t.Fatalf("parseConversationFile failed: %v", err)
 	}
@@ -278,7 +279,7 @@ func TestParseConversationFileSkipsAgentFiles(t *testing.T) {
 		t.Fatalf("failed to write test file: %v", err)
 	}
 
-	conv, err := parseConversationFile(testFile)
+	conv, err := parseConversationFile(testFile, time.Time{}, 0) // No cutoff, no size limit
 	if err != nil {
 		t.Fatalf("parseConversationFile failed: %v", err)
 	}
@@ -297,7 +298,7 @@ func TestParseConversationFileEmptyMessages(t *testing.T) {
 		t.Fatalf("failed to write test file: %v", err)
 	}
 
-	conv, err := parseConversationFile(testFile)
+	conv, err := parseConversationFile(testFile, time.Time{}, 0) // No cutoff, no size limit
 	if err != nil {
 		t.Fatalf("parseConversationFile failed: %v", err)
 	}
@@ -307,3 +308,71 @@ func TestParseConversationFileEmptyMessages(t *testing.T) {
 	}
 }
 
+func TestParseConversationFileSkipsOldFiles(t *testing.T) {
+	tmpDir := t.TempDir()
+	testFile := filepath.Join(tmpDir, "old-session.jsonl")
+
+	content := `{"type":"user","cwd":"/test","message":{"content":"hello"},"timestamp":"2024-01-15T10:00:00Z"}`
+	if err := os.WriteFile(testFile, []byte(content), 0644); err != nil {
+		t.Fatalf("failed to write test file: %v", err)
+	}
+
+	// Set file mtime to 60 days ago
+	oldTime := time.Now().AddDate(0, 0, -60)
+	if err := os.Chtimes(testFile, oldTime, oldTime); err != nil {
+		t.Fatalf("failed to set file mtime: %v", err)
+	}
+
+	// Cutoff is 30 days ago - file should be skipped
+	cutoff := time.Now().AddDate(0, 0, -30)
+	conv, err := parseConversationFile(testFile, cutoff, 0)
+	if err != nil {
+		t.Fatalf("parseConversationFile failed: %v", err)
+	}
+
+	if conv != nil {
+		t.Error("parseConversationFile should return nil for files older than cutoff")
+	}
+}
+
+func TestParseConversationFileIncludesRecentFiles(t *testing.T) {
+	tmpDir := t.TempDir()
+	testFile := filepath.Join(tmpDir, "recent-session.jsonl")
+
+	content := `{"type":"user","cwd":"/test","message":{"content":"hello"},"timestamp":"2024-01-15T10:00:00Z"}`
+	if err := os.WriteFile(testFile, []byte(content), 0644); err != nil {
+		t.Fatalf("failed to write test file: %v", err)
+	}
+
+	// File mtime is now (recent) - cutoff is 30 days ago
+	cutoff := time.Now().AddDate(0, 0, -30)
+	conv, err := parseConversationFile(testFile, cutoff, 0)
+	if err != nil {
+		t.Fatalf("parseConversationFile failed: %v", err)
+	}
+
+	if conv == nil {
+		t.Error("parseConversationFile should include files newer than cutoff")
+	}
+}
+
+func TestParseConversationFileSkipsLargeFiles(t *testing.T) {
+	tmpDir := t.TempDir()
+	testFile := filepath.Join(tmpDir, "large-session.jsonl")
+
+	content := `{"type":"user","cwd":"/test","message":{"content":"hello"},"timestamp":"2024-01-15T10:00:00Z"}`
+	if err := os.WriteFile(testFile, []byte(content), 0644); err != nil {
+		t.Fatalf("failed to write test file: %v", err)
+	}
+
+	// maxSize of 10 bytes - file should be skipped
+	conv, err := parseConversationFile(testFile, time.Time{}, 10)
+	if err != nil {
+		t.Fatalf("parseConversationFile failed: %v", err)
+	}
+
+	if conv != nil {
+		t.Error("parseConversationFile should return nil for files larger than maxSize")
+	}
+}
+