|
|
|
|
@ -46,6 +46,7 @@ void reconnect()
|
|
|
|
|
{
|
|
|
|
|
Serial.println("connected");
|
|
|
|
|
client.subscribe("door/lock");
|
|
|
|
|
client.subscribe("alarm/state");
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
@ -73,11 +74,33 @@ void callback(char* topic, byte* payload, unsigned int length) {
|
|
|
|
|
}
|
|
|
|
|
Serial.println();
|
|
|
|
|
|
|
|
|
|
if (doc["deviceId"] == deviceId && 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 (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);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -98,7 +121,7 @@ bool lastReed = 0;
|
|
|
|
|
|
|
|
|
|
void loop()
|
|
|
|
|
{
|
|
|
|
|
bool reed = !digitalRead(REED_ACTIVATION_PIN);
|
|
|
|
|
bool reed = digitalRead(REED_ACTIVATION_PIN);
|
|
|
|
|
|
|
|
|
|
if (reed != lastReed)
|
|
|
|
|
{
|
|
|
|
|
|