// 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;
}