erster Import

1 files changed, 89 insertions, 0 deletions

diff --git a/src/main.c b/src/main.c
new file mode 100644
index 0000000..9579568
--- /dev/null
+++ b/src/main.c
@@ -0,0 +1,89 @@
+// Standard C
+#include <signal.h>
+#include <stdbool.h>
+#include <stdio.h>
+#include <stdlib.h>
+
+// System
+#include <unistd.h>
+
+// Project
+#include <mosquitto.h>
+
+#define CLIENT_ID "my-client-id"
+#define HOST "192.168.77.2"
+#define PORT 1883
+#define USERNAME "zigbee2mqtt"
+#define PASSWORD "xoorei2uk2booSudies4Numoek1uot"
+#define TOPIC "zigbee2mqtt/Kontaktsensor"
+#define KEEPALIVE 10
+#define WAIT_UNTIL_RECONNECT 10
+
+static volatile bool terminate = false; // NOLINT
+
+void
+handler(int signal)
+{
+        if ( signal == SIGINT ) {
+                terminate = true;
+        }
+}
+
+static void
+message_callback(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)
+{
+        (void) obj;
+        (void) mosq;
+        printf("message '%.*s' for topic '%s'\n",
+               message->payloadlen, (const char *) message->payload,
+               message->topic);
+}
+
+int
+main(void)
+{
+        (void) signal(SIGINT, handler);
+
+        mosquitto_lib_init();
+
+        struct mosquitto *client = mosquitto_new(CLIENT_ID, true, NULL);
+        if ( client == NULL ) {
+                (void) fprintf(stderr, "error on new client...\n");
+                return EXIT_FAILURE;
+        }
+
+        int err = mosquitto_username_pw_set(client, USERNAME, PASSWORD);
+        if ( err != MOSQ_ERR_SUCCESS ) {
+                (void) fprintf(stderr, "error: %s\n", mosquitto_strerror(err));
+                mosquitto_destroy(client);
+                return EXIT_FAILURE;
+        }
+
+        mosquitto_message_callback_set(client, message_callback);
+
+        err = mosquitto_connect(client, HOST, PORT, KEEPALIVE);
+        if ( err != MOSQ_ERR_SUCCESS ) {
+                (void) fprintf(stderr, "error: %s\n", mosquitto_strerror(err));
+                mosquitto_destroy(client);
+                return EXIT_FAILURE;
+        }
+
+        mosquitto_subscribe(client, NULL, TOPIC, 0);
+
+        while ( !terminate ) {
+                err = mosquitto_loop(client, -1, 1);
+                if ( !terminate && err ) {
+                        (void) fprintf(stderr, "connection error: %s\n", mosquitto_strerror(err));
+                        sleep(WAIT_UNTIL_RECONNECT); // NOLINT
+                        mosquitto_reconnect(client);
+                }
+        }
+
+        printf("cleanup...\n");
+        mosquitto_disconnect(client);
+        mosquitto_destroy(client);
+
+        mosquitto_lib_cleanup();
+
+        return EXIT_SUCCESS;
+}