dunkelstern/libmqtt
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Make connect tests work (needs a local MQTT broker)

Browse source
This commit is contained in:
Johannes Schriewer 2018-07-30 02:57:58 +02:00
parent 5d746b6787
commit 022b5a87ec
2 changed files with 48 additions and 38 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
tests/connect_publish.c
View file

@ -4,6 +4,8 @@
#include "mqtt.h" #include "mqtt.h"
bool leave = false;
#define LOG(fmt, ...) fprintf(stdout, fmt "\n", ## __VA_ARGS__) #define LOG(fmt, ...) fprintf(stdout, fmt "\n", ## __VA_ARGS__)
bool err_handler(MQTTHandle *handle, MQTTErrorCode error) { bool err_handler(MQTTHandle *handle, MQTTErrorCode error) {
@ -13,6 +15,28 @@ bool err_handler(MQTTHandle *handle, MQTTErrorCode error) {
return true; return true;
} }
void mqtt_connected(MQTTHandle *handle, void *context) {
LOG("Connected!");
LOG("Trying publish to testsuite/mqtt/test...");
MQTTStatus result = mqtt_publish(handle, "testsuite/mqtt/test", "payload", MQTT_QOS_0);
if (result != MQTT_STATUS_OK) {
LOG("Could not publish");
exit(1);
}
sleep(1);
LOG("Disconnecting...");
result = mqtt_disconnect(handle, NULL, NULL);
if (result != MQTT_STATUS_OK) {
LOG("Could not disconnect");
exit(1);
}
exit(0);
}
int main(int argc, char **argv) { int main(int argc, char **argv) {
MQTTConfig config = { 0 }; MQTTConfig config = { 0 };
@ -21,31 +45,15 @@ int main(int argc, char **argv) {
config.port = 1883; config.port = 1883;
LOG("Trying to connect to %s", config.hostname); LOG("Trying to connect to %s", config.hostname);
MQTTHandle *mqtt = mqtt_connect(&config, err_handler); MQTTHandle *mqtt = mqtt_connect(&config, mqtt_connected, NULL, err_handler);
if (mqtt == NULL) { if (mqtt == NULL) {
LOG("Connection failed!"); LOG("Connection failed!");
return 1; return 1;
} }
LOG("Connected!"); while (!leave) {
LOG("Waiting...");
sleep(5); sleep(1);
LOG("Trying publish to testsuite/mqtt/test...");
MQTTStatus result = mqtt_publish(mqtt, "testsuite/mqtt/test", "payload", MQTT_QOS_0);
if (result != MQTT_STATUS_OK) {
LOG("Could not publish");
return 1;
} }
sleep(5);
LOG("Disconnecting...");
result = mqtt_disconnect(mqtt);
if (result != MQTT_STATUS_OK) {
LOG("Could not disconnect");
return 1;
}
return 0;
} }

38
tests/connect_subscribe.c
View file

@ -1,46 +1,49 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h>
#include <unistd.h> #include <unistd.h>
#include "mqtt.h" #include "mqtt.h"
bool leave = false;
#define LOG(fmt, ...) fprintf(stdout, fmt "\n", ## __VA_ARGS__) #define LOG(fmt, ...) fprintf(stdout, fmt "\n", ## __VA_ARGS__)
bool err_handler(MQTTHandle *handle, MQTTErrorCode error) { bool err_handler(MQTTHandle *handle, MQTTErrorCode error) {
LOG("Error received: %d", error); LOG("Error received: %d", error);
return 1; return 1;
} }
bool leave = false;
void callback(MQTTHandle *handle, char *topic, char *payload) { void callback(MQTTHandle *handle, char *topic, char *payload) {
LOG("Received publish: %s -> %s", topic, payload); LOG("Received publish: %s -> %s", topic, payload);
leave = true; leave = true;
} }
void mqtt_connected(MQTTHandle *handle, void *context) {
LOG("Connected!");
LOG("Trying subscribe on testsuite/mqtt/test...");
MQTTStatus result = mqtt_subscribe(handle, "testsuite/mqtt/test", callback);
if (result != MQTT_STATUS_OK) {
LOG("Could not subscribe");
exit(1);
}
}
int main(int argc, char **argv) { int main(int argc, char **argv) {
MQTTConfig config; MQTTConfig config = { 0 };
config.client_id = "libmqtt_testsuite"; config.client_id = "libmqtt_testsuite";
config.hostname = "test.mosquitto.org"; config.hostname = "localhost";
config.port = 1883; config.port = 1883;
LOG("Trying to connect to test.mosquitto.org"); LOG("Trying to connect to %s...", config.hostname);
MQTTHandle *mqtt = mqtt_connect(&config, err_handler); MQTTHandle *mqtt = mqtt_connect(&config, mqtt_connected, NULL, err_handler);
if (mqtt == NULL) { if (mqtt == NULL) {
LOG("Connection failed!"); LOG("Connection failed!");
return 1; return 1;
} }
LOG("Connected!");
sleep(5);
LOG("Trying subscribe on testsuite/mqtt/test...");
MQTTStatus result = mqtt_subscribe(mqtt, "testsuite/mqtt/test", callback);
if (result != MQTT_STATUS_OK) {
LOG("Could not publish");
return 1;
}
while (!leave) { while (!leave) {
LOG("Waiting..."); LOG("Waiting...");
@ -48,6 +51,5 @@ int main(int argc, char **argv) {
} }
LOG("Disconnecting..."); LOG("Disconnecting...");
mqtt_disconnect(mqtt); mqtt_disconnect(mqtt, NULL, NULL);
return 0;
} }