/*********
  V.O. Rui Santos
  Complete instructions at https://RandomNerdTutorials.com/esp32-plot-readings-charts-multiple/
 rev paulfjujo
*********/
#define VERSION "2022-0623"   // 17H50
// suite rajout image animé de durée reduite de 3sec à 2sec   Data I2C OK
// sans Graph MCP23017
// modif pause Loop de 2500  à 3000mS
//#define VERSION "2022-0622"    //last :14h50
//  Problemo : plus de data I2C
// Rajout d'une table contenant  gauge DS18B20 + gauge pression + image + gif animé 
//#define VERSION "2022-0618"    //last :19h18
// new script.js  see RNTLAB forum
//#define VERSION "14-06-2022"
// add recherche adresse OWS
//#define VERSION "10-06-2022"
// 1 seule sonde OWS

#include <Arduino.h>
#include <WiFi.h>
#include <AsyncTCP.h>
#include <ESPAsyncWebServer.h>
#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include <MCP23017.h>
#include <DHTesp.h>
#include <Adafruit_BMP085.h>
#include <Adafruit_Sensor.h>
#include "SPIFFS.h"
#include <Arduino_JSON.h>
#include <OneWire.h>
#include <DallasTemperature.h>

// Replace with your network credentials
const char* ssid ="ON_AIR2021";
const char* password = "cGT>1_@?LOdBqD6kd%s@v|.b5x^4PD|?s}uu*j4o)Uqpa|r1jftH+H>8_oG6}v4";

#define OLED_ADDR 0x3C
#define SCREEN_WIDTH 128 // OLED display width, in pixels
#define SCREEN_HEIGHT 32 // OLED display height, in pixels
#define OLED_RESET     -1 // Reset pin # (or -1 if sharing Arduino reset pin)
#define SCREEN_ADDRESS 0x3C ///< See datasheet for Address; 0x3D for 128x64, 0x3C for 128x32
#define LOGO_HEIGHT   16
#define LOGO_WIDTH    16
#define paulfjujo_WIDTH 128
#define paulfjujo_HEIGHT 32

// Create AsyncWebServer object on port 80
AsyncWebServer server(80);
// Create an Event Source on /events
AsyncEventSource events("/events");

// Json Variable to Hold Sensor Readings
JSONVar readings;

// Timer variables
unsigned long lastTime = 0;
unsigned long timerDelay = 10000;  //10sec

char BMPOK=0;
char Presschar [10];

#define MCP23017_ADDR 0x20
MCP23017 mcp = MCP23017(MCP23017_ADDR);
byte mcp_PA=0;
byte mcp_PB=0;
unsigned int mcp_PAB=0;
char MCP_Readchar[10];
char  Oled_Msg[64];  // up to 18 char en taille 1

int i,j,k;
byte addr[8];
byte type_s;
//byte data[12];

float temperatureC;
unsigned int Cpt=0;  // 22-06
float   p = 0.0;  // BMP085 Pression
float   t = 0.0 ;  // AM2302 temper
float   h = 0.0 ;  // AM2302 Humid

#define DHTTYPE DHT22 ;  // DHT type (DHT11, DHT22)
int DHTPIN = 2 ;        // GPIO D2 <-- Broche du capteur  AM2302 
char Tempchar [10];
char Humidchar[10];

byte  nDevices = 0;
byte error=0;
byte address=0;

const int LedRouge =  5;  
#define SCL 22            //ESP32 SCL I2C  fil jaune --> SCL BMP085
#define SDA  21           //ESP32 SDA I2C  fil vert --> SDA BMP085 


// Création des objets
const int oneWireBus = 4; // GPIO  DS18B20 
OneWire ds(oneWireBus);// Setup a oneWire instance to communicate with OneWire devices (DS18B20)
DallasTemperature sensors(&ds);// Pass our oneWire reference to Dallas Temperature sensor

Adafruit_BMP085 bmp; // connect to ESP32 I2C (GPIO 21 = SDA, GPIO 22 = SCL)
DHTesp dht;          // AM2302 DHT12
Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);

// Address of each OWS sensor
DeviceAddress sensor1 = { 0x28,0xFF, 0xAA, 0x56, 0xC1, 0x38, 0x14, 0x01}; // ma sonde DS18B20 repérée #3 (CRC= 0x40 )




 void check_if_exist_I2C()
{
  nDevices = 0;
  Serial.println(" ");
  for (address = 1; address < 127; address++ ) 
  {
    // The i2c_scanner uses the return value of
    // the Write.endTransmisstion to see if
    // a device did acknowledge to the address.
    Wire.beginTransmission(address);
    error = Wire.endTransmission();
    if (error == 0)
    {
      Serial.print("I2C device found at address 0x");
      if (address < 16)  Serial.print("0");
      Serial.print(address, HEX);
      switch (address)
            {
                case 0x20:  
                    Serial.println(" MCP23017 2x8 Bits I/O"); // de base + 7 autres
                     break;
                case 0x27:
                case 0x28:
                case 0x29:
                case 0x2A:
                    // case etc ..
                     Serial.println(" PCF8574 8bits I/O"); // de base + 7 autres
                    break;
                case 0x37:
                      Serial.println(" LCD 2119 2x16cars"); // de base + 7 autres
                    break;
                case 0x38:
                case 0x39:
                case 0x3A:
                case 0x3B:
                    // case etc ..
                      Serial.println(" PCF8574A 8bits I/O"); // de base + 7 autres
                    break;
                case 0x3C:
                      Serial.println( " OLED SSD1306");
                      break;
                case 0x53:
                       Serial.println(" ADXL345 board");
                        break;
                case 0x57:
                        Serial.println(" EEPROM 512bytes");
                        break;
                case 0x68:
                        Serial.println(" RTC DS3231");
                        break;
                case 0x77:
                        Serial.println(" BMP 085 Pression");
                        break;
                default:
                        Serial.println(" non reconnue");
                        break;
           } //switch
      nDevices++;
    }
    delay(10);
  } //for loop
  if (nDevices == 0)
    Serial.println("No I2C devices found");
  else
    Serial.printf("Trouve %3d devices sur le Bus I2C\r\n",nDevices);
  delay(200);       
}


//rev 18-06-2022
//Get Sensor Readings and return JSON object
// 1 temperature  -10 à +40
// 2 Compteur   0 à 999
// 3 Presion  980-1030 mbar
// 4 temperature -10 +40
// 8 humidite  0 100%
// 5 degres OWS  -10 +40
// 6  MCP 0 à 1023
String getSensorReadings(){
  sensors.requestTemperatures();
  temperatureC = sensors.getTempCByIndex(0);
  readings["DS18B20"] = String(temperatureC);
  readings["Cpt"] = String(Cpt);
  p = bmp.readPressure() / 100.0F;  //mBar  ou hPa
  readings["Pression"] = String(p);  //
  t = dht.getTemperature();
  readings["Temperature"] = String(t);
  h=dht.getHumidity();
  readings["Humidity"] =  String(h);
  readings["MCP23017"] = String(mcp_PB);
  String jsonString = JSON.stringify(readings);
  Serial.println(jsonString);
  return jsonString;
}

// Initialize SPIFFS
void initSPIFFS() {
  if (!SPIFFS.begin()) {
    Serial.println("An error has occurred while mounting SPIFFS");
  }
  else{
    Serial.println("SPIFFS mounted successfully");
  }
}

// Initialize WiFi
void initWiFi() {
  WiFi.mode(WIFI_STA);
  WiFi.begin(ssid, password);
  Serial.print("Connecting to WiFi ..");
  while (WiFi.status() != WL_CONNECTED) {
    Serial.print('.');
    delay(1000);
  }
   Serial.println();
  Serial.println(WiFi.localIP());
}


void OneWireScanner(){
  if ( !ds.search(addr))
  {
    Serial.println(" No more addresses.");
    Serial.println();
    ds.reset_search();
    return;
  }
  Serial.print(" ROM = ");
  for( i = 0; i < 8; i++)
  {
    Serial.write(' ');
    Serial.print("0x");
    if (addr[i] < 0x10) Serial.write('0');
    Serial.print(addr[i], HEX);
    if ( i != 7 ) {
      Serial.print(", ");
    }
   }
  
  if (OneWire::crc8(addr, 7) != addr[7]) {
      Serial.println("CRC is not valid!");
      return;
  }
  Serial.println();
 
  // the first ROM byte indicates which chip
  switch (addr[0]) {
    case 0x10:
      Serial.println("  Chip = DS18S20");  // or old DS1820
      type_s = 1;
      break;
    case 0x28:
      Serial.println("  Chip = DS18B20");
      type_s = 0;
      break;
    case 0x22:
      Serial.println("  Chip = DS1822");
      type_s = 0;
      break;
    default:
      Serial.println(" Device is not a DS18x20 family device.");
      return;
  } 
    Serial.println();
}

void setup() {
  // Serial port for debugging purposes
  delay(2000);
  Serial.begin(115200);

  pinMode(LedRouge, OUTPUT);
  digitalWrite(LedRouge, 0);

  Serial.println("\r\n_r\n");
  Serial.print(" _ESP32_Charts_DS18B20_BMP085_Cpt_AM2302_BMP085_MSP2307_");
  Serial.println(VERSION);
  Serial.println(" ESP32 Vroom 32 DevkitV1  (Rouge sur COM 56) ou (Bleu sur COM 57) ");
  Serial.println(" Led Rouge sur D5  ");
  Serial.println(" DHT11-AM2302 sur D2 ");
  Serial.println(" Sonde temper.OWS  DS18B20 sur D4 ");
  Serial.println(" I2C Bus sur   D21 (SDA)  et D22 (SCL) "); 
  Serial.println(" BMP085 +  OLED SSD1306 + MCP23017 sur le bus I2C");
  Serial.println(" Recherche devices presents sur le bus I2C SCL=22 SDA=21");
  delay(2000);
  Wire.begin(SDA,SCL); // pin on ESP32
  check_if_exist_I2C();
  Serial.println("\r\n .. Fin de test I2C bus \r\n");
    
  sensors.begin();

  Serial.printf(" Compteur=%5d\r\n",Cpt); 

   //---- Pressure sensor BMP085 ---------------- 
  // Initialisation 
  if ( !bmp.begin() )
   {
    Serial.println(" BMP085 BAD!");
    delay(2000);
    BMPOK=0;
     p=999.99; 
   }
   else 
   {
    Serial.print(" BMP085 OK  ");
    BMPOK=1;
    p = bmp.readPressure() / 100.0F; 
    Serial.printf(" Press.% 5.0f mBar \r\n",p); 
  } 

   Serial.println(" Scan devices on OWS BUS ");
  for (i=0;i<3;i++)
  {
  Serial.printf(" i= %5d \r\n",i);
  OneWireScanner();
  Serial.println();
   delay(2000);
  }
  
   sensors.requestTemperatures();
   temperatureC = sensors.getTempCByIndex(0);
   if (temperatureC < -10.0) temperatureC= -10.0; 
   Serial.printf(" DS18B20 =% 3.2f\r\n",temperatureC);
  

// --- MCP23017 ----------------------
// https://github.com/blemasle/arduino-mcp23017
   Serial.println("  MCP23017 at  @0x20 ");
   mcp.init();
   Serial.println(" Active le PORT A du MCP , en sorties"); 
  //  setGPIOAMode(0);
   mcp.portMode(MCP23017Port::A, 0);  
    Serial.println(" Active le PORT B du MCP , en entrees");
   mcp.portMode(MCP23017Port::B, 0b11111111); //Port B as input
   mcp.writeRegister(MCP23017Register::GPIO_A, 0x00);  //Reset port A 
   mcp.writeRegister(MCP23017Register::GPIO_B, 0x00);  //Reset port B
   // GPIO_B reflects the reverse logic as the input pins state
   mcp.writeRegister(MCP23017Register::IPOL_B, 0xFF);

   //----- DHT11 AM2302 Sensor ----------------
   dht.setup(DHTPIN,DHTesp::DHT22);
   delay(1000);
   t = dht.getTemperature();
   if (isnan(t)) snprintf(Tempchar,6,"%s\t"," ???"); else snprintf(Tempchar,6,"%3.2f\t",t); 
   //-------------------
   h=dht.getHumidity();
   if (isnan(h)) snprintf(Humidchar,6,"%s\t"," ???"); else snprintf(Humidchar,6,"%2.2f\t",h);
   Serial.print(F(" DHT11 Temp.: ")); 
   Serial.println(Tempchar);
   Serial.print(F(" Humid : ")); 
   Serial.println(Humidchar);

   //----------- OLED SSD1306 ----------------  
   // SSD1306_SWITCHCAPVCC = generate display voltage from 3.3V internally
   if(!display.begin(SSD1306_SWITCHCAPVCC, SCREEN_ADDRESS))
   {
     Serial.println(F(" SSD1306 allocation failed"));
      delay(2000);
   }
   else Serial.println(F(" SSD1306 allocation OK"));
   display.clearDisplay();
   display.setTextSize(1);             // Normal 1:1 pixel scale
   display.setTextColor(SSD1306_WHITE);        // Draw white text
   display.setCursor(0,0);             // Start at top-left corner
   delay(2000); // Pause for 2 seconds
   display.clearDisplay();  // Clear the buffer
   delay(1000);
     
   initWiFi();

   display.setTextSize(1);             // Normal 1:1 pixel scale
   display.setTextColor(SSD1306_WHITE);        // Draw white text
   display.setCursor(0,0);             // Start at top-left corner
   display.print(F("IP Adresse        "));
   display.setCursor(0,8);             // Start at top-left corner
   display.print( WiFi.localIP());
   display.setCursor(0,16);
   display.print( WiFi.macAddress());
   display.display();
   delay(2000);
   Serial.println( WiFi.macAddress());
   
   initSPIFFS();

  // Web Server Root URL
  server.on("/", HTTP_GET, [](AsyncWebServerRequest *request){
    request->send(SPIFFS, "/index.html", "text/html");
  });

  server.serveStatic("/", SPIFFS, "/");
  // Request for the latest sensor readings
  server.on("/readings", HTTP_GET, [](AsyncWebServerRequest *request){
    String json = getSensorReadings();
    request->send(200, "application/json", json);
    json = String();
  });

  events.onConnect([](AsyncEventSourceClient *client){
    if(client->lastId()){
      Serial.printf("Client reconnected! Last message ID that it got is: %u\n", client->lastId());
    }
    client->send("hello!", NULL, millis(), 10000);
  });
  server.addHandler(&events);

   display.clearDisplay();

  // Start server
  server.begin();
}

void loop() {
  if ((millis() - lastTime) > timerDelay) {
    // Send Events to the client with the Sensor Readings Every 10 seconds
    events.send("ping",NULL,millis());
    events.send(getSensorReadings().c_str(),"new_readings" ,millis());
    lastTime = millis();
   }
  else
  {
    Serial.printf(" Cpt= %5d ",Cpt);

    display.clearDisplay();
    display.setCursor(0,0); 
    display.print(F("Compteur          ")); 
    display.setCursor(70,0); 
    snprintf(Oled_Msg,6,"% 5d",Cpt);
    display.print(Oled_Msg);
 //   display.display();
 
   
    if (BMPOK==1) p = bmp.readPressure() / 100.0F;  else p=999.99; 
    Serial.printf(", BMP085 P.% 5.0f mBar  ",p); 

    display.setCursor(0,8); 
    display.print(F("BMP085 P.    ")); 
    display.setCursor(70,8); 
    display.print(p);
  //  display.display();

    h=dht.getHumidity();
    if (isnan(h)) snprintf(Humidchar,6,"%s\t"," ???"); else  snprintf(Humidchar,6,"%2.2f\t",h);
    Serial.print(F(", Humid: ")); 
    Serial.print(Humidchar);

    display.setCursor(0,16); 
    display.print(F("AM2302 Humi  ")); 
    display.setCursor(76,16); 
    display.print(Humidchar);
  //  display.display();
    
    t = dht.getTemperature();
    if (isnan(t)) snprintf(Tempchar,6,"%s\t"," ???"); else snprintf(Tempchar,6,"%3.2f\t",t);
    Serial.print(F(",Temp: ")); 
    Serial.print(Tempchar);
    
       }
    
    sensors.requestTemperatures();
    temperatureC = sensors.getTempCByIndex(0);
    if (temperatureC < -10.0) temperatureC= -10.0; 
    Serial.printf(",DS18B20 =% 3.2f °C   ",temperatureC);
// affiche en alternance soit Temperature AM2302 , soit OWS DS18B20 sur la 4em ligne afficheur OLED
 if ((Cpt & 1)==1)
 { 
    digitalWrite(LedRouge,HIGH);
    display.setCursor(0,24); 
    display.print(F("AM2302 Temp      ")); 
    display.setCursor(76,24); 
    display.print(Tempchar);
 }
 else
 { 
    digitalWrite(LedRouge,LOW);
    display.setCursor(0,24); 
    display.print(F("DS18B20          ")); 
    display.setCursor(76,24); 
    display.print(temperatureC);

 }
   display.display();

   mcp_PA= mcp.readPort(MCP23017Port::A);
   mcp_PB= mcp.readPort(MCP23017Port::B);
   mcp.writePort(MCP23017Port::A, i & 0x00FF);
   Serial.print(",MCP : 0x");
   if(mcp_PA<16) Serial.print("0");
   Serial.print(mcp_PA, HEX);
   Serial.print(",0x");
   if(mcp_PB<16) Serial.print("0");
   Serial.println(mcp_PB, HEX);
 
    
    Cpt=Cpt+1.0;
    if (Cpt>999) Cpt=0;
    delay(3000);
  }

/*
 * 
 _ESP32_Charts_DS18B20_BMP085_Cpt_AM2302_BMP085_MSP2307_2022-0618-06-2022
 ESP32 Vroom 32 DevkitV1  (Rouge sur COM 56) ou (Bleu sur COM 57)
 Led Rouge sur D5
 DHT11-AM2302 sur D2
 Sonde temper.OWS  DS18B20 sur D4
 I2C Bus sur   D21 (SDA)  et D22 (SCL)
 BMP085 +  OLED SSD1306 + MCP23017 sur le bus I2C
 Recherche devices presents sur le bus I2C SCL=22 SDA=21

I2C device found at address 0x20 MCP23017 2x8 Bits I/O
I2C device found at address 0x3C OLED SSD1306
I2C device found at address 0x77 BMP 085 Pression
Trouve   3 devices sur le Bus I2C

 .. Fin de test I2C bus

 Compteur=    0
 BMP085 OK   Press.  986 mBar
 Scan devices on OWS BUS
 i=     0
 ROM =  0x28,  0xAA,  0x56,  0xC1,  0x38,  0x14,  0x01,  0x40
  Chip = DS18B20



 DS18B20 = 28.00
  MCP23017 at  @0x20
 Active le PORT A du MCP , en sorties
 Active le PORT B du MCP , en entrees
 DHT11 Temp.: 28.80
 Humid : 79.10
 SSD1306 allocation OK
.
192.168.0.104
7C:9E:BD:54:72:F4
SPIFFS mounted successfully
 Cpt=     0  ,  BMP085 P.  986 mBar  , Humid: 80.40,Temp: 28.70,DS18B20 = 28.00 °C   ,MCP : 0x00,0x82
 Cpt=     1  ,  BMP085 P.  986 mBar  , Humid: 78.30,Temp: 28.80,DS18B20 = 28.00 °C   ,MCP : 0x09,0x82
 
 */