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

// System
#include <unistd.h>

// Project
#include "config.h"
#include "mqtt.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
callback(struct mosquitto *client, void *userdata, const struct mosquitto_message *message)
{
	UNUSED(client);
	UNUSED(userdata);
	printf("message '%.*s' for topic '%s'\n",
	       message->payloadlen, (const char *) message->payload,
	       message->topic);
}

int
main(void)
{
	init();

	struct mosquitto *client = connect(
	    CLIENT_ID,
	    USERNAME,
	    PASSWORD,
	    HOST,
	    PORT,
	    callback,
	    NULL);

	if ( !client ) {
		return EXIT_FAILURE;
	}

	run(client, (const char *[]){ TOPIC, NULL }, &terminate);

	shutdown(client);

	return EXIT_SUCCESS;
}