From e5d482e2c0624b520b017006fa0113ad43ede663 Mon Sep 17 00:00:00 2001 From: lids <1713278948@qq.com> Date: Mon, 25 May 2026 17:25:12 +0800 Subject: [PATCH] =?UTF-8?q?AI=20=E8=87=AA=E5=8A=A8=E7=94=9F=E6=88=90?= =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tests/CMakeLists.txt | 25 +++ tests/test_app.cpp | 386 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 411 insertions(+) create mode 100644 tests/CMakeLists.txt create mode 100644 tests/test_app.cpp diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt new file mode 100644 index 0000000..4cb68f5 --- /dev/null +++ b/tests/CMakeLists.txt @@ -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) \ No newline at end of file diff --git a/tests/test_app.cpp b/tests/test_app.cpp new file mode 100644 index 0000000..f306539 --- /dev/null +++ b/tests/test_app.cpp @@ -0,0 +1,386 @@ +#include +#include +#include +#include +#include "app.hpp" + +// ============================================================ +// Test Fixture for CmsEngine +// ============================================================ +class CmsEngineTest : public ::testing::Test { +protected: + void SetUp() override { + engine = new CmsEngine(); + } + + void TearDown() override { + delete engine; + } + + CmsEngine* engine; +}; + +// ============================================================ +// Tests for ingestEvent +// ============================================================ + +/** + * @brief 正常输入测试：接入有效事件 + * + * 验证 ingestEvent 能够成功接入一个包含有效 ID 和优先级的事件。 + */ +TEST_F(CmsEngineTest, testIngestEventValidInput) { + EventRecord event; + event.id = "EVT-001"; + event.priority = 100; + event.status = EventStatus::Pending; + + 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); + EXPECT_EQ(found->status, EventStatus::Pending); +} + +/** + * @brief 边界值测试：优先级为 0 的事件 + * + * 验证 ingestEvent 能够处理优先级为 0 的边界值。 + */ +TEST_F(CmsEngineTest, testIngestEventPriorityZero) { + EventRecord event; + event.id = "EVT-002"; + event.priority = 0; + event.status = EventStatus::Pending; + + 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 边界值测试：优先级为 255 的事件 + * + * 验证 ingestEvent 能够处理优先级为 255 的边界值。 + */ +TEST_F(CmsEngineTest, testIngestEventPriorityMax) { + EventRecord event; + event.id = "EVT-003"; + event.priority = 255; + event.status = EventStatus::Pending; + + 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 异常输入测试：空 ID 事件 + * + * 验证 ingestEvent 拒绝接入 ID 为空的事件。 + */ +TEST_F(CmsEngineTest, testIngestEventEmptyId) { + EventRecord event; + event.id = ""; + event.priority = 100; + event.status = EventStatus::Pending; + + bool result = engine->ingestEvent(event); + EXPECT_FALSE(result); + + // 验证事件未被存储 + const EventRecord* found = engine->findEventById(""); + EXPECT_EQ(found, nullptr); +} + +/** + * @brief 异常输入测试：优先级超过 255 的事件 + * + * 验证 ingestEvent 拒绝接入优先级超过 255 的事件。 + */ +TEST_F(CmsEngineTest, testIngestEventPriorityOverflow) { + EventRecord event; + event.id = "EVT-004"; + event.priority = 256; + event.status = EventStatus::Pending; + + bool result = engine->ingestEvent(event); + EXPECT_FALSE(result); + + const EventRecord* found = engine->findEventById("EVT-004"); + EXPECT_EQ(found, nullptr); +} + +/** + * @brief 特殊场景测试：接入多个事件 + * + * 验证 ingestEvent 能够连续接入多个事件并正确存储。 + */ +TEST_F(CmsEngineTest, testIngestEventMultipleEvents) { + EventRecord event1; + event1.id = "EVT-005"; + event1.priority = 50; + event1.status = EventStatus::Pending; + + EventRecord event2; + event2.id = "EVT-006"; + event2.priority = 150; + event2.status = EventStatus::Pending; + + EXPECT_TRUE(engine->ingestEvent(event1)); + EXPECT_TRUE(engine->ingestEvent(event2)); + + const EventRecord* found1 = engine->findEventById("EVT-005"); + ASSERT_NE(found1, nullptr); + EXPECT_EQ(found1->priority, 50); + + const EventRecord* found2 = engine->findEventById("EVT-006"); + ASSERT_NE(found2, nullptr); + EXPECT_EQ(found2->priority, 150); +} + +// ============================================================ +// Tests for processPendingEvents +// ============================================================ + +/** + * @brief 正常输入测试：处理待处理事件 + * + * 验证 processPendingEvents 能够正确处理 Pending 状态的事件。 + */ +TEST_F(CmsEngineTest, testProcessPendingEventsValid) { + // 准备待处理事件 + EventRecord event; + event.id = "EVT-010"; + event.priority = 100; + event.status = EventStatus::Pending; + engine->ingestEvent(event); + + size_t processed = engine->processPendingEvents(); + EXPECT_EQ(processed, 1); + + // 验证事件状态已更新 + const EventRecord* found = engine->findEventById("EVT-010"); + ASSERT_NE(found, nullptr); + EXPECT_EQ(found->status, EventStatus::Generated); + + // 验证自动生成了任务方案 + const auto& plans = engine->getAllPlans(); + ASSERT_EQ(plans.size(), 1); + EXPECT_EQ(plans[0].relatedEventId, "EVT-010"); + EXPECT_EQ(plans[0].status, PlanStatus::Drafting); + EXPECT_EQ(plans[0].type, PlanType::Centralized); +} + +/** + * @brief 边界值测试：无待处理事件 + * + * 验证 processPendingEvents 在没有 Pending 事件时返回 0。 + */ +TEST_F(CmsEngineTest, testProcessPendingEventsNoPending) { + // 添加一个非 Pending 状态的事件 + EventRecord event; + event.id = "EVT-011"; + event.priority = 100; + event.status = EventStatus::Generated; + engine->ingestEvent(event); + + size_t processed = engine->processPendingEvents(); + EXPECT_EQ(processed, 0); + + // 验证事件状态未改变 + const EventRecord* found = engine->findEventById("EVT-011"); + ASSERT_NE(found, nullptr); + EXPECT_EQ(found->status, EventStatus::Generated); + + // 验证没有生成任务方案 + const auto& plans = engine->getAllPlans(); + EXPECT_EQ(plans.size(), 0); +} + +/** + * @brief 边界值测试：处理多个待处理事件 + * + * 验证 processPendingEvents 能够同时处理多个 Pending 事件。 + */ +TEST_F(CmsEngineTest, testProcessPendingEventsMultiple) { + EventRecord event1; + event1.id = "EVT-012"; + event1.priority = 100; + event1.status = EventStatus::Pending; + engine->ingestEvent(event1); + + EventRecord event2; + event2.id = "EVT-013"; + event2.priority = 200; + event2.status = EventStatus::Pending; + engine->ingestEvent(event2); + + size_t processed = engine->processPendingEvents(); + EXPECT_EQ(processed, 2); + + // 验证所有事件状态已更新 + const EventRecord* found1 = engine->findEventById("EVT-012"); + ASSERT_NE(found1, nullptr); + EXPECT_EQ(found1->status, EventStatus::Generated); + + const EventRecord* found2 = engine->findEventById("EVT-013"); + ASSERT_NE(found2, nullptr); + EXPECT_EQ(found2->status, EventStatus::Generated); + + // 验证生成了两个任务方案 + const auto& plans = engine->getAllPlans(); + ASSERT_EQ(plans.size(), 2); + EXPECT_EQ(plans[0].relatedEventId, "EVT-012"); + EXPECT_EQ(plans[1].relatedEventId, "EVT-013"); +} + +/** + * @brief 特殊场景测试：混合状态事件处理 + * + * 验证 processPendingEvents 只处理 Pending 状态的事件，忽略其他状态。 + */ +TEST_F(CmsEngineTest, testProcessPendingEventsMixedStatus) { + EventRecord pendingEvent; + pendingEvent.id = "EVT-014"; + pendingEvent.priority = 100; + pendingEvent.status = EventStatus::Pending; + engine->ingestEvent(pendingEvent); + + EventRecord generatedEvent; + generatedEvent.id = "EVT-015"; + generatedEvent.priority = 150; + generatedEvent.status = EventStatus::Generated; + engine->ingestEvent(generatedEvent); + + size_t processed = engine->processPendingEvents(); + EXPECT_EQ(processed, 1); + + // 验证只有 Pending 事件被处理 + const EventRecord* foundPending = engine->findEventById("EVT-014"); + ASSERT_NE(foundPending, nullptr); + EXPECT_EQ(foundPending->status, EventStatus::Generated); + + const EventRecord* foundGenerated = engine->findEventById("EVT-015"); + ASSERT_NE(foundGenerated, nullptr); + EXPECT_EQ(foundGenerated->status, EventStatus::Generated); + + // 验证只生成了一个任务方案 + const auto& plans = engine->getAllPlans(); + ASSERT_EQ(plans.size(), 1); + EXPECT_EQ(plans[0].relatedEventId, "EVT-014"); +} + +// ============================================================ +// Tests for findEventById +// ============================================================ + +/** + * @brief 正常输入测试：查找已存在的事件 + * + * 验证 findEventById 能够正确返回已存储的事件指针。 + */ +TEST_F(CmsEngineTest, testFindEventByIdExisting) { + EventRecord event; + event.id = "EVT-020"; + event.priority = 100; + event.status = EventStatus::Pending; + engine->ingestEvent(event); + + const EventRecord* found = engine->findEventById("EVT-020"); + ASSERT_NE(found, nullptr); + EXPECT_EQ(found->id, "EVT-020"); + EXPECT_EQ(found->priority, 100); + EXPECT_EQ(found->status, EventStatus::Pending); +} + +/** + * @brief 边界值测试：查找不存在的 ID + * + * 验证 findEventById 在查找不存在的 ID 时返回 nullptr。 + */ +TEST_F(CmsEngineTest, testFindEventByIdNonExistent) { + const EventRecord* found = engine->findEventById("NONEXISTENT"); + EXPECT_EQ(found, nullptr); +} + +/** + * @brief 边界值测试：查找空字符串 ID + * + * 验证 findEventById 在查找空字符串 ID 时返回 nullptr。 + */ +TEST_F(CmsEngineTest, testFindEventByIdEmptyString) { + const EventRecord* found = engine->findEventById(""); + EXPECT_EQ(found, nullptr); +} + +/** + * @brief 特殊场景测试：查找多个事件中的特定事件 + * + * 验证 findEventById 在多个事件中能够正确找到目标事件。 + */ +TEST_F(CmsEngineTest, testFindEventByIdMultipleEvents) { + EventRecord event1; + event1.id = "EVT-021"; + event1.priority = 50; + event1.status = EventStatus::Pending; + engine->ingestEvent(event1); + + EventRecord event2; + event2.id = "EVT-022"; + event2.priority = 150; + event2.status = EventStatus::Generated; + engine->ingestEvent(event2); + + EventRecord event3; + event3.id = "EVT-023"; + event3.priority = 200; + event3.status = EventStatus::Pending; + engine->ingestEvent(event3); + + // 查找中间的事件 + const EventRecord* found = engine->findEventById("EVT-022"); + ASSERT_NE(found, nullptr); + EXPECT_EQ(found->id, "EVT-022"); + EXPECT_EQ(found->priority, 150); + EXPECT_EQ(found->status, EventStatus::Generated); + + // 确认其他事件仍然存在 + const EventRecord* found1 = engine->findEventById("EVT-021"); + ASSERT_NE(found1, nullptr); + EXPECT_EQ(found1->id, "EVT-021"); + + const EventRecord* found3 = engine->findEventById("EVT-023"); + ASSERT_NE(found3, nullptr); + EXPECT_EQ(found3->id, "EVT-023"); +} + +/** + * @brief 特殊场景测试：查找已处理事件 + * + * 验证 findEventById 能够找到经过 processPendingEvents 处理的事件。 + */ +TEST_F(CmsEngineTest, testFindEventByIdAfterProcessing) { + EventRecord event; + event.id = "EVT-030"; + event.priority = 100; + event.status = EventStatus::Pending; + engine->ingestEvent(event); + + engine->processPendingEvents(); + + const EventRecord* found = engine->findEventById("EVT-030"); + ASSERT_NE(found, nullptr); + EXPECT_EQ(found->id, "EVT-030"); + EXPECT_EQ(found->status, EventStatus::Generated); +}