egutierrez
bd0c8c0dd3
agents/ ahora solo contiene carpetas de agentes (config, reglas, prompts). El runtime (Agent, Robot, Runner, registry, handler, commands, llm, memory) vive en devagents/ como package devagents. Cambios: - git mv agents/*.go → devagents/*.go - package agents → package devagents en todos los archivos movidos - Actualizar imports en agents/*/agent.go, cmd/launcher/, dev-scripts/ - Actualizar docs: CLAUDE.md, rules/, docs/e2ee.md, issues pendientes Build y tests pasan sin errores. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
65 lines
1.4 KiB
Go
65 lines
1.4 KiB
Go
package devagents
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// TestAgentStopAndDone verifies that Stop() cancels Run and Done() closes.
|
|
// Uses a minimal Agent (no Matrix, no LLM) via direct struct init so the test
|
|
// doesn't require network or external dependencies.
|
|
func TestAgentStopAndDone(t *testing.T) {
|
|
a := &Agent{
|
|
done: make(chan struct{}),
|
|
}
|
|
|
|
// Simulate Run: create the cancel, then immediately block on ctx.
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
a.cancel = cancel
|
|
|
|
started := make(chan struct{})
|
|
go func() {
|
|
close(started)
|
|
// Mimic what Run does: block on ctx, then close done.
|
|
<-ctx.Done()
|
|
close(a.done)
|
|
}()
|
|
|
|
<-started
|
|
|
|
// Stop must unblock the goroutine above.
|
|
a.Stop()
|
|
|
|
select {
|
|
case <-a.Done():
|
|
// ok
|
|
case <-time.After(2 * time.Second):
|
|
t.Fatal("Done() did not close within 2s after Stop()")
|
|
}
|
|
}
|
|
|
|
// TestAgentStopIdempotent verifies that calling Stop() multiple times is safe.
|
|
func TestAgentStopIdempotent(t *testing.T) {
|
|
a := &Agent{
|
|
done: make(chan struct{}),
|
|
}
|
|
_, cancel := context.WithCancel(context.Background())
|
|
a.cancel = cancel
|
|
defer cancel()
|
|
|
|
// Should not panic when called multiple times.
|
|
a.Stop()
|
|
a.Stop()
|
|
a.Stop()
|
|
}
|
|
|
|
// TestAgentStopNilCancel verifies Stop() is safe when cancel is nil.
|
|
func TestAgentStopNilCancel(t *testing.T) {
|
|
a := &Agent{
|
|
done: make(chan struct{}),
|
|
}
|
|
// cancel is nil — must not panic.
|
|
a.Stop()
|
|
}
|