DIY fertilizer mixer and plant watering machine https://www.xythobuz.de/giessomat.html
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.

WifiStuff.cpp 19KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615
  1. #include <Arduino.h>
  2. #ifdef PLATFORM_ESP
  3. #if defined(ARDUINO_ARCH_ESP8266)
  4. #include <ESP8266WiFi.h>
  5. #include <ESP8266WebServer.h>
  6. #include <ESP8266mDNS.h>
  7. #elif defined(ARDUINO_ARCH_ESP32)
  8. #include <WiFi.h>
  9. #include <WebServer.h>
  10. #include <ESPmDNS.h>
  11. #endif
  12. #include <WebSocketsServer.h>
  13. #include "wifi.h"
  14. #include "config.h"
  15. #include "config_pins.h"
  16. #include "Functionality.h"
  17. #include "SimpleUpdater.h"
  18. #include "DebugLog.h"
  19. #include "WifiStuff.h"
  20. UPDATE_WEB_SERVER server(80);
  21. WebSocketsServer socket = WebSocketsServer(81);
  22. SimpleUpdater updater;
  23. unsigned long last_server_handle_time = 0;
  24. unsigned long last_websocket_update_time = 0;
  25. String message_buffer_a;
  26. String message_buffer_b;
  27. String message_buffer_c;
  28. String message_buffer_d;
  29. void wifi_set_message_buffer(String a, String b, String c, String d) {
  30. message_buffer_a = a;
  31. message_buffer_b = b;
  32. message_buffer_c = c;
  33. message_buffer_d = d;
  34. }
  35. void wifi_schedule_websocket(void) {
  36. last_websocket_update_time = 0;
  37. }
  38. void wifi_send_status_broadcast(void) {
  39. if (socket.connectedClients() <= 0) {
  40. return;
  41. }
  42. String a = message_buffer_a ;
  43. String b = message_buffer_b;
  44. String c = message_buffer_c;
  45. String d = message_buffer_d;
  46. a.replace("\"", "'");
  47. b.replace("\"", "'");
  48. c.replace("\"", "'");
  49. d.replace("\"", "'");
  50. String ws = "{\n";
  51. ws += "\"a\": \"" + a + "\",\n";
  52. ws += "\"b\": \"" + b + "\",\n";
  53. ws += "\"c\": \"" + c + "\",\n";
  54. ws += "\"d\": \"" + d + "\",\n";
  55. ws += "\"state\": \"" + String(control_state_name()) + "\",\n";
  56. ws += F("\"valves\": [ ");
  57. for (int i = 0; i < VALVE_COUNT; i++) {
  58. ws += "\"";
  59. ws += get_plants()->getValves()->getPin(i) ? "1" : "0";
  60. ws += "\"";
  61. if (i < (VALVE_COUNT - 1)) {
  62. ws += ", ";
  63. }
  64. }
  65. ws += " ],\n";
  66. ws += F("\"pumps\": [ ");
  67. for (int i = 0; i < PUMP_COUNT; i++) {
  68. ws += "\"";
  69. ws += get_plants()->getPumps()->getPin(i) ? "1" : "0";
  70. ws += "\"";
  71. if (i < (PUMP_COUNT - 1)) {
  72. ws += ", ";
  73. }
  74. }
  75. ws += " ],\n";
  76. ws += F("\"switches\": [ ");
  77. for (int i = 0; i < SWITCH_COUNT; i++) {
  78. bool v = get_plants()->getSwitches()->getPin(i);
  79. #ifdef INVERT_SENSOR_BOTTOM
  80. if (i == 0) {
  81. v = !v;
  82. }
  83. #endif // INVERT_SENSOR_BOTTOM
  84. #ifdef INVERT_SENSOR_TOP
  85. if (i == 1) {
  86. v = !v;
  87. }
  88. #endif // INVERT_SENSOR_TOP
  89. ws += "\"";
  90. ws += v ? "1" : "0";
  91. ws += "\"";
  92. if (i < (SWITCH_COUNT - 1)) {
  93. ws += ", ";
  94. }
  95. }
  96. ws += " ],\n";
  97. ws += "\"switchstate\": \"";
  98. Plants::Waterlevel wl = get_plants()->getWaterlevel();
  99. if (wl == Plants::empty) {
  100. ws += F("tank empty");
  101. } else if (wl == Plants::inbetween) {
  102. ws += F("tank half-filled");
  103. } else if (wl == Plants::full) {
  104. ws += F("tank full");
  105. } else {
  106. ws += F("invalid sensor state");
  107. }
  108. ws += "\"\n";
  109. ws += "}";
  110. wifi_send_websocket(ws);
  111. }
  112. void wifi_send_websocket(String s) {
  113. socket.broadcastTXT(s);
  114. }
  115. void handleRoot() {
  116. String message = F("<!DOCTYPE html>\n");
  117. message += F("<html><head>\n");
  118. message += F("<meta charset='utf-8'/>\n");
  119. message += F("<meta name='viewport' content='width=device-width, initial-scale=1'/>\n");
  120. message += F("<title>Gieß-o-mat</title>\n");
  121. message += F("<style type='text/css'>\n");
  122. message += F(".container {\n");
  123. message += F("display: flex;\n");
  124. message += F("}\n");
  125. message += F(".ui {\n");
  126. message += F("width: max-content;\n");
  127. message += F("height: max-content;\n");
  128. message += F("margin-right: 1em;\n");
  129. message += F("padding: 0 1.0em;\n");
  130. message += F("border: 1px dashed black;\n");
  131. message += F("}\n");
  132. message += F(".io {\n");
  133. message += F("width: max-content;\n");
  134. message += F("height: max-content;\n");
  135. message += F("margin-right: 1em;\n");
  136. message += F("padding: 0.8em 1.0em;\n");
  137. message += F("border: 1px dashed black;\n");
  138. message += F("font-family: monospace;\n");
  139. message += F("}\n");
  140. message += F(".switch {\n");
  141. message += F("width: max-content;\n");
  142. message += F("border: 1px solid black;\n");
  143. message += F("border-radius: 50%;\n");
  144. message += F("padding: 2em;\n");
  145. message += F("margin: 1em;\n");
  146. message += F("}\n");
  147. message += F(".valve {\n");
  148. message += F("width: max-content;\n");
  149. message += F("border: 1px solid black;\n");
  150. message += F("border-radius: 50%;\n");
  151. message += F("padding: 2em;\n");
  152. message += F("margin: 1em;\n");
  153. message += F("}\n");
  154. message += F(".pump {\n");
  155. message += F("width: max-content;\n");
  156. message += F("border: 1px solid black;\n");
  157. message += F("border-radius: 50%;\n");
  158. message += F("padding: 2em;\n");
  159. message += F("margin: 1em;\n");
  160. message += F("}\n");
  161. message += F(".info {\n");
  162. message += F("width: max-content;\n");
  163. message += F("height: max-content;\n");
  164. message += F("padding: 0 1.0em;\n");
  165. message += F("border: 1px dashed black;\n");
  166. message += F("font-family: monospace;\n");
  167. message += F("}\n");
  168. message += F(".log {\n");
  169. message += F("max-height: 300px;\n");
  170. message += F("padding: 0 1.0em;\n");
  171. message += F("margin: 1em 0;\n");
  172. message += F("border: 1px dashed black;\n");
  173. message += F("font-family: monospace;\n");
  174. message += F("overflow-y: scroll;\n");
  175. message += F("word-break: break-all;\n");
  176. message += F("}\n");
  177. message += F("#logbuf {\n");
  178. message += F("white-space: break-spaces;\n");
  179. message += F("}\n");
  180. message += F(".pad {\n");
  181. message += F("background: black;\n");
  182. message += F("border: 3px solid black;\n");
  183. message += F("border-radius: 20px;\n");
  184. message += F("width: max-content;\n");
  185. message += F("padding: 1.5em;\n");
  186. message += F("margin-left: auto;\n");
  187. message += F("margin-right: auto;\n");
  188. message += F("}\n");
  189. message += F(".pad input {\n");
  190. message += F("background: #fff0cf;\n");
  191. message += F("border-radius: 6px;\n");
  192. message += F("font-weight: bold;\n");
  193. message += F("font-family: monospace;\n");
  194. message += F("font-size: 1.2em;\n");
  195. message += F("padding: 0.5em 1em;\n");
  196. message += F("margin: 0.5em;\n");
  197. message += F("}\n");
  198. // https://codepen.io/hawkz/pres/RpPaGK
  199. message += F(".lcd {\n");
  200. //message += F("background: #9ea18c;\n");
  201. message += F("background: #9ed18c;\n");
  202. message += F("border: 5px solid black;\n");
  203. message += F("border-radius: 10px;\n");
  204. message += F("width: max-content;\n");
  205. message += F("padding: 0.65em 1em;\n");
  206. message += F("box-shadow: inset 0 0 5px 5px rgba(0,0,0,.1);\n");
  207. message += F("font-weight: bold;\n");
  208. message += F("font-family: monospace;\n");
  209. message += F("letter-spacing: 0.1em;\n");
  210. message += F("font-size: 1.2em;\n");
  211. message += F("line-height: 160%;\n");
  212. message += F("color: #21230e;\n");
  213. message += F("text-shadow: -1px 2px 1px rgba(0,0,0,.1);\n");
  214. message += F("margin-left: auto;\n");
  215. message += F("margin-right: auto;\n");
  216. message += F("}\n");
  217. message += F("#state {\n");
  218. message += F("text-align: center;\n");
  219. message += F("}\n");
  220. message += F("</style>\n");
  221. message += F("</head><body>\n");
  222. message += F("<h1>Gieß-o-mat</h1>\n");
  223. message += F("<div class='container'>\n");
  224. message += F("<div class='ui'>\n");
  225. message += F("<pre class='lcd'>\n");
  226. message += message_buffer_a + '\n';
  227. message += message_buffer_b + '\n';
  228. message += message_buffer_c + '\n';
  229. message += message_buffer_d + '\n';
  230. message += F("</pre>\n");
  231. message += F("<form class='pad'>\n");
  232. message += F("<input type='button' value='1'>");
  233. message += F("<input type='button' value='2'>");
  234. message += F("<input type='button' value='3'>");
  235. message += F("<br>\n");
  236. message += F("<input type='button' value='4'>");
  237. message += F("<input type='button' value='5'>");
  238. message += F("<input type='button' value='6'>");
  239. message += F("<br>\n");
  240. message += F("<input type='button' value='7'>");
  241. message += F("<input type='button' value='8'>");
  242. message += F("<input type='button' value='9'>");
  243. message += F("<br>\n");
  244. message += F("<input type='button' value='*'>");
  245. message += F("<input type='button' value='0'>");
  246. message += F("<input type='button' value='#'>");
  247. message += F("</form>\n");
  248. message += F("<p id='state'>\n");
  249. message += F("State: ");
  250. message += control_state_name();
  251. message += F("</p></div>\n");
  252. message += F("<div class='io'>\n");
  253. message += F("Switches: <span id='switchstate'>");
  254. Plants::Waterlevel wl = get_plants()->getWaterlevel();
  255. if (wl == Plants::empty) {
  256. message += F("tank empty");
  257. } else if (wl == Plants::inbetween) {
  258. message += F("tank half-filled");
  259. } else if (wl == Plants::full) {
  260. message += F("tank full");
  261. } else {
  262. message += F("invalid sensor state");
  263. }
  264. message += F("</span>");
  265. message += F("<div class='container'>\n");
  266. for (int i = 0; i < SWITCH_COUNT; i++) {
  267. message += F("<div class='switch' style='background-color: ");
  268. bool v = get_plants()->getSwitches()->getPin(i);
  269. #ifdef INVERT_SENSOR_BOTTOM
  270. if (i == 0) {
  271. v = !v;
  272. }
  273. #endif // INVERT_SENSOR_BOTTOM
  274. #ifdef INVERT_SENSOR_TOP
  275. if (i == 1) {
  276. v = !v;
  277. }
  278. #endif // INVERT_SENSOR_TOP
  279. if (v) {
  280. message += F("red");
  281. } else {
  282. message += F("green");
  283. }
  284. message += F(";'>S");
  285. message += String(i + 1);
  286. message += F("</div>");
  287. }
  288. message += F("</div><hr>\n");
  289. message += F("Valves:\n");
  290. message += F("<div class='container'>\n");
  291. for (int i = 0; i < VALVE_COUNT; i++) {
  292. message += F("<div class='valve' style='background-color: ");
  293. if (get_plants()->getValves()->getPin(i)) {
  294. message += F("red");
  295. } else {
  296. message += F("green");
  297. }
  298. message += F(";'>V");
  299. message += String(i + 1);
  300. message += F("</div>");
  301. }
  302. message += F("</div><hr>\n");
  303. message += F("Pumps:\n");
  304. message += F("<div class='container'>\n");
  305. for (int i = 0; i < PUMP_COUNT; i++) {
  306. message += F("<div class='pump' style='background-color: ");
  307. if (get_plants()->getPumps()->getPin(i)) {
  308. message += F("red");
  309. } else {
  310. message += F("green");
  311. }
  312. message += F(";'>P");
  313. message += String(i + 1);
  314. message += F("</div>");
  315. }
  316. message += F("</div><hr>\n");
  317. message += F("Green means valve is closed / pump is off / switch is not submersed.\n");
  318. message += F("<br>\n");
  319. message += F("Red means valve is open / pump is running / switch is submersed.</div>\n");
  320. message += F("<div class='info'><p>\n");
  321. message += F("Version: ");
  322. message += FIRMWARE_VERSION;
  323. message += F("\n<br>\n");
  324. message += F("MAC: ");
  325. message += WiFi.macAddress();
  326. message += F("\n</p>\n");
  327. #if defined(ARDUINO_ARCH_ESP8266)
  328. message += F("\n<p>\n");
  329. message += F("Reset reason: ");
  330. message += ESP.getResetReason();
  331. message += F("\n<br>\n");
  332. message += F("Free heap: ");
  333. message += String(ESP.getFreeHeap());
  334. message += F(" (");
  335. message += String(ESP.getHeapFragmentation());
  336. message += F("% fragmentation)");
  337. message += F("\n<br>\n");
  338. message += F("Free sketch space: ");
  339. message += String(ESP.getFreeSketchSpace());
  340. message += F("\n<br>\n");
  341. message += F("Flash chip real size: ");
  342. message += String(ESP.getFlashChipRealSize());
  343. if (ESP.getFlashChipSize() != ESP.getFlashChipRealSize()) {
  344. message += F("\n<br>\n");
  345. message += F("WARNING: sdk chip size (");
  346. message += (ESP.getFlashChipSize());
  347. message += F(") does not match!");
  348. }
  349. message += F("\n</p>\n");
  350. #elif defined(ARDUINO_ARCH_ESP32)
  351. message += F("\n<p>\n");
  352. message += F("Free heap: ");
  353. message += String(ESP.getFreeHeap() / 1024.0);
  354. message += F("k\n<br>\n");
  355. message += F("Free sketch space: ");
  356. message += String(ESP.getFreeSketchSpace() / 1024.0);
  357. message += F("k\n<br>\n");
  358. message += F("Flash chip size: ");
  359. message += String(ESP.getFlashChipSize() / 1024.0);
  360. message += F("k\n</p>\n");
  361. #endif
  362. message += F("<p>Try <a href='/update'>/update</a> for OTA firmware updates!</p>\n");
  363. message += F("<p>Made by <a href='https://xythobuz.de'>xythobuz</a></p>\n");
  364. message += F("<p><a href='https://git.xythobuz.de/thomas/giess-o-mat'>Project Repository</a></p>\n");
  365. message += F("</div></div>\n");
  366. message += F("<div class='log'><pre id='logbuf'>\n");
  367. message += debug.getBuffer();
  368. message += F("</pre></div>\n");
  369. message += F("</body>\n");
  370. message += F("<script type='text/javascript'>\n");
  371. message += F("var socket = new WebSocket('ws://' + window.location.hostname + ':81');\n");
  372. message += F("socket.onmessage = function(e) {\n");
  373. message += F( "if (e.data.startsWith('log:')) {\n");
  374. message += F( "var log = document.getElementById('logbuf');\n");
  375. message += F( "var div = document.getElementsByClassName('log')[0];\n");
  376. message += F( "log.innerHTML += e.data.substring(4);\n");
  377. message += F( "if (log.innerHTML.length > (1024 * 1024)) {\n");
  378. message += F( "log.innerHTML = log.innerHTML.substring(1024 * 1024);\n");
  379. message += F( "}\n");
  380. message += F( "div.scrollTop = div.scrollHeight;\n");
  381. message += F( "return;\n");
  382. message += F( "}\n");
  383. message += F( "var msg = JSON.parse(e.data);\n");
  384. message += F( "var str = msg.a + '\\n' + msg.b + '\\n' + msg.c + '\\n' + msg.d;\n");
  385. message += F( "console.log(str);\n");
  386. message += F( "var lcd = document.getElementsByClassName('lcd');\n");
  387. message += F( "lcd[0].innerHTML = str;\n");
  388. message += F( "var state = document.getElementById('state');\n");
  389. message += F( "state.innerHTML = \"State: \" + msg.state;\n");
  390. message += F( "for (let i = 0; i < ");
  391. message += String(VALVE_COUNT);
  392. message += F("; i++) {\n");
  393. message += F( "var valves = document.getElementsByClassName('valve');\n");
  394. message += F( "if (msg.valves[i] == '0') {\n");
  395. message += F( "valves[i].style = 'background-color: green;';\n");
  396. message += F( "} else {\n");
  397. message += F( "valves[i].style = 'background-color: red;';\n");
  398. message += F( "}\n");
  399. message += F( "}\n");
  400. message += F( "for (let i = 0; i < ");
  401. message += String(PUMP_COUNT);
  402. message += F("; i++) {\n");
  403. message += F( "var pumps = document.getElementsByClassName('pump');\n");
  404. message += F( "if (msg.pumps[i] == '0') {\n");
  405. message += F( "pumps[i].style = 'background-color: green;';\n");
  406. message += F( "} else {\n");
  407. message += F( "pumps[i].style = 'background-color: red;';\n");
  408. message += F( "}\n");
  409. message += F( "}\n");
  410. message += F( "for (let i = 0; i < ");
  411. message += String(SWITCH_COUNT);
  412. message += F("; i++) {\n");
  413. message += F( "var switches = document.getElementsByClassName('switch');\n");
  414. message += F( "if (msg.switches[i] == '0') {\n");
  415. message += F( "switches[i].style = 'background-color: green;';\n");
  416. message += F( "} else {\n");
  417. message += F( "switches[i].style = 'background-color: red;';\n");
  418. message += F( "}\n");
  419. message += F( "}\n");
  420. message += F( "var switchstate = document.getElementById('switchstate');\n");
  421. message += F( "switchstate.innerHTML = msg.switchstate;\n");
  422. message += F("};\n");
  423. message += F("var buttons = document.getElementsByTagName('input');\n");
  424. message += F("for (let i = 0; i < buttons.length; i++) {\n");
  425. message += F( "buttons[i].addEventListener('click', updateButton);\n");
  426. message += F("}\n");
  427. message += F("function updateButton() {\n");
  428. message += F( "socket.send(this.value);\n");
  429. message += F("}\n");
  430. message += F("</script>\n");
  431. message += F("</html>\n");
  432. server.send(200, "text/html", message);
  433. }
  434. void webSocketEvent(uint8_t num, WStype_t type, uint8_t *payload, size_t length) {
  435. if ((type != WStype_TEXT) || (length != 1)) {
  436. return;
  437. }
  438. char c = payload[0];
  439. if ((c >= '0') && (c <= '9')) {
  440. control_act_input(c - '0');
  441. } else if (c == '*') {
  442. control_act_input(-1);
  443. } else if (c == '#') {
  444. control_act_input(-2);
  445. }
  446. }
  447. void wifi_setup() {
  448. // Build hostname string
  449. String hostname = "giess-o-mat";
  450. #if defined(ARDUINO_ARCH_ESP8266)
  451. // Connect to WiFi AP
  452. debug.println("WiFi: initializing");
  453. WiFi.hostname(hostname);
  454. WiFi.mode(WIFI_STA);
  455. debug.print("WiFi: connecting");
  456. WiFi.begin(WIFI_SSID, WIFI_PW);
  457. while (WiFi.status() != WL_CONNECTED) {
  458. debug.print(".");
  459. delay(LED_CONNECT_BLINK_INTERVAL);
  460. digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));
  461. }
  462. debug.println();
  463. #elif defined(ARDUINO_ARCH_ESP32)
  464. // Set hostname workaround
  465. debug.println("WiFi: set hostname");
  466. WiFi.config(INADDR_NONE, INADDR_NONE, INADDR_NONE);
  467. WiFi.setHostname(hostname.c_str());
  468. // Workaround for WiFi connecting only every 2nd reset
  469. // https://github.com/espressif/arduino-esp32/issues/2501#issuecomment-513602522
  470. debug.println("WiFi: connection work-around");
  471. WiFi.onEvent([](WiFiEvent_t event, WiFiEventInfo_t info) {
  472. if (info.disconnected.reason == 202) {
  473. esp_sleep_enable_timer_wakeup(10);
  474. esp_deep_sleep_start();
  475. delay(100);
  476. }
  477. }, WiFiEvent_t::SYSTEM_EVENT_STA_DISCONNECTED);
  478. // Connect to WiFi AP
  479. debug.println("WiFi: SSID=" WIFI_SSID);
  480. debug.print("WiFi: connecting");
  481. WiFi.mode(WIFI_STA);
  482. WiFi.begin(WIFI_SSID, WIFI_PW);
  483. while (WiFi.status() != WL_CONNECTED) {
  484. debug.print(".");
  485. delay(LED_CONNECT_BLINK_INTERVAL);
  486. digitalWrite(BUILTIN_LED_PIN, !digitalRead(BUILTIN_LED_PIN));
  487. }
  488. debug.println();
  489. // Set hostname workaround
  490. debug.println("WiFi: set hostname work-around");
  491. WiFi.setHostname(hostname.c_str());
  492. #endif
  493. // Setup HTTP Server
  494. debug.println("WiFi: initializing HTTP server");
  495. MDNS.begin(hostname.c_str());
  496. updater.setup(&server);
  497. server.on("/", handleRoot);
  498. server.begin();
  499. MDNS.addService("http", "tcp", 80);
  500. socket.begin();
  501. socket.onEvent(webSocketEvent);
  502. debug.println("WiFi: setup done");
  503. }
  504. void wifi_run() {
  505. if ((millis() - last_server_handle_time) >= SERVER_HANDLE_INTERVAL) {
  506. last_server_handle_time = millis();
  507. server.handleClient();
  508. socket.loop();
  509. #ifdef ARDUINO_ARCH_ESP8266
  510. MDNS.update();
  511. #endif // ARDUINO_ARCH_ESP8266
  512. }
  513. if ((millis() - last_websocket_update_time) >= WEBSOCKET_UPDATE_INTERVAL) {
  514. last_websocket_update_time = millis();
  515. wifi_send_status_broadcast();
  516. }
  517. // reset ESP every 6h to be safe
  518. if (millis() >= (6 * 60 * 60 * 1000)) {
  519. ESP.restart();
  520. }
  521. }
  522. #endif // PLATFORM_ESP