Sonoff_REM_061119

/*  This version of sketch is modified for a third LED in the panel that
 *   responds to the output of the connected sonoff device. One led
 *   indicates that the remote has sent a message and the second LED
 *   lights to prove the signal was received and replied to by the connected
 *   device. Third LED is a simple power indicator. The battery can be recharged
 *   via the micro usb on the Wemos D1 built in charge circuit.I misspelled one led
 *   as LDE to help my febble mind keep track of it in the sketch.
 */
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

const char* ssid = "xxxxx";
const char* password =  "xxxxxxxxx";
const char* mqttServer = "192.168.1.180";
const int mqttPort = 1883;

#define mqtt_publish    "home/office/sonoff01X"
#define mqtt_subscribe  "home/office/sonoff01X"
#define mqtt_subscribe2  "home/office/sonoff01X/state"
#define mqtt_sub1       "on"
#define mqtt_sub2       "off"

#define LED 5 // (gpio5)
#define BUTTON 4 //(gpio4)
#define LDE 12 // (gpio12)

bool lightsOn = false;
bool lightsOn2 = false;

WiFiClient espClient;
PubSubClient client(espClient);

void setup() {

  Serial.begin(115200);
  pinMode(BUTTON, INPUT_PULLUP); // push button
  pinMode(LDE, OUTPUT);//LED 2
  pinMode(LED, OUTPUT); // anything you want to control using a switch e.g. a Led

  delay(500);

  Serial.print("Connecting to WiFi...");
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
  }
  Serial.print("Connected to ");
  Serial.println(ssid);

  client.setServer(mqttServer, mqttPort);
  client.setCallback(callback);

  Serial.print("Connecting to MQTT...");
  while (!client.connected())
  {

    if (client.connect("ESP8266Client" ))
    {
      Serial.println("connected");
    }
    else
    {
      Serial.print("failed with state ");
      Serial.println(client.state());
      delay(2000);

    }
  }


   client.subscribe(mqtt_subscribe);
   client.subscribe(mqtt_subscribe2);
   client.publish(mqtt_publish, "Remote");
}
void loop ()
{
  client.loop();                                            // MQTT houskeeping

  if(digitalRead(BUTTON) == LOW)                            // Button pressed (LOW)
  {
    lightsOn = !lightsOn;                                   // Toggle light state

    if(lightsOn)
    {
      client.publish(mqtt_publish, mqtt_sub1);
    }
    else
    {
      client.publish(mqtt_publish, mqtt_sub2);
    }

    delay(50);                                              // Switch debounce
    while(digitalRead(BUTTON) == LOW)                       // Wait for button to be released
    {
      delay(10);                                            // Short delay to yield else WDT reset will happen
    }
  }
  delay(100);
}


void callback(char* topic, byte * data, unsigned int length)// Callback for subscribed MQTT topics
{
  Serial.print(topic);
  Serial.print(": ");
  for (int i = 0; i < length; i++)
  {
    Serial.print((char)data[i]);
  }
  Serial.println();



if (strncmp(topic, mqtt_subscribe, strlen(mqtt_subscribe)) == 0)    // Check it's the right topic
  {
    if (strncmp((char*)data, mqtt_sub1, strlen(mqtt_sub1)) == 0)             // Check it's the right data
    {
      lightsOn = true;
    }

    if (strncmp((char*)data, mqtt_sub2, strlen(mqtt_sub2)) == 0)             // Check it's the right data
    {
      lightsOn = false;
    }
  }
  digitalWrite(LED, lightsOn);

    if (strncmp(topic, mqtt_subscribe2, strlen(mqtt_subscribe2)) == 0)    // Check it's the right topic
  {
    if (strncmp((char*)data, mqtt_sub1, strlen(mqtt_sub1)) == 0)             // Check it's the right data
    {
      lightsOn2 = true;
    }

    if (strncmp((char*)data, mqtt_sub2, strlen(mqtt_sub2)) == 0)             // Check it's the right data
    {
      lightsOn2 = false;
    }
  }
  digitalWrite(LDE, lightsOn2);

}