just some reformatting - no code changes
This commit is contained in:
27
src/main.cpp
27
src/main.cpp
@@ -1,8 +1,8 @@
|
|||||||
#include <Arduino.h>
|
#include <Arduino.h>
|
||||||
#include <WiFiClient.h>
|
|
||||||
#include <PubSubClient.h>
|
|
||||||
#include <ESP8266WiFi.h>
|
|
||||||
#include <ArduinoJson.h>
|
#include <ArduinoJson.h>
|
||||||
|
#include <ESP8266WiFi.h>
|
||||||
|
#include <PubSubClient.h>
|
||||||
|
#include <WiFiClient.h>
|
||||||
|
|
||||||
const char* ssid = "JoNelsDarlings";
|
const char* ssid = "JoNelsDarlings";
|
||||||
const char* password = "Paris2016";
|
const char* password = "Paris2016";
|
||||||
@@ -11,13 +11,12 @@ const char* mqtt_server = "mqtt.ddns.kawomi.com";
|
|||||||
WiFiClient espClient;
|
WiFiClient espClient;
|
||||||
PubSubClient client(espClient);
|
PubSubClient client(espClient);
|
||||||
|
|
||||||
boolean isOpen=false;
|
boolean isOpen = false;
|
||||||
|
|
||||||
#define MSG_BUFFER_SIZE (50)
|
#define MSG_BUFFER_SIZE (50)
|
||||||
char msg[MSG_BUFFER_SIZE];
|
char msg[MSG_BUFFER_SIZE];
|
||||||
|
|
||||||
void setup_wifi() {
|
void setup_wifi() {
|
||||||
|
|
||||||
delay(10);
|
delay(10);
|
||||||
// We start by connecting to a WiFi network
|
// We start by connecting to a WiFi network
|
||||||
Serial.println();
|
Serial.println();
|
||||||
@@ -40,7 +39,6 @@ void setup_wifi() {
|
|||||||
Serial.println(WiFi.localIP());
|
Serial.println(WiFi.localIP());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
void reconnect() {
|
void reconnect() {
|
||||||
// Loop until we're reconnected
|
// Loop until we're reconnected
|
||||||
while (!client.connected()) {
|
while (!client.connected()) {
|
||||||
@@ -51,7 +49,7 @@ void reconnect() {
|
|||||||
// Attempt to connect
|
// Attempt to connect
|
||||||
if (client.connect(clientId.c_str())) {
|
if (client.connect(clientId.c_str())) {
|
||||||
Serial.println("MQTT connected");
|
Serial.println("MQTT connected");
|
||||||
client.subscribe("Address/Livorno/GaragedoorIndicator",1);
|
client.subscribe("Address/Livorno/GaragedoorIndicator", 1);
|
||||||
} else {
|
} else {
|
||||||
Serial.print("MQTT failed, rc=");
|
Serial.print("MQTT failed, rc=");
|
||||||
Serial.print(client.state());
|
Serial.print(client.state());
|
||||||
@@ -66,7 +64,7 @@ void callback(char* topic, byte* payload, unsigned int length) {
|
|||||||
Serial.print("Message arrived [");
|
Serial.print("Message arrived [");
|
||||||
Serial.print(topic);
|
Serial.print(topic);
|
||||||
|
|
||||||
String recBuf="";
|
String recBuf = "";
|
||||||
Serial.print("] ");
|
Serial.print("] ");
|
||||||
for (unsigned int i = 0; i < length; i++) {
|
for (unsigned int i = 0; i < length; i++) {
|
||||||
recBuf += (char)payload[i];
|
recBuf += (char)payload[i];
|
||||||
@@ -74,16 +72,15 @@ void callback(char* topic, byte* payload, unsigned int length) {
|
|||||||
Serial.println(recBuf);
|
Serial.println(recBuf);
|
||||||
|
|
||||||
StaticJsonDocument<1024> jsonDoc;
|
StaticJsonDocument<1024> jsonDoc;
|
||||||
deserializeJson(jsonDoc,recBuf);
|
deserializeJson(jsonDoc, recBuf);
|
||||||
const char* theText=jsonDoc["status"];
|
const char* theText = jsonDoc["status"];
|
||||||
Serial.println(theText);
|
Serial.println(theText);
|
||||||
|
|
||||||
isOpen=(strncmp(theText,"opened",6)==0);
|
isOpen = (strncmp(theText, "opened", 6) == 0);
|
||||||
|
|
||||||
Serial.println(isOpen?"CALLBACK: OPEN":"CALLBACK: CLOSED");
|
Serial.println(isOpen ? "CALLBACK: OPEN" : "CALLBACK: CLOSED");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
void setup() {
|
void setup() {
|
||||||
Serial.begin(9600);
|
Serial.begin(9600);
|
||||||
|
|
||||||
@@ -103,7 +100,8 @@ void loop() {
|
|||||||
}
|
}
|
||||||
client.loop();
|
client.loop();
|
||||||
|
|
||||||
// !!!! Funny enough - the meaning of the BuiltIn - LED is INVERTED, HIGH is off!!!
|
// !!!! Funny enough - the meaning of the BuiltIn - LED is INVERTED, HIGH is
|
||||||
|
// off!!!
|
||||||
digitalWrite(LED_BUILTIN, HIGH);
|
digitalWrite(LED_BUILTIN, HIGH);
|
||||||
delay(400);
|
delay(400);
|
||||||
|
|
||||||
@@ -114,5 +112,4 @@ void loop() {
|
|||||||
} else {
|
} else {
|
||||||
Serial.print("-");
|
Serial.print("-");
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user