package eventstream

import (
	"strings"
	"testing"

	"charm.land/lipgloss/v2"
)

func TestRenderStatusAndFilterLines(t *testing.T) {
	events := []StreamEvent{{Syscall: "read", Comm: "nginx", PID: 1, TID: 2, DurationNs: 1200, GapNs: 300, Bytes: 64, FileName: "/tmp/a", RetVal: 64}}
	f := Filter{Syscall: &StringFilter{Pattern: "read"}, PID: &NumericFilter{Op: OpEq, Value: 1}}
	out := RenderStreamTable(120, false, 100, 1, 100, 10000, f, nil, events, -1, -1)

	for _, want := range []string{"LIVE", "total:100", "filtered:1", "buffer:100/10000", "Filter:", "syscall~read", "pid=1"} {
		if !strings.Contains(out, want) {
			t.Fatalf("output missing %q\n%s", want, out)
		}
	}
}

func TestRenderPausedAndErrorRow(t *testing.T) {
	events := []StreamEvent{{Syscall: "write", Comm: "worker", PID: 1, TID: 2, DurationNs: 1000000, GapNs: 5000, Bytes: 32, FileName: "/tmp/b", RetVal: -1, IsError: true}}
	out := RenderStreamTable(120, true, 10, 1, 10, 10000, Filter{}, nil, events, -1, -1)

	if !strings.Contains(out, "PAUSED") {
		t.Fatalf("expected PAUSED indicator\n%s", out)
	}
	if !strings.Contains(out, "-1") {
		t.Fatalf("expected return value in row\n%s", out)
	}
	if !strings.Contains(out, "worker") || !strings.Contains(out, "write") {
		t.Fatalf("expected event row in output\n%s", out)
	}
}

func TestRenderShowsFDWhenPresent(t *testing.T) {
	events := []StreamEvent{{Syscall: "read", Comm: "worker", PID: 1, TID: 2, FD: 9, DurationNs: 10, GapNs: 1, Bytes: 8, FileName: "/tmp/b", RetVal: 8}}
	out := RenderStreamTable(120, false, 1, 1, 1, 10000, Filter{}, nil, events, -1, -1)
	if !strings.Contains(out, "FD") || !strings.Contains(out, " 9 ") {
		t.Fatalf("expected FD column/value in output\n%s", out)
	}
}

func TestRenderHeaderAndTruncate(t *testing.T) {
	events := []StreamEvent{{
		Syscall:    "very_long_syscall_name",
		Comm:       "very-long-command-name",
		PID:        1,
		TID:        2,
		DurationNs: 2_000_000,
		GapNs:      100,
		Bytes:      4096,
		FileName:   "/very/long/path/that/should/be/truncated/for/narrow/views/file.log",
		RetVal:     1,
	}}
	out := RenderStreamTable(80, false, 1, 1, 1, 10000, Filter{}, nil, events, -1, -1)

	for _, col := range []string{"Gap", "Latency", "Comm", "PID", "TID", "Syscall", "FD", "Ret", "Bytes", "File"} {
		if !strings.Contains(out, col) {
			t.Fatalf("missing column %q\n%s", col, out)
		}
	}
	if !strings.Contains(out, "...") {
		t.Fatalf("expected truncated field with ellipsis\n%s", out)
	}
}

func TestFormatDurationNs(t *testing.T) {
	cases := []struct {
		in   uint64
		want string
	}{
		{in: 999, want: "999ns"},
		{in: 1500, want: "1.5us"},
		{in: 2_000_000, want: "2.0ms"},
	}
	for _, tc := range cases {
		if got := formatDurationNs(tc.in); got != tc.want {
			t.Fatalf("formatDurationNs(%d) = %q, want %q", tc.in, got, tc.want)
		}
	}
}

func TestRenderEventRowIsSingleLineWithControlCharsAndLongValues(t *testing.T) {
	ev := StreamEvent{
		Syscall:    "very_very_long_syscall_name_that_would_otherwise_overflow",
		Comm:       "cmd\twith\tcontrols",
		PID:        1234567,
		TID:        7654321,
		DurationNs: 123456789012345,
		GapNs:      9988776655443322,
		Bytes:      18446744073709551615,
		FileName:   "/very/long/path/with/newline\nand\ttabs/that/should/not/wrap",
		RetVal:     -9223372036854775808,
	}

	row := renderEventRow(ev, streamColumns(80), false, -1)
	if strings.Contains(row, "\n") || strings.Contains(row, "\r") || strings.Contains(row, "\t") {
		t.Fatalf("expected a sanitized single-line row, got %q", row)
	}
	if !strings.Contains(row, "...") {
		t.Fatalf("expected truncation ellipsis in narrow row, got %q", row)
	}
}

func TestComputeColumnLayoutGivesFileMoreSpace(t *testing.T) {
	cols := computeColumnLayout(120)
	if cols.file < 44 {
		t.Fatalf("expected file column to get most width, got %d", cols.file)
	}
}

func TestRenderStreamTableFitsRequestedWidth(t *testing.T) {
	out := RenderStreamTable(80, false, 1, 1, 1, 10000, Filter{}, nil, []StreamEvent{
		{
			Syscall:    "read",
			Comm:       "worker",
			PID:        1,
			TID:        2,
			DurationNs: 2000,
			GapNs:      100,
			Bytes:      64,
			FileName:   "/very/long/path/that/should/be/truncated/for/narrow/views/file.log",
			RetVal:     1,
		},
	}, -1, -1)

	for _, line := range strings.Split(out, "\n") {
		if lipgloss.Width(line) > 80 {
			t.Fatalf("line exceeds width 80: %d %q", lipgloss.Width(line), line)
		}
	}
}

func TestRenderShowsFilterStackLine(t *testing.T) {
	out := RenderStreamTable(100, true, 3, 1, 3, 10000, Filter{Comm: &StringFilter{Pattern: "system"}}, []string{"comm~system", "fd=20"}, []StreamEvent{{Comm: "systemd", Syscall: "write"}}, -1, -1)
	for _, want := range []string{"Stack:", "comm~system", "fd=20"} {
		if !strings.Contains(out, want) {
			t.Fatalf("expected stack output missing %q\n%s", want, out)
		}
	}
}

func TestRenderFDTraceTableShowsHeaderAndScope(t *testing.T) {
	out := RenderFDTraceTable(100, 123, 7, 2, []StreamEvent{
		{Syscall: "read", PID: 123, TID: 1, FD: 7, FileName: "/tmp/a"},
		{Syscall: "write", PID: 123, TID: 2, FD: 7, FileName: "/tmp/a"},
	})
	for _, want := range []string{"FD Trace (ring snapshot)", "PID:123 FD:7 matched:2", "read", "write"} {
		if !strings.Contains(out, want) {
			t.Fatalf("output missing %q\n%s", want, out)
		}
	}
}