// Standard C
#include <signal.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>

// System
#include <unistd.h>

// Project
#include <mosquitto.h>
#include "config.h"

#ifndef UNUSED
#	define UNUSED(x) (void) (x)
#endif

static volatile bool terminate = false; // NOLINT

static void
handler(int signal)
{
	if ( signal == SIGINT ) {
		terminate = true;
	}
}

static void
cleanup(void)
{
	mosquitto_lib_cleanup();
}

static void
init(void)
{
	(void) signal(SIGINT, handler);

	mosquitto_lib_init();
	(void) atexit(cleanup);
}

static void
message_callback(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)
{
	UNUSED(obj);
	UNUSED(mosq);
	printf("message '%.*s' for topic '%s'\n",
	       message->payloadlen, (const char *) message->payload,
	       message->topic);
}

static struct mosquitto *
setup(void)
{
	struct mosquitto *client = mosquitto_new(CLIENT_ID, true, NULL);
	if ( client == NULL ) {
		(void) fprintf(stderr, "error on new client...\n");
		return NULL;
	}

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

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

	return client;
}

static void
run(struct mosquitto *client)
{
	mosquitto_subscribe(client, NULL, TOPIC, 0);

	while ( !terminate ) {
		static const int defaultTimeout = -1; // 1000ms

		int err = mosquitto_loop(client, defaultTimeout, 1);
		if ( !terminate && err ) {
			(void) fprintf(stderr, "connection error: %s\n", mosquitto_strerror(err));
			sleep(WAIT_UNTIL_RECONNECT); // NOLINT
			mosquitto_reconnect(client);
		}
	}
}

static void
shutdown(struct mosquitto *client)
{
	mosquitto_disconnect(client);
	mosquitto_destroy(client);
}

int
main(void)
{
	init();

	struct mosquitto *client = setup();
	if ( client ) {
		run(client);
		shutdown(client);
	}

	return EXIT_SUCCESS;
}