MMDVM/MMDVMHost
1
0
Fork 0
mirror of https://github.com/g4klx/MMDVMHost synced 2025-12-21 23:45:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update the MQTT and JSON handling slightly.

Browse Source
This commit is contained in:
Jonathan Naylor
2023-07-04 17:08:11 +01:00
parent 893952f024
commit fddabee1b9
3 changed files with 22 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Log.cpp
View File

@@ -101,7 +101,7 @@ void WriteJSON(const std::string& topLevel, nlohmann::json& json)
top[topLevel] = json;
m_mqtt->publish("json", top.dump().c_str());
m_mqtt->publish("json", top.dump());
}
}

37
MQTTConnection.cpp
View File

@@ -84,19 +84,14 @@ bool CMQTTConnection::publish(const char* topic, const char* text)
assert(topic != NULL);
assert(text != NULL);
if (!m_connected)
return false;
return publish(topic, (unsigned char*)text, ::strlen(text));
}
char topicEx[100U];
::sprintf(topicEx, "%s/%s", m_name.c_str(), topic);
bool CMQTTConnection::publish(const char* topic, const std::string& text)
{
assert(topic != NULL);
int rc = ::mosquitto_publish(m_mosq, NULL, topicEx, ::strlen(text), text, static_cast<int>(m_qos), false);
if (rc != MOSQ_ERR_SUCCESS) {
::fprintf(stderr, "MQTT Error publishing: %s\n", ::mosquitto_strerror(rc));
return false;
}
return true;
return publish(topic, (unsigned char*)text.c_str(), text.size());
}
bool CMQTTConnection::publish(const char* topic, const unsigned char* data, unsigned int len)
@@ -107,13 +102,21 @@ bool CMQTTConnection::publish(const char* topic, const unsigned char* data, unsi
if (!m_connected)
return false;
char topicEx[100U];
::sprintf(topicEx, "%s/%s", m_name.c_str(), topic);
if (::strchr(topic, '/') == NULL) {
char topicEx[100U];
::sprintf(topicEx, "%s/%s", m_name.c_str(), topic);
int rc = ::mosquitto_publish(m_mosq, NULL, topicEx, len, data, static_cast<int>(m_qos), false);
if (rc != MOSQ_ERR_SUCCESS) {
::fprintf(stderr, "MQTT Error publishing: %s\n", ::mosquitto_strerror(rc));
return false;
int rc = ::mosquitto_publish(m_mosq, NULL, topicEx, len, data, static_cast<int>(m_qos), false);
if (rc != MOSQ_ERR_SUCCESS) {
::fprintf(stderr, "MQTT Error publishing: %s\n", ::mosquitto_strerror(rc));
return false;
}
} else {
int rc = ::mosquitto_publish(m_mosq, NULL, topic, len, data, static_cast<int>(m_qos), false);
if (rc != MOSQ_ERR_SUCCESS) {
::fprintf(stderr, "MQTT Error publishing: %s\n", ::mosquitto_strerror(rc));
return false;
}
}
return true;

1
MQTTConnection.h
View File

@@ -38,6 +38,7 @@ public:
bool open();
bool publish(const char* topic, const char* text);
bool publish(const char* topic, const std::string& text);
bool publish(const char* topic, const unsigned char* data, unsigned int len);
void close();