hashFeed.ino

/***************************************************
  The following code was developed by Thoreau Bakker & Junjun Zhu, 
  built by editing the template from Tony DiCola as noted immediately below.
  It uses ifttt to route twitter feeds to adafruit.io, and then blinks LEDs on an Adafruit Huzzah in response to hashtags

  Much thanks to Professors's Puckett and Hartman at Ocad University in Toronto, Canada

  

  (original) 
  Written by Tony DiCola for Adafruit Industries.
  MIT license, all text above must be included in any redistribution 
  
 ****************************************************/
#include <ESP8266WiFi.h>
#include "Adafruit_MQTT.h"
#include "Adafruit_MQTT_Client.h"

// the on off button feed turns this LED on/off
#define LED 2  
// the slider feed sets the PWM output of this pin
#define PWMOUT 12

/************************* WiFi Access Point *********************************/

#define WLAN_SSID       "************"
#define WLAN_PASS       "************"

/************************* Adafruit.io Setup *********************************/

#define AIO_SERVER      "io.adafruit.com"
#define AIO_SERVERPORT  1883                   // use 8883 for SSL
#define AIO_USERNAME    "****************"
#define AIO_KEY         "****************"

/************ Global State (you don't need to change this!) ******************/

// Create an ESP8266 WiFiClient class to connect to the MQTT server.
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_USERNAME, AIO_KEY);

/****************************** Feeds ***************************************/

// Notice MQTT paths for AIO follow the form: <username>/feeds/<feedname>
Adafruit_MQTT_Subscribe onoffbutton = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/onoff");
Adafruit_MQTT_Subscribe slider = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/slider");
Adafruit_MQTT_Subscribe hashFeed = Adafruit_MQTT_Subscribe(&mqtt, AIO_USERNAME "/feeds/hashFeed");

/*************************** Sketch Code ************************************/

// Bug workaround for Arduino 1.6.6, it seems to need a function declaration
// for some reason (only affects ESP8266, likely an arduino-builder bug).
void MQTT_connect();

void setup() {
  pinMode(LED, OUTPUT);
  pinMode(PWMOUT, OUTPUT);

  pinMode(13, OUTPUT);
  pinMode(14, OUTPUT);
  pinMode(15, OUTPUT);
  pinMode(16, OUTPUT);

  Serial.begin(115200);
  delay(10);

  Serial.println(F("Adafruit MQTT demo"));

  // Connect to WiFi access point.
  Serial.println(); Serial.println();
  Serial.print("Connecting to ");
  Serial.println(WLAN_SSID);

  WiFi.begin(WLAN_SSID, WLAN_PASS);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println();

  Serial.println("WiFi connected");
  Serial.println("IP address: "); Serial.println(WiFi.localIP());

  // Setup MQTT subscription for onoff & slider feed.
  mqtt.subscribe(&onoffbutton);
  mqtt.subscribe(&slider);
  mqtt.subscribe(&hashFeed);
}

uint32_t x=0;

void loop() {
  // 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.
  MQTT_connect();

  // this is our 'wait for incoming subscription packets' busy subloop
  // try to spend your time here

  Adafruit_MQTT_Subscribe *subscription;
  while ((subscription = mqtt.readSubscription(5000))) {
    // Check if its the onoff button feed
    if (subscription == &onoffbutton) {
      Serial.print(F("On-Off button: "));
      Serial.println((char *)onoffbutton.lastread);
      
      if (strcmp((char *)onoffbutton.lastread, "ON") == 0) {
        digitalWrite(LED, LOW); 
      }
      if (strcmp((char *)onoffbutton.lastread, "OFF") == 0) {
        digitalWrite(LED, HIGH); 
      }
    }
    
    // check if its the slider feed
    if (subscription == &slider) {
      Serial.print(F("Slider: "));
      Serial.println((char *)slider.lastread);
      uint16_t sliderval = atoi((char *)slider.lastread);  // convert to a number
      analogWrite(PWMOUT, sliderval);
    }

    // check if its the hashFeed
    if (subscription == &hashFeed) {
      Serial.print(F("hashFeed: "));
      Serial.println((char *)hashFeed.lastread);
              if (strcmp((char *)hashFeed.lastread, "thanksgiving") == 0) {
              digitalWrite(13, LOW);
              delay(125);
              digitalWrite(13, HIGH);   // turn the LED on (HIGH is the voltage level)
              delay(100);
              digitalWrite(13, LOW);
              delay(100); 
              }
              if (strcmp((char *)hashFeed.lastread, "starboy") == 0) {
              digitalWrite(14, LOW);
              delay(125);
              digitalWrite(14, HIGH);   // turn the LED on (HIGH is the voltage level)
              delay(100);
              digitalWrite(14, LOW);
              delay(100);   
              }
              if (strcmp((char *)hashFeed.lastread, "gilmoregirls") == 0) {
              digitalWrite(15, LOW);
              delay(125);
              digitalWrite(15, HIGH);   // turn the LED on (HIGH is the voltage level)
              delay(100);
              digitalWrite(15, LOW);  
              delay(100);
              }
             if (strcmp((char *)hashFeed.lastread, "trump") == 0) {
              digitalWrite(16, LOW);
              delay(125);
              digitalWrite(16, HIGH);   // turn the LED on (HIGH is the voltage level)
              delay(100);  
              digitalWrite(16, LOW);
              delay(100);
              }

    }

    
  }

  // ping the server to keep the mqtt connection alive
  if(! mqtt.ping()) {
    mqtt.disconnect();
  }

}

// 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 5 seconds...");
       mqtt.disconnect();
       delay(5000);  // wait 5 seconds
       retries--;
       if (retries == 0) {
         // basically die and wait for WDT to reset me
         while (1);
       }
  }
  Serial.println("MQTT Connected!");
}