Ernest Williams
The purpose of this project was to create a system that would allow users to monitor a locked device using a Bluetooth device. This Bluetooth device will show the last user that unlocked the device, and also allows the user to unlock the device using the Bluetooth device. This device can be physically unlocked using a capacitive touch keypad sensor.
Dependencies: mbed Motor Servo
Fork of
SerialPassthrough_LPC1768
by 
jim hamblen
Revision 9:c216d7b63f92, committed 2016-04-30
- Comitter:
- ewilliams61
- Date:
- Sat Apr 30 19:47:54 2016 +0000
- Parent:
- 8:39172c01c0f1
- Commit message:
- Final working code for IOT mailbox
Changed in this revision
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Motor.lib Sat Apr 30 19:47:54 2016 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/simon/code/Motor/#f265e441bcd9
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Servo.lib Sat Apr 30 19:47:54 2016 +0000 @@ -0,0 +1,1 @@ +http://mbed.org/users/simon/code/Servo/#36b69a7ced07
--- a/main.cpp Tue Mar 15 19:36:01 2016 +0000
+++ b/main.cpp Sat Apr 30 19:47:54 2016 +0000
@@ -2,16 +2,23 @@
#include <mpr121.h>
#include <string>
#include "Shiftbrite.h"
+#include "Servo.h"
+#include "Motor.h"
+
//Print output to pc via usb
RawSerial pc(USBTX, USBRX);
//Print output to Bluetooth device
-RawSerial dev(p9,p10);
+RawSerial dev(p13,p14);
+Serial esp(p9, p10); // tx, rx
//LEDs
DigitalOut led1(LED1);
DigitalOut led2(LED2);
DigitalOut led3(LED3);
DigitalOut led4(LED4);
-
+Motor doorPulley(p22, p5, p6); // pwm, fwd, rev
+Motor mailFeed(p21, p11, p12); // pwm, fwd, rev
+Servo lock(p24);
+AnalogIn ds(p16);
//Interrupt for Touchpad
InterruptIn interrupt(p26);
//I2C for Touchpad
@@ -19,7 +26,6 @@
//Touchpad
Mpr121 mpr121(&i2c, Mpr121::ADD_VSS);
//Shiftbrite
-Shiftbrite myShiftbrite(p16, p15, p11, p12, p13);
//Code Combinations
int code1[] = {1,1,1,1};
@@ -30,6 +36,44 @@
volatile int inNdx = 0;//to place combination in input
bool codeIn = false; //determine if code is being entered via bluetooth
+//Webserver variables
+char gotMail[10];
+char audio1[255];
+
+// things for sending/receiving data over serial
+volatile int tx_in=0;
+volatile int tx_out=0;
+volatile int rx_in=0;
+volatile int rx_out=0;
+const int buffer_size = 4095;
+char tx_buffer[buffer_size+1];
+char rx_buffer[buffer_size+1];
+void Tx_interrupt();
+void Rx_interrupt();
+void send_line();
+void read_line();
+int DataRX;
+int update;
+int count;
+char cmdbuff[1024];
+char replybuff[4096];
+char webdata[4096]; // This may need to be bigger depending on WEB browser used
+char webbuff[4096]; // Currently using 1986 characters, Increase this if more web page data added
+char timebuf[30];
+void SendCMD(),getreply(),ReadWebData(),startserver();
+void gettime(),setRTC(), getDS();
+char rx_line[1024];
+int port =80; // set server port
+int SERVtimeout =5; // set server timeout in seconds in case link breaks.
+struct tm t;
+float DSin = 0.0;
+// manual set RTC values
+int minute =00; // 0-59
+int hour =12; // 2-23
+int dayofmonth =26; // 1-31
+int month =8; // 1-12
+int year =15; // last 2 digits
+
//Interrupt method to read from touchpad
void fallInterrupt() {
@@ -92,10 +136,22 @@
int main()
{
+ lock = 0.3;
//reset Shiftbrite
- myShiftbrite.write(0,0,0);
pc.baud(9600);
dev.baud(9600);
+ esp.baud(9600);
+ led1=1,led2=0,led3=0,led4=0;
+ // Setup a serial interrupt function to receive data
+ esp.attach(&Rx_interrupt, Serial::RxIrq);
+ // Setup a serial interrupt function to transmit data
+ esp.attach(&Tx_interrupt, Serial::TxIrq);
+ if (time(NULL) < 1420070400) {
+ setRTC();
+ }
+ startserver();
+ DataRX=0;
+ count=0;
//Set up interrupt
interrupt.fall(&fallInterrupt);
interrupt.mode(PullUp);
@@ -107,8 +163,35 @@
dev.printf("To unlock the device remotely, send 'a'.\n");
while(1) {
- wait(5);
- //If three characters have been entered, attempt to unlock
+ if(DataRX==1) {
+ ReadWebData();
+ esp.attach(&Rx_interrupt, Serial::RxIrq);
+ }
+ if(update==1) // update time, hit count, and analog levels in the HUZZAH chip
+ {
+ // get new values
+ gettime();
+ getDS();
+ count++;
+ // send new values
+ pc.printf("\n\n\n\n%f\r\n\n\n\n", DSin );
+ if (DSin <= 0.5) {
+ strcpy(gotMail, "yes");
+ strcpy(audio1, "http://192.168.43.91/img/youGotmail.mp3");
+ sprintf(cmdbuff, "count,time,yesorno, audio1=%d,\"%s\",\"%s\",\"%s\"\r\n",count,timebuf,gotMail, audio1);
+ SendCMD();
+ getreply();
+ // continue;
+ } else {
+ strcpy(gotMail, "no");
+ strcpy(audio1, "#");
+ }
+ sprintf(cmdbuff, "count,time,yesorno,audio1=%d,\"%s\",\"%s\",\"%s\"\r\n",count,timebuf,gotMail, audio1);
+ SendCMD();
+ getreply();
+ update=0;
+ }
+ //If four characters have been entered, attempt to unlock
if (inNdx > 3) {
dev.printf("Attempting to Unlock\n");
codeIn = false;
@@ -129,19 +212,59 @@
if(c1){
//Send welcome user 1 to bluetooth
dev.printf("Welcome User 1\n");
- myShiftbrite.write(0,255,0);
+ lock = 1.0;
+ wait(1.0);
+ doorPulley.speed(-0.8);
+ wait(2.0);
+ doorPulley.speed(0.0);
+ wait(.3);
+ mailFeed.speed(-0.8);
+ wait(2);
+ mailFeed.speed(0.0);
+ doorPulley.speed(0.3);
+ wait(1.0);
+ doorPulley.speed(0.0);
} else if(c2) {
//Send welcome user 2 to bluetooth
dev.printf("Welcome User 2\n");
- myShiftbrite.write(0,255,0);
+ lock = 1.0;
+ wait(1.0);
+ doorPulley.speed(-0.8);
+ wait(2.0);
+ doorPulley.speed(0.0);
+ wait(.3);
+ mailFeed.speed(-0.8);
+ wait(2);
+ mailFeed.speed(0.0);
+ doorPulley.speed(0.3);
+ wait(1.0);
+ doorPulley.speed(0.0);
+ doorPulley.speed(.3);
+ wait(.8);
+ doorPulley.speed(0.0);
+
+
} else if(c3) {
//Send welcome user 3 to bluetooth
dev.printf("Welcome User 3\n");
- myShiftbrite.write(0,255,0);
+ lock = 1.0;
+ wait(1.0);
+ doorPulley.speed(-0.8);
+ wait(2.0);
+ doorPulley.speed(0.0);
+ wait(.3);
+ mailFeed.speed(-0.8);
+ wait(2);
+ mailFeed.speed(0.0);
+ doorPulley.speed(0.3);
+ wait(1.0);
+ doorPulley.speed(0.0);
+
} else {
//Send welcome Try Again message to bluetooth
dev.printf("Try Again\n");
- myShiftbrite.write(255,0,0);
+ lock = 0.3;
+
}
//reset indexing variable when checking is complete
@@ -151,3 +274,310 @@
}
}
+// Reads and processes GET and POST web data
+void ReadWebData()
+{
+ wait_ms(200);
+ esp.attach(NULL,Serial::RxIrq);
+ DataRX=0;
+ memset(webdata, '\0', sizeof(webdata));
+ strcpy(webdata, rx_buffer);
+ memset(rx_buffer, '\0', sizeof(rx_buffer));
+ rx_in = 0;
+ rx_out = 0;
+ // check web data for form information
+ if( strstr(webdata, "check=led1v") != NULL ) {
+ led1=!led1;
+ DSin = 0;
+ }
+ if( strstr(webdata, "check=led2v") != NULL ) {
+ led2=!led2;
+ }
+ if( strstr(webdata, "check=led3v") != NULL ) {
+ led3=!led3;
+ }
+ if( strstr(webdata, "check=led4v") != NULL ) {
+ led4=!led4;
+ }
+ if( strstr(webdata, "POST") != NULL ) { // set update flag if POST request
+ update=1;
+ }
+ if( strstr(webdata, "GET") != NULL && strstr(webdata, "favicon.ico") == NULL ) { // set update flag for GET request but do not want to update for favicon requests
+ update=1;
+ }
+}
+// Starts webserver
+void startserver()
+{
+ gettime();
+ strcpy(audio1, "#");
+ pc.printf("++++++++++ Resetting ESP ++++++++++\r\n");
+ strcpy(cmdbuff,"node.restart()\r\n");
+ SendCMD();
+ wait(2);
+ getreply();
+
+ pc.printf("\n++++++++++ Starting Server ++++++++++\r\n> ");
+
+ // initial values
+ sprintf(cmdbuff, "count,time,yesorno,audio1=0,\"%s\",\"%s\",\"%s\"\r\n",timebuf,gotMail, audio1);
+ SendCMD();
+ getreply();
+ wait(0.5);
+
+ //create server
+ sprintf(cmdbuff, "srv=net.createServer(net.TCP,%d)\r\n",SERVtimeout);
+ SendCMD();
+ getreply();
+ wait(0.5);
+ strcpy(cmdbuff,"srv:listen(80,function(conn)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff,"conn:on(\"receive\",function(conn,payload) \r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+
+ //print data to mbed
+ strcpy(cmdbuff,"print(payload)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+
+ //web page data
+ strcpy(cmdbuff,"conn:send('<!DOCTYPE html><html><style> h1 {background: #00000;} </style>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.4);
+ strcpy(cmdbuff, "conn:send('<body><h1>Huzzah Mail Receive Notification Center</h1>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.4);
+ strcpy(cmdbuff,"conn:send('Hit count: '..count..'')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff,"conn:send('<br>Last hit (based on mbed RTC time): '..time..'<br><hr>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.4);
+ strcpy(cmdbuff,"conn:send('<h2>Do you have mail?: '..yesorno..' </h2>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<audio autoplay src= '..audio1..' ></audio><hr>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.4);
+
+
+
+ strcpy(cmdbuff,"conn:send('<form name=\"form1\" method=\"POST\"')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<p><input type=\"checkbox\" name=\"check\" value=\"led1v\"> Unlock mailbox?')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<p><input type=\"checkbox\" name=\"check\" value=\"led2v\"> flip LED2')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<p><input type=\"checkbox\" name=\"check\" value=\"led3v\"> flip LED3')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<p><input type=\"checkbox\" name=\"check\" value=\"led4v\"> flip LED4')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff,"conn:send('<p><input type=\"submit\" value=\"Check Mail\"></form>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "conn:send('<script type=\"text/javascript\"> window.onload=function(){window.setTimeout(\"document.form1.submit();\", 5000);}</script>')\r\n");
+ SendCMD();
+ wait(0.4);
+ strcpy(cmdbuff, "conn:send('<p><h2>How to use:</h2><ul><li>Data will automatically update every 5 seconds</li><li>Click Check Mail to manually send data and refresh values</li></ul></body></html>')\r\n");
+ SendCMD();
+ getreply();
+ wait(0.5);
+ // end web page data
+ strcpy(cmdbuff, "conn:on(\"sent\",function(conn) conn:close() end)\r\n"); // close current connection
+ SendCMD();
+ getreply();
+ wait(0.3);
+ strcpy(cmdbuff, "end)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff, "end)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+
+ strcpy(cmdbuff, "tmr.alarm(0, 1000, 1, function()\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff, "if wifi.sta.getip() == nil then\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff, "print(\"Connecting to AP...\\n\")\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff, "else\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff, "ip, nm, gw=wifi.sta.getip()\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff,"print(\"IP Address: \",ip)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff,"tmr.stop(0)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff,"end\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+ strcpy(cmdbuff,"end)\r\n");
+ SendCMD();
+ getreply();
+ wait(0.2);
+
+ pc.printf("\n\n++++++++++ Ready ++++++++++\r\n\n");
+}
+
+
+// ESP Command data send
+void SendCMD()
+{
+ int i;
+ char temp_char;
+ bool empty;
+ i = 0;
+// Start Critical Section - don't interrupt while changing global buffer variables
+ NVIC_DisableIRQ(UART1_IRQn);
+ empty = (tx_in == tx_out);
+ while ((i==0) || (cmdbuff[i-1] != '\n')) {
+// Wait if buffer full
+ if (((tx_in + 1) % buffer_size) == tx_out) {
+// End Critical Section - need to let interrupt routine empty buffer by sending
+ NVIC_EnableIRQ(UART1_IRQn);
+ while (((tx_in + 1) % buffer_size) == tx_out) {
+ }
+// Start Critical Section - don't interrupt while changing global buffer variables
+ NVIC_DisableIRQ(UART1_IRQn);
+ }
+ tx_buffer[tx_in] = cmdbuff[i];
+ i++;
+ tx_in = (tx_in + 1) % buffer_size;
+ }
+ if (esp.writeable() && (empty)) {
+ temp_char = tx_buffer[tx_out];
+ tx_out = (tx_out + 1) % buffer_size;
+// Send first character to start tx interrupts, if stopped
+ esp.putc(temp_char);
+ }
+// End Critical Section
+ NVIC_EnableIRQ(UART1_IRQn);
+ return;
+}
+
+// Get Command and ESP status replies
+void getreply()
+{
+ read_line();
+ sscanf(rx_line,replybuff);
+}
+
+// Read a line from the large rx buffer from rx interrupt routine
+void read_line() {
+ int i;
+ i = 0;
+// Start Critical Section - don't interrupt while changing global buffer variables
+ NVIC_DisableIRQ(UART1_IRQn);
+// Loop reading rx buffer characters until end of line character
+ while ((i==0) || (rx_line[i-1] != '\r')) {
+// Wait if buffer empty
+ if (rx_in == rx_out) {
+// End Critical Section - need to allow rx interrupt to get new characters for buffer
+ NVIC_EnableIRQ(UART1_IRQn);
+ while (rx_in == rx_out) {
+ }
+// Start Critical Section - don't interrupt while changing global buffer variables
+ NVIC_DisableIRQ(UART1_IRQn);
+ }
+ rx_line[i] = rx_buffer[rx_out];
+ i++;
+ rx_out = (rx_out + 1) % buffer_size;
+ }
+// End Critical Section
+ NVIC_EnableIRQ(UART1_IRQn);
+ rx_line[i-1] = 0;
+ return;
+}
+
+
+// Interupt Routine to read in data from serial port
+void Rx_interrupt() {
+ DataRX=1;
+ //getDS();
+ //led3=1;
+// Loop just in case more than one character is in UART's receive FIFO buffer
+// Stop if buffer full
+ while ((esp.readable()) && (((rx_in + 1) % buffer_size) != rx_out)) {
+ rx_buffer[rx_in] = esp.getc();
+// Uncomment to Echo to USB serial to watch data flow
+ pc.putc(rx_buffer[rx_in]);
+ rx_in = (rx_in + 1) % buffer_size;
+ }
+ //led3=0;
+ return;
+}
+
+
+// Interupt Routine to write out data to serial port
+void Tx_interrupt() {
+ //led2=1;
+// Loop to fill more than one character in UART's transmit FIFO buffer
+// Stop if buffer empty
+ while ((esp.writeable()) && (tx_in != tx_out)) {
+ esp.putc(tx_buffer[tx_out]);
+ tx_out = (tx_out + 1) % buffer_size;
+ }
+ //led2=0;
+ return;
+}
+
+void gettime()
+{
+ time_t seconds = time(NULL);
+ strftime(timebuf,50,"%H:%M:%S %a %d %b %y", localtime(&seconds));
+}
+
+void setRTC()
+{
+ t.tm_sec = (0); // 0-59
+ t.tm_min = (minute); // 0-59
+ t.tm_hour = (hour); // 0-23
+ t.tm_mday = (dayofmonth); // 1-31
+ t.tm_mon = (month-1); // 0-11 "0" = Jan, -1 added for Mbed RCT clock format
+ t.tm_year = ((year)+100); // year since 1900, current DCF year + 100 + 1900 = correct year
+ set_time(mktime(&t)); // set RTC clock
+}
+
+void getDS()
+{
+ DSin = ds.read();
+}
\ No newline at end of file