thomas
/
esp-env
Watch 1
Star 0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
ESP32 / ESP8266 & BME280 / SHT2x sensor with InfluxDB support
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
6 Commits
1 Branch
Tree: be1fef30e4
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'be1fef30e4'
${ noResults }
esp-env/src/main.cpp

main.cpp 21KB
History Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820 
  1. /*

  2.  * main.cpp

  3.  *

  4.  * ESP8266 / ESP32 Environmental Sensor

  5.  *

  6.  * ----------------------------------------------------------------------------

  7.  * "THE BEER-WARE LICENSE" (Revision 42):

  8.  * <xythobuz@xythobuz.de> wrote this file.  As long as you retain this notice

  9.  * you can do whatever you want with this stuff. If we meet some day, and you

  10.  * think this stuff is worth it, you can buy me a beer in return.   Thomas Buck

  11.  * ----------------------------------------------------------------------------

  12.  */

  13. 

  14. #include <Arduino.h>

  15. #include <Adafruit_BME280.h>

  16. #include <SHT2x.h>

  17. 

  18. #if defined(ARDUINO_ARCH_ESP8266)

  19. 

  20. #include <ESP8266WiFi.h>

  21. #include <ESP8266WebServer.h>

  22. #include <ESP8266mDNS.h>

  23. 

  24. #define ESP_PLATFORM_NAME "ESP8266"

  25. 

  26. #elif defined(ARDUINO_ARCH_ESP32)

  27. 

  28. #include <WiFi.h>

  29. #include <WebServer.h>

  30. #include <ESPmDNS.h>

  31. 

  32. #define ESP_PLATFORM_NAME "ESP32"

  33. 

  34. #endif

  35. 

  36. #include "config.h"

  37. #include "moisture.h"

  38. 

  39. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  40. 

  41. #include <Wire.h>

  42. #include "SimpleUpdater.h"

  43. 

  44. #define BUILTIN_LED_PIN 1

  45. 

  46. UPDATE_WEB_SERVER server(80);

  47. SimpleUpdater updater;

  48. 

  49. #elif defined(ARDUINO_ARCH_AVR)

  50. 

  51. #define ESP_PLATFORM_NAME "Uno WiFi"

  52. #define BUILTIN_LED_PIN 13

  53. 

  54. #endif

  55. 

  56. #ifdef ENABLE_INFLUXDB_LOGGING

  57. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  58. #include <InfluxDb.h>

  59. #else

  60. #include "SimpleInflux.h"

  61. #endif

  62. 

  63. Influxdb influx(INFLUXDB_HOST, INFLUXDB_PORT);

  64. 

  65. #define INFLUX_MAX_ERRORS_RESET 10

  66. int error_count = 0;

  67. #endif // ENABLE_INFLUXDB_LOGGING

  68. 

  69. #define SHT_I2C_ADDRESS HTDU21D_ADDRESS

  70. #define BME_I2C_ADDRESS_1 0x76

  71. #define BME_I2C_ADDRESS_2 0x77

  72. 

  73. #if defined(ARDUINO_ARCH_ESP8266)

  74. 

  75. #define I2C_SDA_PIN 2

  76. #define I2C_SCL_PIN 0

  77. 

  78. TwoWire Wire2;

  79. SHT2x sht(SHT_I2C_ADDRESS, &Wire2);

  80. 

  81. #elif defined(ARDUINO_ARCH_ESP32)

  82. 

  83. SHT2x sht(SHT_I2C_ADDRESS, &Wire);

  84. 

  85. #elif defined(ARDUINO_ARCH_AVR)

  86. 

  87. #include <UnoWiFiDevEdSerial1.h>

  88. #include <WiFiLink.h>

  89. 

  90. WiFiServer server(80);

  91. SHT2x sht(SHT_I2C_ADDRESS, &Wire);

  92. 

  93. #endif

  94. 

  95. //#define ENABLE_RELAIS_TEST

  96. 

  97. Adafruit_BME280 bme1, bme2;

  98. 

  99. bool found_bme1 = false;

  100. bool found_bme2 = false;

  101. bool found_sht = false;

  102. 

  103. unsigned long last_server_handle_time = 0;

  104. unsigned long last_db_write_time = 0;

  105. unsigned long last_led_blink_time = 0;

  106. 

  107. #ifdef ENABLE_RELAIS_TEST

  108. 

  109. #include "relais.h"

  110. 

  111. static void relaisTest() {

  112.     for (int i = 0; i < 10; i++) {

  113.         relais_enable(i, 400 + (i * 1000));

  114.         delay(100);

  115.     }

  116. }

  117. 

  118. void handleRelaisTest() {

  119.     String message = F("<html><head>");

  120.     message += F("<title>" ESP_PLATFORM_NAME " Environment Sensor</title>");

  121.     message += F("</head><body>");

  122.     message += F("<p>Relais Test started!</p>");

  123.     message += F("<p><a href=\"/\">Return to Home</a></p>");

  124.     message += F("</body></html>");

  125.     

  126.     server.send(200, "text/html", message);

  127.     

  128.     relaisTest();

  129. }

  130. 

  131. #endif // ENABLE_RELAIS_TEST

  132. 

  133. static float bme1_temp(void) {

  134.     while (1) {

  135.         float a = bme1.readTemperature();

  136.         float b = bme1.readTemperature();

  137.         

  138.         if ((a > b) && ((a - b) < 2.0)) {

  139.             return (a + b) / 2.0;

  140.         }

  141.         

  142.         if ((a < b) && ((b - a) < 2.0)) {

  143.             return (a + b) / 2.0;

  144.         }

  145.     }

  146.     return 0.0;

  147. }

  148. 

  149. static float bme2_temp(void) {

  150.     while (1) {

  151.         float a = bme2.readTemperature();

  152.         float b = bme2.readTemperature();

  153.         

  154.         if ((a > b) && ((a - b) < 2.0)) {

  155.             return (a + b) / 2.0;

  156.         }

  157.         

  158.         if ((a < b) && ((b - a) < 2.0)) {

  159.             return (a + b) / 2.0;

  160.         }

  161.     }

  162.     return 0.0;

  163. }

  164. 

  165. static float bme1_humid(void) {

  166.     while (1) {

  167.         float a = bme1.readHumidity();

  168.         float b = bme1.readHumidity();

  169.         

  170.         if ((a > b) && ((a - b) < 2.0)) {

  171.             return (a + b) / 2.0;

  172.         }

  173.         

  174.         if ((a < b) && ((b - a) < 2.0)) {

  175.             return (a + b) / 2.0;

  176.         }

  177.     }

  178.     return 0.0;

  179. }

  180. 

  181. static float bme2_humid(void) {

  182.     while (1) {

  183.         float a = bme2.readHumidity();

  184.         float b = bme2.readHumidity();

  185.         

  186.         if ((a > b) && ((a - b) < 2.0)) {

  187.             return (a + b) / 2.0;

  188.         }

  189.         

  190.         if ((a < b) && ((b - a) < 2.0)) {

  191.             return (a + b) / 2.0;

  192.         }

  193.     }

  194.     return 0.0;

  195. }

  196. 

  197. static float bme1_pressure(void) {

  198.     while (1) {

  199.         float a = bme1.readPressure();

  200.         float b = bme1.readPressure();

  201.         

  202.         if ((a > b) && ((a - b) < 2.0)) {

  203.             return (a + b) / 2.0;

  204.         }

  205.         

  206.         if ((a < b) && ((b - a) < 2.0)) {

  207.             return (a + b) / 2.0;

  208.         }

  209.     }

  210.     return 0.0;

  211. }

  212. 

  213. static float bme2_pressure(void) {

  214.     while (1) {

  215.         float a = bme2.readPressure();

  216.         float b = bme2.readPressure();

  217.         

  218.         if ((a > b) && ((a - b) < 2.0)) {

  219.             return (a + b) / 2.0;

  220.         }

  221.         

  222.         if ((a < b) && ((b - a) < 2.0)) {

  223.             return (a + b) / 2.0;

  224.         }

  225.     }

  226.     return 0.0;

  227. }

  228. 

  229. static float sht_temp(void) {

  230.     while (1) {

  231.         float a = sht.GetTemperature();

  232.         float b = sht.GetTemperature();

  233.         

  234.         if ((a > b) && ((a - b) < 2.0)) {

  235.             return (a + b) / 2.0;

  236.         }

  237.         

  238.         if ((a < b) && ((b - a) < 2.0)) {

  239.             return (a + b) / 2.0;

  240.         }

  241.     }

  242.     return 0.0;

  243. }

  244. 

  245. static float sht_humid(void) {

  246.     while (1) {

  247.         float a = sht.GetHumidity();

  248.         float b = sht.GetHumidity();

  249.         

  250.         if ((a > b) && ((a - b) < 2.0)) {

  251.             return (a + b) / 2.0;

  252.         }

  253.         

  254.         if ((a < b) && ((b - a) < 2.0)) {

  255.             return (a + b) / 2.0;

  256.         }

  257.     }

  258.     return 0.0;

  259. }

  260. 

  261. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  262. void handleRoot() {

  263. #else

  264. void handleRoot(WiFiClient &client) {

  265. #endif

  266.     String message;

  267. 

  268.     message += F("<html><head>");

  269.     message += F("<title>" ESP_PLATFORM_NAME " Environment Sensor</title>");

  270.     message += F("</head><body>");

  271.     message += F("<h1>" ESP_PLATFORM_NAME " Environment Sensor</h1>");

  272.     message += F("\n<p>\n");

  273.     message += F("Version: ");

  274.     message += esp_env_version;

  275.     message += F("\n<br>\n");

  276.     message += F("Location: ");

  277.     message += sensor_location;

  278. 

  279. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  280.     message += F("\n<br>\n");

  281.     message += F("MAC: ");

  282.     message += WiFi.macAddress();

  283. #endif

  284. 

  285.     message += F("\n</p>\n");

  286. 

  287. #if defined(ARDUINO_ARCH_AVR)

  288.     do {

  289.         size_t len = message.length(), off = 0;

  290.         while (off < len) {

  291.             if ((len - off) >= 50) {

  292.                 client.write(message.c_str() + off, 50);

  293.                 off += 50;

  294.             } else {

  295.                 client.write(message.c_str() + off, len - off);

  296.                 off = len;

  297.             }

  298.         }

  299.         message = "";

  300.     } while (false);

  301. #endif

  302. 

  303. #if defined(ARDUINO_ARCH_ESP8266)

  304.     

  305.     message += F("<p>");

  306.     message += F("Reset reason: ");

  307.     message += ESP.getResetReason();

  308.     message += F("<br>");

  309.     message += F("Free heap: ");

  310.     message += String(ESP.getFreeHeap());

  311.     message += F(" (");

  312.     message += String(ESP.getHeapFragmentation());

  313.     message += F("% fragmentation)");

  314.     message += F("<br>");

  315.     message += F("Free sketch space: ");

  316.     message += String(ESP.getFreeSketchSpace());

  317.     message += F("<br>");

  318.     message += F("Flash chip real size: ");

  319.     message += String(ESP.getFlashChipRealSize());

  320. 

  321.     if (ESP.getFlashChipSize() != ESP.getFlashChipRealSize()) {

  322.         message += F("<br>");

  323.         message += F("WARNING: sdk chip size (");

  324.         message += (ESP.getFlashChipSize());

  325.         message += F(") does not match!");

  326.     }

  327.     

  328.     message += F("</p>");

  329.     

  330. #elif defined(ARDUINO_ARCH_ESP32)

  331. 

  332.     message += F("<p>");

  333.     message += F("Free heap: ");

  334.     message += String(ESP.getFreeHeap() / 1024.0);

  335.     message += F("k<br>");

  336.     message += F("Free sketch space: ");

  337.     message += String(ESP.getFreeSketchSpace() / 1024.0);

  338.     message += F("k<br>");

  339.     message += F("Flash chip size: ");

  340.     message += String(ESP.getFlashChipSize() / 1024.0);

  341.     message += F("k</p>");

  342.     

  343. #endif

  344. 

  345.     message += F("\n<p>\n");

  346.     if (found_bme1) {

  347.         message += F("BME280 Low:");

  348.         message += F("\n<br>\n");

  349.         message += F("Temperature: ");

  350.         message += String(bme1_temp());

  351.         message += F("\n<br>\n");

  352.         message += F("Humidity: ");

  353.         message += String(bme1_humid());

  354.         message += F("\n<br>\n");

  355.         message += F("Pressure: ");

  356.         message += String(bme1_pressure());

  357.     } else {

  358.         message += F("BME280 (low) not connected!");

  359.     }

  360.     message += F("\n</p>\n");

  361. 

  362.     message += F("\n<p>\n");

  363.     if (found_bme2) {

  364.         message += F("BME280 High:");

  365.         message += F("\n<br>\n");

  366.         message += F("Temperature: ");

  367.         message += String(bme2_temp());

  368.         message += F("\n<br>\n");

  369.         message += F("Humidity: ");

  370.         message += String(bme2_humid());

  371.         message += F("\n<br>\n");

  372.         message += F("Pressure: ");

  373.         message += String(bme2_pressure());

  374.     } else {

  375.         message += F("BME280 (high) not connected!");

  376.     }

  377.     message += F("\n</p>\n");

  378. 

  379.     message += F("\n<p>\n");

  380.     if (found_sht) {

  381.         message += F("SHT21:");

  382.         message += F("\n<br>\n");

  383.         message += F("Temperature: ");

  384.         message += String(sht_temp());

  385.         message += F("\n<br>\n");

  386.         message += F("Humidity: ");

  387.         message += String(sht_humid());

  388.     } else {

  389.         message += F("SHT21 not connected!");

  390.     }

  391.     message += F("\n</p>\n");

  392. 

  393. #if defined(ARDUINO_ARCH_AVR)

  394.     do {

  395.         size_t len = message.length(), off = 0;

  396.         while (off < len) {

  397.             if ((len - off) >= 50) {

  398.                 client.write(message.c_str() + off, 50);

  399.                 off += 50;

  400.             } else {

  401.                 client.write(message.c_str() + off, len - off);

  402.                 off = len;

  403.             }

  404.         }

  405.         message = "";

  406.     } while (false);

  407. #endif

  408. 

  409.     for (int i = 0; i < moisture_count(); i++) {

  410.         int moisture = moisture_read(i);

  411.         if (moisture < moisture_max()) {

  412.             message += F("\n<p>\n");

  413.             message += F("Sensor ");

  414.             message += String(i + 1);

  415.             message += F(":\n<br>\n");

  416.             message += F("Moisture: ");

  417.             message += String(moisture);

  418.             message += F(" / ");

  419.             message += String(moisture_max());

  420.             message += F("\n</p>\n");

  421.         }

  422.     }

  423.     

  424.     if (moisture_count() <= 0) {

  425.         message += F("\n<p>\n");

  426.         message += F("No moisture sensors configured!");

  427.         message += F("\n</p>\n");

  428.     }

  429. 

  430. #if ! defined(ARDUINO_ARCH_AVR)

  431.     message += F("<p>");

  432.     message += F("Try <a href=\"/update\">/update</a> for OTA firmware updates!");

  433.     message += F("</p>");

  434. #endif

  435.     

  436.     message += F("<p>");

  437. #ifdef ENABLE_INFLUXDB_LOGGING

  438.     message += F("InfluxDB: ");

  439.     message += INFLUXDB_DATABASE;

  440.     message += F(" @ ");

  441.     message += INFLUXDB_HOST;

  442.     message += F(":");

  443.     message += String(INFLUXDB_PORT);

  444. #else

  445.     message += F("InfluxDB logging not enabled!");

  446. #endif

  447.     message += F("</p>");

  448.     

  449. #ifdef ENABLE_RELAIS_TEST

  450.     message += F("<p><a href=\"/relaistest\">Relais Test</a></p>");

  451. #endif // ENABLE_RELAIS_TEST

  452. 

  453.     message += F("</body></html>");

  454. 

  455. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  456.     server.send(200, "text/html", message);

  457. #else

  458.     do {

  459.         size_t len = message.length(), off = 0;

  460.         while (off < len) {

  461.             if ((len - off) >= 50) {

  462.                 client.write(message.c_str() + off, 50);

  463.                 off += 50;

  464.             } else {

  465.                 client.write(message.c_str() + off, len - off);

  466.                 off = len;

  467.             }

  468.         }

  469.     } while (false);

  470. #endif

  471. }

  472. 

  473. void setup() {

  474.     pinMode(BUILTIN_LED_PIN, OUTPUT);

  475.     

  476. #ifdef ENABLE_RELAIS_TEST

  477.     relais_init();

  478. #endif // ENABLE_RELAIS_TEST

  479. 

  480.     // Blink LED for init

  481.     for (int i = 0; i < 2; i++) {

  482.         digitalWrite(BUILTIN_LED_PIN, LOW); // LED on

  483.         delay(LED_INIT_BLINK_INTERVAL);

  484.         digitalWrite(BUILTIN_LED_PIN, HIGH); // LED off

  485.         delay(LED_INIT_BLINK_INTERVAL);

  486.     }

  487.     

  488.     moisture_init();

  489. 

  490.     // Init I2C and try to connect to sensors

  491. #if defined(ARDUINO_ARCH_ESP8266)

  492. 

  493.     Wire2.begin(I2C_SDA_PIN, I2C_SCL_PIN);

  494.     found_bme1 = (!bme1.begin(BME_I2C_ADDRESS_1, &Wire2)) ? false : true;

  495.     found_bme2 = (!bme2.begin(BME_I2C_ADDRESS_2, &Wire2)) ? false : true;

  496. 

  497. #elif defined(ARDUINO_ARCH_ESP32)

  498. 

  499.     Wire.begin();

  500.     found_bme1 = (!bme1.begin(BME_I2C_ADDRESS_1, &Wire)) ? false : true;

  501.     found_bme2 = (!bme2.begin(BME_I2C_ADDRESS_2, &Wire)) ? false : true;

  502. 

  503. #elif defined(ARDUINO_ARCH_AVR)

  504. 

  505.     found_bme1 = (!bme1.begin(BME_I2C_ADDRESS_1, &Wire)) ? false : true;

  506.     found_bme2 = (!bme2.begin(BME_I2C_ADDRESS_2, &Wire)) ? false : true;

  507. 

  508. #endif

  509. 

  510.     found_sht = sht.GetAlive();

  511. 

  512.     // Build hostname string

  513.     String hostname = SENSOR_HOSTNAME_PREFIX;

  514.     hostname += sensor_location;

  515. 

  516. #if defined(ARDUINO_ARCH_ESP8266)

  517. 

  518.     // Connect to WiFi AP

  519.     WiFi.hostname(hostname);

  520.     WiFi.mode(WIFI_STA);

  521.     WiFi.begin(ssid, password);

  522.     while (WiFi.status() != WL_CONNECTED) {

  523.         delay(LED_CONNECT_BLINK_INTERVAL);

  524.         digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));

  525.     }

  526.     

  527. #elif defined(ARDUINO_ARCH_ESP32)

  528. 

  529.     // Set hostname workaround

  530.     WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE);

  531.     WiFi.setHostname(hostname.c_str());

  532.     

  533.     // Workaround for WiFi connecting only every 2nd reset

  534.     // https://github.com/espressif/arduino-esp32/issues/2501#issuecomment-513602522

  535.     WiFi.onEvent([](WiFiEvent_t event, WiFiEventInfo_t info) {

  536.         if (info.disconnected.reason == 202) {

  537.             esp_sleep_enable_timer_wakeup(10);

  538.             esp_deep_sleep_start();

  539.             delay(100);

  540.         }

  541.     }, WiFiEvent_t::SYSTEM_EVENT_STA_DISCONNECTED);

  542. 

  543.     // Connect to WiFi AP

  544.     WiFi.mode(WIFI_STA);

  545.     WiFi.begin(ssid, password);

  546.     while (WiFi.status() != WL_CONNECTED) {

  547.         delay(LED_CONNECT_BLINK_INTERVAL);

  548.         digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));

  549.     }

  550.     

  551.     // Set hostname workaround

  552.     WiFi.setHostname(hostname.c_str());

  553. 

  554. #elif defined(ARDUINO_ARCH_AVR)

  555. 

  556.     Serial.begin(115200);

  557.     Serial1.begin(115200);

  558. 

  559.     WiFi.init(&Serial1);

  560. 

  561.     Serial.print(F("Connecting WiFi"));

  562.     WiFi.begin(ssid, password);

  563.     while (WiFi.status() != WL_CONNECTED) {

  564.         delay(LED_CONNECT_BLINK_INTERVAL);

  565.         digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));

  566.         Serial.print(F("."));

  567.     }

  568.     Serial.println(F("\nWiFi connected!"));

  569. 

  570. #endif

  571. 

  572. #ifdef ENABLE_INFLUXDB_LOGGING

  573.     // Setup InfluxDB Client

  574.     influx.setDb(INFLUXDB_DATABASE);

  575. #endif // ENABLE_INFLUXDB_LOGGING

  576. 

  577. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  578.     // Setup HTTP Server

  579.     MDNS.begin(hostname.c_str());

  580.     updater.setup(&server);

  581.     server.on("/", handleRoot);

  582. 

  583. #ifdef ENABLE_RELAIS_TEST

  584.     server.on("/relaistest", handleRelaisTest);

  585. #endif

  586. 

  587.     MDNS.addService("http", "tcp", 80);

  588. #endif

  589. 

  590.     server.begin();

  591. }

  592. 

  593. #if defined(ARDUINO_ARCH_AVR)

  594. void http_server() {

  595.     // listen for incoming clients

  596.     WiFiClient client = server.available();

  597.     if (client) {

  598.         Serial.println(F("new http client"));

  599. 

  600.         // an http request ends with a blank line

  601.         boolean currentLineIsBlank = true;

  602. 

  603.         while (client.connected()) {

  604.             if (client.available()) {

  605.                 char c = client.read();

  606.                 Serial.write(c);

  607. 

  608.                 // if you've gotten to the end of the line (received a newline

  609.                 // character) and the line is blank, the http request has ended,

  610.                 // so you can send a reply

  611.                 if ((c == '\n') && currentLineIsBlank) {

  612.                     // send a standard http response header

  613.                     client.println(F("HTTP/1.1 200 OK"));

  614.                     client.println(F("Content-Type: text/html"));

  615.                     client.println(F("Connection: close"));

  616.                     client.println();

  617.                     handleRoot(client);

  618.                     break;

  619.                 }

  620. 

  621.                 if (c == '\n') {

  622.                     // you're starting a new line

  623.                     currentLineIsBlank = true;

  624.                 } else if (c != '\r') {

  625.                     // you've gotten a character on the current line

  626.                     currentLineIsBlank = false;

  627.                 }

  628.             }

  629.         }

  630. 

  631.         // give the web browser time to receive the data

  632.         delay(10);

  633. 

  634.         // close the connection

  635.         client.stop();

  636.         Serial.println(F("http client disconnected"));

  637.     }

  638. }

  639. #endif

  640. 

  641. void handleServers() {

  642. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  643.     server.handleClient();

  644. #else

  645.     http_server();

  646. #endif

  647.     

  648. #if defined(ARDUINO_ARCH_ESP8266)

  649.     MDNS.update();

  650. #endif

  651. }

  652. 

  653. #ifdef ENABLE_INFLUXDB_LOGGING

  654. static boolean writeMeasurement(InfluxData &measurement) {

  655.     boolean success = influx.write(measurement);

  656.     if (!success) {

  657.         error_count++;

  658.         for (int i = 0; i < 10; i++) {

  659.             digitalWrite(BUILTIN_LED_PIN, LOW); // LED on

  660.             delay(LED_ERROR_BLINK_INTERVAL);

  661.             digitalWrite(BUILTIN_LED_PIN, HIGH); // LED off

  662.             delay(LED_ERROR_BLINK_INTERVAL);

  663.         }

  664.     }

  665.     return success;

  666. }

  667. 

  668. void writeDatabase() {

  669. #if defined(ARDUINO_ARCH_AVR)

  670.     Serial.println(F("Writing to InfluxDB"));

  671. 

  672.     InfluxData measurement("");

  673. #endif

  674. 

  675.     if (found_bme1) {

  676. #if defined(ARDUINO_ARCH_AVR)

  677.         measurement.clear();

  678.         measurement.setName("environment");

  679. #else

  680.         InfluxData measurement("environment");

  681. #endif

  682. 

  683.         measurement.addTag("location", sensor_location);

  684.         measurement.addTag("placement", "1");

  685.         measurement.addTag("sensor", "bme280");

  686. 

  687. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  688.         measurement.addTag("device", WiFi.macAddress());

  689. #endif

  690. 

  691.         measurement.addValue("temperature", bme1_temp());

  692.         measurement.addValue("pressure", bme1_pressure());

  693.         measurement.addValue("humidity", bme1_humid());

  694. 

  695.         Serial.println(F("Writing bme1"));

  696.         writeMeasurement(measurement);

  697.         Serial.println(F("Done!"));

  698.     }

  699. 

  700.     if (found_bme2) {

  701. #if defined(ARDUINO_ARCH_AVR)

  702.         measurement.clear();

  703.         measurement.setName("environment");

  704. #else

  705.         InfluxData measurement("environment");

  706. #endif

  707. 

  708.         measurement.addTag("location", sensor_location);

  709.         measurement.addTag("placement", "2");

  710.         measurement.addTag("sensor", "bme280");

  711. 

  712. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  713.         measurement.addTag("device", WiFi.macAddress());

  714. #endif

  715. 

  716.         measurement.addValue("temperature", bme2_temp());

  717.         measurement.addValue("pressure", bme2_pressure());

  718.         measurement.addValue("humidity", bme2_humid());

  719. 

  720.         Serial.println(F("Writing bme2"));

  721.         writeMeasurement(measurement);

  722.         Serial.println(F("Done!"));

  723.     }

  724. 

  725.     if (found_sht) {

  726. #if defined(ARDUINO_ARCH_AVR)

  727.         measurement.clear();

  728.         measurement.setName("environment");

  729. #else

  730.         InfluxData measurement("environment");

  731. #endif

  732. 

  733.         measurement.addTag("location", sensor_location);

  734.         measurement.addTag("sensor", "sht21");

  735. 

  736. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  737.         measurement.addTag("device", WiFi.macAddress());

  738. #endif

  739. 

  740.         measurement.addValue("temperature", sht_temp());

  741.         measurement.addValue("humidity", sht_humid());

  742. 

  743.         Serial.println(F("Writing sht"));

  744.         writeMeasurement(measurement);

  745.         Serial.println(F("Done!"));

  746.     }

  747.     

  748.     for (int i = 0; i < moisture_count(); i++) {

  749.         int moisture = moisture_read(i);

  750.         if (moisture < moisture_max()) {

  751. #if defined(ARDUINO_ARCH_AVR)

  752.             measurement.clear();

  753.             measurement.setName("moisture");

  754. #else

  755.             InfluxData measurement("moisture");

  756. #endif

  757. 

  758.             measurement.addTag("location", sensor_location);

  759.             String sensor(i + 1, DEC);

  760.             measurement.addTag("sensor", sensor);

  761. 

  762. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  763.             measurement.addTag("device", WiFi.macAddress());

  764. #endif

  765. 

  766.             measurement.addValue("value", moisture);

  767.             measurement.addValue("maximum", moisture_max());

  768. 

  769.             Serial.print(F("Writing moisture "));

  770.             Serial.println(i);

  771.             writeMeasurement(measurement);

  772.             Serial.println(F("Done!"));

  773.         }

  774.     }

  775. 

  776.     Serial.println(F("All Done!"));

  777. }

  778. #endif // ENABLE_INFLUXDB_LOGGING

  779. 

  780. void loop() {

  781.     unsigned long time = millis();

  782.     

  783. #ifdef ENABLE_RELAIS_TEST

  784.     relais_run();

  785. #endif // ENABLE_RELAIS_TEST

  786. 

  787.     if ((time - last_server_handle_time) >= SERVER_HANDLE_INTERVAL) {

  788.         last_server_handle_time = time;

  789.         handleServers();

  790.     }

  791. 

  792. #ifdef ENABLE_INFLUXDB_LOGGING

  793.     if ((time - last_db_write_time) >= DB_WRITE_INTERVAL) {

  794.         last_db_write_time = time;

  795.         writeDatabase();

  796.     }

  797.     

  798. #ifdef INFLUX_MAX_ERRORS_RESET

  799.     if (error_count >= INFLUX_MAX_ERRORS_RESET) {

  800. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  801.         ESP.restart();

  802. #endif

  803.     }

  804. #endif // INFLUX_MAX_ERRORS_RESET

  805. #endif // ENABLE_INFLUXDB_LOGGING

  806. 

  807.     // blink heartbeat LED

  808.     if ((time - last_led_blink_time) >= LED_BLINK_INTERVAL) {

  809.         last_led_blink_time = time;

  810.         digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));

  811.     }

  812.     

  813. #if defined(ARDUINO_ARCH_ESP8266) || defined(ARDUINO_ARCH_ESP32)

  814.     // reset ESP every 6h to be safe

  815.     if (time >= (6 * 60 * 60 * 1000)) {

  816.         ESP.restart();

  817.     }

  818. #endif

  819. }