Libelium - Development

RSS

Monitoring Sensor Data and Sending Alarm SMS's with Meshlium

This code example has been tested and improved to be executed in Meshlium with the data coming from a Wireless Sensor Network created with Waspmote.

Alerts

This example will define a simple trigger based on an arbitrary value. Values over the trigger will be considered an alert and a SMS message will be sent.

Note that on real applications each sensor usage has it's own alert parameters, and several alerts can be launched over different sensors.

For this example the frame will have the same structure used in previous tutorials

ID_<mote>#Sensor_value

A valid frame can be:

ID_12#239

Creating Database

The database to store data will store the following values: ID of the mote, sensor value recived, and the time of the received frame will be stored.

First we need to create the database for the example.

create database sensordemo;
use sensordemo;

Add a user that can access the database.

GRANT ALL PRIVILEGES ON sensordemo.* TO 'sdemo'@'localhost' IDENTIFIED BY 'sdemopass' WITH GRANT OPTION;
flush privileges;

Finally create the database.

CREATE TABLE sensor_data (
  id INT UNSIGNED NOT NULL AUTO_INCREMENT,
  date timestamp not null,
  mote_id INT UNSIGNED NOT NULL,
  sensor_value INT UNSIGNED NOT NULL,
  PRIMARY KEY  (id)
);

Sniffer with SMS alert code

This program reads frames received through a Bluetooth Serial Port or a XBee module and store it on a MySQL database. If a detected value if greater that alert_value, an alarm is processed and a SMS message is sent.

File:
"sniffer_ddbb_sms_alarm.c"

Compilation on Meshlium:
gcc -o sniffer_ddbb_sms_alarm -I/usr/include/mysql sniffer_ddbb_sms_alarm.c -L/usr/lib/mysql -lmysqlclient -Wall

Usage:
sniffer_ddbb_sms_alarm S0 localhost

Note:
Serial port speed should be set on sniffer execution.

Code


/*
 *  Copyright (C) 2008 Libelium Comunicaciones Distribuidas S.L.
 *  http://www.libelium.com
 *
 *  This program is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation, either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 *  Version 0.1
 *  Author: Octavio Benedi Sanchez
 */


#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <stdlib.h>
#include <termios.h> /* Terminal control library (POSIX) */
#include <ctype.h>
#include <mysql.h>

#define MAX 500
#define MAX_SQL 700

int main(int argc, char *argv[]) {
    int sd = 3;
    char *serialPort = "";
    char *serialPort0 = "/dev/ttyS0";
    char *serialPort1 = "/dev/ttyS1";
    char *USBserialPort0 = "/dev/ttyUSB0";
    char *USBserialPort1 = "/dev/ttyUSB1";
    char *USBserialPort2 = "/dev/ttyUSB2";
    char *USBserialPort3 = "/dev/ttyUSB3";
    char *USBserialPort4 = "/dev/ttyUSB4";
    char *USBserialPort5 = "/dev/ttyUSB5";
    char *BTserialPort0 = "/dev/rfcomm0";
    char *BTserialPort1 = "/dev/rfcomm1";
    char *BTserialPort2 = "/dev/rfcomm2";
    char valor[MAX] = "";
    char c;
    struct termios opciones;
    char *s0 = "S0";
    char *s1 = "S1";
    char *u0 = "USB0";
    char *u1 = "USB1";
    char *u2 = "USB2";
    char *u3 = "USB3";
    char *u4 = "USB4";
    char *u5 = "USB5";
    char *bt0 = "rfcomm0";
    char *bt1 = "rfcomm1";
    char *bt2 = "rfcomm2";

    int speed = B19200;

    typedef struct {
        char *name;
        int flag;
    } speed_spec;

    speed_spec speeds[] ={
        {"1200", B1200},
        {"2400", B2400},
        {"4800", B4800},
        {"9600", B9600},
        {"19200", B19200},
        {"38400", B38400},
        {"57600", B57600},
        {"115200", B115200},
        {NULL, 0}
    };

    /**************************************
     * Defines for MYSQL
     *************************************/
    char sql[MAX_SQL] = "";
    MYSQL mysql;

    /**************************************
     * Alarm values
     *************************************/
    int alarm_value = 612;

    /* STARTING MAIN */
    if (argc != 4) {
        fprintf(stderr, "Usage: %s port speed bbdd_ip\n", argv[0]);
        exit(0);
    }
    if (argc == 4) {
        speed_spec *s;
        for (s = speeds; s->name; s++) {
            if (strcmp(s->name, argv[2]) == 0) {
                speed = s->flag;
                fprintf(stderr, "setting speed %s\n", s->name);
                break;
            }
        }
    }

    if (!strcmp(argv[1], s0)) {
        //fprintf(stderr,"ttyS0 chosen\n...");
        serialPort = serialPort0;
    }
    if (!strcmp(argv[1], s1)) {
        //fprintf(stderr,"ttyS1 chosen\n...");
        serialPort = serialPort1;
    }
    if (!strcmp(argv[1], u0)) {
        //fprintf(stderr,"ttyUSB0 chosen\n...");
        serialPort = USBserialPort0;
    }
    if (!strcmp(argv[1], u1)) {
        //fprintf(stderr,"ttyUSB1 chosen\n...");
        serialPort = USBserialPort1;
    }
    if (!strcmp(argv[1], u2)) {
        //fprintf(stderr,"ttyUSB2 chosen\n...");
        serialPort = USBserialPort2;
    }
    if (!strcmp(argv[1], u3)) {
        //fprintf(stderr,"ttyUSB3 chosen\n...");
        serialPort = USBserialPort3;
    }
    if (!strcmp(argv[1], u4)) {
        //fprintf(stderr,"ttyUSB4 chosen\n...");
        serialPort = USBserialPort4;
    }
    if (!strcmp(argv[1], u5)) {
        //fprintf(stderr,"ttyUSB5 chosen\n...");
        serialPort = USBserialPort5;
    }
    if (!strcmp(argv[1], bt0)) {
        //fprintf(stderr,"rfcomm0 chosen\n...");
        serialPort = BTserialPort0;
    }
    if (!strcmp(argv[1], bt1)) {
        //fprintf(stderr,"rfcomm1 chosen\n...");
        serialPort = BTserialPort1;
    }
    if (!strcmp(argv[1], bt2)) {
        //fprintf(stderr,"rfcomm2 chosen\n...");
        serialPort = BTserialPort2;
    }
    if (!strcmp(serialPort, "")) {
        fprintf(stderr, "Choose a valid port (S0, S1, USB0, USB1, USB2, USB3, USB4, USB5, rfcomm0, rfcomm1, rfcomm2)\n");
        exit(0);
    }

    if ((sd = open(serialPort, O_RDWR | O_NOCTTY | O_NONBLOCK)) == -1) {
        fprintf(stderr, "Unable to open the serial port %s - \n", serialPort);
        exit(-1);
    } else {
        if (!sd) {
            /*Sometimes the first time you call open it does not return the
             * right value (3) of the free file descriptor to use, for this
             * reason you can set manually the sd value to 3 or call again
             * the open function (normally returning 4 to sd), advised!*/
            sd = open(serialPort, O_RDWR | O_NOCTTY | O_NONBLOCK);
        }
        //fprintf(stderr,"Serial Port open at: %i\n", sd);
        fcntl(sd, F_SETFL, 0);
    }
    tcgetattr(sd, &opciones);
    cfsetispeed(&opciones, speed);
    cfsetospeed(&opciones, speed);
    opciones.c_cflag |= (CLOCAL | CREAD);
    /*No parity*/
    opciones.c_cflag &= ~PARENB;
    opciones.c_cflag &= ~CSTOPB;
    opciones.c_cflag &= ~CSIZE;
    opciones.c_cflag |= CS8;
    /*raw input:
     * making the applycation ready to receive*/
    opciones.c_lflag &= ~(ICANON | ECHO | ECHOE | ISIG);
    /*Ignore parity errors*/
    opciones.c_iflag |= ~(INPCK | ISTRIP | PARMRK);
    opciones.c_iflag |= IGNPAR;
    opciones.c_iflag &= ~(IXON | IXOFF | IXANY | IGNCR | IGNBRK);
    opciones.c_iflag |= BRKINT;
    /*raw output
     * making the applycation ready to transmit*/
    opciones.c_oflag &= ~OPOST;
    /*aply*/
    tcsetattr(sd, TCSANOW, &opciones);
    int j = 0;
    int ret;
    int mote_id;
    int sensor_value;

    mysql_init(&mysql);
    mysql_options(&mysql, MYSQL_READ_DEFAULT_GROUP, "your_prog_name");
    if (!mysql_real_connect(&mysql, argv[3], "sdemo", "sdemopass", "sensordemo", 0, NULL, 0)) {
        fprintf(stderr, "Failed to connect to database: Error: %s\n", mysql_error(&mysql));
        exit(-1);
    }
    else {
        fprintf(stderr, "Connected to database: return: %s\n", mysql_error(&mysql));
    }


    while (1) {
        read(sd, &c, 1);
        valor[j] = c;
        j++;
        if ((c == '\n') || (j == (MAX - 1))) {
            valor[j] = '\0';
            ret = sscanf(valor, "ID_%d#%d", &mote_id, &sensor_value);
            if (ret == 2) {
                sprintf(sql, "insert into sensor_data values(NULL,NULL,'%d','%d');", mote_id, sensor_value);
                if (mysql_query(&mysql, sql) != 0) {
                    fprintf(stderr, "BBDDFailed:%s\n", sql);
                }
                else {
                    fprintf(stdout, "BBDDSucceeded:%s\n", sql);
                }
                if (sensor_value > alarm_value) {
                    // send an alarm sms
                    int pid;
                    char *message = "Alert from meshlium, detected sensor value:";
                    char *tlf_number = "555555555";
                    pid = fork();
                    if (pid == 0) {
                        // This is the child. Should exec and die.
                        char order[255];
                        sprintf(order, "sms-send USB0 %s \"%s %d\"", tlf_number, message, sensor_value);
                        system(order);
                        return (0);
                    }
                }
            }
            else {
                fprintf(stderr, "Bad frame received\n");
            }
            j = 0;
            valor[j] = '\0';
        }

    }
    mysql_close(&mysql);
    close(sd);
    exit(0);
}

Download code

You can download the code of this tutorial.

(*)

I have read and I accept the privacy policy

In order to comply with the provisions in Spanish Data Protection Act (L.O. 15/1999 of 13th December) and its implementing Regulation (R.D. 1720/2007, of 21st December), LIBELIUM hereby informs its Customers and websites users that any personal data supplied through the forms contained in its websites shall be recorded in a file named “CUSTOMERS” for which LIBELIUM is responsible, located at LIBELIUM´s registered address and which has been registered with the Spanish General Registry for Data Protection (Registro General de Protección de Datos de la Agencia Española de Protección de Datos).

Except for those fields expressly requesting compulsory filling, answers to the questions contained in any form are voluntary and therefore, the lack of answer does not imply a reduction of the quantity or quality of LIBELIUM´s services. The aim of this data collection are to provide access to LIBELIUM´s online shop, to send information on LIBELIUM´s Product(s) and services as well as to collect Customer’s acceptance to the terms of use of the forums and other sections in LIBELIUM´s websites. By filling these forms Customers consent in receiving promotional offers concerning LIBELIUM´s Product(s) and services. You further consent further that LIBELIUM may make such data available to its services suppliers to the sole purpose of enabling service provision.

Any User providing personal data through any of the forms in LIBELIUM´s websites shall count on a 30 day period to inform LIBELIUM in writing of his/her refusal to the processing of his/her personal data. Unless this communication is made, it shall be deemed that the User consents the processing of his/her personal data according to the terms set forth in these T&C. All personal data collected shall be processed by using the security measures requested by Law to avoid their loss, damage or access by any unauthorised third party. User may nevertheless be aware of the fact that the existing security measures for computer systems on the Internet are not entirely trustworthy. Should you think that your email address has been disclosed to us without your consent, do not hesitate to inform us thereof. Users may at any time exercise their rights of access, rectification, update, cancellation and objection, as well as revoke the consent granted for all of any of the above-mentioned processings, by sending a written statement to LIBELIUM, either through the “Contact” section in our website http://www.libelium.com or by post to the following address: LIBELIUM COMUNICACIONES DISTRIBUIDAS, S.L., c/ María de Luna, 11, nave 5, CEEIARAGON. 50018 Zaragoza (Spain).

To exercise the above-mentioned rights you must indicate your name, ID/passport number, full address, date and signature, including any document supporting your request, in case it is needed; a copy of your ID card/passport must be enclosed, unless you use an electronic signature. User shall be liable for the veracity of data provided and only in case of holders of parental rights concerning children under fourteen and in connection with said children, shall LIBELIUM accept the disclosure of personal data concerning third parties. Users shall assume all liability for direct or consequential damages arising out of or in connection with the provision of false, inaccurate, incomplete or non updated data.

Furthermore, LIBELIUM reserves its right to exclude from any service for which prior registration is required, to any User having provided false data or failing to comply with these T&C, notwithstanding any other legal action to which LIBELIUM may be entitled. LIBELIUM reserves its right to modify its Privacy Policy or these T&C to adapt them to the regulations in force or for any other reason. Provided that the use of LIBELIUM´s websites by Users shall be deemed as User’s acceptance of LIBELIUM´s Privacy Policy and T&C, User is hereby requested to check these T&C and any further amendments from time to time.

Privacy Policy
Users may visit LIBELIUM´s websites without disclosing neither their identity nor any personal data. LIBELIUM´s servers may only collect domain names but not email addresses of their visitors. This kind of information is used to elaborate reports on visit statistics, the time spent in the websites, websites accessed, the general origin of visitors (through “Favourites”, search engines, links from other websites, etc.) to the sole purposes of getting information on how the websites are used and improving their contents and services.

Linked sites
LIBELIUM´s websites may provide links to other sites but LIBELIUM assumes no liability on the privacy policies adopted by the linked sites, directly or indirectly. Links to other sites are provided as a suggestion only and do not imply LIBELIUM´s warranty or liability concerning their quality, accuracy or contents of the information provided therein.

LIBELIUM does not warrant the veracity or accuracy of the information disclosed by its suppliers or third parties whose products or services are offered through LIBELIUM, their origin, ownership or the use or practical implementation made by Customers.

(*) Mandatory fields

| Terms of use