arduino-sketches – Diff between revs 8 and 17

Subversion Repositories:

?pathlinks?

Rev 8 – Details – Blame – Last modification – View Log

 /*************************************************************************/
-/*    Copyright (C) 2022 Wizardry and Steamworks - License: GNU GPLv3    */
+/*    Copyright (C) 2023 Wizardry and Steamworks - License: GNU GPLv3    */
 /*************************************************************************/
+// Removing comment for debugging over the first serial port.
 // #define DEBUG 1
 // The AP to connect to via Wifi.
 #define STA_SSID ""
 // The AP Wifi password.
 #define STA_PSK ""
 // Platform specific defines.
 #if defined(ARDUINO_ARCH_ESP8266)
 #define GET_CHIP_ID() (ESP.getChipId())
 #elif defined(ARDUINO_ARCH_ESP32)
-#define GET_CHIP_ID() ((uint16_t)(ESP.getEfuseMac()>>32))
+#define GET_CHIP_ID() ((uint16_t)(ESP.getEfuseMac() >> 32))
 #endif
 // Miscellaneous defines.
 #if defined(ARDUINO_ARCH_ESP32)
 #include <FS.h>
 #include <SPIFFS.h>
 #endif
-const char *sta_ssid = STA_SSID;
-const char *sta_psk = STA_PSK;
-const char *mqtt_host = MQTT_HOST;
-const char *mqtt_username = MQTT_USERNAME;
-const char *mqtt_password = MQTT_PASSWORD;
-const int mqtt_port = MQTT_PORT;
-const char *ota_password = OTA_PASSWORD;
-const int ota_port = OTA_PORT;
 WiFiClient espClient;
 PubSubClient mqttClient(espClient);
 // Define GPIO pins for supported architectures.
 #if defined(ARDUINO_ARCH_ESP8266)
 int PINS[] = { D0, D1, D2, D3, D4, D5, D6, D7, D8 };
 #elif defined(ARDUINO_ARCH_ESP32)
 int PINS[] = { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11,
 , 13, 14, 15, 16, 17, 18, 19, 21, 22,
-, 25, 26, 27, 32, 33, 34, 35, 36, 37,
-, 39
+, 25, 26, 27, 32, 33, 34, 35, 36, 37,
-             };
+, 39 };
 #endif
 void mqttCallback(char *topic, byte *payload, unsigned int length) {
   String msgTopic = String(topic);
   // payload is not null terminated and casting will not work
   char msgPayload[length + 1];
   snprintf(msgPayload, length + 1, "%s", payload);
+#ifdef DEBUG
   Serial.println("Message received on topic: " + String(topic) + " with payload: " + String(msgPayload));
+#endif
   // Parse the payload sent to the MQTT topic as a JSON document.
+  StaticJsonDocument<256> doc;
-  StaticJsonDocument<256> doc;
+#ifdef DEBUG
+  Serial.println("Deserializing message....");
-  Serial.println("Deserializing message....");
+#endif
   DeserializationError error = deserializeJson(doc, msgPayload);
+  if (error) {
-  if (error) {
+#ifdef DEBUG
+    Serial.println("Failed to parse MQTT payload as JSON: " + String(error.c_str()));
-    Serial.println("Failed to parse MQTT payload as JSON: " + String(error.c_str()));
+#endif
     return;
+  }
   // Do not process messages without an action key.
   if (!doc.containsKey("action")) {
     return;
   }
   String action = (const char *)doc["action"];
-  if(action == "set") {
+  if (action == "set") {
-      String state = (const char *)doc["state"];
+    String state = (const char *)doc["state"];
-      const int pin = (const int)doc["pin"];
+    const int pin = (const int)doc["pin"];
+#ifdef DEBUG
-      Serial.println("Setting pin: " + String(pin) + " to state: " + String(state));
-      pinMode(PINS[pin], OUTPUT);
-      if (state == "on") {
-        digitalWrite(PINS[pin], HIGH);
-        int status = digitalRead(PINS[pin]);
+    Serial.println("Setting pin: " + String(pin) + " to state: " + String(state));
-        Serial.println("Pin " + String(pin) + " state is now: " + String(status));
+#endif
-        return;
+    pinMode(PINS[pin], OUTPUT);
     if (state == "on") {
+      digitalWrite(PINS[pin], HIGH);
       int status = digitalRead(PINS[pin]);
-      digitalWrite(PINS[pin], LOW);
+#ifdef DEBUG
-      int status = digitalRead(PINS[pin]);
-      Serial.println("Pin " + String(pin) + " state is now: " + String(status));
-      return;
-  }
+      Serial.println("Pin " + String(pin) + " state is now: " + String(status));
-  if(action == "get") {
+#endif
+      return;
-      const int pin = (const int)doc["pin"];
+    }
+    digitalWrite(PINS[pin], LOW);
+    int status = digitalRead(PINS[pin]);
+#ifdef DEBUG
+    Serial.println("Pin " + String(pin) + " state is now: " + String(status));
+#endif
+    return;
+  }
+  if (action == "get") {
+    const int pin = (const int)doc["pin"];
+#ifdef DEBUG
+    Serial.println("Getting pin: " + String(pin) + " state.");
-      Serial.println("Getting pin: " + String(pin) + " state.");
+#endif
+    int status = digitalRead(PINS[pin]);
-      int status = digitalRead(PINS[pin]);
+#ifdef DEBUG
-      Serial.println("Pin " + String(pin) + " state is now: " + String(status));
+    Serial.println("Pin " + String(pin) + " state is now: " + String(status));
+#endif
-      // Announce the action.
+    // Announce the action.
-      StaticJsonDocument<256> msg;
+    StaticJsonDocument<256> msg;
-      msg["pin"] = pin;
+    msg["pin"] = pin;
-      switch(status) {
+    switch (status) {
-        case 1:
+      case 1:
-          msg["state"] = "on";
+        msg["state"] = "on";
-          break;
+        break;
-        case 0:
+      case 0:
-          msg["state"] = "off";
+        msg["state"] = "off";
-          break;
+        break;
-        default:
+      default:
-          msg["state"] = "unknown";
+        msg["state"] = "unknown";
-          break;
+        break;
+    }
-      }
+    mqttClient.publish(MQTT_TOPIC().c_str(), mqttSerialize(msg).c_str());
+    return;
       mqttClient.publish(MQTT_TOPIC().c_str(), mqttSerialize(msg).c_str());
-      return;
+}
 bool mqttConnect() {
+#ifdef DEBUG
   Serial.println("Attempting to connect to MQTT broker: " + String(MQTT_HOST));
 #endif
-bool mqttConnect() {
+  mqttClient.setServer(MQTT_HOST, MQTT_PORT);
-  Serial.println("Attempting to connect to MQTT broker: " + String(mqtt_host));
+  StaticJsonDocument<256> msg;
+  if (mqttClient.connect(MQTT_CLIENT_ID().c_str(), MQTT_USERNAME, MQTT_PASSWORD)) {
-  mqttClient.setServer(mqtt_host, mqtt_port);
+#ifdef DEBUG
+    Serial.println("Established connection with MQTT broker using client ID: " + MQTT_CLIENT_ID());
 #endif
+    mqttClient.setCallback(mqttCallback);
-  StaticJsonDocument<256> msg;
+    msg["action"] = "connected";
-  if (mqttClient.connect(MQTT_CLIENT_ID().c_str(), mqtt_username, mqtt_password)) {
+    mqttClient.publish(MQTT_TOPIC().c_str(), mqttSerialize(msg).c_str());
+#ifdef DEBUG
-    Serial.println("Established connection with MQTT broker using client ID: " + MQTT_CLIENT_ID());
+    Serial.println("Attempting to subscribe to MQTT topic: " + MQTT_TOPIC());
+#endif
-    mqttClient.setCallback(mqttCallback);
+    if (!mqttClient.subscribe(MQTT_TOPIC().c_str())) {
-    msg["action"] = "connected";
+#ifdef DEBUG
-    mqttClient.publish(MQTT_TOPIC().c_str(), mqttSerialize(msg).c_str());
+      Serial.println("Failed to subscribe to MQTT topic: " + MQTT_TOPIC());
-    Serial.println("Attempting to subscribe to MQTT topic: " + MQTT_TOPIC());
+#endif
-    if (!mqttClient.subscribe(MQTT_TOPIC().c_str())) {
+      return false;
-      Serial.println("Failed to subscribe to MQTT topic: " + MQTT_TOPIC());
+    }
-      return false;
+#ifdef DEBUG
-    }
+    Serial.println("Subscribed to MQTT topic: " + MQTT_TOPIC());
-    Serial.println("Subscribed to MQTT topic: " + MQTT_TOPIC());
+#endif
     msg.clear();
     msg["action"] = "subscribed";
     mqttClient.publish(MQTT_TOPIC().c_str(), mqttSerialize(msg).c_str());
   return true;
+}
 void setup() {
+  Serial.begin(115200);
-  Serial.begin(115200);
+#ifdef DEBUG
+  Serial.println("Booted, setting up Wifi in 10s...");
-  Serial.println("Booted, setting up Wifi in 10s...");
+#endif
   delay(10000);
   WiFi.mode(WIFI_STA);
 #if defined(ARDUINO_ARCH_ESP8266)
   WiFi.hostname(HOSTNAME().c_str());
 #elif defined(ARDUINO_ARCH_ESP32)
   WiFi.setHostname(HOSTNAME().c_str());
 #endif
+  WiFi.begin(STA_SSID, STA_PSK);
-  WiFi.begin(sta_ssid, sta_psk);
+  while (WiFi.waitForConnectResult() != WL_CONNECTED) {
+#ifdef DEBUG
-  while (WiFi.waitForConnectResult() != WL_CONNECTED) {
+    Serial.println("Failed to connect to Wifi, rebooting in 5s...");
-    Serial.println("Failed to connect to Wifi, rebooting in 5s...");
+#endif
     delay(5000);
     ESP.restart();
+  }
+#ifdef DEBUG
   Serial.print("Connected to Wifi: ");
-  Serial.print("Connected to Wifi: ");
+#endif
   Serial.println(WiFi.localIP());
+#ifdef DEBUG
   Serial.println("Setting up OTA in 10s...");
-  Serial.println("Setting up OTA in 10s...");
+#endif
   delay(10000);
   // Port defaults to 8266
-  ArduinoOTA.setPort(ota_port);
+  ArduinoOTA.setPort(OTA_PORT);
   // Hostname defaults to esp-[ChipID]
   ArduinoOTA.setHostname(HOSTNAME().c_str());
+  // Set the OTA password
-  // Set the OTA password
+  ArduinoOTA.setPassword(OTA_PASSWORD);
-  ArduinoOTA.setPassword(ota_password);
+  ArduinoOTA.onStart([]() {
     switch (ArduinoOTA.getCommand()) {
-  ArduinoOTA.onStart([]() {
+      case U_FLASH:  // Sketch
-    switch (ArduinoOTA.getCommand()) {
+#ifdef DEBUG
-      case U_FLASH: // Sketch
+        Serial.println("OTA start updating sketch.");
-        Serial.println("OTA start updating sketch.");
+#endif
+        break;
-        break;
+#if defined(ARDUINO_ARCH_ESP8266)
+      case U_FS:
-#if defined(ARDUINO_ARCH_ESP8266)
+#elif defined(ARDUINO_ARCH_ESP32)
-      case U_FS:
+      case U_SPIFFS:
-#elif defined(ARDUINO_ARCH_ESP32)
+#endif
+#ifdef DEBUG
-      case U_SPIFFS:
+        Serial.println("OTA start updating filesystem.");
+#endif
-#endif
+        SPIFFS.end();
-        Serial.println("OTA start updating filesystem.");
+        break;
-        SPIFFS.end();
+      default:
-        break;
+#ifdef DEBUG
+        Serial.println("Unknown OTA update type.");
-      default:
+#endif
+        break;
         Serial.println("Unknown OTA update type.");
-        break;
+  });
   ArduinoOTA.onEnd([]() {
-  });
+#ifdef DEBUG
-  ArduinoOTA.onEnd([]() {
+    Serial.println("OTA update complete.");
-    Serial.println("OTA update complete.");
+#endif
     SPIFFS.begin();
 #if defined(ARDUINO_ARCH_ESP8266)
+    // For what it's worth, check the filesystem on ESP8266.
-    // For what it's worth, check the filesystem on ESP8266.
+    SPIFFS.check();
+#endif
-    SPIFFS.check();
+    ESP.restart();
-#endif
+  });
+  ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
-    ESP.restart();
+#ifdef DEBUG
+    Serial.printf("OTA update progress: %u%%\r", (progress / (total / 100)));
-  });
+#endif
-  ArduinoOTA.onProgress([](unsigned int progress, unsigned int total) {
+  });
+  ArduinoOTA.onError([](ota_error_t error) {
-    Serial.printf("OTA update progress: %u%%\r", (progress / (total / 100)));
+#ifdef DEBUG
+    Serial.printf("OTA update error [%u]: ", error);
-  });
+#endif
-  ArduinoOTA.onError([](ota_error_t error) {
+    switch (error) {
+      case OTA_AUTH_ERROR:
-    Serial.printf("OTA update error [%u]: ", error);
+#ifdef DEBUG
+        Serial.println("OTA authentication failed");
-    switch (error) {
+#endif
-      case OTA_AUTH_ERROR:
+        break;
+      case OTA_BEGIN_ERROR:
-        Serial.println("OTA authentication failed");
+#ifdef DEBUG
+        Serial.println("OTA begin failed");
-        break;
+#endif
-      case OTA_BEGIN_ERROR:
+        break;
+      case OTA_CONNECT_ERROR:
-        Serial.println("OTA begin failed");
+#ifdef DEBUG
+        Serial.println("OTA connect failed");
-        break;
+#endif
-      case OTA_CONNECT_ERROR:
+        break;
+      case OTA_RECEIVE_ERROR:
-        Serial.println("OTA connect failed");
+#ifdef DEBUG
+        Serial.println("OTA receive failed");
-        break;
+#endif
-      case OTA_RECEIVE_ERROR:
+        break;
+      case OTA_END_ERROR:
-        Serial.println("OTA receive failed");
+#ifdef DEBUG
+        Serial.println("OTA end failed");
-        break;
+#endif
-      case OTA_END_ERROR:
+        break;
-        Serial.println("OTA end failed");
+      default:
-        break;
+#ifdef DEBUG
-      default:
+        Serial.println("Unknown OTA failure");
-        Serial.println("Unknown OTA failure");
+#endif
         break;
+    }
     ESP.restart();
+  });
-  });
+  ArduinoOTA.begin();
-  ArduinoOTA.begin();
+  // Set up MQTT client.
   mqttClient.setServer(MQTT_HOST, MQTT_PORT);
-  // Set up MQTT client.
+  mqttClient.setCallback(mqttCallback);
   mqttClient.setServer(mqtt_host, mqtt_port);
         break;
+      }
       delay(1);
       break;
     case WL_NO_SHIELD:
+#ifdef DEBUG
       Serial.println("No Wifi shield present.");
+#endif
       goto DEFAULT_CASE;
       break;
     case WL_NO_SSID_AVAIL:
+#ifdef DEBUG
       Serial.println("Configured SSID not found.");
+#endif
       goto DEFAULT_CASE;
       break;
     // Temporary statuses indicating transitional states.
     case WL_IDLE_STATUS:
     case WL_SCAN_COMPLETED:
     // Fatal Wifi statuses trigger a delayed ESP restart.
     case WL_CONNECT_FAILED:
     case WL_CONNECTION_LOST:
     case WL_DISCONNECTED:
     default:
+#ifdef DEBUG
       Serial.println("Wifi connection failed with status: " + String(wifiStatus));
+#endif
 DEFAULT_CASE:
       delay(10000);
       ESP.restart();
       break;
+  }