feat: add stdin/pipe reader for command composability

.gitignore

@@ -1,4 +1,4 @@
-logpilot
+/logpilot
 *.exe
 dist/
 .DS_Store

cmd/logpilot/main.go

@@ -1,10 +1,15 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"os"
+	"os/signal"
+	"syscall"
 
 	tea "github.com/charmbracelet/bubbletea"
+	"github.com/clarabennett2626/logpilot/internal/parser"
+	"github.com/clarabennett2626/logpilot/internal/source"
 	"github.com/clarabennett2626/logpilot/internal/tui"
 )
 
@@ -20,10 +25,54 @@ func main() {
 		os.Exit(0)
 	}
 
+	// If stdin is a pipe, run in streaming mode (no TUI).
+	if source.IsPipe() {
+		if err := runPipeMode(); err != nil {
+			fmt.Fprintf(os.Stderr, "Error: %v\n", err)
+			os.Exit(1)
+		}
+		return
+	}
+
 	p := tea.NewProgram(tui.NewModel(), tea.WithAltScreen())
 	if _, err := p.Run(); err != nil {
 		fmt.Fprintf(os.Stderr, "Error: %v\n", err)
 		os.Exit(1)
 	}
 }
 
+// runPipeMode reads from stdin, parses each line, and renders output to stdout.
+func runPipeMode() error {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	// Handle signals for graceful shutdown.
+	sigCh := make(chan os.Signal, 1)
+	signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)
+	go func() {
+		<-sigCh
+		cancel()
+	}()
+
+	src := source.NewStdinSource()
+	autoParser := parser.NewAutoParser()
+	renderer := tui.NewRenderer(tui.DefaultConfig())
+
+	// Start reading stdin in a goroutine.
+	errCh := make(chan error, 1)
+	go func() {
+		errCh <- src.Start(ctx)
+	}()
+
+	// Consume lines and render them.
+	for entry := range src.Lines() {
+		parsed := autoParser.Parse(entry.Line)
+		fmt.Println(renderer.RenderEntry(parsed))
+	}
+
+	// Check for read errors.
+	if err := <-errCh; err != nil && ctx.Err() == nil {
+		return err
+	}
+	return nil
+}

cmd/logpilot/main_test.go

@@ -0,0 +1,81 @@
+package main
+
+import (
+	"bytes"
+	"os/exec"
+	"strings"
+	"testing"
+)
+
+func TestPipeMode_JSON(t *testing.T) {
+	cmd := exec.Command("go", "run", ".")
+	cmd.Stdin = strings.NewReader(`{"level":"info","msg":"hello","ts":"2024-01-01T00:00:00Z"}` + "\n")
+	var out bytes.Buffer
+	cmd.Stdout = &out
+	cmd.Stderr = &bytes.Buffer{}
+
+	if err := cmd.Run(); err != nil {
+		t.Fatalf("command failed: %v", err)
+	}
+
+	output := out.String()
+	if !strings.Contains(output, "hello") {
+		t.Errorf("expected output to contain 'hello', got: %q", output)
+	}
+}
+
+func TestPipeMode_MultiFormat(t *testing.T) {
+	input := `{"level":"info","msg":"json line"}
+level=warn msg="logfmt line"
+plain text line
+`
+	cmd := exec.Command("go", "run", ".")
+	cmd.Stdin = strings.NewReader(input)
+	var out bytes.Buffer
+	cmd.Stdout = &out
+	cmd.Stderr = &bytes.Buffer{}
+
+	if err := cmd.Run(); err != nil {
+		t.Fatalf("command failed: %v", err)
+	}
+
+	output := out.String()
+	for _, want := range []string{"json line", "logfmt line", "plain text line"} {
+		if !strings.Contains(output, want) {
+			t.Errorf("expected output to contain %q, got: %q", want, output)
+		}
+	}
+}
+
+func TestPipeMode_EmptyInput(t *testing.T) {
+	cmd := exec.Command("go", "run", ".")
+	cmd.Stdin = strings.NewReader("")
+	var out bytes.Buffer
+	cmd.Stdout = &out
+	cmd.Stderr = &bytes.Buffer{}
+
+	if err := cmd.Run(); err != nil {
+		t.Fatalf("command failed: %v", err)
+	}
+
+	if out.Len() != 0 {
+		t.Errorf("expected no output for empty input, got: %q", out.String())
+	}
+}
+
+func TestPipeMode_LongLine(t *testing.T) {
+	long := strings.Repeat("x", 500_000)
+	cmd := exec.Command("go", "run", ".")
+	cmd.Stdin = strings.NewReader(long + "\n")
+	var out bytes.Buffer
+	cmd.Stdout = &out
+	cmd.Stderr = &bytes.Buffer{}
+
+	if err := cmd.Run(); err != nil {
+		t.Fatalf("command failed: %v", err)
+	}
+
+	if !strings.Contains(out.String(), "xxx") {
+		t.Error("expected long line to be processed")
+	}
+}