fabian/simple_iot
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: fabian:047d8e090227d5e7b5dccf80d870fa39d71d8aa2
Branches Tags
fabian:master
..
compare: fabian:cc472c72df1f54ee7e815f568c9c8ca3d79f347f
Branches Tags
fabian:master

No commits in common. "047d8e090227d5e7b5dccf80d870fa39d71d8aa2" and "cc472c72df1f54ee7e815f568c9c8ca3d79f347f" have entirely different histories.
047d8e0902 ... cc472c72df

2 changed files with 2 additions and 16 deletions
Show Stats Expand all files Collapse all files

2
library.json
View File

@ -14,7 +14,7 @@
"export": { "export": {
"exclude": "examples" "exclude": "examples"
}, },
"version": "0.2.0", "version": "0.1.0",
"frameworks": "arduino", "frameworks": "arduino",
"platforms": "espressif8266", "platforms": "espressif8266",
"dependencies": { "dependencies": {

16
simple_iot.h
View File

@ -78,7 +78,6 @@ public:
bool act_on(String topic, IOTActionHandlerFunction f); bool act_on(String topic, IOTActionHandlerFunction f);
bool report_on(String topic, IOTReportHandlerFunction f, unsigned long update_interval, bool use_cache); bool report_on(String topic, IOTReportHandlerFunction f, unsigned long update_interval, bool use_cache);
void log(const char* fmt, ...) __attribute__((format (printf, 2, 3))); void log(const char* fmt, ...) __attribute__((format (printf, 2, 3)));
void publish(String topic, String payload, bool retain=false);
}; };
/** /**
@ -339,23 +338,10 @@ void SimpleIOT::_mqtt_callback(char* top, byte* pl, uint len) {
} }
void SimpleIOT::_mqtt_publish_report(String topic, String report) { void SimpleIOT::_mqtt_publish_report(String topic, String report) {
publish(topic, report, true);
}
/**
* Publishes a message via MQTT.
*
* @param topic The topic to publish to. Will be appended to base_topic.
* @param payload The payload to publish.
* @param retain Whether to ask the broker to retain the message.
*/
void SimpleIOT::publish(String topic, String payload, bool retain) {
if (!_mqtt_enabled) return;
String final_topic = String(_mqtt_topic); String final_topic = String(_mqtt_topic);
final_topic.concat(topic); final_topic.concat(topic);
_mqtt_client.publish(final_topic.c_str(), payload.c_str(), retain); _mqtt_client.publish(final_topic.c_str(), report.c_str(), true);
} }
/***** End of MQTT stuff *****/ /***** End of MQTT stuff *****/
/***** HTTP stuff *****/ /***** HTTP stuff *****/