#include <ESP8266WiFi.h>
#include <WiFiClient.h>
#include <ESP8266WebServer.h>
#include <DNSServer.h>
#include <WiFiManager.h>
WiFiManager wifiManager;
#include <PubSubClient.h>
ESP8266WebServer httpServer(80);

const char* mqtt_server = "192.168.1.103"; //INDIQUER ICI L'URL DU BROKER
const char* mqtt_user = "monuser";
const char* mqtt_pass = "monpass";
const char* ID = "ESP_teleinfo";
const char* willTopic= "ESP_teleinfo/status";

WiFiClient espClient;
PubSubClient client(espClient);

long readInterval=60*1000;

long lastRead = 60000;

String trame="init.";
void setup() {
  Serial.begin(1200,SERIAL_7E1); //config pour lire la TI
  wifiManager.setDebugOutput(false);
    wifiManager.autoConnect(ID);
    client.setServer(mqtt_server, 1883);

  httpServer.on("/", [](){httpServer.send(200, "text/html", "it's works!");Serial.println("http");});
  httpServer.on("/info", [](){displayInfo();Serial.println("httpinfo");});
  httpServer.begin();
  delay(1000);

}
void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect
    if (client.connect(ID,willTopic,mqtt_user,mqtt_pass,0,true,"Offline")) { //connection avec un LWT
      Serial.println("connected");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
    }
  }
}
void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();
  httpServer.handleClient();
  if(millis()-lastRead > readInterval || millis()-lastRead < 0){
    boolean erreur=false;
    lastRead=millis();
    //Serial.println("reading..");
    trame="";
    //client.publish("maison/compteurEDF/debug","debut mesure");
    while(Serial.available()){Serial.read();} //Vide le buffer : indispensable !
    int i=0;
    while(Serial.read()!=0x02){//On attend le debut (et on arrete si ca dure plus de 5 secondes)
      client.loop();
      yield();
      if(millis() - lastRead > 5000){
          erreur=true;
          client.publish(willTopic,"Erreur compteur",true);
          trame="Erreur de lecteur sur le compteur";
          break;
      }
    }
    if(erreur==false){
      while(true){ //boucle pour récuperer le contenu du port serie
        while(!Serial.available()){client.loop();yield();} //On attent le buffer, (!)
        char c=Serial.read();
        if(c==0X03){break;}//fin de la trame
        else{
          trame+=c;
        }
        yield();
      }
      int start=-1;
      int stop=-1;
      i=0;
      if(trame.length()>0){
        while(true){
          start=trame.indexOf(0x0A,stop+1); //le stop précédent
          if(start==-1){break;} //fini !
          stop=trame.indexOf(0x0D,start+1);
          int sep1=trame.indexOf(0x20,start+1);
          int sep2=trame.indexOf(0x20,sep1+1);

          String libel=trame.substring(start+1,sep1);
          String val=trame.substring(sep1+1,sep2);
          String crc=trame.substring(sep2+1,stop);
          sendMQTT(libel,val); //if checksum ok
          i++;
          if(i>50){break;Serial.println("Erreur");}
          client.loop();
          yield();
        }
        client.publish(willTopic,"OK",true);
      }
    }

  }
}

String checksum(String libel, String val){
  String str=libel+' '+val;
  char sum=0;
  for (int i = 0 ; i<=str.length() ; i++){
    sum=sum+str[i];
  }
  sum=(sum & 0x3F)+0x20 ;//garder que les 6bits de fin
  String sumS = String(sum);
  return sumS;

}
void sendMQTT(String libel, String val){
  String topic = ID+String("/");
  topic += libel;

  char topicChar[50];
  char valChar[35];
  topic.toCharArray(topicChar,50);
  val.toCharArray(valChar,35);
  client.publish(topicChar,valChar);
}
void displayInfo(){
  String html="<pre>";
  html+=trame;
  html+="</pre>";
  httpServer.send(200, "text/html", html);
}