feature add device connect error to sentry

This commit is contained in:
alves
2025-12-24 16:27:04 +08:00
parent 42c739cdad
commit 996dd9bbcb
2 changed files with 26 additions and 0 deletions

View File

@@ -54,6 +54,12 @@
#define BP_LOCAL_SERVER_ERR_CODE "bury_point_local_server_err_code"
//device connect error info
#define DEVICE_CONNECT_ERR "error_device_connect"
#define DEVICE_SUBSCRIBE_ERR "error_device_subscribe"
#define DEVICE_PBLISH_ERR "error_device_publish"
#define DEVICE_SET_ENGINE_ERR "error_device_set_engine"
//webview bury point

View File

@@ -4707,6 +4707,8 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_connect()
try {
if (!m_param_data.count("id") || !m_param_data["id"].is_string()) {
handle_general_fail(-1, "param [id] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_connect param [id] is required or wrong type"), DEVICE_CONNECT_ERR);
return;
}
@@ -4714,6 +4716,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_connect()
if (!validate_id(id)) {
handle_general_fail(-1, "id is illegal");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_connect id is illegal"),DEVICE_CONNECT_ERR);
return;
}
@@ -4805,6 +4808,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_subscribe()
try {
if (!m_param_data.count("id") || !m_param_data["id"].is_string()) {
handle_general_fail(-1, "param [id] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_subscribe param [id] is required or wrong type"), DEVICE_SUBSCRIBE_ERR);
return;
}
@@ -4812,11 +4816,13 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_subscribe()
if (!validate_id(id)) {
handle_general_fail(-1, "id is illegal");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_subscribe id is illegal with:")+id,DEVICE_SUBSCRIBE_ERR);
return;
}
if (m_event_id == "") {
handle_general_fail(-1, "event_id is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_subscribe event_id is required or wrong type with:") + id,DEVICE_SUBSCRIBE_ERR);
return;
}
@@ -4824,6 +4830,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_subscribe()
if (!m_param_data.count("topic") || !m_param_data["topic"].is_string()) {
handle_general_fail(-1, "param [topic] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_subscribe param [topic] is required or wrong type"),DEVICE_SUBSCRIBE_ERR);
return;
}
std::string topic = m_param_data["topic"].get<std::string>();
@@ -4834,6 +4841,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_subscribe()
if (!m_param_data.count("qos") || !m_param_data["qos"].is_number()) {
handle_general_fail(-1, "param [qos] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_subscribe param [qos] is required or wrong type"), DEVICE_SUBSCRIBE_ERR);
return;
}
int qos = m_param_data["qos"].get<int>();
@@ -4945,6 +4953,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_set_engine()
try {
if (!m_param_data.count("engine_id") || !m_param_data["engine_id"].is_string()) {
handle_general_fail(-1, "param [engine_id] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine param [engine_id] is required or wrong type"),DEVICE_SET_ENGINE_ERR);
return;
}
@@ -4952,17 +4961,20 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_set_engine()
if (!validate_id(engine_id)) {
handle_general_fail(-1, "id is illegal");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine id is illegal with:") + engine_id, DEVICE_SET_ENGINE_ERR);
return;
}
if (!m_param_data.count("ip") || !m_param_data["ip"].is_string()) {
handle_general_fail(-1, "param [ip] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine param [ip] is required or wrong type"),DEVICE_SET_ENGINE_ERR);
return;
}
std::string ip = m_param_data["ip"].get<std::string>();
if (!m_param_data.count("port") || !m_param_data["port"].is_number()) {
handle_general_fail(-1, "param [port] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine param [port] is required or wrong type"), DEVICE_SET_ENGINE_ERR);
return;
}
@@ -4989,6 +5001,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_set_engine()
if (engine == nullptr) {
handle_general_fail(-1, "invalid engine");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine invalid engine"),DEVICE_SET_ENGINE_ERR);
return;
}
@@ -4997,6 +5010,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_set_engine()
if (!engine->CheckConnected()) {
BOOST_LOG_TRIVIAL(error) << "[SSWCP_MqttAgent_Instance] 引擎连接状态异常";
handle_general_fail(-1, "engine connection lost");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine engine connection lost"), DEVICE_SET_ENGINE_ERR);
return;
}
BOOST_LOG_TRIVIAL(info) << "[SSWCP_MqttAgent_Instance] 引擎连接状态正常";
@@ -5089,6 +5103,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_set_engine()
if (!host) {
handle_general_fail(-1, "host created failed");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_set_engine host created failed"), DEVICE_SET_ENGINE_ERR);
return;
} else {
auto weak_self = std::weak_ptr<SSWCP_Instance>(shared_from_this());
@@ -5530,6 +5545,7 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_publish()
try {
if (!m_param_data.count("id") || !m_param_data["id"].is_string()) {
handle_general_fail(-1, "param [id] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_publish host created failed"), DEVICE_PBLISH_ERR);
return;
}
@@ -5537,23 +5553,27 @@ void SSWCP_MqttAgent_Instance::sw_mqtt_publish()
if (!validate_id(id)) {
handle_general_fail(-1, "id is illegal");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_publish id is illegal"), DEVICE_PBLISH_ERR);
return;
}
if (!m_param_data.count("topic") || !m_param_data["topic"].is_string()) {
handle_general_fail(-1, "param [topic] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_publish param [topic] is required or wrong type"), DEVICE_PBLISH_ERR);
return;
}
std::string topic = m_param_data["topic"].get<std::string>();
if (!m_param_data.count("qos") || !m_param_data["qos"].is_number()) {
handle_general_fail(-1, "param [qos] is required or wrong type");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_publish param [qos] is required or wrong type"), DEVICE_PBLISH_ERR);
return;
}
int qos = m_param_data["qos"].get<int>();
if (!m_param_data.count("payload") || !m_param_data["payload"].is_string()) {
handle_general_fail(-1, "param [payload] required");
Slic3r::sentryReportLog(Slic3r::SENTRY_LOG_ERROR, std::string("device_publish param [payload] required"), DEVICE_PBLISH_ERR);
return;
}
std::string payload = m_param_data["payload"].get<std::string>();