gabrielkheisa/antares-esp8266-mqtt
1
0
Fork 0
mirror of https://github.com/gabrielkheisa/antares-esp8266-mqtt.git synced 2025-08-21 11:31:09 +00:00
Code Issues Projects Releases Wiki Activity

Changed payload to Antares format

Browse Source
This commit is contained in:
vmasdani
2019-01-17 17:03:09 +07:00
parent 37e82f2ace
commit 508c58428f
11 changed files with 35 additions and 624 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/AntaresESP8266MQTT.cpp
View File

@@ -125,15 +125,40 @@ void AntaresESP8266MQTT::printDebug(String text) {
void AntaresESP8266MQTT::publish(String projectName, String deviceName) {
String topic = "/oneM2M/req/" + _accessKey + "/antares-cse/json";
char jsonDataChar[_jsonDataString.length() + 1];
String finalData;
_jsonDataString.replace("\"", "\\\"");
Serial.println(_jsonDataString);
finalData += "{";
finalData += "\"m2m:rqp\": {";
finalData += "\"fr\": \"" + _accessKey +"\",";
finalData += "\"to\": \"/antares-cse/antares-id/" + projectName + "/" + deviceName + "\",";
finalData += "\"op\": 1,";
finalData += "\"rqi\": 123456,";
finalData += "\"pc\": {";
finalData += "\"m2m:cin\": {";
finalData += "\"cnf\": \"message\",";
finalData += "\"con\": \""+ _jsonDataString + "\"";
finalData += "}";
finalData += "},";
finalData += "\"ty\": 4";
finalData += "}";
finalData += "}";
// DynamicJsonBuffer jsonBuffer;
// JsonObject& object = jsonBuffer.parseObject(finalData);
// object.prettyPrintTo(Serial);
char finalDataChar[finalData.length() + 1];
char topicChar[topic.length() + 1];
_jsonDataString.toCharArray(jsonDataChar, _jsonDataString.length() + 1);
finalData.toCharArray(finalDataChar, finalData.length() + 1);
topic.toCharArray(topicChar, topic.length() + 1);
_jsonDataString = "{}";
client.publish(topicChar, jsonDataChar);
client.publish(topicChar, finalDataChar);
}
void AntaresESP8266MQTT::setCallback(std::function<void(char*, uint8_t*, unsigned int)> callbackFunc) {

2
src/PubSubClient.h
View File

@@ -23,7 +23,7 @@
// MQTT_MAX_PACKET_SIZE : Maximum packet size
#ifndef MQTT_MAX_PACKET_SIZE
#define MQTT_MAX_PACKET_SIZE 128
#define MQTT_MAX_PACKET_SIZE 2500
#endif
// MQTT_KEEPALIVE : keepAlive interval in Seconds