Automatic Mailbox Notification Unit

////////////////////////////////////////Mark Leasure's Mailbox Notification Sensor////////////////////////////////////////////////

// The function of the mailbox notification sensor is as follows:
//      1. Use magnetic reed switch to trigger if/then loop in code
//      2. If/then loop publishes information to IFTTT apps, which send an email and an sms text to my smartphone.
//      3. If/then loop writes information to Thingspeak graph.
//      4. If/then loop sends code to Twilio APP, which then sends SMS text to my smartphonw.
//      5. Code sends voltage information to Ubidots.
//      6. Particle code is subscribed to by second Particle Photon.

// The Thingspeak Libray widget must be added for publishing to work.
#include "ThingSpeak/ThingSpeak.h"

TCPClient client;

// The HttpClient Library widget was added for making sure the reed switch was functioning
#include "HttpClient/HttpClient.h"

// ---------------------------------------------
// Check if the sensor is open. Send to Ubidots.
// Ubidots is a web-based sensor data collection
// service. 
// ---------------------------------------------
// thanks to susan.donovan@bcc.cuny.edu for the ubidots example code

//Load HTTP libray needed to connect to Ubidots.com
HttpClient http;

//These values come from Ubidots profile information.
#define VARIABLE_ID "583a03847625421a8a18cfd2"
#define VARIABLE_ID_analog "583a03ee7625421ea119dceb" 
#define TOKEN "PW64DEs3zfmqATQnCKmO3R4YtFwb9E"


// Headers currently need to be set at init, useful for API keys etc.
http_header_t headers[] = {

    { "Content-Type", "application/json" },
    { "X-Auth-Token" , TOKEN },
    { NULL, NULL } // NOTE: Always terminate headers with NULL
};

http_request_t request;
http_response_t response;

// List your variables for each scenario:
char resultstr[64];
char resultstrAnalog[64];
int unixTime = 0;
int doorStat = 0;
int doorStatOLD = 0;
int rawAnalogStrength = 0;
unsigned long myChannelNumber = 195557;
const char * myWriteAPIKey = "D1P5OY7GZ0S4NIUC";

// Create the setup for the Particle code.
void setup() {
//Create particle variables    
    Particle.variable("isClosed", &doorStat, INT);
    Particle.variable("whenToggle", &unixTime, INT);
    Particle.variable("analogSignal", &rawAnalogStrength, INT);
// Initialize D0 pin as output   
    pinMode(D0, OUTPUT);
// WKP pin is reed switch input.
    pinMode(WKP, INPUT);
    request.hostname = "things.ubidots.com";
    request.port = 80;
// Run the Thingspeak Application
    ThingSpeak.begin(client);
}

void loop() {
// The returned value from the Core is going to be in the range from 0 to 4095

        rawAnalogStrength = analogRead(WKP);
        if (rawAnalogStrength < 400) {
            doorStatOLD = doorStat; // Save current value for later
            doorStat = 1; //closed
            digitalWrite(D0, LOW);    // Turn OFF the LED pins
            delay(100); 
           
            float voltage = rawAnalogStrength * (3.3 / 4095.0);
            ThingSpeak.writeField(myChannelNumber, 1, voltage, myWriteAPIKey);
            delay(20000); // ThingSpeak will only accept updates every 15 seconds.
            
        } else {
            doorStatOLD = doorStat; // Save current value for later
            doorStat = 0; //open
            digitalWrite(D0, HIGH);   // Turn ON the LED pins
            delay(100); 
            
            Particle.publish("doorStat","0"); // Publishes to IFTT
            
            float voltage = rawAnalogStrength * (3.3 / 4095.0);
            ThingSpeak.writeField(myChannelNumber, 1, voltage, myWriteAPIKey);
            delay(20000); // ThingSpeak will only accept updates every 15 seconds
        
            Particle.publish("mailbox_opened");
        }
//Thanks to Hans for the Thinspeak code base.  
if (doorStatOLD != doorStat) { //If the door has opened or closed since the last reading then
// Send to Ubidots

    request.path = "/api/v1.6/variables/"VARIABLE_ID_analog"/values"; //send sensor data
    sprintf(resultstrAnalog, "{\"value\":%i}",rawAnalogStrength); 
    request.body = resultstrAnalog;
    http.post(request, response, headers);
    Serial.println(response.body);
    
    

    request.path = "/api/v1.6/variables/"VARIABLE_ID"/values"; //send binary result
    sprintf(resultstr, "{\"value\":%i}",doorStat); 
    request.body = resultstr;
    http.post(request, response, headers);
    Serial.println(response.body);
    delay(100);
}
}