refactor(executor): update runners and tests for generic agents

1 files changed, 23 insertions, 12 deletions

diff --git a/internal/executor/executor_test.go b/internal/executor/executor_test.go
index 6d13873..2f205f8 100644
--- a/internal/executor/executor_test.go
+++ b/internal/executor/executor_test.go
@@ -64,7 +64,7 @@ func makeTask(id string) *task.Task {
 	now := time.Now().UTC()
 	return &task.Task{
 		ID: id, Name: "Test " + id,
-		Claude:    task.ClaudeConfig{Instructions: "test"},
+		Agent:    task.AgentConfig{Type: "claude", Instructions: "test"},
 		Priority:  task.PriorityNormal,
 		Retry:     task.RetryConfig{MaxAttempts: 1, Backoff: "linear"},
 		Tags:      []string{},
@@ -77,8 +77,9 @@ func makeTask(id string) *task.Task {
 func TestPool_Submit_TopLevel_GoesToReady(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("ps-1") // no ParentTaskID → top-level
 	store.CreateTask(tk)
@@ -104,8 +105,9 @@ func TestPool_Submit_TopLevel_GoesToReady(t *testing.T) {
 func TestPool_Submit_Subtask_GoesToCompleted(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("sub-1")
 	tk.ParentTaskID = "parent-99" // subtask
@@ -132,8 +134,9 @@ func TestPool_Submit_Subtask_GoesToCompleted(t *testing.T) {
 func TestPool_Submit_Failure(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{err: fmt.Errorf("boom"), exitCode: 1}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("pf-1")
 	store.CreateTask(tk)
@@ -151,8 +154,9 @@ func TestPool_Submit_Failure(t *testing.T) {
 func TestPool_Submit_Timeout(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{delay: 5 * time.Second}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("pt-1")
 	tk.Timeout.Duration = 50 * time.Millisecond
@@ -168,8 +172,9 @@ func TestPool_Submit_Timeout(t *testing.T) {
 func TestPool_Submit_Cancellation(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{delay: 5 * time.Second}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	ctx, cancel := context.WithCancel(context.Background())
 	tk := makeTask("pc-1")
@@ -188,8 +193,9 @@ func TestPool_Submit_Cancellation(t *testing.T) {
 func TestPool_Cancel_StopsRunningTask(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{delay: 5 * time.Second}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("cancel-1")
 	store.CreateTask(tk)
@@ -209,8 +215,9 @@ func TestPool_Cancel_StopsRunningTask(t *testing.T) {
 func TestPool_Cancel_UnknownTask_ReturnsFalse(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	if ok := pool.Cancel("nonexistent"); ok {
 		t.Error("Cancel returned true for unknown task")
@@ -220,8 +227,9 @@ func TestPool_Cancel_UnknownTask_ReturnsFalse(t *testing.T) {
 func TestPool_AtCapacity(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{delay: time.Second}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(1, runner, store, logger)
+	pool := NewPool(1, runners, store, logger)
 
 	tk1 := makeTask("cap-1")
 	store.CreateTask(tk1)
@@ -265,8 +273,9 @@ func (m *logPatherMockRunner) Run(ctx context.Context, t *task.Task, e *storage.
 func TestPool_Execute_LogPathsPreSetBeforeRun(t *testing.T) {
 	store := testStore(t)
 	runner := &logPatherMockRunner{logDir: t.TempDir()}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("lp-1")
 	store.CreateTask(tk)
@@ -296,8 +305,9 @@ func TestPool_Execute_LogPathsPreSetBeforeRun(t *testing.T) {
 func TestPool_Execute_NoLogPather_PathsEmptyBeforeRun(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{} // does NOT implement LogPather
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(2, runner, store, logger)
+	pool := NewPool(2, runners, store, logger)
 
 	tk := makeTask("nolp-1")
 	store.CreateTask(tk)
@@ -313,8 +323,9 @@ func TestPool_Execute_NoLogPather_PathsEmptyBeforeRun(t *testing.T) {
 func TestPool_ConcurrentExecution(t *testing.T) {
 	store := testStore(t)
 	runner := &mockRunner{delay: 50 * time.Millisecond}
+	runners := map[string]Runner{"claude": runner}
 	logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
-	pool := NewPool(3, runner, store, logger)
+	pool := NewPool(3, runners, store, logger)
 
 	for i := 0; i < 3; i++ {
 		tk := makeTask(fmt.Sprintf("cc-%d", i))