Check alarm/state change field

src/main.cpp

@@ -3,10 +3,12 @@
 #include <PubSubClient.h>
 #include <ArduinoJson.h>
 
-const char *ssid = "PET Aflytningsvogn #43";
-const char *password = "zwr33htm";
+const char *ssid = "PET Aflytningsvogn #42";
+const char *password = "FuckGFwifi123";
 
-const char *mqtt_server = "192.168.24.215";
+const char *mqtt_server = "192.168.137.86";
+
+const int deviceId = 2;
 
 WiFiClient espClient;
 PubSubClient client(espClient);
@@ -44,6 +46,7 @@ void reconnect()
         {
             Serial.println("connected");
             client.subscribe("door/lock");
+            client.subscribe("alarm/state");
         }
         else
         {
@@ -57,6 +60,7 @@ void reconnect()
 }
 
 #define RELAY_ACTIVATION_PIN D6
+#define REED_ACTIVATION_PIN D5
 
 void callback(char* topic, byte* payload, unsigned int length) {
     StaticJsonDocument<256> doc;
@@ -65,16 +69,40 @@ void callback(char* topic, byte* payload, unsigned int length) {
     Serial.print("Message arrived [");
     Serial.print(topic);
     Serial.print("] ");
-    for (int i = 0; i < length; i++) {
+    for (size_t i = 0; i < length; i++) {
         Serial.print((char)payload[i]);
     }
     Serial.println();
 
-    if (doc["deviceId"] == 2 && doc["lock"] == true) {
-        digitalWrite(RELAY_ACTIVATION_PIN, HIGH);   // Turn the relay on
-    } else {
-        digitalWrite(RELAY_ACTIVATION_PIN, LOW);  // Turn the relay off
+    if (strcmp(topic, "door/lock") == 0) 
+    {
+        if (doc["deviceId"] == deviceId && doc["lock"] == true) {
+            digitalWrite(RELAY_ACTIVATION_PIN, HIGH);
+        } else {
+            digitalWrite(RELAY_ACTIVATION_PIN, LOW);
+        }
+    }    
+    else if (strcmp(topic, "alarm/state") == 0)
+    {
+        if (doc["changed"] == true) {
+            if (strcmp(doc["status"], "Armed") == 0)
+            {
+                if (bool reed = digitalRead(REED_ACTIVATION_PIN) == 1)
+                {
+                    DynamicJsonDocument doc(1024);
+
+                    doc["deviceId"] = deviceId;
+                    doc["open"] = reed;
+
+                    char buffer[1024];
+                    size_t n = serializeJson(doc, buffer);
+                    
+                    client.publish("door/status", buffer, n);
+                }   
+            }
+        }
     }
+    
 
 }
 
@@ -83,6 +111,7 @@ void setup()
     Serial.begin(115200);
 
     pinMode(RELAY_ACTIVATION_PIN, OUTPUT);
+    pinMode(REED_ACTIVATION_PIN, INPUT);
 
     setup_wifi();
     client.setServer(mqtt_server, 1883);
@@ -90,7 +119,30 @@ void setup()
     reconnect();
 }
 
+bool lastReed = 0;
+
 void loop()
 {
+    bool reed = digitalRead(REED_ACTIVATION_PIN);
+    
+    if (reed != lastReed)
+    {
+        Serial.print("Reed has changed to: ");
+        Serial.println(reed);
+        
+
+        DynamicJsonDocument doc(1024);
+
+        doc["deviceId"] = deviceId;
+        doc["open"] = reed;
+
+        char buffer[1024];
+        size_t n = serializeJson(doc, buffer);
+        
+        client.publish("door/status", buffer, n);
+        lastReed = reed;
+    }
+    
+
     client.loop();
 }