Compare commits
1 Commits
main
...
test_20260
| Author | SHA1 | Date |
|---|---|---|
|
|
5b959debc7 |
114
src/app.cpp
114
src/app.cpp
|
|
@ -9,10 +9,6 @@
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="核心引擎初始化", id="REQ-ENGINE-INIT-001")
|
|
||||||
* 构造函数需初始化系统状态上下文,设置默认运行模式为空闲模式,
|
|
||||||
* 并重置自增计数器,为后续业务操作提供初始状态。
|
|
||||||
*
|
|
||||||
* @brief 构造函数,初始化系统状态上下文与自增计数器
|
* @brief 构造函数,初始化系统状态上下文与自增计数器
|
||||||
*/
|
*/
|
||||||
CmsEngine::CmsEngine()
|
CmsEngine::CmsEngine()
|
||||||
|
|
@ -25,11 +21,8 @@ CmsEngine::CmsEngine()
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="唯一标识生成", id="REQ-UTIL-IDGEN-001")
|
|
||||||
* 系统需支持生成格式为 "ID-xxxxx" 的自增唯一标识,
|
|
||||||
* 用于任务方案、事件等实体的 ID 分配。
|
|
||||||
*
|
|
||||||
* @brief 生成自增唯一标识
|
* @brief 生成自增唯一标识
|
||||||
|
*
|
||||||
* @return std::string 格式如 "ID-00001"
|
* @return std::string 格式如 "ID-00001"
|
||||||
*/
|
*/
|
||||||
std::string CmsEngine::generateNextId()
|
std::string CmsEngine::generateNextId()
|
||||||
|
|
@ -44,11 +37,10 @@ std::string CmsEngine::generateNextId()
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="战场事件接入", id="REQ-EVENT-INGEST-001")
|
|
||||||
* 系统需支持从外部事件总线接入原始战场事件,执行基本合法性校验
|
|
||||||
* (ID 不能为空、优先级范围检查),通过后存入事件库。
|
|
||||||
*
|
|
||||||
* @brief 接入原始战场事件
|
* @brief 接入原始战场事件
|
||||||
|
*
|
||||||
|
* 执行基本合法性校验(ID 不能为空、优先级范围检查),通过后存入事件库。
|
||||||
|
*
|
||||||
* @param event 战场事件
|
* @param event 战场事件
|
||||||
* @return true 接入成功
|
* @return true 接入成功
|
||||||
* @return false 接入失败
|
* @return false 接入失败
|
||||||
|
|
@ -66,11 +58,11 @@ bool CmsEngine::ingestEvent(const EventRecord& event)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="待处理事件处理", id="REQ-EVENT-PROC-001")
|
|
||||||
* 系统需遍历事件库中所有 Pending 状态的事件,自动将其状态标记为 Generated,
|
|
||||||
* 并据此生成一个对应的 TaskPlan 草案,实现事件到方案的自动转化。
|
|
||||||
*
|
|
||||||
* @brief 处理待处理事件队列
|
* @brief 处理待处理事件队列
|
||||||
|
*
|
||||||
|
* 遍历事件库中所有 Pending 状态的事件,自动将其状态标记为 Generated,
|
||||||
|
* 并据此生成一个对应的 TaskPlan 草案。
|
||||||
|
*
|
||||||
* @return size_t 处理的事件数量
|
* @return size_t 处理的事件数量
|
||||||
*/
|
*/
|
||||||
size_t CmsEngine::processPendingEvents()
|
size_t CmsEngine::processPendingEvents()
|
||||||
|
|
@ -98,11 +90,8 @@ size_t CmsEngine::processPendingEvents()
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="事件查询", id="REQ-EVENT-QUERY-001")
|
|
||||||
* 系统需支持根据事件 ID 在事件库中查找对应的事件记录,
|
|
||||||
* 找到则返回事件指针,未找到返回 nullptr。
|
|
||||||
*
|
|
||||||
* @brief 根据事件 ID 查找事件
|
* @brief 根据事件 ID 查找事件
|
||||||
|
*
|
||||||
* @param eventId 事件标识
|
* @param eventId 事件标识
|
||||||
* @return const EventRecord* 事件指针,未找到返回 nullptr
|
* @return const EventRecord* 事件指针,未找到返回 nullptr
|
||||||
*/
|
*/
|
||||||
|
|
@ -121,11 +110,10 @@ const EventRecord* CmsEngine::findEventById(const std::string& eventId) const
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="任务方案创建", id="REQ-PLAN-CREATE-001")
|
|
||||||
* 系统需校验方案名称非空后,为其分配系统 ID 并存入方案库,
|
|
||||||
* 确保方案数据的完整性和可追溯性。
|
|
||||||
*
|
|
||||||
* @brief 创建任务方案
|
* @brief 创建任务方案
|
||||||
|
*
|
||||||
|
* 校验方案名称非空后,为其分配系统 ID 并存入方案库。
|
||||||
|
*
|
||||||
* @param plan 待创建方案(id 由系统填充)
|
* @param plan 待创建方案(id 由系统填充)
|
||||||
* @return true 创建成功
|
* @return true 创建成功
|
||||||
* @return false 名称不合法
|
* @return false 名称不合法
|
||||||
|
|
@ -142,10 +130,8 @@ bool CmsEngine::createTaskPlan(TaskPlan& plan)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="任务方案列表查询", id="REQ-PLAN-LIST-001")
|
|
||||||
* 系统需返回全部任务方案列表的引用,以支撑方案全局视图展示。
|
|
||||||
*
|
|
||||||
* @brief 获取所有任务方案列表
|
* @brief 获取所有任务方案列表
|
||||||
|
*
|
||||||
* @return const std::vector<TaskPlan>& 方案列表
|
* @return const std::vector<TaskPlan>& 方案列表
|
||||||
*/
|
*/
|
||||||
const std::vector<TaskPlan>& CmsEngine::getAllPlans() const
|
const std::vector<TaskPlan>& CmsEngine::getAllPlans() const
|
||||||
|
|
@ -154,11 +140,8 @@ const std::vector<TaskPlan>& CmsEngine::getAllPlans() const
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="任务方案查找", id="REQ-PLAN-FIND-001")
|
|
||||||
* 系统需支持根据任务 ID 在方案库中遍历查找对应方案,
|
|
||||||
* 找到返回方案指针,未找到返回 nullptr。
|
|
||||||
*
|
|
||||||
* @brief 根据 ID 查找任务方案
|
* @brief 根据 ID 查找任务方案
|
||||||
|
*
|
||||||
* @param planId 任务标识
|
* @param planId 任务标识
|
||||||
* @return const TaskPlan* 方案指针,未找到返回 nullptr
|
* @return const TaskPlan* 方案指针,未找到返回 nullptr
|
||||||
*/
|
*/
|
||||||
|
|
@ -173,11 +156,8 @@ const TaskPlan* CmsEngine::findPlanById(const std::string& planId) const
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="任务方案状态更新", id="REQ-PLAN-UPDATE-001")
|
|
||||||
* 系统需支持根据任务 ID 查找方案并更新其状态,返回是否更新成功,
|
|
||||||
* 以驱动方案从草稿到完成的生命周期流转。
|
|
||||||
*
|
|
||||||
* @brief 更新任务方案状态
|
* @brief 更新任务方案状态
|
||||||
|
*
|
||||||
* @param planId 任务标识
|
* @param planId 任务标识
|
||||||
* @param newStatus 新状态
|
* @param newStatus 新状态
|
||||||
* @return true 更新成功
|
* @return true 更新成功
|
||||||
|
|
@ -199,10 +179,8 @@ bool CmsEngine::updatePlanStatus(const std::string& planId, PlanStatus newStatus
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="模板注册", id="REQ-TMPL-REG-001")
|
|
||||||
* 系统需支持将模板实例添加到模板库中,为后续场景匹配提供候选模板。
|
|
||||||
*
|
|
||||||
* @brief 注册模板实例
|
* @brief 注册模板实例
|
||||||
|
*
|
||||||
* @param tmpl 模板实例
|
* @param tmpl 模板实例
|
||||||
*/
|
*/
|
||||||
void CmsEngine::registerTemplate(const TemplateInstance& tmpl)
|
void CmsEngine::registerTemplate(const TemplateInstance& tmpl)
|
||||||
|
|
@ -211,11 +189,10 @@ void CmsEngine::registerTemplate(const TemplateInstance& tmpl)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="模板匹配", id="REQ-TMPL-MATCH-001")
|
|
||||||
* 系统需遍历模板库,返回置信度最高的模板(简单策略:置信度最大者),
|
|
||||||
* 空库时返回 nullptr。
|
|
||||||
*
|
|
||||||
* @brief 根据场景匹配最佳模板
|
* @brief 根据场景匹配最佳模板
|
||||||
|
*
|
||||||
|
* 遍历模板库,返回置信度最高的模板(简单策略:置信度最大者)。
|
||||||
|
*
|
||||||
* @param scenario 场景描述(当前未用于精确匹配,仅做演示)
|
* @param scenario 场景描述(当前未用于精确匹配,仅做演示)
|
||||||
* @return const TemplateInstance* 最佳模板,无匹配返回 nullptr
|
* @return const TemplateInstance* 最佳模板,无匹配返回 nullptr
|
||||||
*/
|
*/
|
||||||
|
|
@ -239,11 +216,10 @@ const TemplateInstance* CmsEngine::matchTemplate(const std::string& scenario) co
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="执行状态上报", id="REQ-MON-REPORT-001")
|
|
||||||
* 系统需将节点遥测数据写入内部状态表,按 nodeId 覆盖更新,
|
|
||||||
* 以维护各节点最新的执行状态。
|
|
||||||
*
|
|
||||||
* @brief 上报节点执行状态
|
* @brief 上报节点执行状态
|
||||||
|
*
|
||||||
|
* 将节点遥测数据写入内部状态表,按 nodeId 覆盖更新。
|
||||||
|
*
|
||||||
* @param status 执行状态
|
* @param status 执行状态
|
||||||
*/
|
*/
|
||||||
void CmsEngine::reportExecutionStatus(const ExecutionStatus& status)
|
void CmsEngine::reportExecutionStatus(const ExecutionStatus& status)
|
||||||
|
|
@ -252,11 +228,10 @@ void CmsEngine::reportExecutionStatus(const ExecutionStatus& status)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="节点健康检查", id="REQ-MON-HEALTH-001")
|
|
||||||
* 系统需遍历所有节点状态,依据健康指数 < 0.5、异常码 != 0 或
|
|
||||||
* 距最后上报超过 30 秒的判据筛选异常节点,返回异常节点状态列表。
|
|
||||||
*
|
|
||||||
* @brief 检查所有节点健康状态
|
* @brief 检查所有节点健康状态
|
||||||
|
*
|
||||||
|
* 异常判据:健康指数 < 0.5 或异常码 != 0 或心跳超时(距最后上报 > 30秒)。
|
||||||
|
*
|
||||||
* @return std::vector<ExecutionStatus> 异常节点列表
|
* @return std::vector<ExecutionStatus> 异常节点列表
|
||||||
*/
|
*/
|
||||||
std::vector<ExecutionStatus> CmsEngine::checkHealth() const
|
std::vector<ExecutionStatus> CmsEngine::checkHealth() const
|
||||||
|
|
@ -293,10 +268,10 @@ std::vector<ExecutionStatus> CmsEngine::checkHealth() const
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="用户会话创建", id="REQ-SESS-CREATE-001")
|
|
||||||
* 系统需校验 userId 非空且不重复后存入会话表,确保用户会话的唯一性。
|
|
||||||
*
|
|
||||||
* @brief 创建用户会话
|
* @brief 创建用户会话
|
||||||
|
*
|
||||||
|
* 校验 userId 非空且不重复后存入会话表。
|
||||||
|
*
|
||||||
* @param session 用户会话
|
* @param session 用户会话
|
||||||
* @return true 创建成功
|
* @return true 创建成功
|
||||||
* @return false 用户已存在或 ID 为空
|
* @return false 用户已存在或 ID 为空
|
||||||
|
|
@ -314,11 +289,10 @@ bool CmsEngine::createSession(const UserSession& session)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="权限校验", id="REQ-SESS-PERM-001")
|
|
||||||
* 系统需检查用户会话的权限位图是否包含所需的权限掩码,
|
|
||||||
* 通过按位与运算进行判定,以保障系统操作安全。
|
|
||||||
*
|
|
||||||
* @brief 校验用户权限
|
* @brief 校验用户权限
|
||||||
|
*
|
||||||
|
* 检查用户会话的权限位图是否包含所需的权限掩码。
|
||||||
|
*
|
||||||
* @param userId 用户 ID
|
* @param userId 用户 ID
|
||||||
* @param permissionMask 所需权限位掩码
|
* @param permissionMask 所需权限位掩码
|
||||||
* @return true 有权限
|
* @return true 有权限
|
||||||
|
|
@ -339,10 +313,8 @@ bool CmsEngine::checkPermission(const std::string& userId,
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="通知推送", id="REQ-NOTIF-PUSH-001")
|
|
||||||
* 系统需支持将通知消息添加到消息队列尾部,以支撑系统内实时信息传达。
|
|
||||||
*
|
|
||||||
* @brief 推送通知消息
|
* @brief 推送通知消息
|
||||||
|
*
|
||||||
* @param msg 通知消息
|
* @param msg 通知消息
|
||||||
*/
|
*/
|
||||||
void CmsEngine::pushNotification(const NotificationMessage& msg)
|
void CmsEngine::pushNotification(const NotificationMessage& msg)
|
||||||
|
|
@ -351,11 +323,8 @@ void CmsEngine::pushNotification(const NotificationMessage& msg)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="未读通知查询", id="REQ-NOTIF-UNREAD-001")
|
|
||||||
* 系统需遍历通知队列,筛选出所有未读通知并返回列表,
|
|
||||||
* 以支撑用户快速查看待处理信息。
|
|
||||||
*
|
|
||||||
* @brief 获取所有未读通知
|
* @brief 获取所有未读通知
|
||||||
|
*
|
||||||
* @return std::vector<NotificationMessage> 未读通知列表
|
* @return std::vector<NotificationMessage> 未读通知列表
|
||||||
*/
|
*/
|
||||||
std::vector<NotificationMessage> CmsEngine::getUnreadNotifications() const
|
std::vector<NotificationMessage> CmsEngine::getUnreadNotifications() const
|
||||||
|
|
@ -374,11 +343,10 @@ std::vector<NotificationMessage> CmsEngine::getUnreadNotifications() const
|
||||||
// ══════════════════════════════════════════════════════════════════════════════
|
// ══════════════════════════════════════════════════════════════════════════════
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="运行模式切换", id="REQ-MODE-SWITCH-001")
|
|
||||||
* 系统需支持运行模式切换,降级模式下不允许切换到其他模式(模拟故障隔离策略),
|
|
||||||
* 切换成功后更新时间戳和一致性标记。
|
|
||||||
*
|
|
||||||
* @brief 切换系统运行模式
|
* @brief 切换系统运行模式
|
||||||
|
*
|
||||||
|
* 降级模式下不允许切换到其他模式(模拟故障隔离策略),其余模式可自由切换。
|
||||||
|
*
|
||||||
* @param newMode 目标模式
|
* @param newMode 目标模式
|
||||||
* @return true 切换成功
|
* @return true 切换成功
|
||||||
* @return false 切换被拒绝
|
* @return false 切换被拒绝
|
||||||
|
|
@ -396,11 +364,8 @@ bool CmsEngine::switchMode(RunMode newMode)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="系统状态查询", id="REQ-MODE-QUERY-001")
|
|
||||||
* 系统需返回当前系统状态上下文的常量引用,包括运行模式、上下文快照、
|
|
||||||
* 一致性标记和切换时间,以支撑状态监控与审计。
|
|
||||||
*
|
|
||||||
* @brief 获取当前系统状态上下文
|
* @brief 获取当前系统状态上下文
|
||||||
|
*
|
||||||
* @return const SystemStateContext& 状态上下文
|
* @return const SystemStateContext& 状态上下文
|
||||||
*/
|
*/
|
||||||
const SystemStateContext& CmsEngine::getSystemContext() const
|
const SystemStateContext& CmsEngine::getSystemContext() const
|
||||||
|
|
@ -409,11 +374,8 @@ const SystemStateContext& CmsEngine::getSystemContext() const
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @requirement(name="引擎摘要生成", id="REQ-SUMM-GEN-001")
|
|
||||||
* 系统需汇总事件数、方案数、模板数、监控节点数、活跃会话数、
|
|
||||||
* 未读通知数和当前运行模式,生成格式化的引擎运行摘要字符串。
|
|
||||||
*
|
|
||||||
* @brief 获取引擎摘要信息
|
* @brief 获取引擎摘要信息
|
||||||
|
*
|
||||||
* @return std::string 包含事件数、方案数、节点数、未读通知数等
|
* @return std::string 包含事件数、方案数、节点数、未读通知数等
|
||||||
*/
|
*/
|
||||||
std::string CmsEngine::getSummary() const
|
std::string CmsEngine::getSummary() const
|
||||||
|
|
|
||||||
|
|
@ -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 14)
|
||||||
|
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,205 @@
|
||||||
|
#include "app.hpp"
|
||||||
|
#include <gtest/gtest.h>
|
||||||
|
#include <thread>
|
||||||
|
#include <chrono>
|
||||||
|
|
||||||
|
using namespace std;
|
||||||
|
|
||||||
|
class CmsEngineTest : public ::testing::Test {
|
||||||
|
protected:
|
||||||
|
CmsEngine engine;
|
||||||
|
};
|
||||||
|
|
||||||
|
// 1. CmsEngine 构造函数
|
||||||
|
TEST_F(CmsEngineTest, testCmsEngineNormal) {
|
||||||
|
const auto& ctx = engine.getSystemContext();
|
||||||
|
EXPECT_EQ(ctx.currentMode, RunMode::Idle);
|
||||||
|
EXPECT_EQ(ctx.consistencyMark, 0);
|
||||||
|
EXPECT_FALSE(ctx.contextSnapshot.empty());
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. generateNextId (通过公开接口间接验证或假设测试友元)
|
||||||
|
TEST_F(CmsEngineTest, testGenerateNextIdNormal) {
|
||||||
|
TaskPlan p1, p2;
|
||||||
|
p1.name = "P1"; p2.name = "P2";
|
||||||
|
engine.createTaskPlan(p1);
|
||||||
|
engine.createTaskPlan(p2);
|
||||||
|
EXPECT_EQ(p1.id, "ID-00001");
|
||||||
|
EXPECT_EQ(p2.id, "ID-00002");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. ingestEvent
|
||||||
|
TEST_F(CmsEngineTest, testIngestEventNormal) {
|
||||||
|
EventRecord evt; evt.id = "evt1"; evt.priority = 100; evt.status = EventStatus::Pending;
|
||||||
|
EXPECT_TRUE(engine.ingestEvent(evt));
|
||||||
|
EXPECT_NE(engine.findEventById("evt1"), nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testIngestEventBoundary) {
|
||||||
|
EventRecord e1, e2;
|
||||||
|
e1.id = ""; e1.priority = 100;
|
||||||
|
e2.id = "e2"; e2.priority = 256;
|
||||||
|
EXPECT_FALSE(engine.ingestEvent(e1));
|
||||||
|
EXPECT_FALSE(engine.ingestEvent(e2));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. processPendingEvents
|
||||||
|
TEST_F(CmsEngineTest, testProcessPendingEventsNormal) {
|
||||||
|
EventRecord e1, e2;
|
||||||
|
e1.id = "e1"; e1.priority = 1; e1.status = EventStatus::Pending;
|
||||||
|
e2.id = "e2"; e2.priority = 1; e2.status = EventStatus::Generated;
|
||||||
|
engine.ingestEvent(e1); engine.ingestEvent(e2);
|
||||||
|
EXPECT_EQ(engine.processPendingEvents(), 1);
|
||||||
|
EXPECT_EQ(engine.findEventById("e1")->status, EventStatus::Generated);
|
||||||
|
EXPECT_EQ(engine.getAllPlans().size(), 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 5. findEventById
|
||||||
|
TEST_F(CmsEngineTest, testFindEventByIdNormal) {
|
||||||
|
EventRecord e; e.id = "findMe"; e.priority = 1; e.status = EventStatus::Pending;
|
||||||
|
engine.ingestEvent(e);
|
||||||
|
EXPECT_NE(engine.findEventById("findMe"), nullptr);
|
||||||
|
EXPECT_EQ(engine.findEventById("notExist"), nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 6. createTaskPlan
|
||||||
|
TEST_F(CmsEngineTest, testCreateTaskPlanNormal) {
|
||||||
|
TaskPlan p; p.name = "ValidPlan";
|
||||||
|
EXPECT_TRUE(engine.createTaskPlan(p));
|
||||||
|
EXPECT_FALSE(p.id.empty());
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testCreateTaskPlanBoundary) {
|
||||||
|
TaskPlan p; p.name = "";
|
||||||
|
EXPECT_FALSE(engine.createTaskPlan(p));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 7. getAllPlans
|
||||||
|
TEST_F(CmsEngineTest, testGetAllPlansNormal) {
|
||||||
|
EXPECT_TRUE(engine.getAllPlans().empty());
|
||||||
|
TaskPlan p; p.name = "P1";
|
||||||
|
engine.createTaskPlan(p);
|
||||||
|
EXPECT_EQ(engine.getAllPlans().size(), 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 8. findPlanById
|
||||||
|
TEST_F(CmsEngineTest, testFindPlanByIdNormal) {
|
||||||
|
TaskPlan p; p.name = "P1";
|
||||||
|
engine.createTaskPlan(p);
|
||||||
|
EXPECT_NE(engine.findPlanById(p.id), nullptr);
|
||||||
|
EXPECT_EQ(engine.findPlanById("fake"), nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 9. updatePlanStatus
|
||||||
|
TEST_F(CmsEngineTest, testUpdatePlanStatusNormal) {
|
||||||
|
TaskPlan p; p.name = "P1";
|
||||||
|
engine.createTaskPlan(p);
|
||||||
|
EXPECT_TRUE(engine.updatePlanStatus(p.id, PlanStatus::Approved));
|
||||||
|
EXPECT_EQ(engine.findPlanById(p.id)->status, PlanStatus::Approved);
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testUpdatePlanStatusException) {
|
||||||
|
EXPECT_FALSE(engine.updatePlanStatus("nonexistent", PlanStatus::Approved));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 10. registerTemplate
|
||||||
|
TEST_F(CmsEngineTest, testRegisterTemplateNormal) {
|
||||||
|
TemplateInstance t; t.confidence = 0.7;
|
||||||
|
engine.registerTemplate(t);
|
||||||
|
EXPECT_EQ(engine.matchTemplate("any")->confidence, 0.7);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 11. matchTemplate
|
||||||
|
TEST_F(CmsEngineTest, testMatchTemplateNormal) {
|
||||||
|
TemplateInstance t1, t2;
|
||||||
|
t1.confidence = 0.5; t2.confidence = 0.9;
|
||||||
|
engine.registerTemplate(t1); engine.registerTemplate(t2);
|
||||||
|
EXPECT_EQ(engine.matchTemplate("scene")->confidence, 0.9);
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testMatchTemplateBoundary) {
|
||||||
|
EXPECT_EQ(engine.matchTemplate("empty"), nullptr);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 12. reportExecutionStatus
|
||||||
|
TEST_F(CmsEngineTest, testReportExecutionStatusNormal) {
|
||||||
|
ExecutionStatus s; s.nodeId = "n1"; s.healthIndex = 0.9; s.errorCode = 0;
|
||||||
|
s.lastReport = chrono::system_clock::now();
|
||||||
|
engine.reportExecutionStatus(s);
|
||||||
|
EXPECT_EQ(engine.checkHealth().size(), 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 13. checkHealth
|
||||||
|
TEST_F(CmsEngineTest, testCheckHealthSpecial) {
|
||||||
|
ExecutionStatus s1, s2, s3;
|
||||||
|
s1.nodeId = "low_health"; s1.healthIndex = 0.4; s1.errorCode = 0; s1.lastReport = chrono::system_clock::now();
|
||||||
|
s2.nodeId = "error"; s2.healthIndex = 0.9; s2.errorCode = 1; s2.lastReport = chrono::system_clock::now();
|
||||||
|
s3.nodeId = "timeout"; s3.healthIndex = 0.9; s3.errorCode = 0; s3.lastReport = chrono::system_clock::now() - chrono::seconds(31);
|
||||||
|
engine.reportExecutionStatus(s1); engine.reportExecutionStatus(s2); engine.reportExecutionStatus(s3);
|
||||||
|
EXPECT_EQ(engine.checkHealth().size(), 3);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 14. createSession
|
||||||
|
TEST_F(CmsEngineTest, testCreateSessionNormal) {
|
||||||
|
UserSession sess; sess.userId = "u1"; sess.permissionBitmap = 0xFF;
|
||||||
|
EXPECT_TRUE(engine.createSession(sess));
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testCreateSessionBoundary) {
|
||||||
|
UserSession s1, s2;
|
||||||
|
s1.userId = ""; s1.permissionBitmap = 1;
|
||||||
|
s2.userId = "dup"; s2.permissionBitmap = 1;
|
||||||
|
EXPECT_FALSE(engine.createSession(s1));
|
||||||
|
EXPECT_TRUE(engine.createSession(s2));
|
||||||
|
EXPECT_FALSE(engine.createSession(s2));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 15. checkPermission
|
||||||
|
TEST_F(CmsEngineTest, testCheckPermissionNormal) {
|
||||||
|
UserSession sess; sess.userId = "u1"; sess.permissionBitmap = 0x0F;
|
||||||
|
engine.createSession(sess);
|
||||||
|
EXPECT_TRUE(engine.checkPermission("u1", 0x03));
|
||||||
|
EXPECT_FALSE(engine.checkPermission("u1", 0x10));
|
||||||
|
EXPECT_FALSE(engine.checkPermission("u2", 0x01));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 16. pushNotification
|
||||||
|
TEST_F(CmsEngineTest, testPushNotificationNormal) {
|
||||||
|
NotificationMessage msg; msg.isRead = false;
|
||||||
|
engine.pushNotification(msg);
|
||||||
|
EXPECT_EQ(engine.getUnreadNotifications().size(), 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 17. getUnreadNotifications
|
||||||
|
TEST_F(CmsEngineTest, testGetUnreadNotificationsNormal) {
|
||||||
|
NotificationMessage m1, m2;
|
||||||
|
m1.isRead = false; m2.isRead = true;
|
||||||
|
engine.pushNotification(m1); engine.pushNotification(m2);
|
||||||
|
EXPECT_EQ(engine.getUnreadNotifications().size(), 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 18. switchMode
|
||||||
|
TEST_F(CmsEngineTest, testSwitchModeNormal) {
|
||||||
|
EXPECT_TRUE(engine.switchMode(RunMode::AutoExec));
|
||||||
|
EXPECT_EQ(engine.getSystemContext().currentMode, RunMode::AutoExec);
|
||||||
|
}
|
||||||
|
|
||||||
|
TEST_F(CmsEngineTest, testSwitchModeSpecial) {
|
||||||
|
engine.switchMode(RunMode::Degraded);
|
||||||
|
EXPECT_FALSE(engine.switchMode(RunMode::Idle));
|
||||||
|
EXPECT_TRUE(engine.switchMode(RunMode::Degraded));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 19. getSystemContext
|
||||||
|
TEST_F(CmsEngineTest, testGetSystemContextNormal) {
|
||||||
|
const auto& ctx = engine.getSystemContext();
|
||||||
|
EXPECT_EQ(ctx.currentMode, RunMode::Idle);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 20. getSummary
|
||||||
|
TEST_F(CmsEngineTest, testGetSummaryNormal) {
|
||||||
|
string summary = engine.getSummary();
|
||||||
|
EXPECT_NE(summary.find("CMS Engine Summary"), string::npos);
|
||||||
|
EXPECT_NE(summary.find("Events"), string::npos);
|
||||||
|
EXPECT_NE(summary.find("Idle"), string::npos);
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue