#include <Adafruit_NeoPixel.h>
#define PIN  2
#define NUMPIXELS      150
Adafruit_NeoPixel pixels = Adafruit_NeoPixel(NUMPIXELS, PIN, NEO_GRB + NEO_KHZ800);

const int relay = 5;

#include <MCP3008.h>


// define pin connections
#define CS_PIN 15
#define CLOCK_PIN 14
#define MOSI_PIN 13
#define MISO_PIN 12

// put pins inside MCP3008 constructor
MCP3008 adc(CLOCK_PIN, MOSI_PIN, MISO_PIN, CS_PIN);

int delayval = 50;
#define BRIGHTNESS 100
#include <ESP8266WiFi.h>

#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"
 
#define WLAN_SSID       "your ssid"
#define WLAN_PASS       "your password"
#define AIO_SERVER      "io.adafruit.com"
#define AIO_SERVERPORT  1883                  
#define AIO_USERNAME    "your username"
#define AIO_KEY         "your aio key"
 

int sensor =A0;

int led= LOW;
 
WiFiClient client;
// or... use WiFiFlientSecure for SSL
//WiFiClientSecure client;
 
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details.
Adafruit_MQTT_Client mqtt(&client, AIO_SERVER, AIO_SERVERPORT, AIO_USERNAME, AIO_KEY);
 
/****************************** Feeds ***************************************/
 
// i am going to publish my data alone. no need of subscription, so feed is enough
 
// Notice MQTT paths for AIO follow the form: <username>/feeds/<feedname>
Adafruit_MQTT_Publish moisture_level = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME "/feeds/moisture_level");

Adafruit_MQTT_Publish moisture_level_B = Adafruit_MQTT_Publish(&mqtt, AIO_USERNAME "/feeds/moisture_level_B");

Adafruit_MQTT_Subscribe LED = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/ledcolorpicker");

Adafruit_MQTT_Subscribe relay_pump = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/relay_pump");


 
/*************************** Sketch Code ************************************/
void setup() 
{
  Serial.begin(115200);
   
   pixels.begin();
   pixels.setBrightness(BRIGHTNESS);
   pinMode(relay, OUTPUT);
   digitalWrite(relay, LOW);
 
  // Connect to WiFi access point.
  Serial.print("\n\n\nConnecting to ");
  Serial.println(WLAN_SSID);
  WiFi.begin(WLAN_SSID, WLAN_PASS);
  
   
  while (WiFi.status() != WL_CONNECTED)
  {
    Serial.print(">>");
    delay(5000);
  }
  Serial.println("WiFi connected");
  Serial.println("IP address: "); Serial.println(WiFi.localIP());
 mqtt.subscribe(&LED);
 mqtt.subscribe(&relay_pump);
}
 
void loop()
{
   MQTT_connect();

  int plant_a = adc.readADC(0); // read Chanel 0 from MCP3008 ADC
  Serial.print("Plant A: ");
  Serial.println(plant_a);
  delay(1000);
  Serial.print("Plant B: ");
  int plant_b = adc.readADC(1); // read Chanel 0 from MCP3008 ADC
  Serial.println(plant_b);
  
   
  // Ensure the connection to the MQTT server is alive (this will make the first
  // connection and automatically reconnect when disconnected).  See the MQTT_connect
  // function definition further below.

Adafruit_MQTT_Subscribe *subscription;
  while ((subscription = mqtt.readSubscription(5000))) {
    
    
    if (subscription == &LED) {
      Serial.print(F("Got: "));
      Serial.println((char *)LED.lastread);
      String hexstring = (char *)LED.lastread;


    // String hexstring = "B787B7";
    long number = (long) strtol( &hexstring[1], NULL, 16);
    int r = number >> 16;
    int g = number >> 8 & 0xFF;
    int b = number & 0xFF;

    Serial.print("red is ");
    Serial.println(r);
    Serial.print("green is ");
    Serial.println(g);
    Serial.print("blue is ");
    Serial.println(b);     
    for(int i=0;i<NUMPIXELS;i++){
    pixels.setPixelColor(i, pixels.Color(r,g,b)); // Moderately bright green color.
    pixels.show(); // This sends the updated pixel color to the hardware.
    delay(delayval); // Delay for a period of time (in milliseconds).
        }  
    }

   if (subscription == &relay_pump) {
      Serial.print(F("Got: "));
      Serial.println((char *)relay_pump.lastread);
      //String hexstring = (char *)LED.lastread;
      String relaypump = (char *)relay_pump.lastread;
        if (relaypump == "ON")
        {
            digitalWrite(relay, HIGH);                                                                                                                                                                                             
            Serial.println("Pump ON");
        }
        else {
            digitalWrite(relay, LOW);                                                                                                                                                                                             
            Serial.println("Pump OFF");
        }
  }
  
  }

if ((plant_a > 700) || (plant_b > 700))

{
    for(int i=0;i<NUMPIXELS;i++)
    
    {
    pixels.setPixelColor(i, pixels.Color(255,0,0)); // Moderately bright green color.
    pixels.show(); // This sends the updated pixel color to the hardware.
    delay(delayval); // Delay for a period of time (in milliseconds).
    String low_moisture = "ff7f00";  
    
}
}

else
{
 for(int i=0;i<NUMPIXELS;i++){
    pixels.setPixelColor(i, pixels.Color(0,255,0)); // Moderately bright green color.
    pixels.show(); // This sends the updated pixel color to the hardware.
    delay(delayval); // Delay for a period of time (in milliseconds).
    String high_moisture = "00ff00";
}
}

  // Now we can publish stuff to the feeds

  
  Serial.print(F("\nSending analog val "));
  Serial.print(plant_a);
  
  if (! moisture_level.publish(plant_a++)) {
    Serial.println(F("\nFailed"));
  } else {
    Serial.println(F("\nOK!"));
  }
  
  if (! moisture_level.publish(plant_a++)) {
    Serial.println(F("\nFailed"));
  } else {
    Serial.println(F("\nOK!"));
    delay (500);
  }

  Serial.print(F("\nSending analog val "));
  Serial.print(plant_b);
  
  if (! moisture_level_B.publish(plant_b++)) {
    Serial.println(F("\nFailed"));
  } else {
    Serial.println(F("\nOK!"));
  }
  
  if (! moisture_level_B.publish(plant_b++)) {
    Serial.println(F("\nFailed"));
  } else {
    Serial.println(F("\nOK!"));
    delay (500);
  }
}
 
// Function to connect and reconnect as necessary to the MQTT server.
// Should be called in the loop function and it will take care if connecting.

void MQTT_connect()
 
{
  int8_t ret;
 
  // Stop if already connected.
  if (mqtt.connected())
  {
    return;
  }
 
  Serial.print("Connecting to MQTT... ");
 
  uint8_t retries = 3;
  while ((ret = mqtt.connect()) != 0) { // connect will return 0 for connected
       Serial.println(mqtt.connectErrorString(ret));
       Serial.println("Retrying MQTT connection in 3 seconds...");
       mqtt.disconnect();
       delay(3000);  // wait 3 seconds
       retries--;
       if (retries == 0) {
         // basically die and wait for WDT to reset me
         while (1);
       }
  }
  Serial.println("MQTT Connected!");
}