Function TestPool_Resume

pkg/core/pool_test.go:428–487

TestPool_Resume 测试恢复 Agent 注意: 这个测试依赖于 Agent 实际保存消息到 Store,在单元测试环境中可能会失败

(t *testing.T)

// TestPool_Resume 测试恢复 Agent
// 注意: 这个测试依赖于 Agent 实际保存消息到 Store,在单元测试环境中可能会失败
func TestPool_Resume(t *testing.T) {
	t.Skip("Skipping Resume test - requires real agent message persistence")
	deps := createTestDeps(t)
	ctx := context.Background()

	// 第一个池 - 创建并保存 Agent
	pool1 := NewPool(&PoolOptions{
		Dependencies: deps,
		MaxAgents:    10,
	})

	config := createTestConfig("persistent-agent")

	// 创建 Agent
	ag1, err := pool1.Create(ctx, config)
	if err != nil {
		t.Fatalf("Failed to create agent: %v", err)
	}

	// 发送消息以保存状态
	err = ag1.Send(ctx, "Test message")
	if err != nil {
		t.Logf("Send message warning: %v", err)
	}

	// 等待保存完成
	time.Sleep(100 * time.Millisecond)

	// 关闭第一个池
	if err := pool1.Shutdown(); err != nil {
		t.Fatalf("Failed to shutdown pool1: %v", err)
	}

	// 第二个池 - 恢复 Agent
	pool2 := NewPool(&PoolOptions{
		Dependencies: deps,
		MaxAgents:    10,
	})
	defer func() {
		if err := pool2.Shutdown(); err != nil {
			t.Errorf("Shutdown failed: %v", err)
		}
	}()

	// 恢复 Agent
	ag2, err := pool2.Resume(ctx, "persistent-agent", config)
	if err != nil {
		t.Fatalf("Failed to resume agent: %v", err)
	}

	if ag2 == nil {
		t.Fatal("Resumed agent is nil")
	}

	// 验证 Agent 在池中
	_, exists := pool2.Get("persistent-agent")
	if !exists {
		t.Error("Resumed agent not found in pool")