Added sensor logging on SPIFFS.

Author: CelliesProjects

ESP8266-temp-server.ino

@@ -2,16 +2,30 @@
 #include <ESP8266WiFi.h>
 #include <ESPAsyncTCP.h>
 #include <ESPAsyncWebServer.h>
+#include <FS.h>
+#include <time.h>                       // time() ctime()
+#include <sys/time.h>                   // struct timeval
+
 #include "index_htm.h"
+#include "logs_htm.h"
 
 #define ONE_WIRE_BUS              D1
 
-const char * WIFISSID =           "yourSSID";
-const char * WIFIPSK =            "yourPSK";
+#define TZ              1       // (utc+) TZ in hours
+#define DST_MN          60      // use 60mn for summer time in some countries
+#define TZ_MN           ((TZ)*60)
+#define TZ_SEC          ((TZ)*3600)
+#define DST_SEC         ((DST_MN)*60)
+
+const char WIFISSID[]  =           "yourSSID";
+const char WIFIPSK[]  =            "yourPSK";
+
+const float SENSOR_ERROR = -273.15;
 
 AsyncWebServer server(80);
 
-float currentTemp = -273.15;
+float currentTemp = SENSOR_ERROR;
+bool dstStatus = true;
 
 OneWire  ds( ONE_WIRE_BUS ); // (a 4.7K resistor is necessary)
 
@@ -20,9 +34,7 @@ void setup(void)
   Serial.begin( 115200 );
   Serial.println();
 
-  analogWriteFreq( 40000 );
-  pinMode( BUILTIN_LED, OUTPUT );
-  digitalWrite( BUILTIN_LED, LOW );
+  configTime( TZ_SEC, DST_SEC, "nl.pool.ntp.org" );
 
   WiFi.mode( WIFI_STA );
   if ( !connectWifi() )
@@ -36,12 +48,6 @@ void setup(void)
       delay( 100 );
     }
   }
-  else
-  {
-    Serial.println( "Connected!" );
-    Serial.println( WiFi.localIP().toString() );
-    digitalWrite( BUILTIN_LED, HIGH );
-  }
 
   static const char * HTML_HEADER = "text/html";
 
@@ -51,45 +57,77 @@ void setup(void)
     request->send(response);
   });
 
+
   server.on( "/data", HTTP_GET, [] ( AsyncWebServerRequest * request )
+  {
+    if ( currentTemp == SENSOR_ERROR )
+    {
+      request->send( 200, HTML_HEADER, F( "<p style=\"font-size:100px;color:red;\">SENSOR ERROR</p>" ) );
+    }
+    else
+    {
+      AsyncResponseStream *response = request->beginResponseStream( HTML_HEADER );
+      response->printf( "%.1f&deg;C", currentTemp );
+      request->send( response );
+    }
+  });
+
+  server.on( "/logs", HTTP_GET, [] ( AsyncWebServerRequest * request )
+  {
+    AsyncWebServerResponse *response = request->beginResponse_P( 200, HTML_HEADER, logs_htm, logs_htm_len );
+    request->send(response);
+  });
+
+  server.on( "/files", HTTP_GET, [] ( AsyncWebServerRequest * request )
   {
     AsyncResponseStream *response = request->beginResponseStream( HTML_HEADER );
-    response->printf( "%.1f&deg;C", currentTemp );
+    Dir dir = SPIFFS.openDir("/");
+    while (dir.next()) response->printf( "%s\n", dir.fileName().c_str() );
     request->send( response );
   });
 
+  server.on( "/dststatus", HTTP_GET, [] ( AsyncWebServerRequest * request )
+  {
+    if ( request->hasArg( "dst" ) )
+    {
+      if ( request->arg( "dst" ) == "on" ) dstStatus = true;
+      else if ( request->arg( "dst" ) == "off" ) dstStatus = false;
+    }
+    AsyncResponseStream *response = request->beginResponseStream( HTML_HEADER );
+    response->printf( "DST is %s", dstStatus ? "on" : "off" );
+    request->send( response );
+  });
+
+  server.serveStatic( "/", SPIFFS, "/" );
+
   server.onNotFound( []( AsyncWebServerRequest * request )
   {
-    Serial.printf( "Not found http://%s%s\n", request->host().c_str(), request->url().c_str());
     request->send( 404 );
   });
 
   DefaultHeaders::Instance().addHeader( "Access-Control-Allow-Origin", "*" );
   server.begin();
-}
 
-void loop(void)
-{
-  const uint16_t delayTime = 1000; /* milliseconds */
-  static unsigned long nextHeartBeat = millis() + delayTime;
+  time_t now;
+  struct tm timeinfo;
 
-  if ( (long)( millis() - nextHeartBeat ) >= 0 )
-  {
-    analogWrite( BUILTIN_LED, PWMRANGE >> 5 );
-    delay(3);
-    digitalWrite( BUILTIN_LED, HIGH );
-    nextHeartBeat += delayTime;
+  while ( timeinfo.tm_year < ( 2016 - 1900 ) ) {
+    delay(50);
+    time( &now );
+    localtime_r( &now, &timeinfo );
   }
+  Serial.print( F( "Time synced at " ) );
+  Serial.println( asctime( localtime( &now ) ) );
 
-  if ( !WiFi.isConnected() )
-  {
-    analogWriteFreq( 10 );
-    analogWrite( BUILTIN_LED, PWMRANGE / 2 );
-    Serial.println( "WiFi is disconnected." );
-    if ( !connectWifi() ) return;
-    Serial.println( "WiFi just reconnected" );
-  }
+  if ( !SPIFFS.begin() )
+    Serial.println( F( "SPIFFS could not be mounted" ) );
+}
+
+time_t nextLogTime = 0;
+const time_t logDelaySeconds = 120;
 
+void loop(void)
+{
   byte addr[8];
 
   if ( !ds.search(addr))
@@ -100,7 +138,7 @@ void loop(void)
 
   if (OneWire::crc8(addr, 7) != addr[7])
   {
-    Serial.println("Sensor CRC is not valid!");
+    Serial.println( F( "Sensor CRC is not valid!" ) );
     return;
   }
 
@@ -156,6 +194,20 @@ void loop(void)
     //// default is 12 bit resolution, 750 ms conversion time
   }
   currentTemp = (float)raw / 16.0;
+
+  time_t now;
+  time( &now );
+  if ( now >= nextLogTime )
+  {
+    logToSPIFFS( now );
+    nextLogTime = now + logDelaySeconds;
+  }
+  if ( !WiFi.isConnected() )
+  {
+    Serial.println( F( "WiFi is disconnected." ) );
+    if ( !connectWifi() ) return;
+    Serial.println( F( "WiFi just reconnected" ) );
+  }
 }
 
 bool connectWifi()
@@ -164,20 +216,19 @@ bool connectWifi()
 
   if ( netWorks )
   {
-    for (int i = 0; i < netWorks; ++i)
+    for ( int i = 0; i < netWorks; ++i )
     {
       if ( WiFi.SSID(i) == WIFISSID )
       {
-        Serial.print( "Found " );
-        Serial.print(WiFi.SSID(i));
+        Serial.print( F( "Found " ) );
+        Serial.print( WiFi.SSID(i) );
         Serial.print( " " );
-        Serial.print(WiFi.RSSI(i));
-        Serial.println("dB");
+        Serial.print( WiFi.RSSI(i) );
+        Serial.println( F( "dB" ) );
         WiFi.persistent( false );
-        Serial.println( "Connecting..." );
+        Serial.print( F( "Connecting" ) );
         WiFi.disconnect();
-        WiFi.mode(WIFI_STA);
-        digitalWrite( BUILTIN_LED, LOW );
+        WiFi.mode( WIFI_STA );
         WiFi.begin( WIFISSID, WIFIPSK );
         unsigned long timeout = millis() + 15000;
         while ( (long)( millis() - timeout ) < 0 && ( WiFi.status() != WL_CONNECTED ) )
@@ -186,7 +237,6 @@ bool connectWifi()
           Serial.print ( F( "." ) );
         }
         Serial.println();
-        digitalWrite( BUILTIN_LED, HIGH );
       }
     }
   }

index.htm

@@ -7,8 +7,15 @@
 <link rel="icon" href="data:;base64,iVBORw0KGgo=">  <!--prevent favicon requests-->
 <style>
 body{
-margin:0;
-text-align: center;
+  margin:0 auto;
+  text-align:center;
+  font-variant: small-caps;
+  font-size:20px;
+  font-family: monospace;
+}
+#linkBar{
+  background-color:aqua;
+  margin:0;
 }
 #data{
 line-height: 300px;
@@ -20,6 +27,7 @@
 </style>
 </head>
 <body>
+<p id="linkBar"><a class="systemLink" href="logs">LOGS</a></p>
 <h1 style="text-align:center;">ESP8266-temp-server</h1>
 <script>
 function loaded_log(str){

index_htm.h

@@ -26,20 +26,36 @@ const uint8_t index_htm[] PROGMEM = {
   0x2d, 0x70, 0x72, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x20, 0x66, 0x61, 0x76,
   0x69, 0x63, 0x6f, 0x6e, 0x20, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
   0x73, 0x2d, 0x2d, 0x3e, 0x0a, 0x3c, 0x73, 0x74, 0x79, 0x6c, 0x65, 0x3e,
-  0x0a, 0x62, 0x6f, 0x64, 0x79, 0x7b, 0x0a, 0x6d, 0x61, 0x72, 0x67, 0x69,
-  0x6e, 0x3a, 0x30, 0x3b, 0x0a, 0x74, 0x65, 0x78, 0x74, 0x2d, 0x61, 0x6c,
-  0x69, 0x67, 0x6e, 0x3a, 0x20, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x3b,
-  0x0a, 0x7d, 0x0a, 0x23, 0x64, 0x61, 0x74, 0x61, 0x7b, 0x0a, 0x6c, 0x69,
-  0x6e, 0x65, 0x2d, 0x68, 0x65, 0x69, 0x67, 0x68, 0x74, 0x3a, 0x20, 0x33,
-  0x30, 0x30, 0x70, 0x78, 0x3b, 0x0a, 0x66, 0x6f, 0x6e, 0x74, 0x2d, 0x73,
-  0x69, 0x7a, 0x65, 0x3a, 0x20, 0x32, 0x35, 0x30, 0x70, 0x78, 0x3b, 0x0a,
-  0x6d, 0x61, 0x72, 0x67, 0x69, 0x6e, 0x3a, 0x20, 0x61, 0x75, 0x74, 0x6f,
-  0x3b, 0x0a, 0x6f, 0x76, 0x65, 0x72, 0x66, 0x6c, 0x6f, 0x77, 0x3a, 0x20,
-  0x68, 0x69, 0x64, 0x64, 0x65, 0x6e, 0x3b, 0x0a, 0x62, 0x61, 0x63, 0x6b,
-  0x67, 0x72, 0x6f, 0x75, 0x6e, 0x64, 0x2d, 0x63, 0x6f, 0x6c, 0x6f, 0x72,
-  0x3a, 0x20, 0x61, 0x71, 0x75, 0x61, 0x3b, 0x0a, 0x7d, 0x0a, 0x3c, 0x2f,
-  0x73, 0x74, 0x79, 0x6c, 0x65, 0x3e, 0x0a, 0x3c, 0x2f, 0x68, 0x65, 0x61,
-  0x64, 0x3e, 0x0a, 0x3c, 0x62, 0x6f, 0x64, 0x79, 0x3e, 0x0a, 0x3c, 0x68,
+  0x0a, 0x62, 0x6f, 0x64, 0x79, 0x7b, 0x0a, 0x20, 0x20, 0x6d, 0x61, 0x72,
+  0x67, 0x69, 0x6e, 0x3a, 0x30, 0x20, 0x61, 0x75, 0x74, 0x6f, 0x3b, 0x0a,
+  0x20, 0x20, 0x74, 0x65, 0x78, 0x74, 0x2d, 0x61, 0x6c, 0x69, 0x67, 0x6e,
+  0x3a, 0x63, 0x65, 0x6e, 0x74, 0x65, 0x72, 0x3b, 0x0a, 0x20, 0x20, 0x66,
+  0x6f, 0x6e, 0x74, 0x2d, 0x76, 0x61, 0x72, 0x69, 0x61, 0x6e, 0x74, 0x3a,
+  0x20, 0x73, 0x6d, 0x61, 0x6c, 0x6c, 0x2d, 0x63, 0x61, 0x70, 0x73, 0x3b,
+  0x0a, 0x20, 0x20, 0x66, 0x6f, 0x6e, 0x74, 0x2d, 0x73, 0x69, 0x7a, 0x65,
+  0x3a, 0x32, 0x30, 0x70, 0x78, 0x3b, 0x0a, 0x20, 0x20, 0x66, 0x6f, 0x6e,
+  0x74, 0x2d, 0x66, 0x61, 0x6d, 0x69, 0x6c, 0x79, 0x3a, 0x20, 0x6d, 0x6f,
+  0x6e, 0x6f, 0x73, 0x70, 0x61, 0x63, 0x65, 0x3b, 0x0a, 0x7d, 0x0a, 0x23,
+  0x6c, 0x69, 0x6e, 0x6b, 0x42, 0x61, 0x72, 0x7b, 0x0a, 0x20, 0x20, 0x62,
+  0x61, 0x63, 0x6b, 0x67, 0x72, 0x6f, 0x75, 0x6e, 0x64, 0x2d, 0x63, 0x6f,
+  0x6c, 0x6f, 0x72, 0x3a, 0x61, 0x71, 0x75, 0x61, 0x3b, 0x0a, 0x20, 0x20,
+  0x6d, 0x61, 0x72, 0x67, 0x69, 0x6e, 0x3a, 0x30, 0x3b, 0x0a, 0x7d, 0x0a,
+  0x23, 0x64, 0x61, 0x74, 0x61, 0x7b, 0x0a, 0x6c, 0x69, 0x6e, 0x65, 0x2d,
+  0x68, 0x65, 0x69, 0x67, 0x68, 0x74, 0x3a, 0x20, 0x33, 0x30, 0x30, 0x70,
+  0x78, 0x3b, 0x0a, 0x66, 0x6f, 0x6e, 0x74, 0x2d, 0x73, 0x69, 0x7a, 0x65,
+  0x3a, 0x20, 0x32, 0x35, 0x30, 0x70, 0x78, 0x3b, 0x0a, 0x6d, 0x61, 0x72,
+  0x67, 0x69, 0x6e, 0x3a, 0x20, 0x61, 0x75, 0x74, 0x6f, 0x3b, 0x0a, 0x6f,
+  0x76, 0x65, 0x72, 0x66, 0x6c, 0x6f, 0x77, 0x3a, 0x20, 0x68, 0x69, 0x64,
+  0x64, 0x65, 0x6e, 0x3b, 0x0a, 0x62, 0x61, 0x63, 0x6b, 0x67, 0x72, 0x6f,
+  0x75, 0x6e, 0x64, 0x2d, 0x63, 0x6f, 0x6c, 0x6f, 0x72, 0x3a, 0x20, 0x61,
+  0x71, 0x75, 0x61, 0x3b, 0x0a, 0x7d, 0x0a, 0x3c, 0x2f, 0x73, 0x74, 0x79,
+  0x6c, 0x65, 0x3e, 0x0a, 0x3c, 0x2f, 0x68, 0x65, 0x61, 0x64, 0x3e, 0x0a,
+  0x3c, 0x62, 0x6f, 0x64, 0x79, 0x3e, 0x0a, 0x3c, 0x70, 0x20, 0x69, 0x64,
+  0x3d, 0x22, 0x6c, 0x69, 0x6e, 0x6b, 0x42, 0x61, 0x72, 0x22, 0x3e, 0x3c,
+  0x61, 0x20, 0x63, 0x6c, 0x61, 0x73, 0x73, 0x3d, 0x22, 0x73, 0x79, 0x73,
+  0x74, 0x65, 0x6d, 0x4c, 0x69, 0x6e, 0x6b, 0x22, 0x20, 0x68, 0x72, 0x65,
+  0x66, 0x3d, 0x22, 0x6c, 0x6f, 0x67, 0x73, 0x22, 0x3e, 0x4c, 0x4f, 0x47,
+  0x53, 0x3c, 0x2f, 0x61, 0x3e, 0x3c, 0x2f, 0x70, 0x3e, 0x0a, 0x3c, 0x68,
   0x31, 0x20, 0x73, 0x74, 0x79, 0x6c, 0x65, 0x3d, 0x22, 0x74, 0x65, 0x78,
   0x74, 0x2d, 0x61, 0x6c, 0x69, 0x67, 0x6e, 0x3a, 0x63, 0x65, 0x6e, 0x74,
   0x65, 0x72, 0x3b, 0x22, 0x3e, 0x45, 0x53, 0x50, 0x38, 0x32, 0x36, 0x36,
@@ -92,4 +108,4 @@ const uint8_t index_htm[] PROGMEM = {
   0x63, 0x72, 0x69, 0x70, 0x74, 0x3e, 0x0a, 0x3c, 0x2f, 0x62, 0x6f, 0x64,
   0x79, 0x3e, 0x0a, 0x3c, 0x2f, 0x68, 0x74, 0x6d, 0x6c, 0x3e, 0x0a
 };
-unsigned int index_htm_len = 1103;
+unsigned int index_htm_len = 1295;

logger.ino

@@ -0,0 +1,47 @@
+void logToSPIFFS( const time_t now )
+{
+  struct tm          timeinfo;
+  char           fileName[17];
+  char            content[60];
+
+  localtime_r( &now, &timeinfo );
+  strftime( fileName , sizeof( fileName ), "/%F.log", &timeinfo );
+
+  Serial.printf(  "Current logfile: %s\n", fileName );
+
+  snprintf( content, sizeof( content ), "%i,%3.2f", now - DST_SEC - TZ_SEC, currentTemp );
+
+  if ( !writelnFile( SPIFFS, fileName, content ) )
+  {
+    Serial.println( F( "Something wrong writing to file" ) );
+  }
+
+  Serial.println();
+  Serial.println( F( "Files on spiffs:" ) );
+  Dir dir = SPIFFS.openDir( "/" );
+  while ( dir.next() ) {
+    Serial.print( dir.fileName() );
+    Serial.print( F( " size: " ) );
+    File f = dir.openFile( "r" );
+    Serial.println( f.size() );
+  }
+  Serial.println();
+}
+
+bool writelnFile( fs::FS &fs, const char * path, const char * message )
+{
+  File file = fs.open( path, "a+" );
+  if ( !file )
+  {
+    Serial.println( F( "file could not be opened" ) );
+    return false;
+  }
+  if ( !file.println( message ) )
+  {
+    Serial.println( F( "file could not be written to" ) );
+    file.close();
+    return false;
+  }
+  file.close();
+  return true;
+}