/* ESP8266+Arduino IDE Test code
Object :
- TCP Socket(port 4444) Server.
- ESP8266 AP mode test.
Requirement :
- ESP8266WiFi.h Library (https://github.com/esp8266/Arduino)
- PubSubClient.h Library (https://github.com/Imroy/pubsubclient)
- DW.miniESP board  (https://github.com/deaware/dwminiesp_firmware_support)
- Arduino IDE 1.6.4

Write by : Myconfix (http://www.myconfix.com/)
Fanpage : https://www.facebook.com/myconfix
github : https://github.com/myconfix/ESP8266ArduinoExample
*/


#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// Prepare AP id&password.
//const char *ssid = "Desktech";  //your access point ssid // cannot be longer than 32 characters!
//const char *password = "N1B8072824"; //your access point password

const char *ssid = "ifce-alunos";  //your access point ssid // cannot be longer than 32 characters!
const char *password = "ifce4lun0s"; //your access point password


//Prepare Mqtt connection data
const char *MQTTBroker = "m10.cloudmqtt.com";
const char *MQTTuser = "water";
const char *MQTTpassword = "12345678";
const char *Topic = "/water";
const char *Topicid = "/water";
uint16_t port = 11536;
//uint16_t port = 1883;  //defalut port


int count = 0;

PubSubClient mqtt(MQTTBroker,port);

void mqtt_callback(char* topic, byte* payload, unsigned int length)
{

    String msg;

    //obtem a string do payload recebido
    for(int i = 0; i < length; i++)
    {
       char c = (char)payload[i];
       msg += c;
    }

    //toma ação dependendo da string recebida:
    //verifica se deve colocar nivel alto de tensão na saída D0:
    //IMPORTANTE: o Led já contido na placa é acionado com lógica invertida (ou seja,
    //enviar HIGH para o output faz o Led apagar / enviar LOW faz o Led acender)
    if (msg.equals("L"))
    {
        Serial.println("Aqui2");
//        digitalWrite(D0, LOW);
//        EstadoSaida = '1';
    }

    //verifica se deve colocar nivel alto de tensão na saída D0:
    if (msg.equals("D"))
    {
//        digitalWrite(D0, HIGH);
//        EstadoSaida = '0';
    }

}

void callback(const MQTT::Publish& pub){
	// handle message arrived
//  Serial.println("Aqui");
	Serial.println(pub.payload_string());

  if (pub.payload_string().equals("L"))
      {
          Serial.println("Liga");
          digitalWrite(D4, LOW);
  //        EstadoSaida = '1';
      }

      //verifica se deve colocar nivel alto de tensão na saída D0:
      if (pub.payload_string().equals("D"))
      {
          digitalWrite(D4, HIGH);
  //        EstadoSaida = '0';
      }
}
void setup()
{
  pinMode(D4, OUTPUT);
	Serial.begin(115200);
	WiFi.mode(WIFI_STA);
	WiFi.disconnect();
	WiFi.begin(ssid, password);
	while (WiFi.status() != WL_CONNECTED) {
		delay(500);
		Serial.print(".");
	}
	Serial.println("");
	Serial.println("WiFi connected");
	Serial.println("IP address: ");
	Serial.println(WiFi.localIP());
	WiFi.printDiag(Serial);

	mqtt.set_callback(callback);  //Set Callback function

	if (mqtt.connect(MQTT::Connect("esp8266").set_auth(MQTTuser,MQTTpassword))){
		mqtt.publish(Topic, "Hello");  //publish
		mqtt.subscribe(Topicid);		//subscribe
	}

}


void loop()
{


  count++;
  String con = String(count);
//  delay(1000);
//  Serial.println(con);

//  mqtt.publish(Topic, con);  //publish
//  if(mqtt.subscribe(Topicid)!=0)    //subscribe
//  {
//    Serial.println(Topicid);
//  }


  mqtt.loop();


}