feat: implement strata query input and improve pulse grouping

- Implement interactive query prompt in Strata UI when pressing '/'
- Fix Strata startup schema error by ignoring empty queries on connection
- Clean up Pulse groups view by normalizing timestamps to <TIMESTAMP> and IPs to <IP>

Signed-off-by: night-slayer18 <samanuaia257@gmail.com>

Author: night-slayer18

apps/pulse/internal/model/group.go

@@ -11,18 +11,22 @@ import (
 // more specific patterns (UUIDs, hex) must run before the generic number
 // pattern would otherwise partially rewrite them.
 var (
-	reUUID   = regexp.MustCompile(`(?i)\b[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}\b`)
-	reHex    = regexp.MustCompile(`(?i)\b0x[0-9a-f]+\b|\b[0-9a-f]{8,}\b`)
-	reNumber = regexp.MustCompile(`\b\d+(\.\d+)?\b`)
-	reSpaces = regexp.MustCompile(`\s+`)
+	reUUID      = regexp.MustCompile(`(?i)\b[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}\b`)
+	reTimestamp = regexp.MustCompile(`\b\d{4}-\d{2}-\d{2}[T ]\d{2}:\d{2}:\d{2}(?:\.\d+)?(?:Z|[+-]\d{2}:?\d{2})?\b`)
+	reIP        = regexp.MustCompile(`\b\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}\b`)
+	reHex       = regexp.MustCompile(`(?i)\b0x[0-9a-f]+\b|\b[0-9a-f]{8,}\b`)
+	reNumber    = regexp.MustCompile(`\b\d+(\.\d+)?\b`)
+	reSpaces    = regexp.MustCompile(`\s+`)
 )
 
-// Normalize collapses the variable parts of a log line — UUIDs, hex strings,
-// and numeric literals — into fixed placeholder tokens and squeezes runs of
-// whitespace. Two log lines that differ only in those variable parts normalize
-// to the same template, which is the basis for grouping similar errors.
+// Normalize collapses the variable parts of a log line — UUIDs, timestamps,
+// IP addresses, hex strings, and numeric literals — into fixed placeholder tokens
+// and squeezes runs of whitespace. Two log lines that differ only in those variable
+// parts normalize to the same template, which is the basis for grouping similar errors.
 func Normalize(line string) string {
 	s := reUUID.ReplaceAllString(line, "<UUID>")
+	s = reTimestamp.ReplaceAllString(s, "<TIMESTAMP>")
+	s = reIP.ReplaceAllString(s, "<IP>")
 	s = reHex.ReplaceAllString(s, "<HEX>")
 	s = reNumber.ReplaceAllString(s, "<NUM>")
 	s = reSpaces.ReplaceAllString(s, " ")

apps/pulse/internal/model/group_test.go

@@ -34,6 +34,31 @@ func TestNormalizeCollapsesWhitespace(t *testing.T) {
 	}
 }
 
+func TestNormalizeReplacesTimestamp(t *testing.T) {
+	cases := []struct {
+		in   string
+		want string
+	}{
+		{"2024-05-17 09:00:01 INFO log message", "<TIMESTAMP> INFO log message"},
+		{"time=2024-05-17T09:00:01Z level=info", "time=<TIMESTAMP> level=info"},
+		{"time=2024-05-17T09:00:01.123456Z level=info", "time=<TIMESTAMP> level=info"},
+		{"time=2024-05-17T09:00:01+05:30 level=info", "time=<TIMESTAMP> level=info"},
+	}
+	for _, tc := range cases {
+		if got := Normalize(tc.in); got != tc.want {
+			t.Errorf("Normalize(%q) = %q, want %q", tc.in, got, tc.want)
+		}
+	}
+}
+
+func TestNormalizeReplacesIP(t *testing.T) {
+	got := Normalize("client 10.0.4.18 exceeded limit")
+	want := "client <IP> exceeded limit"
+	if got != want {
+		t.Fatalf("got %q want %q", got, want)
+	}
+}
+
 func TestGroupSimilarCollapsesByTemplate(t *testing.T) {
 	in := entries(
 		"connection failed for user 1",

apps/strata/internal/ui/root.go

@@ -25,6 +25,10 @@ type Root struct {
 	size     tui.Size
 	showHelp bool
 
+	// searching reports whether the query input line is active.
+	searching bool
+	// queryInput holds the in-progress query while searching.
+	queryInput string
 	// conn is the connection string supplied on the command line, if any. It is
 	// resolved to a backend + DSN and connected on Init.
 	conn string
@@ -87,15 +91,60 @@ func (r Root) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 		r.connect(msg.conn)
 		return r, nil
 	case tea.KeyMsg:
-		switch r.keys.Dispatch(msg) {
-		case tui.ActionQuit:
-			return r, tea.Quit
-		case tui.ActionHelp:
-			r.showHelp = !r.showHelp
-		case tui.ActionUp, tui.ActionDown, tui.ActionLeft, tui.ActionRight,
-			tui.ActionPageUp, tui.ActionPageDown, tui.ActionTop, tui.ActionBottom:
-			r.state.Table.Navigate(msg.String())
+		return r.handleKey(msg)
+	}
+	return r, nil
+}
+
+// handleKey routes key presses either to the query input line or to standard navigation.
+func (r Root) handleKey(msg tea.KeyMsg) (tea.Model, tea.Cmd) {
+	if r.searching {
+		return r.handleSearchKey(msg)
+	}
+
+	switch r.keys.Dispatch(msg) {
+	case tui.ActionQuit:
+		return r, tea.Quit
+	case tui.ActionHelp:
+		r.showHelp = !r.showHelp
+	case tui.ActionSearch:
+		r.searching = true
+		// Pre-populate input with current query if any
+		r.queryInput = ""
+	case tui.ActionUp, tui.ActionDown, tui.ActionLeft, tui.ActionRight,
+		tui.ActionPageUp, tui.ActionPageDown, tui.ActionTop, tui.ActionBottom:
+		r.state.Table.Navigate(msg.String())
+	}
+	return r, nil
+}
+
+// handleSearchKey handles character input and executes or cancels queries.
+func (r Root) handleSearchKey(msg tea.KeyMsg) (tea.Model, tea.Cmd) {
+	switch msg.Type {
+	case tea.KeyEnter:
+		r.searching = false
+		if r.queryInput != "" {
+			r.state.SetSchemaQuery(r.queryInput)
+			if _, err := r.state.ReadSchema(); err != nil {
+				r.status = fmt.Sprintf("schema error: %v", err)
+				return r, nil
+			}
+			n, err := r.state.RunQuery(r.queryInput)
+			if err != nil {
+				r.status = fmt.Sprintf("query error: %v", err)
+				return r, nil
+			}
+			r.status = fmt.Sprintf("loaded %d rows", n)
 		}
+	case tea.KeyEsc:
+		r.searching = false
+		r.queryInput = ""
+	case tea.KeyBackspace:
+		if len(r.queryInput) > 0 {
+			r.queryInput = r.queryInput[:len(r.queryInput)-1]
+		}
+	case tea.KeyRunes, tea.KeySpace:
+		r.queryInput += string(msg.Runes)
 	}
 	return r, nil
 }
@@ -115,7 +164,9 @@ func (r Root) View() string {
 	}
 
 	var footer string
-	if r.showHelp {
+	if r.searching {
+		footer = r.styles.Footer.Width(r.size.Width).Render("Query: " + r.queryInput + "▏")
+	} else if r.showHelp {
 		footer = r.styles.Footer.Width(r.size.Width).Render(r.help.View(r.keys))
 	} else {
 		hints := r.help.ShortHelpView(r.keys.ShortHelp())
@@ -143,10 +194,17 @@ func (r *Root) connect(conn string) {
 		r.status = fmt.Sprintf("connect %s: %v", backend, err)
 		return
 	}
-	// For SQL backends, derive the schema from the connected database/table the
-	// user is exploring. When the source exposes fixed metadata this is a no-op.
+	// For SQL/NoSQL backends, derive the schema from the connected database/table the
+	// user is exploring. Ignore initial lack of query/collection errors.
 	if _, err := r.state.ReadSchema(); err != nil {
-		r.status = err.Error()
+		errMsg := err.Error()
+		if strings.Contains(errMsg, "no schema query configured") ||
+			strings.Contains(errMsg, "no collection configured") ||
+			strings.Contains(errMsg, "no table configured") {
+			r.status = fmt.Sprintf("connected to %s", backend)
+			return
+		}
+		r.status = errMsg
 		return
 	}
 	r.status = fmt.Sprintf("connected to %s", backend)