/// © MiroZ 2024

#include "Mqtt.h"

#include <esp_log.h>
#include "TaskFactory.h"

static const char * mqtt_broker = "mqtt-dev-server.westus2-1.ts.eventgrid.azure.net";
static const char * topic = "wellnuotopics/topic1";
static const int mqtt_port = 8883;

static const char * TAG = "mqtts";

void Mqtt::callback(char* topic, uint8_t * payload, uint32_t length)
{
	ESP_LOGI(TAG, "Message arrived in topic: %s\n", topic);
	payload[length] = 0;
	ESP_LOGW(TAG, "%s", (char*)payload);
}

void Mqtt::task()
{
	while(true)
	{
		while (!m_mqtt_client->connected()) 
		{
			ESP_LOGI(TAG, "connecting to mqtt broker...");
			if (m_mqtt_client->connect("Esp32 client", "client1-authn-ID", NULL)) 
				ESP_LOGI(TAG, "connected");
			else 
			{
				ESP_LOGE(TAG, "failed with state %d", m_mqtt_client->state());
			    delay(5000);
			}
		}

		int n = 0;

		while(true)
		{
			if(!m_mqtt_client->connected())
				break;

			m_mqtt_client->loop();

			ESP_LOGI(TAG, "publishing...");
            bool val = m_mqtt_client->publish(topic, "Hi I'm ESP32 ^^");

            if(val)
                ESP_LOGI(TAG, "%d publish ok", n);
            else
                ESP_LOGE(TAG, "%d publish failed", n);

			ESP_LOGI(TAG, "%d", TaskFactory::getStackHighWaterMark());

			delay(50000);

			n++;
		}
	}
}

void Mqtt::start()
{
	ESP_LOGW(TAG, "Starting mqtt");

	m_esp_client = new WiFiClientSecure();
	m_mqtt_client = new PubSubClient(*m_esp_client);

	m_esp_client->setCACert((const char*)server_cert);
	m_esp_client->setCertificate((const char *)client_cert);  // for client verification
	m_esp_client->setPrivateKey((const char *)client_key);    // for client verification

	m_mqtt_client->setServer(mqtt_broker, mqtt_port);
	m_mqtt_client->setCallback(std::bind(&Mqtt::callback, this, _1, _2, _3));

	m_task = TASK_FACTORY.createTask(std::bind(&Mqtt::task, this), "mqtt task", 6144, 5, 0);
}