diff --git a/certs/ca.crt b/certs/ca.crt
new file mode 100644
index 0000000..7bb0512
--- /dev/null
+++ b/certs/ca.crt
@@ -0,0 +1,22 @@
+-----BEGIN CERTIFICATE-----
+MIIDkTCCAnmgAwIBAgIUXOA2Y0XQBCdhzZT5AfVejPufq6MwDQYJKoZIhvcNAQEL
+BQAwVzELMAkGA1UEBhMCREsxEDAOBgNVBAgMB0Rlbm1hcmsxDzANBgNVBAcMBkFh
+cmh1czELMAkGA1UECgwCSDQxCzAJBgNVBAsMAkNBMQswCQYDVQQDDAJDQTAgFw0y
+MzA4MTYwOTQ5NTFaGA8yMTIzMDcyMzA5NDk1MVowVzELMAkGA1UEBhMCREsxEDAO
+BgNVBAgMB0Rlbm1hcmsxDzANBgNVBAcMBkFhcmh1czELMAkGA1UECgwCSDQxCzAJ
+BgNVBAsMAkNBMQswCQYDVQQDDAJDQTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCC
+AQoCggEBALyivQcGcp8qafr6CKy2ztXQ7GYwuuK+ZxfVD+PbH/JvbG4QsdWspRMa
+3TT+IEh/5gP0ZkhK/64ERk82ELzSQa6JMxbywBnnFMHrhC1skVbnFjD2WLcTb+nb
+IOmXbTjTKFXzMLWRbw8z5qHgsRth5TEuHG4wZZURbVKL7pYiuhLZx99Fx/1Od1so
+QJWfauFZGHChYYwN/Pyo1f8sKscyX1s0X3fPnPoNOqXWhPbfIpyNL5V0mig9ch5S
+ul3FinDIxbJrgpvLPU+rWPvEwjskvJLsPNJ5oAr82FEybztCyUjr21Msu7+eAmiI
+ZoFUVptrPmVvJu1rl+nzl0XV5UYaHgECAwEAAaNTMFEwHQYDVR0OBBYEFHBiOzLL
+4HmZAh5DXKNvcbFJw2OZMB8GA1UdIwQYMBaAFHBiOzLL4HmZAh5DXKNvcbFJw2OZ
+MA8GA1UdEwEB/wQFMAMBAf8wDQYJKoZIhvcNAQELBQADggEBAB3I6/W8ISpPDrRT
+Twl9U55lF9GK9NceIPg6AGfrC7RaVRU67NnQC8rTYJFglU/Mt0O4EvL6CiNvlhMI
+IYwi2IbscUJLm8O7sNJ2N51h37vHSHCB4TNVSIZVbukLcJWxxsUpNp+Rgg2ylWL4
+mn7zvh8omaz9rdfcB4Zqc4/J91iXV8BaBpqyoMMKYWBS5NMeKZDxaaAW6VhePBOp
+wo6K1zpe++z5ovN4FkWeeH4qmnOdATViHogX88m5w86x5BTreYuSUpGslbag+de6
+y/zWOOFbWqWI9ALURAdrNzu2YeMZRFPYHvPgGuTd+KGtjzMfTG3KiyVsJ53JhZX+
+4Tqbblc=
+-----END CERTIFICATE-----
\ No newline at end of file
diff --git a/mqtt.js b/mqtt.js
index d4ba7e6..0e3221d 100644
--- a/mqtt.js
+++ b/mqtt.js
@@ -1,7 +1,20 @@
 const StateManager = require("./StateManager");
 const mqtt = require("mqtt");
 
-const mqttClient = mqtt.connect(process.env.MQTT, { clean: true, });
+const fs = require("fs");
+
+// console.log(fs.readFileSync("certs/ca.crt", {encoding: "utf-8"}));
+
+const mqttClient = mqtt.connect(process.env.MQTT, {
+	clean: true,
+	ca: fs.readFileSync("certs/ca.crt", {encoding: "utf-8"}),
+	cert: fs.readFileSync("certs/client-alarm-controller.crt", {encoding: "utf-8"}),
+	key: fs.readFileSync("certs/client-alarm-controller.key", {encoding: "utf-8"})
+});
+
+mqttClient.on("error", (err) => {
+	console.log(err);
+})
 
 mqttClient.on("connect", (a) => {
 	console.log(`Connected to ${process.env.MQTT}`);