#define SMTP_SERVER "mail.mailserver.net" //Your outbound mail server (SMTP Server)
#define SMTP_USER_BASE64 "username" //I am sure your email provider requires authentication put those goodies here.
#define SMTP_PASS_BASE64 "password" //And also here. (I hope your password isn't really password)
 
#define SMTP_FROM_EMAIL "TheFrontDoor@domain.com" //Put in your email address
#define SMTP_TO_EMAIL1 "me@domain.com" //Where you want the email to be sent
#define SMTP_TO_EMAIL2 "5555555555@mms.att.net" //If you take advantage of most cell carriers email to text feature, you can send a text to your phone by using your phone's email address. This is how ATT's are formatted.
#define SMTP_SUBJECT "" //Type something here if you want a subject. I left it blank so the texts were cleaner and shorter.
#define SMTP_BODY "Ding-Dong!" //Type whatever you wish for the alert to say. Ding-Dong made the most sense to me. (It is a doorbell...)
 
#include "application.h"
#include <string.h>
 
 
//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 bell = D1;
 
void setup() {
    pinMode(D0, INPUT_PULLUP);
    pinMode(bell, OUTPUT);
    digitalWrite(bell, LOW);
    
    Spark.variable("emailSent", &sentOnce, INT);
    
    Serial.begin(9600);
}
 
 
 
void loop() {
    if (digitalRead(D0) == LOW) {
     //   if (sentOnce == 0) {
            RGB.control(true);
            
			//make the LED Red
            RGB.color(250, 0, 0);
            
			//ring doorbell with relay
            digitalWrite(bell, HIGH);
            delay(250);
            digitalWrite(bell, LOW);
			
			//send the email/text notification
            sentOnce = SendEmail(SMTP_SERVER, SMTP_USER_BASE64, SMTP_PASS_BASE64, SMTP_FROM_EMAIL, SMTP_TO_EMAIL1, SMTP_TO_EMAIL2, SMTP_SUBJECT, SMTP_BODY);
            
            if (sentOnce) {
	            RGB.color(0, 250, 0);
            }
            RGB.control(false);
       // }
    }
}
 
void idle() {
    SPARK_WLAN_Loop();
}
 
/**
 * Thank you @jboswell !
 */
int SendEmail(char *smtpServer, char *username, char *password, char *fromEmail, char *toEmail1, char *toEmail2, char *subject, char *body) {
 
    if (!client.connect(smtpServer, 25)) {
         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(toEmail1) + String(">") + String("\r\n"));
    echoSocketWrite(client, String("RCPT TO:<") + String(toEmail2) + 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(toEmail1) + String("\r\n"));
    echoSocketWrite(client, String("to: ") + String(toEmail2) + 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");
    Serial.write(sentOnce);
    return 0;
}