feat: working on the split engine, lots of progress.

Need colors and a real display.

internal/tui/messages.go

@@ -0,0 +1,11 @@
+package tui
+
+import "termtap.dev/internal/model"
+
+type EventMsg struct {
+	value model.Event
+}
+
+type ErrMsg struct {
+	err error
+}

internal/tui/model.go

@@ -4,58 +4,55 @@ import (
 	"fmt"
 
 	tea "github.com/charmbracelet/bubbletea"
-	"github.com/google/uuid"
 	"termtap.dev/internal/model"
 )
 
+// TODO: How big can we actually make this?
 const (
-	maxEvents   = 200
-	maxRequests = 200
+	maxEvents   = 256
+	maxRequests = 256
 )
 
-type EventMsg struct {
-	value model.Event
-}
-
-type ErrMsg struct {
-	err error
-}
-
 type Model struct {
-	msgCh <-chan model.Event
+	channel <-chan model.Event
 
-	events       []model.Event
-	requestOrder []uuid.UUID
-	requests     map[uuid.UUID]model.Request
+	events   []model.Event
+	requests []model.Request
 
 	width  int
 	height int
+
+	showEvents bool
+	showStd    bool
+	showSearch bool
 }
 
-func NewModel(msgCh <-chan model.Event) Model {
+func NewModel(ch <-chan model.Event) Model {
 	return Model{
-		msgCh:        msgCh,
-		events:       make([]model.Event, 0, maxEvents),
-		requestOrder: make([]uuid.UUID, 0, maxRequests),
-		requests:     map[uuid.UUID]model.Request{},
-		width:        100,
-		height:       28,
+		channel:    ch,
+		events:     make([]model.Event, 0, maxEvents),
+		requests:   make([]model.Request, 0, maxRequests),
+		width:      0,
+		height:     0,
+		showEvents: false,
+		showStd:    false,
+		showSearch: false,
 	}
 }
 
-func Run(msgCh <-chan model.Event) error {
-	p := tea.NewProgram(NewModel(msgCh), tea.WithAltScreen())
+func Run(ch <-chan model.Event) error {
+	p := tea.NewProgram(NewModel(ch), tea.WithAltScreen())
 	_, err := p.Run()
 	return err
 }
 
 func (m Model) Init() tea.Cmd {
-	return waitForAppMessage(m.msgCh)
+	return waitForEvent(m.channel)
 }
 
-func waitForAppMessage(msgCh <-chan model.Event) tea.Cmd {
+func waitForEvent(ch <-chan model.Event) tea.Cmd {
 	return func() tea.Msg {
-		msg, ok := <-msgCh
+		msg, ok := <-ch
 		if !ok {
 			return ErrMsg{err: fmt.Errorf("event channel closed")}
 		}

internal/tui/split.go

@@ -0,0 +1,110 @@
+package tui
+
+import "strings"
+
+func (m Model) renderAppPane() string {
+	var (
+		searchW int = m.width
+		searchH int = 1
+
+		reqW int = int(float64(m.width) * 0.6)
+		reqH int = m.height
+
+		detW int = int(float64(m.width) * 0.4)
+		detH int = m.height
+
+		eventW int = m.width
+		eventH int = int(float64(m.height) * 0.15)
+
+		stdW int = m.width
+		stdH int = int(float64(m.height) * 0.2)
+	)
+
+	if m.showSearch {
+		reqH -= searchH
+		detH -= searchH
+	}
+
+	if m.showEvents {
+		reqH -= eventH
+		detH -= eventH
+	}
+
+	if m.showStd {
+		reqH -= stdH
+		detH -= stdH
+	}
+
+	reqPane := m.renderRequestPane(reqW, reqH)
+	detPane := m.renderDetailsPane(detW, detH)
+
+	if len(reqPane) != len(detPane) {
+		return "height of request and details did not match"
+	}
+
+	var screen []string
+	if m.showSearch {
+		searchPane := m.renderSearchPane(searchW, searchH)
+		screen = append(screen, searchPane...)
+	}
+
+	for i := range reqPane {
+		screen = append(screen, reqPane[i]+detPane[i])
+	}
+
+	if m.showEvents {
+		eventPane := m.renderEventsPane(eventW, eventH)
+		screen = append(screen, eventPane...)
+	}
+
+	if m.showStd {
+		stdPane := m.renderStdPane(stdW, stdH)
+		screen = append(screen, stdPane...)
+	}
+
+	if len(screen) != m.height {
+		return "height of screen does not match terminal height"
+	}
+
+	return strings.Join(screen, ("\n"))
+}
+
+func (m Model) renderSearchPane(w, h int) []string {
+	lines := make([]string, h)
+	for y := range lines {
+		lines[y] = strings.Repeat(" ", w)
+	}
+	return lines
+}
+
+func (m Model) renderRequestPane(w, h int) []string {
+	lines := make([]string, h)
+	for y := range lines {
+		lines[y] = strings.Repeat(".", w)
+	}
+	return lines
+}
+
+func (m Model) renderDetailsPane(w, h int) []string {
+	lines := make([]string, h)
+	for y := range lines {
+		lines[y] = strings.Repeat("^", w)
+	}
+	return lines
+}
+
+func (m Model) renderEventsPane(w, h int) []string {
+	lines := make([]string, h)
+	for y := range lines {
+		lines[y] = strings.Repeat("~", w)
+	}
+	return lines
+}
+
+func (m Model) renderStdPane(w, h int) []string {
+	lines := make([]string, h)
+	for y := range lines {
+		lines[y] = strings.Repeat(" ", w)
+	}
+	return lines
+}

internal/tui/update.go

@@ -4,7 +4,6 @@ import (
 	"fmt"
 
 	tea "github.com/charmbracelet/bubbletea"
-	"github.com/google/uuid"
 	"termtap.dev/internal/model"
 )
 
@@ -15,10 +14,19 @@ func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 		m.height = msg.Height
 		return m, nil
 
+	// TODO: Abstract the keymaps
 	case tea.KeyMsg:
 		switch msg.String() {
-		case "ctrl+c", "q", "esc":
+		case "ctrl+c", "q":
 			return m, tea.Quit
+		case "e":
+			m.showEvents = !m.showEvents
+		case "o":
+			m.showStd = !m.showStd
+		case "/":
+			m.showSearch = true
+		case "esc":
+			m.showSearch = false
 		}
 		return m, nil
 
@@ -32,7 +40,7 @@ func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 	case EventMsg:
 		m.pushEvent(msg.value)
 		m.applyMessage(msg.value)
-		return m, waitForAppMessage(m.msgCh)
+		return m, waitForEvent(m.channel)
 	}
 
 	return m, nil
@@ -48,30 +56,29 @@ func (m *Model) pushEvent(msg model.Event) {
 func (m *Model) applyMessage(msg model.Event) {
 	switch msg.Type {
 	case model.EventTypeRequestStarted:
-		m.upsertRequest(msg.Request, true)
+		m.createRequest(msg.Request)
 	case model.EventTypeRequestFinished, model.EventTypeRequestFailed:
-		m.upsertRequest(msg.Request, false)
+		m.updateRequest(msg.Request)
 	}
 }
 
-func (m *Model) upsertRequest(req model.Request, addIfMissing bool) {
-	if req.ID == uuid.Nil {
-		return
-	}
+func (m *Model) createRequest(req model.Request) {
+	m.requests = append(m.requests, req)
 
-	_, exists := m.requests[req.ID]
-	if !exists && !addIfMissing {
-		return
+	// If we passed the max, delete the first one
+	// Maybe we should notify the user?
+	if len(m.requests) > maxRequests {
+		m.requests = m.requests[1:]
 	}
+}
 
-	if !exists {
-		m.requestOrder = append(m.requestOrder, req.ID)
-		if len(m.requestOrder) > maxRequests {
-			drop := m.requestOrder[0]
-			delete(m.requests, drop)
-			m.requestOrder = m.requestOrder[1:]
+func (m *Model) updateRequest(req model.Request) {
+	// Traverse backward, since the newest one is at the end, and its likely we will be
+	// updated a new request.
+	for i := len(m.requests) - 1; i >= 0; i-- {
+		if m.requests[i].ID == req.ID {
+			m.requests[i] = req
+			break
 		}
 	}
-
-	m.requests[req.ID] = req
 }

internal/tui/view.go

@@ -9,20 +9,23 @@ import (
 
 // TODO: This is all temporary
 func (m Model) View() string {
-	eventLines := m.renderEvents(8)
-	requestLines := m.renderRequests(12)
+	return m.renderAppPane()
 
-	return strings.Join([]string{
-		"termtap - live session",
-		fmt.Sprintf("events=%d requests=%d", len(m.events), len(m.requestOrder)),
-		"keys: q/esc/ctrl+c quit",
-		"",
-		"Recent events:",
-		eventLines,
-		"",
-		"Recent requests:",
-		requestLines,
-	}, "\n")
+	// eventLines := m.renderEvents(8)
+	// requestLines := m.renderRequests(12)
+	//
+	// return strings.Join([]string{
+	// 	"termtap - live session",
+	// 	fmt.Sprintf("events=%d requests=%d", len(m.events), len(m.requests)),
+	// 	fmt.Sprintf("%dx%d", m.height, m.width),
+	// 	"keys: q/esc/ctrl+c quit",
+	// 	"",
+	// 	"Recent events:",
+	// 	eventLines,
+	// 	"",
+	// 	"Recent requests:",
+	// 	requestLines,
+	// }, "\n")
 }
 
 func (m Model) renderEvents(limit int) string {
@@ -42,22 +45,16 @@ func (m Model) renderEvents(limit int) string {
 }
 
 func (m Model) renderRequests(limit int) string {
-	if len(m.requestOrder) == 0 {
+	if len(m.requests) == 0 {
 		return "  (none yet)"
 	}
 
-	start := len(m.requestOrder) - limit
-	if start < 0 {
-		start = 0
-	}
+	start := max(0, len(m.requests)-limit)
 
-	rows := make([]string, 0, len(m.requestOrder)-start)
-	for i := start; i < len(m.requestOrder); i++ {
-		id := m.requestOrder[i]
-		req, ok := m.requests[id]
-		if !ok {
-			continue
-		}
+	// Traverse backwards since we don't have a stack
+	rows := make([]string, 0, len(m.requests)-start)
+	for i := len(m.requests) - 1; i >= start; i-- {
+		req := m.requests[i]
 
 		state := "done"
 		if req.Pending {