SparkCore_Door_Notification_with Email.ino

#define SMTP_SERVER "Your Eamil SMTP server"
#define SMTP_USER_BASE64 "Your User Name(Email address) with Base64"
#define SMTP_PASS_BASE64 "Your Password with Base64"

#define SMTP_FROM_EMAIL "Your Email address"
#define SMTP_TO_EMAIL "Target Email address you want to send to"
#define SMTP_SUBJECT "Door notification"


#include "application.h"
#include <string.h>

int ledPin = D7;                 // LED connected to digital pin 13
int analogPin = A1; //this pin is for door magnetic sensor
int Pin = 0; //value from A1. for door magnetic sensor close is below 4060..
char *msg;

//void idle();
//int SendEmail(char *smtpServer, char *username, char *password, char *fromEmail, char *toEmail, char *subject, char *body);
//int handshake(char *smtpServer);
//int authenticate(char *username, char *password);
//void echoSocketWrite(TCPClient src, const char *line) ;
//void echoSocketWrite(TCPClient src, String line);
//void flushToSerial(TCPClient src);
//int blockForResponse(char *response, unsigned int maxWait);


TCPClient client;
int sentOnce = 0;
int count = 0;

void setup() {
    Serial.begin(9600);
    Spark.variable("emailSent", &sentOnce, INT);
    pinMode(ledPin, OUTPUT);      // sets the digital pin as output
    pinMode(analogPin, INPUT); //Pin for door magnetic sensor
    digitalWrite(ledPin, LOW); //turn off LED for reset
}



void loop() {
    Pin = analogRead(analogPin);
    if(4060 < Pin){
     digitalWrite(ledPin, HIGH);
     Serial.println(Pin);
     delay(1000);
     }else{ 
     digitalWrite(ledPin, HIGH);
     delay(500);
     digitalWrite(ledPin, LOW);
     delay(500);
     digitalWrite(ledPin, HIGH);
     delay(500);
     digitalWrite(ledPin, LOW);
     delay(500);
     digitalWrite(ledPin, HIGH);
    Serial.println(Pin);
    msg = "Door is opened";
    Serial.println(msg);
    char *SMTP_BODY = msg;
    sentOnce = SendEmail(SMTP_SERVER, SMTP_USER_BASE64, SMTP_PASS_BASE64, SMTP_FROM_EMAIL, SMTP_TO_EMAIL, SMTP_SUBJECT, SMTP_BODY);
    delay(300000); //5min
     }
}

void idle() {
    SPARK_WLAN_Loop();
}

/**
 * Thank you @jboswell !
 */
int SendEmail(char *smtpServer, char *username, char *password, char *fromEmail, char *toEmail, char *subject, char *body) {

    if (!client.connect(smtpServer, 587)) {
         return 0;
    }


    Serial.write("Connected!\n");
    
    if (!handshake(smtpServer)) {
        Serial.write("handshake failed...");
        client.stop();
        return 0;
    }
    
    if (!authenticate(username, password)) {
        Serial.write("auth failed...");
        client.stop();
        return 0;
    }
    
    
    Serial.write("sending mail...\n");
    echoSocketWrite(client, String("MAIL FROM:<") + String(fromEmail) + String(">") + String("\r\n"));
    echoSocketWrite(client, String("RCPT TO:<") + String(toEmail) + String(">") + String("\r\n"));
    flushToSerial(client); //client.flush();

    echoSocketWrite(client, "DATA\r\n");
    echoSocketWrite(client, String("from: ") + String(fromEmail) + String("\r\n"));
    echoSocketWrite(client, String("to: ") + String(toEmail) + String("\r\n"));
    echoSocketWrite(client, String("subject: ") + String(subject) + String("\r\n"));
    flushToSerial(client); //client.flush();

    echoSocketWrite(client, "\r\n");
    echoSocketWrite(client, body);
    echoSocketWrite(client, "\r\n");
    echoSocketWrite(client, ".");
    echoSocketWrite(client, "\r\n");
    echoSocketWrite(client, "\r\n");
    flushToSerial(client); //client.flush();

    if (blockForResponse("250", 2500) == 1) {
    	Serial.write("Email sent.\n");
    }

    echoSocketWrite(client, "quit\r\n");
    echoSocketWrite(client, "\r\n");
    if (blockForResponse("220", 2500) == 1) {
    	Serial.write("Said goodbye.\n");
    }
    
    flushToSerial(client); //client.flush();
    client.stop();
    delay(100);
}


int handshake(char *smtpServer) {
    //wait for the server to say something.
    
    flushToSerial(client); //client.flush();
    Serial.write("waiting for the server to say hello...\n");
    if (blockForResponse("220", 5000) == 0) {
    	//handshake failed.
    	return 0;
    }
    idle();

    Serial.write("Saying hello back.\n");
    echoSocketWrite(client, String("EHLO ") + String(smtpServer) + String("\r\n"));
    if (blockForResponse("250", 1250) == 0) {
    	//handshake failed.
    	return 0;
    }
    idle();
    
    return 1;
}


int authenticate(char *username, char *password) {
    Serial.write("logging in...\n");
    echoSocketWrite(client, "AUTH LOGIN\r\n");
    blockForResponse("334", 5000);

    echoSocketWrite(client, String(username) + String("\r\n"));
    blockForResponse("334", 5000);

    echoSocketWrite(client, String(password) + String("\r\n"));
    blockForResponse("235", 5000);
     
    idle();
    return 1;
}



void echoSocketWrite(TCPClient src, const char *line) {
    Serial.write(line);
    src.print(line);
}
void echoSocketWrite(TCPClient src, String line) {
	flushToSerial(src);
	delay(10);

    Serial.write(line.c_str());
    src.print(line.c_str());
}

void flushToSerial(TCPClient src) {
    while (src.available()) {
        Serial.write(src.read());
    }
}

/* really basic / error prone way of listening for and parsing results */
int blockForResponse(char *response, unsigned int maxWait) {
    unsigned int startTime = millis();
    int idx = 0;
    char buffer[16];
    
    while ((millis() - startTime) < maxWait) {
        
        while (client.available()) {
            buffer[idx] = client.read();
            Serial.write(buffer[idx]);
            
            idx++;
            if (idx > 16) { 
                idx = 0; 
            }
            
            if (strstr(buffer, response) != NULL) {
                Serial.write("heard response.\n");
                return 1;
            }
        }
        
        delay(100);
    }
    
    Serial.write("timed out.\n");
    return 0;
}