feat(ui): фильтр уровней логов в панели «Логи»

internal/events/log_test.go

@@ -21,7 +21,8 @@ func TestLogWriterLines(t *testing.T) {
 	if !ok {
 		t.Fatalf("got %T, want LogLine", first)
 	}
-	if ll.Text != "first line" || ll.Level != "log" {
+	// строка без маркеров ошибок/отладки — информационная
+	if ll.Text != "first line" || ll.Level != LevelInfo {
 		t.Fatalf("unexpected first line: %+v", ll)
 	}
 
@@ -73,4 +74,49 @@ func TestLogWriterMultiSplit(t *testing.T) {
 	if strings.Join(texts, ",") != "line1,line2,line3" {
 		t.Fatalf("got %v", texts)
 	}
+}
+
+// ClassifyLevel определяет уровень строки по маркерам в тексте.
+func TestClassifyLevel(t *testing.T) {
+	cases := []struct {
+		line string
+		want string
+	}{
+		{"app: db opened /tmp/r.db", LevelInfo},
+		{"app: worker started", LevelInfo},
+		{"opencode: debug: poll request", LevelDebug},
+		{"trace: session resumed", LevelDebug},
+		{"tg: warn: long poll timeout", LevelWarning},
+		{"ПРЕДУПРЕЖДЕНИЕ: конфиг не задан", LevelWarning},
+		{"app: process /start #5: run failed: exit status 1", LevelError},
+		{"ERROR: connection refused", LevelError},
+		{"worker: job failed after 3 retries", LevelError},
+		{"panic: runtime error", LevelError},
+	}
+	for _, c := range cases {
+		if got := ClassifyLevel(c.line); got != c.want {
+			t.Errorf("ClassifyLevel(%q) = %q, want %q", c.line, got, c.want)
+		}
+	}
+}
+
+// LogWriter публикует уровень, определённый по тексту строки.
+func TestLogWriterClassifiesLevels(t *testing.T) {
+	lbus := NewLogBus(16)
+	ch, unsub := lbus.Subscribe()
+	defer unsub()
+
+	w := NewLogWriter(lbus)
+	if _, err := w.Write([]byte("all good\nERROR: boom\n")); err != nil {
+		t.Fatalf("Write: %v", err)
+	}
+
+	first := receiveOne(t, ch).(LogLine)
+	if first.Level != LevelInfo || first.Text != "all good" {
+		t.Fatalf("unexpected first: %+v", first)
+	}
+	second := receiveOne(t, ch).(LogLine)
+	if second.Level != LevelError || second.Text != "ERROR: boom" {
+		t.Fatalf("unexpected second: %+v", second)
+	}
 }