feat: mejorar ProgressReporter con deteccion de pasos del pipeline

El ProgressReporter ahora muestra mensajes legibles cuando detecta
comandos conocidos del pipeline de creacion de agentes:

- create-full.sh → "📦 Creando agente: scaffold, build, register..."
- health-check.sh → "🏥 Verificando health check..."
- notify-developer.sh → "📨 Enviando bienvenida a developers..."
- restart.sh / start.sh → "🔄 Reiniciando launcher..."
- go build → "🔨 Compilando..."
- go test → "🧪 Ejecutando tests..."
- Edit/Write → "✏️ Editando: <archivo>"
- Read → "📖 Leyendo: <archivo>"
- Glob/Grep → "🔍 Buscando: <patron>"

Incluye contador de pasos visible ("Paso N — <descripcion>") para que
el usuario pueda seguir el progreso. Si no reconoce el comando, usa
el formato generico anterior.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
2026-04-10 23:14:34 +00:00
parent fe742bea59
commit deaefb5cd3
+81 -14
View File
@@ -4,6 +4,7 @@ import (
"context"
"fmt"
"log/slog"
"strings"
"sync"
"time"
@@ -15,16 +16,19 @@ import (
// emits streaming events (tool_use, text, result).
//
// It rate-limits edits to at most one per second to avoid flooding the
// homeserver.
// homeserver. When it recognises well-known pipeline commands (e.g.
// create-full.sh, health-check.sh) it shows a human-readable step name
// instead of the raw command.
type ProgressReporter struct {
sender MatrixSender
roomID string
logger *slog.Logger
mu sync.Mutex
eventID string // Matrix event ID of the progress message (empty until first send)
lastEdit time.Time // timestamp of last edit, for rate limiting
mu sync.Mutex
eventID string // Matrix event ID of the progress message (empty until first send)
lastEdit time.Time // timestamp of last edit, for rate limiting
minInterval time.Duration
step int // visible step counter (incremented on each tool_use)
}
// NewProgressReporter creates a ProgressReporter that sends progress updates
@@ -53,16 +57,12 @@ func (p *ProgressReporter) handleEvent(evt coretypes.StreamEvent) {
switch evt.Kind {
case coretypes.StreamToolUse:
// Show which tool is being used
input := evt.ToolInput
if len(input) > 60 {
input = input[:57] + "..."
}
if input != "" {
markdown = fmt.Sprintf("\U0001f527 *%s*: `%s`", evt.ToolName, input)
} else {
markdown = fmt.Sprintf("\U0001f527 *%s*", evt.ToolName)
}
p.mu.Lock()
p.step++
step := p.step
p.mu.Unlock()
markdown = formatToolEvent(step, evt.ToolName, evt.ToolInput)
case coretypes.StreamResult:
// Final result — no need to update progress; the handler will send the actual reply
@@ -86,6 +86,73 @@ func (p *ProgressReporter) handleEvent(evt coretypes.StreamEvent) {
p.updateMessage(markdown)
}
// pipelineHint describes a well-known command pattern and its human-readable label.
type pipelineHint struct {
substr string // substring to match in the tool input
emoji string
label string
}
// pipelineHints maps well-known pipeline commands to friendly labels.
// Order matters: first match wins.
var pipelineHints = []pipelineHint{
{"create-full.sh", "\U0001f4e6", "Creando agente: scaffold, build, register, E2EE, avatar..."},
{"health-check.sh", "\U0001f3e5", "Verificando health check..."},
{"notify-developer.sh", "\U0001f4e8", "Enviando bienvenida a developers..."},
{"restart.sh", "\U0001f504", "Reiniciando launcher..."},
{"start.sh", "\U0001f504", "Arrancando launcher..."},
{"go build", "\U0001f528", "Compilando..."},
{"go test", "\U0001f9ea", "Ejecutando tests..."},
}
// formatToolEvent returns a human-readable markdown line for a streaming tool event.
// If the tool/input matches a well-known pipeline pattern, a friendly label is shown;
// otherwise falls back to a generic format.
func formatToolEvent(step int, toolName, toolInput string) string {
prefix := fmt.Sprintf("**Paso %d** \u2014 ", step)
// Check pipeline hints for Bash commands
if toolName == "Bash" {
for _, h := range pipelineHints {
if strings.Contains(toolInput, h.substr) {
return prefix + h.emoji + " " + h.label
}
}
// Generic Bash command
input := truncateInput(toolInput, 50)
return prefix + "\U0001f527 `" + input + "`"
}
// File operation tools with agent path detection
if toolName == "Edit" || toolName == "Write" {
file := truncateInput(toolInput, 60)
return prefix + "\u270f\ufe0f Editando: `" + file + "`"
}
if toolName == "Read" {
file := truncateInput(toolInput, 60)
return prefix + "\U0001f4d6 Leyendo: `" + file + "`"
}
if toolName == "Glob" || toolName == "Grep" {
input := truncateInput(toolInput, 50)
return prefix + "\U0001f50d Buscando: `" + input + "`"
}
// Generic fallback
if toolInput != "" {
input := truncateInput(toolInput, 50)
return prefix + "\U0001f527 *" + toolName + "*: `" + input + "`"
}
return prefix + "\U0001f527 *" + toolName + "*"
}
// truncateInput shortens a string for display, appending "..." if truncated.
func truncateInput(s string, maxLen int) string {
if len(s) <= maxLen {
return s
}
return s[:maxLen-3] + "..."
}
// updateMessage sends or edits the progress message, respecting rate limits.
func (p *ProgressReporter) updateMessage(markdown string) {
p.mu.Lock()