From c271d9cf413537af1a47331f1e885b6fdca69cd2 Mon Sep 17 00:00:00 2001
From: Relintai <relintai@protonmail.com>
Date: Sat, 1 May 2021 17:54:12 +0200
Subject: [PATCH] Update the engine., and init an mqtt broken in main.

---
 HEADS    |  2 +-
 main.cpp | 10 +++++++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/HEADS b/HEADS
index fbb8516..5dde0b7 100644
--- a/HEADS
+++ b/HEADS
@@ -1 +1 @@
-{"engine": {"master": "8c483b4f8ee02bebb9db275a262208254f0d34fc"}}
\ No newline at end of file
+{"engine": {"master": "09e13d255cee057e788b2acceec896a2e86df615"}}
\ No newline at end of file
diff --git a/main.cpp b/main.cpp
index 3f2597f..a1e851d 100644
--- a/main.cpp
+++ b/main.cpp
@@ -14,6 +14,8 @@
 
 #include "core/settings.h"
 
+#include "modules/mqtt_server/mqtt_server.h"
+
 #define MAIN_CLASS RDNApplication
 
 void create_databases() {
@@ -25,7 +27,7 @@ void create_databases() {
 		return;
 	}
 
-/*
+	/*
 	rapidjson::Value dbs = settings->settings["databases"];
 
 	if (!dbs.IsArray()) {
@@ -79,14 +81,20 @@ int main(int argc, char **argv) {
 	server->port = 8080;
 	server->initialize();
 
+	MQTTServer *mqtt_server = new MQTTServer();
+	mqtt_server->initialize();
+
 	if (!migrate) {
 		printf("Initialized!\n");
+
+		mqtt_server->run_async();
 		server->main_loop();
 	} else {
 		printf("Running migrations.\n");
 		app->migrate();
 	}
 
+	delete mqtt_server;
 	delete server;
 	delete app;
 	delete dbm;