Function TestResumeAgentIDMismatch

internal/controller/executor/executor_test.go:301–336

(t *testing.T)

}

func TestResumeAgentIDMismatch(t *testing.T) {
	ctx := context.Background()
	eventLog := memoryEventLog()

	registry := map[string]agent.Agent{
		"root": AgentFunc(func(inputs []*proto.Message, tm agent.Executor, o agent.OutputHandler) {
			// Do nothing to leave it in PENDING state
		}),
		"other": AgentFunc(func(inputs []*proto.Message, tm agent.Executor, o agent.OutputHandler) {
		}),
	}

	tm := DefaultExecutor(eventLog, registry)

	// First run: starts as "root"
	if _, err := tm.Exec(ctx, "test-conv", "task1", &proto.AgentStart{
		AgentId:  "root",
		Messages: []*proto.Message{text("user", "hello!")},
	}, nil); err != nil {
		t.Fatal(err)
	}

	// Second run: attempts to resume as "other" for same execID "task1"
	_, err := tm.Exec(ctx, "test-conv", "task1", &proto.AgentStart{
		AgentId:  "other",
		Messages: []*proto.Message{text("user", "hello again!")},
	}, nil)

	if err == nil {
		t.Fatal("expected error due to agent ID mismatch, got nil")
	}

	if !strings.Contains(err.Error(), "resumption not allowed") {
		t.Fatalf("expected 'resumption not allowed' error, got: %v", err)
	}
}

func TestResumeConfirmation(t *testing.T) {
	ctx := context.Background()