init

2 years ago · 69e33b86a2
7 changed files with 374 additions and 0 deletions
--- a/data/main.css
+++ b/data/main.css
@ -0,0 +1,30 @@
+body{
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    margin: 0 auto;
+    height: 100vh;
+    background-color: #f1f1f1;
+}
+
+table{
+  width: 80%;
+}
+
+.font{
+  font-size: 2em;
+  font-family: 'Impact', 'fantasy';
+  text-align: center;
+}
+
+.td_title{
+  width: 200px;
+}
+
+.td_data{
+  width: 100px;
+}
+
+input{
+  vertical-align: middle;
+}
--- a/data/main.html
+++ b/data/main.html
@ -0,0 +1,91 @@
+<!DOCTYPE html>
+<html>
+  <head>
+    <meta charset="utf-8">
+    <title>HEAT</title>
+    <link rel="stylesheet" href="main.css">
+    <script>
+      var gateway = 'ws://' + window.location.hostname + '/ws';
+      var websocket;
+
+      function initWebSocket() {
+        console.log('Trying to open a WebSocket connection...');
+        websocket = new WebSocket(gateway);
+        websocket.onopen    = onOpen;
+        websocket.onclose   = onClose;
+        websocket.onmessage = onMessage; // <-- add this line
+      }
+
+      function onOpen(event) {
+        console.log('Connection opened');
+      }
+
+      function onClose(event) {
+        console.log('Connection closed');
+        setTimeout(initWebSocket, 2000);
+      }
+
+      function onMessage(event) {
+        var head = String(event.data).slice(0, 3);
+        var data = String(event.data).slice(3);
+        console.log([head, data]);
+        if(head == "h1c"){
+          document.getElementById("temp1_current").innerHTML = data;
+        }else if(head == "h2c"){
+          document.getElementById("temp2_current").innerHTML = data;
+        }else if(head == "h1t"){
+          document.getElementById("temp1_target_report").innerHTML = data;
+        }else if(head == "h2t"){
+          document.getElementById("temp2_target_report").innerHTML = data;
+        }
+      }
+
+      window.addEventListener('load', onLoad);
+
+      function onLoad(event) {
+        initWebSocket();
+      }
+
+      function update_text(element){
+        var power = document.getElementById("power_slider").value;
+        document.getElementById("now_var").innerHTML = power;
+      }
+
+      function send_val(element){
+        var data
+        if(element == document.getElementById("temp1_target")){
+          data = "h1t" + document.getElementById("temp1_target").value
+        }else if(element == document.getElementById("temp2_target")){
+          data = "h2t" + document.getElementById("temp2_target").value
+        }
+        websocket.send(data);
+      }
+    </script>
+  </head>
+  <body>
+    <dev>
+      <table>
+        <tr>
+          <td class="font td_title">HEAT 0</td>
+          <td class="font td_title">current</td>
+          <td class="font td_data" id="temp1_current">0</td>
+          <td class="font td_title">target</td>
+          <td class="font td_data" id="temp1_target_report">0</td>
+          <td class="font">
+            <input type="text" id="temp1_target" min="0" max="300" placeholder="target temp" onchange="send_val(this)">
+          </td>
+        </tr>
+        <tr>
+          <td class="font td_title">HEAT 1</td>
+          <td class="font td_title">current</td>
+          <td class="font td_data" id="temp2_current">0</td>
+          <td class="font td_title">target</td>
+          <td class="font td_data" id="temp2_target_report">0</td>
+          <td class="font">
+            <input type="text" id="temp2_target" min="0" max="300" placeholder="target temp" onchange="send_val(this)">
+          </td>
+        </tr>
+      </table>
+    </dev>
+  </body>
+</html>
--- a/include/README
+++ b/include/README
@ -0,0 +1,39 @@
+
+This directory is intended for project header files.
+
+A header file is a file containing C declarations and macro definitions
+to be shared between several project source files. You request the use of a
+header file in your project source file (C, C++, etc) located in `src` folder
+by including it, with the C preprocessing directive `#include'.
+
+```src/main.c
+
+#include "header.h"
+
+int main (void)
+{
+ ...
+}
+```
+
+Including a header file produces the same results as copying the header file
+into each source file that needs it. Such copying would be time-consuming
+and error-prone. With a header file, the related declarations appear
+in only one place. If they need to be changed, they can be changed in one
+place, and programs that include the header file will automatically use the
+new version when next recompiled. The header file eliminates the labor of
+finding and changing all the copies as well as the risk that a failure to
+find one copy will result in inconsistencies within a program.
+
+In C, the usual convention is to give header files names that end with `.h'.
+It is most portable to use only letters, digits, dashes, and underscores in
+header file names, and at most one dot.
+
+Read more about using header files in official GCC documentation:
+
+* Include Syntax
+* Include Operation
+* Once-Only Headers
+* Computed Includes
+
+https://gcc.gnu.org/onlinedocs/cpp/Header-Files.html
--- a/lib/README
+++ b/lib/README
@ -0,0 +1,46 @@
+
+This directory is intended for project specific (private) libraries.
+PlatformIO will compile them to static libraries and link into executable file.
+
+The source code of each library should be placed in a an own separate directory
+("lib/your_library_name/[here are source files]").
+
+For example, see a structure of the following two libraries `Foo` and `Bar`:
+
+|--lib
+|  |
+|  |--Bar
+|  |  |--docs
+|  |  |--examples
+|  |  |--src
+|  |     |- Bar.c
+|  |     |- Bar.h
+|  |  |- library.json (optional, custom build options, etc) https://docs.platformio.org/page/librarymanager/config.html
+|  |
+|  |--Foo
+|  |  |- Foo.c
+|  |  |- Foo.h
+|  |
+|  |- README --> THIS FILE
+|
+|- platformio.ini
+|--src
+   |- main.c
+
+and a contents of `src/main.c`:
+```
+#include <Foo.h>
+#include <Bar.h>
+
+int main (void)
+{
+  ...
+}
+
+```
+
+PlatformIO Library Dependency Finder will find automatically dependent
+libraries scanning project source files.
+
+More information about PlatformIO Library Dependency Finder
+- https://docs.platformio.org/page/librarymanager/ldf.html
--- a/platformio.ini
+++ b/platformio.ini
@ -0,0 +1,18 @@
+; PlatformIO Project Configuration File
+;
+;   Build options: build flags, source filter
+;   Upload options: custom upload port, speed and extra flags
+;   Library options: dependencies, extra library storages
+;   Advanced options: extra scripting
+;
+; Please visit documentation for the other options and examples
+; https://docs.platformio.org/page/projectconf.html
+
+[env:nodemcuv2]
+platform = espressif8266
+board = nodemcuv2
+framework = arduino
+lib_deps = ottowinter/ESPAsyncWebServer-esphome@^3.0.0
+board_build.filesystem = littlefs
+upload_speed = 921600
+monitor_speed = 115200
--- a/src/main.cpp
+++ b/src/main.cpp
@ -0,0 +1,139 @@
+#include <Arduino.h>
+#include <ESPAsyncWebServer.h>
+#include <ESP8266WiFi.h>
+#include <LITTLEFS.h>
+#include <Ticker.h>
+
+/*===== Define =====*/
+/*[const]*/
+#define HEAT_OFF -300
+
+/*[wifi]*/
+#define AP_SSID "test"
+#define AP_PASSWD "sonofussr"
+#define AP_CHANNEL 1
+#define AP_MAX_CLIENT 4
+
+/*[heat]*/
+#define MAX_TEMP 350
+
+
+/*===== Object =====*/
+
+AsyncWebServer server(80);
+AsyncWebSocket ws("/ws");
+
+Ticker temp_reporter;
+
+
+/*===== Variable =====*/
+
+//-300: off
+double temp1_current = 0;
+double temp1_target = HEAT_OFF;
+double temp2_current = 0;
+double temp2_target = HEAT_OFF;
+
+
+/*===== Handler =====*/
+
+void handleWebSocketMessage(void *arg, uint8_t *data, size_t len) {
+  AwsFrameInfo *info = (AwsFrameInfo*)arg;
+  if (info->final && info->index == 0 && info->len == len && info->opcode == WS_TEXT) {
+    data[len] = '\0';
+
+    Serial.println((char*)data);
+    String str_data = (String)(char*)data;
+    String head = str_data.substring(0,3);
+    String body = str_data.substring(3,str_data.length());
+
+    Serial.println("head: "+ head + " body: " + body);
+    
+    if(head == "h1t"){
+      temp1_target = body.toDouble();
+    }else if(head == "h2t"){
+      temp2_target = body.toDouble();
+    }
+    //Serial.println(power);
+
+    //pinMode(LED_PIN, 0);
+    //LED_handler.attach_ms(300, led_off);
+  }
+}
+
+
+void onEvent(AsyncWebSocket *server, AsyncWebSocketClient *client, AwsEventType type, void *arg, uint8_t *data, size_t len) {
+  switch (type) {
+    case WS_EVT_CONNECT:
+      Serial.printf("WebSocket client #%u connected from %s\n", client->id(), client->remoteIP().toString().c_str());
+      temp1_target = HEAT_OFF;
+      temp2_target = HEAT_OFF;
+      break;
+    case WS_EVT_DISCONNECT:
+      Serial.printf("WebSocket client #%u disconnected\n", client->id());
+      temp1_target = HEAT_OFF;
+      temp2_target = HEAT_OFF;
+      break;
+    case WS_EVT_DATA:
+      handleWebSocketMessage(arg, data, len);
+      break;
+    case WS_EVT_PONG:
+    case WS_EVT_ERROR:
+      temp1_target = HEAT_OFF;
+      temp2_target = HEAT_OFF;
+      break;
+  }
+}
+
+
+void temp_report_handler(){
+  ws.textAll("h1c" + String(temp1_current));
+  ws.textAll("h2c" + String(temp2_current));
+  ws.textAll("h1t" + String(temp1_target));
+  ws.textAll("h2t" + String(temp2_target));
+  Serial.println("report temp" + String(" h1c: ") + String(temp1_current) + " h2c: " + String(temp2_current) + " h1t: " + String(temp1_target) + " h2t: " + String(temp2_target));
+}
+
+
+/*===== Main =====*/
+
+void setup() {
+  Serial.begin(115200);
+
+  //init LittleFS
+  if(!LittleFS.begin()){
+    Serial.println("fail init fs");
+    return;
+  }
+
+  //show all files
+  Dir root = LittleFS.openDir("/");
+  while (root.next()) {
+    File file = root.openFile("r");
+    Serial.print(" FILE: ");
+    Serial.print(root.fileName());
+    Serial.print(" SIZE: ");
+    Serial.println(file.size());
+    file.close();
+  }
+
+  //init Wifi
+  WiFi.softAP(AP_SSID, AP_PASSWD, AP_CHANNEL, 0, AP_MAX_CLIENT);
+
+  //web handler
+  ws.onEvent(onEvent);
+  server.addHandler(&ws);
+  server.onNotFound([](AsyncWebServerRequest *request){ request->redirect("/"); }); //captive portal redirect
+  server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){ request->send(LittleFS, "/main.html", "text/html"); }); //main html
+  server.on("/main.css", HTTP_GET, [](AsyncWebServerRequest *request){ request->send(LittleFS, "/main.css", "text/css"); }); //main css
+
+  server.begin();
+
+  temp_reporter.attach(0.5, temp_report_handler);
+}
+
+void loop() {
+  temp1_current = rand()%100;
+  temp2_current = rand()%100;
+  delay(100);
+}
--- a/test/README
+++ b/test/README
@ -0,0 +1,11 @@
+
+This directory is intended for PlatformIO Test Runner and project tests.
+
+Unit Testing is a software testing method by which individual units of
+source code, sets of one or more MCU program modules together with associated
+control data, usage procedures, and operating procedures, are tested to
+determine whether they are fit for use. Unit testing finds problems early
+in the development cycle.
+
+More information about PlatformIO Unit Testing:
+- https://docs.platformio.org/en/latest/advanced/unit-testing/index.html