Консоль не пустеет после перезапуска менеджера

Номера строк консоли живут в памяти менеджера и после его перезапуска
начинаются заново, а открытая вкладка отбрасывает всё, чей номер не больше
последнего увиденного. После обновления панели консоль оставалась пустой при
живом сервере — до перезагрузки страницы.

У буфера появилась метка запуска: поток отдаёт её отдельным событием, и по
её смене вкладка сбрасывает счётчик, чистит экран и забирает историю нового
запуска заново.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

internal/api/handlers_server.go

@@ -79,7 +79,10 @@ func (s *Server) handleConsole(w http.ResponseWriter, r *http.Request) {
 // handleLogs отдаёт историю консоли начиная с указанного номера строки.
 func (s *Server) handleLogs(w http.ResponseWriter, r *http.Request) {
 	since, _ := strconv.ParseInt(r.URL.Query().Get("since"), 10, 64)
-	writeJSON(w, http.StatusOK, map[string]any{"lines": translateLines(r, s.sup.Lines(since))})
+	writeJSON(w, http.StatusOK, map[string]any{
+		"epoch": s.sup.LogEpoch(),
+		"lines": translateLines(r, s.sup.Lines(since)),
+	})
 }
 
 // translateLines переводит строки консоли на язык читающего. Буфер один на
@@ -119,7 +122,13 @@ func (s *Server) handleLogStream(w http.ResponseWriter, r *http.Request) {
 
 	lang := i18n.FromRequest(r)
 
-	// Сначала отдаём хвост истории, чтобы вкладка не открывалась пустой.
+	// Метка запуска идёт первой: по ней вкладка понимает, что менеджер
+	// перезапустился и нумерация строк началась заново.
+	if !writeSSEEvent(w, "meta", map[string]string{"epoch": s.sup.LogEpoch()}) {
+		return
+	}
+
+	// Затем хвост истории, чтобы вкладка не открывалась пустой.
 	since, _ := strconv.ParseInt(r.URL.Query().Get("since"), 10, 64)
 	for _, line := range translateLines(r, s.sup.Lines(since)) {
 		if !writeSSE(w, line) {
@@ -162,3 +171,14 @@ func writeSSE(w http.ResponseWriter, line pzserver.LogLine) bool {
 	_, err = fmt.Fprintf(w, "data: %s\n\n", payload)
 	return err == nil
 }
+
+// writeSSEEvent отправляет именованное событие: браузер ловит его отдельным
+// слушателем и не путает со строками консоли.
+func writeSSEEvent(w http.ResponseWriter, name string, value any) bool {
+	payload, err := json.Marshal(value)
+	if err != nil {
+		return true
+	}
+	_, err = fmt.Fprintf(w, "event: %s\ndata: %s\n\n", name, payload)
+	return err == nil
+}

internal/pzserver/logbuf.go

@@ -1,8 +1,12 @@
 package pzserver
 
 import (
+	"crypto/rand"
+	"encoding/hex"
 	"regexp"
+	"strconv"
 	"sync"
+	"time"
 )
 
 // ansiRe ловит управляющие последовательности терминала: SteamCMD и сам
@@ -32,6 +36,7 @@ type logBuffer struct {
 	lines    []LogLine
 	capacity int
 	nextSeq  int64
+	epoch    string
 	subs     map[int]chan LogLine
 	nextSub  int
 }
@@ -41,10 +46,25 @@ func newLogBuffer(capacity int) *logBuffer {
 		lines:    make([]LogLine, 0, capacity),
 		capacity: capacity,
 		nextSeq:  1,
+		epoch:    newEpoch(),
 		subs:     make(map[int]chan LogLine),
 	}
 }
 
+// newEpoch помечает этот запуск менеджера. Номера строк живут только в памяти
+// и после перезапуска начинаются заново — открытая вкладка приняла бы новые
+// строки за уже показанные и молчала бы до перезагрузки страницы. По смене
+// метки браузер понимает, что нумерацию надо начать с нуля.
+func newEpoch() string {
+	var raw [8]byte
+	if _, err := rand.Read(raw[:]); err != nil {
+		// Случайность здесь не нужна для безопасности: метку достаточно
+		// отличать от предыдущей, и время запуска с этим справляется.
+		return strconv.FormatInt(time.Now().UnixNano(), 36)
+	}
+	return hex.EncodeToString(raw[:])
+}
+
 // append кладёт строку в буфер и рассылает подписчикам.
 func (b *logBuffer) append(line LogLine) {
 	// Чистим здесь, а не у каждого источника: через буфер проходят и вывод

internal/pzserver/logbuf_test.go

@@ -39,3 +39,21 @@ func TestAppendStripsANSI(t *testing.T) {
 		t.Errorf("в буфер попала строка с кодами: %q", lines[0].Text)
 	}
 }
+
+// Номера строк живут в памяти менеджера: после перезапуска они начинаются
+// заново. Метка запуска должна это показывать, иначе открытая вкладка примет
+// новые строки за уже показанные.
+func TestLogBufferEpochDiffers(t *testing.T) {
+	first, second := newLogBuffer(8), newLogBuffer(8)
+	if first.epoch == "" {
+		t.Fatal("метка запуска пустая")
+	}
+	if first.epoch == second.epoch {
+		t.Fatalf("метки совпали: %q", first.epoch)
+	}
+	first.append(LogLine{Stream: "manager", Text: "первый запуск"})
+	second.append(LogLine{Stream: "manager", Text: "второй запуск"})
+	if got := second.since(0); len(got) != 1 || got[0].Seq != 1 {
+		t.Fatalf("нумерация нового буфера: %+v", got)
+	}
+}

internal/pzserver/supervisor.go

@@ -157,6 +157,9 @@ func (s *Supervisor) AppendLog(stream, text string) {
 // Lines возвращает историю консоли начиная с номера seq.
 func (s *Supervisor) Lines(seq int64) []LogLine { return s.log.since(seq) }
 
+// LogEpoch — метка этого запуска менеджера. Меняется вместе с нумерацией строк.
+func (s *Supervisor) LogEpoch() string { return s.log.epoch }
+
 // Subscribe отдаёт канал новых строк консоли и функцию отписки.
 func (s *Supervisor) Subscribe() (<-chan LogLine, func()) { return s.log.subscribe(256) }