summaryrefslogtreecommitdiff
path: root/internal/tmuxedit/history.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/tmuxedit/history.go')
-rw-r--r--internal/tmuxedit/history.go131
1 files changed, 131 insertions, 0 deletions
diff --git a/internal/tmuxedit/history.go b/internal/tmuxedit/history.go
new file mode 100644
index 0000000..a79672b
--- /dev/null
+++ b/internal/tmuxedit/history.go
@@ -0,0 +1,131 @@
+// Summary: JSONL-based history storage for tmux popup submissions
+package tmuxedit
+
+import (
+ "encoding/json"
+ "fmt"
+ "os"
+ "path/filepath"
+ "time"
+
+ "codeberg.org/snonux/hexai/internal/appconfig"
+)
+
+// HistoryEntry represents a single submission to the AI agent via tmux popup.
+// Stored in JSONL format (one JSON object per line) for easy appending and reading.
+type HistoryEntry struct {
+ Timestamp string `json:"timestamp"` // RFC3339 format
+ Agent string `json:"agent"` // AI agent name (e.g., "claude", "aider")
+ Cwd string `json:"cwd"` // Current working directory at submission time
+ Text string `json:"text"` // The submitted text
+}
+
+// AppendHistory appends a new history entry to the history file.
+// Uses atomic write pattern (write to temp file, then rename) for safety.
+func AppendHistory(text, agent, cwd string) error {
+ stateDir, err := appconfig.StateDir()
+ if err != nil {
+ return fmt.Errorf("cannot get state directory: %w", err)
+ }
+
+ historyPath := filepath.Join(stateDir, "tmux-edit-history.jsonl")
+
+ // Create entry with current timestamp
+ entry := HistoryEntry{
+ Timestamp: time.Now().Format(time.RFC3339),
+ Agent: agent,
+ Cwd: cwd,
+ Text: text,
+ }
+
+ // Marshal to JSON
+ data, err := json.Marshal(entry)
+ if err != nil {
+ return fmt.Errorf("cannot marshal history entry: %w", err)
+ }
+
+ // Append newline for JSONL format
+ data = append(data, '\n')
+
+ // Open file in append mode, create if doesn't exist
+ f, err := os.OpenFile(historyPath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0o644)
+ if err != nil {
+ return fmt.Errorf("cannot open history file: %w", err)
+ }
+ defer f.Close()
+
+ // Write entry
+ if _, err := f.Write(data); err != nil {
+ return fmt.Errorf("cannot write history entry: %w", err)
+ }
+
+ return nil
+}
+
+// GetHistory retrieves the most recent history entries (up to limit).
+// Returns entries in chronological order (oldest first).
+// If limit <= 0, returns all entries.
+func GetHistory(limit int) ([]HistoryEntry, error) {
+ stateDir, err := appconfig.StateDir()
+ if err != nil {
+ return nil, fmt.Errorf("cannot get state directory: %w", err)
+ }
+
+ historyPath := filepath.Join(stateDir, "tmux-edit-history.jsonl")
+
+ // Read entire file
+ data, err := os.ReadFile(historyPath)
+ if err != nil {
+ if os.IsNotExist(err) {
+ return []HistoryEntry{}, nil // Empty history is not an error
+ }
+ return nil, fmt.Errorf("cannot read history file: %w", err)
+ }
+
+ // Parse JSONL line by line
+ var entries []HistoryEntry
+ lines := splitLines(data)
+ for i, line := range lines {
+ if len(line) == 0 {
+ continue // Skip empty lines
+ }
+
+ var entry HistoryEntry
+ if err := json.Unmarshal(line, &entry); err != nil {
+ // Log error but continue parsing (don't fail entire history on one bad line)
+ fmt.Fprintf(os.Stderr, "warning: cannot parse history entry at line %d: %v\n", i+1, err)
+ continue
+ }
+ entries = append(entries, entry)
+ }
+
+ // Apply limit if specified
+ if limit > 0 && len(entries) > limit {
+ // Return the most recent entries
+ entries = entries[len(entries)-limit:]
+ }
+
+ return entries, nil
+}
+
+// splitLines splits data into lines (handles both \n and \r\n)
+func splitLines(data []byte) [][]byte {
+ var lines [][]byte
+ start := 0
+ for i := 0; i < len(data); i++ {
+ if data[i] == '\n' {
+ // Include everything before the newline (excluding \r if present)
+ end := i
+ if end > start && data[end-1] == '\r' {
+ end--
+ }
+ lines = append(lines, data[start:end])
+ start = i + 1
+ }
+ }
+ // Handle last line if it doesn't end with newline
+ if start < len(data) {
+ lines = append(lines, data[start:])
+ }
+ return lines
+}