feat(ui): кнопка «Перезапустить» — полный аналог /retry N

Reviewed-on: http://gitea.hal9000.home/kamelion/ratatoskr-go/pulls/13

docs/ui-spec.md

@@ -223,7 +223,12 @@
     отбрасываются (буфер ограничен);
   - `Clear()` — очистить при недоступной задаче.
 - Композитор: поле ввода + кнопки команд, подключённые к `ui.Commands` через
-  `SetCommands(c)` (ввод → `SendText`, кнопки → Start/Approve/Skip/Cancel).
+  `SetCommands(c)` (ввод → `SendText`, кнопки → Start/Approve/Skip/Retry/Cancel).
+- Кнопка «Перезапустить» — полный аналог Telegram-команды `/retry N`: отправляет
+  `/retry N` тем же путём, что и ручной ввод (Commands → Router → Core).
+  Активна только для вкладки с привязанной задачей; окно сообщает ID задачи
+  через `SetBoundTask(taskID)` (при создании вкладки в `addTab` и при привязке
+  свободной вкладки в `bindTaskSession`); `0` — кнопка неактивна.
 - Доставка: окно (как chat.Channel) рендерит `Send`/`Ask`/историю через
   `Append`; строка роли = pure `FormatRole(role)` (👤/🤖).
 - Обновление — на потоке Fyne; вызывающий уже внутри `fyne.Do`.

internal/ui/chat_panel.go

@@ -15,6 +15,10 @@ type ChatPanel interface {
 	Clear()
 	// SetCommands подключает команды к композитору (ввод + кнопки).
 	SetCommands(c *Commands)
+	// SetBoundTask сообщает панели задачу, к которой привязана вкладка
+	// (0 — свободный чат). Кнопка «Перезапустить» (/retry N) активна только
+	// для вкладки с привязанной задачей.
+	SetBoundTask(taskID int64)
 }
 
 // NilChatPanel — no-op реализация ChatPanel для headless-режима и тестов.
@@ -27,6 +31,7 @@ func (NilChatPanel) SetTranscript(string) {}
 func (NilChatPanel) Append(string)        {}
 func (NilChatPanel) Clear()               {}
 func (NilChatPanel) SetCommands(*Commands) {}
+func (NilChatPanel) SetBoundTask(int64)   {}
 
 // FormatRole — строка роли в диалоге (pure-функция, спец 12.12).
 func FormatRole(role string) string {

internal/ui/chat_panel_test.go

@@ -23,4 +23,32 @@ func TestNilChatPanelNoop(t *testing.T) {
 	p.Append("строка")
 	p.Clear()
 	p.SetCommands(c)
+	p.SetBoundTask(7)
+}
+
+// Кнопка «Перезапустить» — полный аналог Telegram-команды /retry N:
+// в канал уходит ровно тот же текст, что при ручном вводе команды.
+func TestRetryButtonSubmitsSameCommandAsTelegram(t *testing.T) {
+	var got []string
+	c := NewCommands(func(text string) { got = append(got, text) })
+
+	c.Retry(42)
+
+	if len(got) != 1 || got[0] != "/retry 42" {
+		t.Fatalf("got %v, want [/retry 42]", got)
+	}
+}
+
+// Свободная вкладка (без задачи): Retry(id<=0) — no-op, ничего не отправляется
+// (кнопка «Перезапустить» на такой вкладке неактивна).
+func TestRetryWithoutTaskIsNoop(t *testing.T) {
+	var got []string
+	c := NewCommands(func(text string) { got = append(got, text) })
+
+	c.Retry(0)
+	c.Retry(-5)
+
+	if len(got) != 0 {
+		t.Fatalf("got %v, want nothing submitted", got)
+	}
 }

internal/ui/commands.go

@@ -30,8 +30,14 @@ func (c *Commands) Cancel() { c.Submit("/cancel") }
 // Skip — пропустить сбор, сформировать черновик (/skip).
 func (c *Commands) Skip() { c.Submit("/skip") }
 
-// Retry — перезапустить задачу N (/retry N).
+// Retry — перезапустить задачу N (/retry N): полный аналог Telegram-команды.
-func (c *Commands) Retry(id int64) { c.Submit(fmt.Sprintf("/retry %d", id)) }
+// id <= 0 — no-op (кнопка «Перезапустить» на свободной вкладке неактивна).
+func (c *Commands) Retry(id int64) {
+	if id <= 0 {
+		return
+	}
+	c.Submit(fmt.Sprintf("/retry %d", id))
+}
 
 // Status — запросить статус задачи N (/status N).
 func (c *Commands) Status(id int64) { c.Submit(fmt.Sprintf("/status %d", id)) }

internal/ui/desktop/chat_panel.go

@@ -21,6 +21,8 @@ type ChatPanel struct {
 	convLbl   *widget.Label
 	input     *widget.Entry
 	commands  *ui.Commands
+	retryBtn  *widget.Button // «Перезапустить» — полный аналог /retry N
+	boundTask int64          // >0 — вкладка привязана к задаче №boundTask
 }
 
 // NewChatPanel создаёт ChatPanel.
@@ -30,6 +32,8 @@ func NewChatPanel() *ChatPanel {
 	p.convLbl.Wrapping = fyne.TextWrapWord
 	p.input = widget.NewEntry()
 	p.input.SetPlaceHolder("Сообщение… (Enter — отправить)")
+	p.retryBtn = widget.NewButton("Перезапустить", p.retryTask)
+	p.retryBtn.Disable() // активируется при привязке вкладки к задаче (SetBoundTask)
 	return p
 }
 
@@ -44,11 +48,32 @@ func (p *ChatPanel) Composer() fyne.CanvasObject {
 		widget.NewButton("Новая", func() { if p.commands != nil { p.commands.Start() } }),
 		widget.NewButton("Создавай", func() { if p.commands != nil { p.commands.Approve() } }),
 		widget.NewButton("Пропустить", func() { if p.commands != nil { p.commands.Skip() } }),
+		p.retryBtn,
 		widget.NewButton("Отмена", func() { if p.commands != nil { p.commands.Cancel() } }),
 	)
 	return container.NewBorder(nil, nil, cmdBar, nil, p.input)
 }
 
+// retryTask — колбэк кнопки «Перезапустить»: отправляет "/retry N" тем же
+// путём, что и ввод пользователя (Commands → Router → Core), т.е. серверная
+// логика полностью совпадает с Telegram-командой /retry N.
+func (p *ChatPanel) retryTask() {
+	if p.commands != nil {
+		p.commands.Retry(p.boundTask)
+	}
+}
+
+// SetBoundTask включает кнопку «Перезапустить», когда вкладка привязана к
+// задаче (taskID > 0); для свободной вкладки кнопка неактивна.
+func (p *ChatPanel) SetBoundTask(taskID int64) {
+	p.boundTask = taskID
+	if taskID > 0 {
+		p.retryBtn.Enable()
+	} else {
+		p.retryBtn.Disable()
+	}
+}
+
 // SetTranscript заменяет содержимое диалога (спец 12.12).
 func (p *ChatPanel) SetTranscript(text string) {
 	p.convLbl.SetText(text)

internal/ui/desktop/log_panel.go

@@ -116,21 +116,39 @@ func (p *LogPanel) flush() {
 	}
 }
 
-// render перестраивает текст ленты из буфера с учётом выбранного набора
+// render перерисовывает ленту: дописывает в label только новые видимые
-// уровней. Пустой набор → пустая лента (без ошибок).
+// записи (RenderNew). Если вытеснение задело уже выведенные записи (stale),
+// RenderNew возвращает полный текст — пересобираем label целиком. Так при
+// росте ленты мимо лимита флаш дешёвый (только дельта), а полная пересборка
+// происходит лишь по вытеснению/смене фильтра.
 func (p *LogPanel) render() {
-	p.label.SetText(p.buf.Render(p.selected))
+	delta, full := p.buf.RenderNew(p.selected)
+	if full {
+		p.label.SetText(delta)
+		return
+	}
+	if delta == "" {
+		return
+	}
+	cur := p.label.Text
+	if cur == "" {
+		p.label.SetText(delta)
+	} else {
+		p.label.SetText(cur + delta)
+	}
 }
 
 // setLevel включает/выключает показ уровня и сразу обновляет ленту.
-// Вызывается только с потока Fyne (колбэки чекбоксов).
+// Вызывается только с потока Fyne (колбэки чекбоксов). Смена набора уровней
+// меняет видимость уже выведенных записей, поэтому — полный пересбор.
 func (p *LogPanel) setLevel(level string, on bool) {
 	if p.selected[level] == on {
 		return
 	}
 	p.selected[level] = on
 	p.btn.SetText(p.filterCaption())
-	p.render()
+	p.label.SetText(p.buf.Render(p.selected))
+	p.buf.ResetRendered()
 }
 
 // filterCaption — подпись кнопки-дропдауна: текущий выбранный набор уровней.

internal/ui/desktop/window.go

@@ -150,6 +150,8 @@ func (w *Window) addTab(sess *ui.Session) {
 	panel.SetCommands(ui.NewCommands(func(text string) {
 		w.submitText(sess.UserID, sess.Address, text)
 	}))
+	// Кнопка «Перезапустить» активна только у вкладки с задачей (/retry N).
+	panel.SetBoundTask(sess.BoundTask)
 
 	content := container.NewBorder(nil, panel.Composer(), nil, nil, panel.Transcript())
 	tab := container.NewTabItem(sess.Title, content)
@@ -309,6 +311,9 @@ func (w *Window) bindTaskSession(chatID string, taskID int64) {
 			continue
 		}
 		s.BoundTask = taskID
+		if panel := w.panels[addr]; panel != nil {
+			panel.SetBoundTask(taskID)
+		}
 		if tab := w.tabForAddress(addr); tab != nil {
 			tab.Text = "Задача #" + ui.Itoa(taskID)
 			w.tabs.Refresh()

internal/ui/log_panel.go

@@ -87,6 +87,13 @@ type LogBuffer struct {
 	start   int // индекс первого «живого» элемента (ленивое вытеснение)
 	total   int // суммарный объём текста живых записей [start..], байты
 	maxLen  int // лимит суммарного объёма текста записей, байты
+
+	// Инкрементальная отрисовка (RenderNew): rendered — сколько живых записей
+	// от начала уже выведено в текст ленты; stale — вытеснение задело уже
+	// выведенные записи, так что текст ленты нельзя дополнить дельтом и нужен
+	// полный пересбор. Эти поля поддерживаются только рендером.
+	rendered int
+	stale    bool
 }
 
 // NewLogBuffer создаёт буфер ёмкостью maxLen байт текста записей.
@@ -113,18 +120,36 @@ func (b *LogBuffer) Append(level, text string) bool {
 func (b *LogBuffer) trim() bool {
 	dropped := false
 	live := len(b.entries) - b.start
+	evicted := 0
 	for b.total > b.maxLen && live > 1 {
 		b.total -= len(b.entries[b.start].Text) + 1
 		b.start++
 		live--
+		evicted++
 		dropped = true
 	}
+	// Если вытеснена хотя бы одна уже выведенная запись (b.rendered), текст
+	// ленты устарел: дельта не может убрать верхние строки, нужен полный
+	// пересбор. rendered при этом уменьшается на число вытесненных.
+	if evicted > 0 && b.rendered > 0 {
+		b.stale = true
+	}
+	if evicted >= b.rendered {
+		b.rendered = 0
+	} else {
+		b.rendered -= evicted
+	}
 	// Компакция «мёртвых» записей пачкой, а не на каждом append.
 	if b.start >= compactThreshold {
 		b.entries = b.entries[b.start:]
 		b.start = 0
 	}
 	if n := len(b.entries); n > b.start && len(b.entries[n-1].Text) > b.maxLen {
+		// Обрезка последней записи меняет уже выведенный текст, если она
+		// была отрисована.
+		if b.rendered == n-b.start {
+			b.stale = true
+		}
 		b.entries[n-1].Text = b.entries[n-1].Text[len(b.entries[n-1].Text)-b.maxLen:]
 		b.total = b.maxLen + 1
 		dropped = true
@@ -141,12 +166,55 @@ func (b *LogBuffer) Entries() []LogEntry {
 
 // Render строит текст ленты только из живых записей уровней, отмеченных в
 // selected (уровень → показывать). Пустой или nil набор → пустая лента.
+// Полный рендер: используется для первичной отрисовки и после смены фильтра.
 func (b *LogBuffer) Render(selected map[string]bool) string {
 	if selected == nil {
 		return ""
 	}
+	return b.renderFrom(b.start, selected)
+}
+
+// ResetRendered помечает все живые записи как уже выведенные. Зовётся после
+// полного рендера (SetText(Render)), чтобы следующий RenderNew вернул только
+// новые записи.
+func (b *LogBuffer) ResetRendered() {
+	b.rendered = len(b.entries) - b.start
+	b.stale = false
+}
+
+// RenderNew отдаёт текст ещё не выведенных видимых записей и флаг, требует
+// ли слой полного пересбора ленты. Если вытеснение задело уже выведенные
+// записи (stale), возвращаемый текст — полный рендер с нуля (и флаг true), а
+// не дельта. Иначе — только текст новых записей, которым можно дополнить
+// текущий текст ленты.
+func (b *LogBuffer) RenderNew(selected map[string]bool) (text string, full bool) {
+	if selected == nil {
+		return "", false
+	}
+	live := len(b.entries) - b.start
+	if b.stale {
+		b.stale = false
+		b.rendered = live
+		return b.renderFrom(b.start, selected), true
+	}
+	from := b.start + b.rendered
 	var s strings.Builder
-	for i := b.start; i < len(b.entries); i++ {
+	for i := from; i < len(b.entries); i++ {
+		e := b.entries[i]
+		if !selected[e.Level] {
+			continue
+		}
+		s.WriteString(e.Text)
+		s.WriteByte('\n')
+	}
+	b.rendered = live
+	return s.String(), false
+}
+
+// renderFrom строит текст записей, начиная с индекса from, с учётом selected.
+func (b *LogBuffer) renderFrom(from int, selected map[string]bool) string {
+	var s strings.Builder
+	for i := from; i < len(b.entries); i++ {
 		e := b.entries[i]
 		if !selected[e.Level] {
 			continue

internal/ui/log_panel_test.go

@@ -229,3 +229,92 @@ func TestLogBufferBytesCap(t *testing.T) {
 		t.Fatalf("oversized entry text = %q, want %q", entries[0].Text, "longtext")
 	}
 }
+
+// Первый RenderNew отдаёт весь видимый текст, последующие — только новые
+// записи (инкрементальная отрисовка: повторный вызов без Append пуст).
+func TestLogBufferRenderNewDelta(t *testing.T) {
+	b := NewLogBuffer(1000)
+	sel := allLevels()
+
+	b.Append(LogLevelError, "e1")
+	b.Append(LogLevelInfo, "i1")
+	text, full := b.RenderNew(sel)
+	if full {
+		t.Fatalf("первый RenderNew не должен требовать полного пересбора, got full")
+	}
+	if text != "e1\ni1\n" {
+		t.Fatalf("первый RenderNew = %q, want %q", text, "e1\ni1\n")
+	}
+
+	// Без новых записей — пустой дельта.
+	text, full = b.RenderNew(sel)
+	if full || text != "" {
+		t.Fatalf("повторный RenderNew без новых записей = (%q, %v), want (\"\", false)", text, full)
+	}
+
+	// Новые записи — только их текст, без повторной отдачи старых.
+	b.Append(LogLevelInfo, "i2")
+	text, _ = b.RenderNew(sel)
+	if text != "i2\n" {
+		t.Fatalf("дельта RenderNew = %q, want %q", text, "i2\n")
+	}
+}
+
+// RenderNew применяет фильтр: невидимые уровни не попадают в дельту.
+func TestLogBufferRenderNewFiltered(t *testing.T) {
+	b := NewLogBuffer(1000)
+	sel := map[string]bool{LogLevelError: true}
+	b.Append(LogLevelError, "e1")
+	b.Append(LogLevelInfo, "i1")
+	b.Append(LogLevelError, "e2")
+
+	text, _ := b.RenderNew(sel)
+	if text != "e1\ne2\n" {
+		t.Fatalf("RenderNew(error only) = %q, want %q", text, "e1\ne2\n")
+	}
+}
+
+// RenderNew уважает ResetRendered: после полного рендера новые записи
+// добавляются дельтом, а не вытесняют уже выведенный текст.
+func TestLogBufferRenderNewAfterReset(t *testing.T) {
+	b := NewLogBuffer(1000)
+	sel := allLevels()
+	b.Append(LogLevelInfo, "old")
+	b.Append(LogLevelInfo, "base")
+
+	text, full := b.RenderNew(sel)
+	if full || text != "old\nbase\n" {
+		t.Fatalf("RenderNew = (%q, %v), want (\"old\\nbase\\n\", false)", text, full)
+	}
+	b.ResetRendered() // имитация полной пересборки ленты
+
+	b.Append(LogLevelInfo, "new")
+	text, full = b.RenderNew(sel)
+	if full || text != "new\n" {
+		t.Fatalf("RenderNew после Reset = (%q, %v), want (\"new\\n\", false)", text, full)
+	}
+}
+
+// Вытеснение уже выведенных записей помечает рендер как требующий полного
+// пересбора (stale): дельта не может убрать верхние строки.
+func TestLogBufferRenderNewEvictionStale(t *testing.T) {
+	b := NewLogBuffer(25) // записи по 10 байт + \n: помещаются 2, 3-я вытесняет 1-ю
+	sel := allLevels()
+
+	b.Append(LogLevelInfo, "0123456789")
+	b.Append(LogLevelInfo, "0123456789")
+	text, full := b.RenderNew(sel)
+	if full || text != "0123456789\n0123456789\n" {
+		t.Fatalf("RenderNew = (%q, %v), want two lines", text, full)
+	}
+
+	// Третья запись вытесняет первую (уже отрисованную) — stale.
+	b.Append(LogLevelInfo, "0123456789")
+	text, full = b.RenderNew(sel)
+	if !full {
+		t.Fatalf("RenderNew после вытеснения = (full=%v), want full=true", full)
+	}
+	if text != "0123456789\n0123456789\n" {
+		t.Fatalf("полный текст после вытеснения = %q, want последние две записи", text)
+	}
+}