Add stream event table renderer

1 files changed, 157 insertions, 0 deletions

diff --git a/internal/tui/eventstream/render.go b/internal/tui/eventstream/render.go
new file mode 100644
index 0000000..3fd2d26
--- /dev/null
+++ b/internal/tui/eventstream/render.go
@@ -0,0 +1,157 @@
+package eventstream
+
+import (
+	"fmt"
+	"ior/internal/tui/common"
+	"strconv"
+	"strings"
+)
+
+type columnLayout struct {
+	gap     int
+	latency int
+	comm    int
+	pidTid  int
+	syscall int
+	ret     int
+	bytes   int
+	file    int
+}
+
+func RenderStreamTable(width int, paused bool, totalCount, filteredCount, bufferLen, bufferCap int, filter Filter, events []StreamEvent) string {
+	if width <= 0 {
+		width = 100
+	}
+
+	lines := make([]string, 0, len(events)+3)
+	lines = append(lines, renderStatusLine(paused, totalCount, filteredCount, bufferLen, bufferCap))
+	lines = append(lines, renderFilterLine(filter))
+	lines = append(lines, renderColumnHeader(width))
+	for _, ev := range events {
+		lines = append(lines, renderEventRow(ev, width))
+	}
+
+	return common.PanelStyle.Width(width).Render(strings.Join(lines, "\n"))
+}
+
+func renderStatusLine(paused bool, totalCount, filteredCount, bufferLen, bufferCap int) string {
+	state := common.HighlightStyle.Render("LIVE")
+	if paused {
+		state = common.ErrorStyle.Render("PAUSED")
+	}
+	buffer := strconv.Itoa(bufferLen)
+	if bufferCap > 0 {
+		buffer = fmt.Sprintf("%d/%d", bufferLen, bufferCap)
+	}
+	return fmt.Sprintf("%s | total:%d filtered:%d buffer:%s", state, totalCount, filteredCount, buffer)
+}
+
+func renderFilterLine(filter Filter) string {
+	summary := filter.Summary()
+	if summary == "all" {
+		summary = common.HighlightStyle.Render(summary)
+	}
+	return common.HeaderStyle.Render("Filter:") + " " + summary
+}
+
+func renderColumnHeader(width int) string {
+	cols := computeColumnLayout(width)
+	header := fmt.Sprintf("%-*s %-*s %-*s %-*s %-*s %-*s %-*s %s",
+		cols.gap, "Gap",
+		cols.latency, "Latency",
+		cols.comm, "Comm",
+		cols.pidTid, "PID.TID",
+		cols.syscall, "Syscall",
+		cols.ret, "Ret",
+		cols.bytes, "Bytes",
+		"File",
+	)
+	return common.HelpBarStyle.Render(header)
+}
+
+func renderEventRow(ev StreamEvent, width int) string {
+	cols := computeColumnLayout(width)
+	pidTid := fmt.Sprintf("%d.%d", ev.PID, ev.TID)
+	row := fmt.Sprintf("%-*s %-*s %-*s %-*s %-*s %-*d %-*d %s",
+		cols.gap, formatDurationNs(ev.GapNs),
+		cols.latency, formatDurationNs(ev.DurationNs),
+		cols.comm, truncateMiddle(ev.Comm, cols.comm),
+		cols.pidTid, truncateMiddle(pidTid, cols.pidTid),
+		cols.syscall, truncateMiddle(ev.Syscall, cols.syscall),
+		cols.ret, ev.RetVal,
+		cols.bytes, ev.Bytes,
+		truncateMiddle(ev.FileName, cols.file),
+	)
+	if ev.IsError {
+		return common.ErrorStyle.Render(row)
+	}
+	return row
+}
+
+func computeColumnLayout(width int) columnLayout {
+	if width <= 0 {
+		width = 100
+	}
+
+	gap := 8
+	latency := 9
+	comm := 14
+	pidTid := 12
+	syscall := 11
+	ret := 6
+	bytes := 10
+	fixed := gap + latency + comm + pidTid + syscall + ret + bytes + 7
+	file := width - fixed
+	if file >= 18 {
+		return columnLayout{gap: gap, latency: latency, comm: comm, pidTid: pidTid, syscall: syscall, ret: ret, bytes: bytes, file: file}
+	}
+
+	if width < 90 {
+		comm = 10
+		syscall = 9
+	} else {
+		comm = 12
+		syscall = 10
+	}
+	fixed = gap + latency + comm + pidTid + syscall + ret + bytes + 7
+	file = width - fixed
+	if file < 8 {
+		file = 8
+	}
+	return columnLayout{gap: gap, latency: latency, comm: comm, pidTid: pidTid, syscall: syscall, ret: ret, bytes: bytes, file: file}
+}
+
+func formatDurationNs(v uint64) string {
+	if v < 1000 {
+		return fmt.Sprintf("%dns", v)
+	}
+	us := float64(v) / 1000
+	if us < 1000 {
+		return fmt.Sprintf("%.1fus", us)
+	}
+	ms := us / 1000
+	if ms < 1000 {
+		return fmt.Sprintf("%.1fms", ms)
+	}
+	s := ms / 1000
+	return fmt.Sprintf("%.2fs", s)
+}
+
+func truncateMiddle(path string, limit int) string {
+	if limit <= 0 {
+		return ""
+	}
+	if len(path) <= limit {
+		return path
+	}
+	if limit <= 3 {
+		return path[:limit]
+	}
+
+	head := (limit - 3) / 2
+	tail := limit - 3 - head
+	if tail <= 0 {
+		return path[:limit]
+	}
+	return path[:head] + "..." + path[len(path)-tail:]
+}