#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include "MQTTClient.h"

int msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message)
{
    printf("Response auth: %s\n", (char *) message->payload);
    MQTTClient_freeMessage(&message);
    MQTTClient_free(topicName);
    return 1;
}


int main(int argc, char* argv[]) {
	MQTTClient mqttClient;
	MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
    MQTTClient_SSLOptions sslOptions = MQTTClient_SSLOptions_initializer;
    sslOptions.trustStore = "/etc/ssl/certs/ca-certificates.crt";
   
	int rc, ch;

	MQTTClient_create(&mqttClient, "ssl://brokerAddress:8905", "test", MQTTCLIENT_PERSISTENCE_NONE, NULL);
	conn_opts.keepAliveInterval = 20;
    conn_opts.cleansession = 1;
    conn_opts.username = "username";
    conn_opts.password = "password";
    conn_opts.ssl = &sslOptions;

    MQTTClient_setCallbacks(mqttClient, NULL, NULL, msgarrvd, NULL);

    if ((rc = MQTTClient_connect(mqttClient, &conn_opts)) != MQTTCLIENT_SUCCESS)
    {
        printf("Failed to connect, return code %d\n Error: %s\n", rc, strerror(errno));
        exit(-1);
    }

    
    MQTTClient_subscribe(mqttClient, "testtopic", 0);

    do 
    {
        ch = getchar();
    } while(ch!='Q' && ch != 'q');

    MQTTClient_disconnect(mqttClient, 10000);
    MQTTClient_destroy(&mqttClient);

	return 0;
}