Compare commits
1 Commits
main
...
test_20260
| Author | SHA1 | Date |
|---|---|---|
|
|
840ccd6725 |
|
|
@ -0,0 +1,25 @@
|
||||||
|
cmake_minimum_required(VERSION 3.10.0)
|
||||||
|
project(test_plan_execute_t1)
|
||||||
|
include(FetchContent)
|
||||||
|
if (MSVC)
|
||||||
|
add_compile_options(/utf-8)
|
||||||
|
endif()
|
||||||
|
FetchContent_Declare(
|
||||||
|
googletest
|
||||||
|
URL https://github.com/google/googletest/archive/03597a01ee50ed33e9dfd640b249b4be3799d395.zip
|
||||||
|
)
|
||||||
|
# For Windows: Prevent overriding the parent project's compiler/linker settings
|
||||||
|
set(gtest_force_shared_crt ON CACHE BOOL "" FORCE)
|
||||||
|
FetchContent_MakeAvailable(googletest)
|
||||||
|
set(CMAKE_CXX_STANDARD 17)
|
||||||
|
set(CMAKE_CXX_STANDARD_REQUIRED ON)
|
||||||
|
include_directories(${CMAKE_CURRENT_SOURCE_DIR}/../include)
|
||||||
|
|
||||||
|
include(CTest)
|
||||||
|
enable_testing()
|
||||||
|
|
||||||
|
add_executable(test_plan_execute_t1 test_app.cpp ../src/app.cpp)
|
||||||
|
|
||||||
|
target_link_libraries(test_plan_execute_t1 gtest gmock gtest_main)
|
||||||
|
include(GoogleTest)
|
||||||
|
gtest_discover_tests(test_plan_execute_t1)
|
||||||
|
|
@ -0,0 +1,337 @@
|
||||||
|
#include <gtest/gtest.h>
|
||||||
|
#include <string>
|
||||||
|
#include <vector>
|
||||||
|
#include <chrono>
|
||||||
|
#include "app.hpp"
|
||||||
|
|
||||||
|
// 辅助函数:创建一个有效的 EventRecord
|
||||||
|
EventRecord createValidEvent(const std::string& id = "EVT-001", uint32_t priority = 100, EventStatus status = EventStatus::Pending) {
|
||||||
|
EventRecord event;
|
||||||
|
event.id = id;
|
||||||
|
event.priority = priority;
|
||||||
|
event.status = status;
|
||||||
|
event.timestamp = std::chrono::system_clock::now();
|
||||||
|
event.source = "test_source";
|
||||||
|
event.type = "test_type";
|
||||||
|
event.payload = R"({"key":"value"})";
|
||||||
|
return event;
|
||||||
|
}
|
||||||
|
|
||||||
|
// ============================================================================
|
||||||
|
// 测试 ingestEvent 函数
|
||||||
|
// ============================================================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 正常输入:有效事件应成功接入
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventNormal) {
|
||||||
|
CmsEngine engine;
|
||||||
|
EventRecord event = createValidEvent();
|
||||||
|
|
||||||
|
bool result = engine.ingestEvent(event);
|
||||||
|
|
||||||
|
EXPECT_TRUE(result);
|
||||||
|
// 验证事件已存储
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-001");
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->id, "EVT-001");
|
||||||
|
EXPECT_EQ(found->priority, 100);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 空 ID:应返回 false
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventEmptyId) {
|
||||||
|
CmsEngine engine;
|
||||||
|
EventRecord event = createValidEvent("", 100);
|
||||||
|
|
||||||
|
bool result = engine.ingestEvent(event);
|
||||||
|
|
||||||
|
EXPECT_FALSE(result);
|
||||||
|
// 验证事件未被存储
|
||||||
|
const EventRecord* found = engine.findEventById("");
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 优先级边界:优先级为 0 应成功
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventPriorityMin) {
|
||||||
|
CmsEngine engine;
|
||||||
|
EventRecord event = createValidEvent("EVT-002", 0);
|
||||||
|
|
||||||
|
bool result = engine.ingestEvent(event);
|
||||||
|
|
||||||
|
EXPECT_TRUE(result);
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-002");
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->priority, 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 优先级边界:优先级为 255 应成功
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventPriorityMax) {
|
||||||
|
CmsEngine engine;
|
||||||
|
EventRecord event = createValidEvent("EVT-003", 255);
|
||||||
|
|
||||||
|
bool result = engine.ingestEvent(event);
|
||||||
|
|
||||||
|
EXPECT_TRUE(result);
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-003");
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->priority, 255);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 优先级越界:优先级为 256 应失败
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventPriorityOverflow) {
|
||||||
|
CmsEngine engine;
|
||||||
|
EventRecord event = createValidEvent("EVT-004", 256);
|
||||||
|
|
||||||
|
bool result = engine.ingestEvent(event);
|
||||||
|
|
||||||
|
EXPECT_FALSE(result);
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-004");
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 ingestEvent 大量事件:验证存储容量
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testIngestEventMultipleEvents) {
|
||||||
|
CmsEngine engine;
|
||||||
|
const int eventCount = 100;
|
||||||
|
|
||||||
|
for (int i = 0; i < eventCount; ++i) {
|
||||||
|
std::string id = "EVT-" + std::to_string(i);
|
||||||
|
EventRecord event = createValidEvent(id, i % 256);
|
||||||
|
EXPECT_TRUE(engine.ingestEvent(event));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 验证所有事件都能被找到
|
||||||
|
for (int i = 0; i < eventCount; ++i) {
|
||||||
|
std::string id = "EVT-" + std::to_string(i);
|
||||||
|
const EventRecord* found = engine.findEventById(id);
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->priority, i % 256);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ============================================================================
|
||||||
|
// 测试 processPendingEvents 函数
|
||||||
|
// ============================================================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 processPendingEvents 正常处理 Pending 事件
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testProcessPendingEventsNormal) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
// 添加多个 Pending 事件
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100, EventStatus::Pending));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-002", 200, EventStatus::Pending));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-003", 50, EventStatus::Pending));
|
||||||
|
|
||||||
|
size_t processed = engine.processPendingEvents();
|
||||||
|
|
||||||
|
EXPECT_EQ(processed, 3);
|
||||||
|
|
||||||
|
// 验证事件状态已更新
|
||||||
|
const EventRecord* evt1 = engine.findEventById("EVT-001");
|
||||||
|
ASSERT_NE(evt1, nullptr);
|
||||||
|
EXPECT_EQ(evt1->status, EventStatus::Generated);
|
||||||
|
|
||||||
|
const EventRecord* evt2 = engine.findEventById("EVT-002");
|
||||||
|
ASSERT_NE(evt2, nullptr);
|
||||||
|
EXPECT_EQ(evt2->status, EventStatus::Generated);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 processPendingEvents 无 Pending 事件
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testProcessPendingEventsNoPending) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
// 添加非 Pending 事件
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100, EventStatus::Generated));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-002", 200, EventStatus::Completed));
|
||||||
|
|
||||||
|
size_t processed = engine.processPendingEvents();
|
||||||
|
|
||||||
|
EXPECT_EQ(processed, 0);
|
||||||
|
|
||||||
|
// 验证事件状态未改变
|
||||||
|
const EventRecord* evt1 = engine.findEventById("EVT-001");
|
||||||
|
ASSERT_NE(evt1, nullptr);
|
||||||
|
EXPECT_EQ(evt1->status, EventStatus::Generated);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 processPendingEvents 混合状态事件
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testProcessPendingEventsMixed) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100, EventStatus::Pending));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-002", 200, EventStatus::Generated));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-003", 50, EventStatus::Pending));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-004", 150, EventStatus::Failed));
|
||||||
|
|
||||||
|
size_t processed = engine.processPendingEvents();
|
||||||
|
|
||||||
|
EXPECT_EQ(processed, 2);
|
||||||
|
|
||||||
|
// 验证只有 Pending 事件被处理
|
||||||
|
const EventRecord* evt1 = engine.findEventById("EVT-001");
|
||||||
|
ASSERT_NE(evt1, nullptr);
|
||||||
|
EXPECT_EQ(evt1->status, EventStatus::Generated);
|
||||||
|
|
||||||
|
const EventRecord* evt2 = engine.findEventById("EVT-002");
|
||||||
|
ASSERT_NE(evt2, nullptr);
|
||||||
|
EXPECT_EQ(evt2->status, EventStatus::Generated); // 未改变
|
||||||
|
|
||||||
|
const EventRecord* evt4 = engine.findEventById("EVT-004");
|
||||||
|
ASSERT_NE(evt4, nullptr);
|
||||||
|
EXPECT_EQ(evt4->status, EventStatus::Failed); // 未改变
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 processPendingEvents 生成 TaskPlan 的完整性
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testProcessPendingEventsTaskPlanGeneration) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100, EventStatus::Pending));
|
||||||
|
|
||||||
|
size_t processed = engine.processPendingEvents();
|
||||||
|
EXPECT_EQ(processed, 1);
|
||||||
|
|
||||||
|
// 验证生成的 TaskPlan
|
||||||
|
const std::vector<TaskPlan>& plans = engine.getAllPlans();
|
||||||
|
ASSERT_EQ(plans.size(), 1);
|
||||||
|
|
||||||
|
const TaskPlan& plan = plans[0];
|
||||||
|
EXPECT_EQ(plan.name, "AutoPlan-EVT-001");
|
||||||
|
EXPECT_EQ(plan.type, PlanType::Centralized);
|
||||||
|
EXPECT_EQ(plan.status, PlanStatus::Drafting);
|
||||||
|
EXPECT_EQ(plan.relatedEventId, "EVT-001");
|
||||||
|
EXPECT_DOUBLE_EQ(plan.resourceQuota, 0.5);
|
||||||
|
EXPECT_EQ(plan.constraints, "自动生成约束");
|
||||||
|
EXPECT_FALSE(plan.id.empty());
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 processPendingEvents 空事件库
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testProcessPendingEventsEmpty) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
size_t processed = engine.processPendingEvents();
|
||||||
|
|
||||||
|
EXPECT_EQ(processed, 0);
|
||||||
|
EXPECT_TRUE(engine.getAllPlans().empty());
|
||||||
|
}
|
||||||
|
|
||||||
|
// ============================================================================
|
||||||
|
// 测试 findEventById 函数
|
||||||
|
// ============================================================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 正常查找
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdNormal) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-002", 200));
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-001");
|
||||||
|
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->id, "EVT-001");
|
||||||
|
EXPECT_EQ(found->priority, 100);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 不存在的 ID
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdNotFound) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("NONEXISTENT");
|
||||||
|
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 空字符串
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdEmptyString) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("");
|
||||||
|
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 空事件库
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdEmptyEngine) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-001");
|
||||||
|
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 多个事件中查找最后一个
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdLastEvent) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-002", 200));
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-003", 300));
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("EVT-003");
|
||||||
|
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->id, "EVT-003");
|
||||||
|
EXPECT_EQ(found->priority, 300);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 大小写敏感性
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdCaseSensitive) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
|
||||||
|
const EventRecord* found = engine.findEventById("evt-001");
|
||||||
|
|
||||||
|
EXPECT_EQ(found, nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @brief 测试 findEventById 返回指针的常量正确性
|
||||||
|
*/
|
||||||
|
TEST(CmsEngineTest, testFindEventByIdConstCorrectness) {
|
||||||
|
CmsEngine engine;
|
||||||
|
|
||||||
|
engine.ingestEvent(createValidEvent("EVT-001", 100));
|
||||||
|
|
||||||
|
const CmsEngine& constEngine = engine;
|
||||||
|
const EventRecord* found = constEngine.findEventById("EVT-001");
|
||||||
|
|
||||||
|
ASSERT_NE(found, nullptr);
|
||||||
|
EXPECT_EQ(found->id, "EVT-001");
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue