Jacob Smith
IoT for mbed1
Dependencies: 4DGL-uLCD-SE IoTsecuritySys PinDetect mbed-rtos mbed
Fork of
IoT
by 
Tal Landes
Diff: main.cpp
- Revision:
- 1:7f873efe5b11
- Parent:
- 0:04dcbfb4388c
- Child:
- 2:922d5b43bee3
--- a/main.cpp Tue Nov 24 20:15:53 2015 +0000
+++ b/main.cpp Sat Dec 05 15:23:55 2015 +0000
@@ -1,22 +1,31 @@
#include <mbed.h>
+#include "rtos.h"
#include <mpr121.h>
#include <stdlib.h>
#include "PinDetect.h"
-
+#include "uLCD_4DGL.h"
+#include "SongPlayer.h"
+#include "PinDetect.h"
+#include "Speaker.h"
+#include "EthernetInterface.h"
/* CODE_LENGTH needs to be double the amount of numbers you
want in your authenticator/passcode because of the way interrupt.fall(&fallInterrupt)
works. It is called twice every time an interrupt is detected.
The extra numbers in the array will just be filled with zeros and ignored in checking
code sequences, so they will not matter either way */
/* i.e, you want a code with 7 numbers, CODE_LENGTH needs to be 14 */
-#define CODE_LENGTH 14
+#define CODE_LENGTH 8
DigitalOut led1(LED1);
DigitalOut led2(LED2);
DigitalOut led3(LED3);
DigitalOut led4(LED4);
-DigitalOut doorlock(p29);
+DigitalOut doorlock(p21);
+
+
+//uLCD_4DGL uLCD(p9,p10,p11); // serial tx, serial rx, reset pin;
+uLCD_4DGL uLCD(p28, p27, p29);
// Create the interrupt receiver object on pin 26
InterruptIn interrupt(p30);
@@ -31,15 +40,53 @@
// pc serial communication for testing
Serial pc(USBTX, USBRX);
+//Set up IR sensor
+AnalogIn IrSensor(p20);
+
+//Shiftbright
+DigitalOut latch(p15);
+DigitalOut enable(p16);
+//AnalogOut DACout(p18);
+//Cycles through different colors on RGB LED
+SPI spi(p11, p12, p13);
+
+
+SongPlayer mySpeaker(p26);
+Speaker NotePlayer(p26);
+
+// ethernet setup
+EthernetInterface eth;
+
+//Lock timeout
+Ticker flipper;
+
// ***** GLOBALS ***** //
// Timer is to seed rand
Timer t1;
// code counter is the next position in inputCode array
-int codeCounter;
+volatile int codeCounter;
// inputCode array is the sequence of numbers the user will enter
-int inputCode[CODE_LENGTH];
-bool code_enabled;
-
+volatile int inputCode[CODE_LENGTH];
+volatile bool code_enabled;
+volatile float IrVoltage = 0.0;
+volatile enum Statetype { Armed =0 ,IR_sensed = 1,Second_Step = 2,Cleared = 3, Alarm_ON = 4};
+Statetype state = Armed;
+
+float note[18]= {1568.0,1396.9};
+float duration[18]= {0.48,0.24};
+
+Mutex LCD_Access;
+Semaphore Consul_Access(5);
+
+void Shiftbright_thread(void const *args);
+void IR_thread(void const *args);
+void LCD_Code_Enter_Thread(void const *args);
+void uLCD_thread(void const *args);
+void RGB_LED(int red, int green, int blue);
+void Speaker_thread(void const *args);
+void Ethernet_thread(void const *args);
+void Activate_Lock();
+void init_LCD();
// Key hit/release interrupt routine
void fallInterrupt() {
int key_code=0;
@@ -66,7 +113,7 @@
// only save the even numbers (see lines 6-10)
else{
inputCode[codeCounter] = key_code - 1;
- pc.printf("codeCounter: %d -- code: %d\n\r", codeCounter, key_code - 1);
+ //pc.printf("codeCounter: %d -- code: %d\n\r", codeCounter, key_code - 1);
}
codeCounter++;
}
@@ -74,12 +121,12 @@
// generate randomized code
void generate_random_code(int (&codeArray)[CODE_LENGTH]){
- int i = 0;
+ //int i = 0;
// only care about the even numbers (see lines 6-10)
pc.printf("NEW CODE: ");
- for(i = 0; i < CODE_LENGTH; i+=2){
+ for(int i = 0; i < CODE_LENGTH; i+=2){
srand(t1.read_us());
- codeArray[i] = rand() % 12;
+ codeArray[i] = (rand() % 9)+1; //nake code only 1-9
pc.printf("%d, ", codeArray[i]);
}
pc.printf("\n\r");
@@ -103,12 +150,14 @@
int main() {
interrupt.fall(&fallInterrupt);
interrupt.mode(PullUp);
+ pc.baud(921600);
+
// authenticator is the randomly generated sequence of numbers by the machine
// the user has to match this sequence to gain access, used for phase 2
int authenticator[CODE_LENGTH];
// passcode is the user's personal passcode, used for phase 1
- int passcode[CODE_LENGTH] = {0,0,1,0,2,0,3,0,4,0,5,0,6,0};
+ int passcode[CODE_LENGTH] = {1,0,2,0,3,0,4,0};//,4,0,5,0,6,0};
codeCounter = 0;
bool pass = false;
@@ -126,13 +175,25 @@
// go ahead and start the timer so that when a random code is generated,
// the seed will always be random, unlike the predecessor version
t1.start();
-
+ init_LCD();
+ //start threads:
+ pc.printf("\n\n\nSetting up Ethernet\n\r");
+ //Thread Ethernetthread(Ethernet_thread);
+ //wait(5); //Give the Ethernet connection some time to set up
+ Thread IRthread(IR_thread);
+ Thread Shiftbright(Shiftbright_thread);
+ Thread LCDthread(uLCD_thread);
+ Thread LCD_CodeEnterThread(LCD_Code_Enter_Thread);
+ Thread Speakerthread(Speaker_thread);
// while loop constantly checks if the entered code sequence is right or wrong,
// given that the correct amount of numbers were entered
pc.printf("Please Enter Your Personal Security Code\n\r");
+ doorlock = 0; // make sure locked
while (1){
- switch(code_enabled){
- case false:
+ switch(state){
+ case Cleared:
+ break;
+ case IR_sensed:
if(codeCounter >= CODE_LENGTH){
pass = check_code_sequence(passcode);
if(pass == true){
@@ -142,7 +203,8 @@
t1.reset(); // so that it is an even
t1.start(); // 30 seconds before 1st new code is generated
codeCounter = 0;
- code_enabled = true;
+ //code_enabled = true;
+ state = Second_Step;
}
else{
pc.printf("WRONG passcode\n\r");
@@ -150,18 +212,20 @@
}
}
break;
- case true:
+ case Second_Step:
if(codeCounter >= CODE_LENGTH){
pass = check_code_sequence(authenticator);
if(pass == true){
pc.printf("ACCESS GRANTED\n\r");
- doorlock = 1;
- wait(5);
- doorlock = 0;
+ doorlock = 1;
+ flipper.attach(&Activate_Lock, 5.0);
+ //wait(5);
+ //doorlock = 0;*/
pc.printf("Resetting....\n\r");
pc.printf("\n\n\rPlease Enter Your Personal Security Code\n\r");
codeCounter = 0;
code_enabled = false;
+ state = Cleared;
}
else{
pc.printf("ACCESS DENIED\n\r");
@@ -187,4 +251,275 @@
t1.start();
}
}
-}
\ No newline at end of file
+}
+
+
+void Shiftbright_thread(void const *args){
+ spi.format(16,0);
+ spi.frequency(500000);
+ enable=0;
+ latch=0;
+
+ while(1) {
+ switch (state) {
+ case Armed:
+ for (int i = 0; i <= 50; i++) {
+ RGB_LED( i, 0, 0);
+ Thread::wait(10);
+ }
+ for (int i = 50; i >= 0; i--) {
+ RGB_LED( i, 0, 0);
+ Thread::wait(10);
+ }
+ break;
+ case IR_sensed:
+ RGB_LED( 100, 0, 0);
+ Thread::wait(500);
+ RGB_LED( 0, 0, 0);
+ break;
+ case Alarm_ON:
+ for (int i = 0; i <= 100; i++) {
+ RGB_LED( i, i/2, 0);
+ Thread::wait(10);
+ }
+ for (int i = 100; i >= 0; i--) {
+ RGB_LED( i, i/3, 0);
+ Thread::wait(10);
+ }
+ break;
+ case Cleared:
+ RGB_LED( 0, 100, 0);
+ break;
+ }
+ Thread::wait(1000);
+ }
+}
+
+
+void IR_thread(void const *args) {
+
+ Timer t;
+ t.start();
+
+ while(1) {
+
+ if (state == Armed) {
+ IrVoltage=IrSensor.read();
+ if (IrVoltage <= 0.1) { //if value just nois reset timer
+ t.reset();
+ state = Armed;
+ }
+ if (t.read() >= 5) { //wait 5 seconds to make sure that sense someone
+ state = IR_sensed;
+ }
+ Thread::wait(1000);
+ }
+ else {
+ //nothing to do for this thread make space for others
+ Thread::wait(1000);
+ }
+ }
+}
+
+void RGB_LED(int red, int green, int blue) {
+
+ unsigned int low_color=0;
+ unsigned int high_color=0;
+ high_color=(blue<<4)|((red&0x3C0)>>6);
+ low_color=(((red&0x3F)<<10)|(green));
+ spi.write(high_color);
+ spi.write(low_color);
+ latch=1;
+ latch=0;
+}
+
+void init_LCD() {
+ uLCD.baudrate(3000000);
+ uLCD.background_color(BLACK);
+
+}
+
+
+void uLCD_thread(void const *args) {
+ int Change = 99;
+ while(1) {
+
+ if (Change != state) {
+ Change = state;
+ switch (state) {
+ case Armed:
+ LCD_Access.lock();
+ uLCD.cls();
+ uLCD.color(WHITE);
+ uLCD.text_width(2);
+ uLCD.text_height(2);
+ uLCD.printf(" ARMED\r\n");
+ uLCD.text_width(1);
+ uLCD.text_height(1);
+
+ if (eth.getIPAddress() == "\0") {
+ uLCD.printf("\n\n No Internet connection");
+ }
+ else {
+ uLCD.printf("\n\nConnected to the Internet\n");
+ uLCD.printf("IP Address: \n%s ", eth.getIPAddress());
+ }
+ LCD_Access.unlock();
+ break;
+ case IR_sensed:
+ LCD_Access.lock();
+ uLCD.cls();
+ uLCD.printf("\nSensor triggred \n");
+ uLCD.printf("\n Enter the code ...");
+ LCD_Access.unlock();
+ for (int i=30; i>=0; --i) {
+ if (state == IR_sensed) {
+ LCD_Access.lock();
+ uLCD.text_width(4);
+ uLCD.text_height(4);
+ uLCD.color(RED);
+ uLCD.locate(1,2);
+ uLCD.printf("%2D",i);
+ LCD_Access.unlock();
+ Thread::wait(1000);
+ }
+ }
+ if (state == IR_sensed) {
+ state = Alarm_ON;
+ }
+
+ break;
+ case Second_Step:
+ LCD_Access.lock();
+ uLCD.cls();
+ uLCD.color(BLUE);
+ uLCD.printf("\nPleas enter code from text massage \n");
+ LCD_Access.unlock();
+ break;
+ case Alarm_ON:
+ LCD_Access.lock();
+ uLCD.cls();
+ uLCD.color(RED);
+ uLCD.text_width(1.5); //4X size text
+ uLCD.text_height(1.5);
+ uLCD.printf("\nALARM IS ON \nText message sent \n");
+ LCD_Access.unlock();
+ break;
+ case Cleared:
+ LCD_Access.lock();
+ uLCD.cls();
+ uLCD.color(GREEN);
+ uLCD.printf("\n\nAccess Granted. \n\n");
+ LCD_Access.unlock();
+ break;
+ }
+ }
+ Thread::wait(500);
+ }
+}
+
+void LCD_Code_Enter_Thread(void const *args) {
+ int LineHight = 120;
+ int LineWidth = 10;
+ int SpaceWidth = 5;
+ int MidPoint = 127/2;
+ while(1) {
+ switch (state) {
+ case Armed:
+ break;
+ case IR_sensed:
+ case Cleared:
+ case Second_Step:
+
+ Thread::wait(500);
+ while((state == IR_sensed)||(state == Cleared)||(state == Second_Step)) {
+ LCD_Access.lock();
+ //dusplay four lines
+ uLCD.line(MidPoint-2*(LineWidth+SpaceWidth), LineHight, MidPoint- 2*SpaceWidth-LineWidth, LineHight, WHITE); //line( int x1, int y1, int x2, int y2, int color)
+ uLCD.line(MidPoint-LineWidth-SpaceWidth, LineHight, MidPoint-SpaceWidth, LineHight, WHITE); //line( int x1, int y1, int x2, int y2, int color)
+ uLCD.line(MidPoint+SpaceWidth, LineHight, MidPoint+SpaceWidth+LineWidth, LineHight, WHITE); //line( int x1, int y1, int x2, int y2, int color)
+ uLCD.line(MidPoint+2*SpaceWidth+LineWidth, LineHight, MidPoint+2*(SpaceWidth+LineWidth), LineHight, WHITE); //line( int x1, int y1, int x2, int y2, int color)
+ uLCD.locate(5,14);
+ uLCD.text_width(1); //4X size text
+ uLCD.text_height(1);
+ uLCD.color(WHITE);
+ // add black numbers
+ uLCD.printf("%d %d %d %d",inputCode[0],inputCode[2],inputCode[4],inputCode[6]);
+ LCD_Access.unlock();
+ }
+
+ case Alarm_ON:
+ break;
+ }
+ }
+}
+
+void Speaker_thread(void const *args) {
+ while (1) {
+ if (state == Alarm_ON) {
+ mySpeaker.PlaySong(note,duration);
+ Thread::wait(1000);
+ }
+ }
+}
+
+void Ethernet_thread(void const *args) {
+
+ int Change = 99;
+
+ eth.init(); //Use DHCP
+ eth.connect();
+ pc.printf("IP Address is: %s\n\r", eth.getIPAddress());
+
+ while(1) {
+ if (Change != state) {
+
+ Change = state;
+ switch (state) {
+ case Armed:
+ //add code that verifies connection every so often
+ Thread::wait(1000);
+ break;
+ case Second_Step:
+ Thread::wait(1000);
+ break;
+ case Alarm_ON: {
+ // send alert
+ char buffer[300];
+ int ret;
+ TCPSocketConnection sock;
+ sock.connect("dreamphysix.com", 80);
+
+ char http_cmd[] = "GET http://dreamphysix.com/alert.php?authcode=0e9cae34a0 HTTP/1.0\n\n";
+ sock.send_all(http_cmd, sizeof(http_cmd)-1);
+
+
+ while (true) {
+ ret = sock.receive(buffer, sizeof(buffer)-1);
+ if (ret <= 0)
+ break;
+ buffer[ret] = '\0';
+ Consul_Access.wait();
+ pc.printf("Received %d chars from server:\n%s\n", ret, buffer);
+ Consul_Access.release();
+ }
+ sock.close();
+ }
+ break;
+ case Cleared:
+ //nothing to do for this thread make space for others
+ Thread::wait(1000);
+ break;
+ case IR_sensed:
+ //nothing to do for this thread make space for others
+ Thread::wait(1000);
+ break;
+ }
+ }
+ }
+}
+
+void Activate_Lock(){
+
+ doorlock =! doorlock;
+}