1 changed files with 0 additions and 181 deletions
@ -1,181 +0,0 @@ |
|||
const app = require('express')(); //loading express module
|
|||
const http = require('http').createServer(app); //creating server
|
|||
const io = require('socket.io')(http); //loading socket.io module using HTTP transport
|
|||
const parser = require('body-parser'); //loading body-parser module
|
|||
const Data = require('nedb'); //loading nedb module
|
|||
const nodemailer = require('nodemailer'); //loading nodemailer module
|
|||
require('dotenv').config(); //for database security
|
|||
|
|||
|
|||
var temp_old_value = 0; //inserting the previous value of temperature
|
|||
var temp_flag = 0; //flag to check if we got the previous value of temperature
|
|||
var temp_result = 0; //inserting the percentage difference of temperature
|
|||
|
|||
var hum_old_value = 0; //inserting the previous value of air humidity
|
|||
var hum_flag = 0; //flag to check if we got the previous value of air humidity
|
|||
var hum_result = 0; //inserting the percentage difference of air humidity
|
|||
|
|||
var temp_list = []; //we need the lists to send the data to client
|
|||
var air_list = []; |
|||
var ground_list = []; |
|||
var beauf_list = []; |
|||
|
|||
var temp_count = 0; //our lists will have 10 values so we need counters to insert and update the values
|
|||
var air_count = 0; |
|||
var ground_count = 0; |
|||
var beauf_count = 0; |
|||
|
|||
app.use(parser.urlencoded({extended: true})); //precises that the request.body object will contain values of any type instead of just strings
|
|||
|
|||
const database = new Data('rasp_measurements.db'); //creating database with name rasp_measurements.db
|
|||
database.loadDatabase(); //loading database or creating it if it doesn't exist
|
|||
|
|||
|
|||
function calculate(old, neww){ //calculating the percentage difference between the old and the new measure
|
|||
return (neww-old)/old*100; |
|||
} |
|||
|
|||
|
|||
app.get('/', (req,res) => { //sending the page.html as a result of clients request
|
|||
res.sendFile(__dirname + '/page.html'); |
|||
}); |
|||
|
|||
app.post('/', (request, response) => { //server sends data to Gmail, database and the client
|
|||
let transporter = nodemailer.createTransport({//to notify the client we need specify the name of the email service we will use
|
|||
service: 'gmail', |
|||
auth: { //the file .env has the email and password and the file .gitignore makes sure the file .env never gets pushed
|
|||
user: process.env.EMAIL, |
|||
pass: process.env.PASSWORD |
|||
} |
|||
}); |
|||
|
|||
if (request.body[0]){ |
|||
if(temp_flag == 0){ //if we don't have the previous value then..
|
|||
temp_old_value = request.body[0]; //..insert it to temp_old_value
|
|||
temp_flag = 1; //then set temp_flag to 1
|
|||
} else if(temp_flag == 1){ //now that we have the previous value we will get the new value..
|
|||
console.log('Old value:',temp_old_value,', New value:',request.body[0]); |
|||
temp_result = calculate(temp_old_value, request.body[0]); //..to find the percentage defference between the new and old value
|
|||
|
|||
console.log('Temperature percentage difference:',temp_result.toFixed(1) + "%!\n"); |
|||
database.insert({measure: 'temperature',value:parseInt(request.body[0])}); //inserting the new values to database
|
|||
temp_flag = 0; //making temp_flag = 0 to do the same things for the next values
|
|||
|
|||
temp_list[temp_count] = parseInt(request.body[0]); //inserting the new value to list temp_list at temp_count position
|
|||
console.log('List of temperatures:',temp_list); //for better understanding
|
|||
temp_count +=1; //increasing the temp_count counter
|
|||
|
|||
if(temp_count == 10){ //if we have 10 values in the list then insert at the 11th position the correct id (0 for temperature)
|
|||
temp_list[temp_count] = 0; //inserting the correct id
|
|||
temp_count = 0; //start from the begining and update the values
|
|||
|
|||
io.on('connection', socket => { //then send the list to client
|
|||
console.log('We have a connection'); |
|||
socket.emit('graph', temp_list); |
|||
}); |
|||
} |
|||
|
|||
if(temp_result > 40){ //if temperature increased by 50% then send an email to kampe.test@gmail.com to warn him
|
|||
|
|||
let mailOptions = { |
|||
from: process.env.EMAIL, |
|||
to: 'kampe.test@gmail.com', |
|||
subject: 'ATTENTION', |
|||
text: 'Temperature increased alot!' |
|||
}; |
|||
|
|||
transporter.sendMail(mailOptions, function(err, data) { //sending the email
|
|||
if (err){ |
|||
console.log('Error Occurs'); |
|||
} else { |
|||
console.log('Email sent (for temperature).'); |
|||
} |
|||
}); |
|||
} |
|||
} |
|||
} else if (request.body[1]) { |
|||
if(hum_flag == 0){ //if we don't have the previous value then..
|
|||
hum_old_value = request.body[1]; //..insert it to temp_old_value
|
|||
hum_flag = 1; //then set temp_flag to 1
|
|||
} else if(hum_flag == 1){ //now that we have the previous value we will get the new value..
|
|||
console.log('Old value:',hum_old_value,', New value:',request.body[1]); |
|||
hum_result = calculate(hum_old_value, request.body[1]);//..to find the percentage defference between the new and old value
|
|||
|
|||
console.log('Air humidity percentage difference:',hum_result.toFixed(1) + '%!'); |
|||
database.insert({measure: 'air humidity',value:parseInt(request.body[1])}); //inserting the new values to database
|
|||
hum_flag = 0; //making hum_flag = 0 to do the same things for the next values
|
|||
|
|||
air_list[air_count] = parseInt(request.body[1]); //inserting the new value to list air_list at air_count position
|
|||
console.log('List of air humidity:',air_list); //for better understanding
|
|||
air_count +=1; //increasing the air_count counter
|
|||
|
|||
if(air_count == 10){ //if we have 10 values in the list then insert at the 11th position the correct id (1 for air humidity)
|
|||
air_list[air_count] = 1; //inserting the correct id
|
|||
air_count = 0; //start from the begining and update the values
|
|||
|
|||
io.on('connection', socket => { //then send the list to client
|
|||
console.log('We have a connection'); |
|||
socket.emit('graph', air_list); |
|||
}); |
|||
} |
|||
|
|||
if(hum_result < 50){ //if humidity decreased by 50% then send an email to kampe.test@gmail.com to warn him
|
|||
let mailOptions = { |
|||
from: process.env.EMAIL, |
|||
to: 'kampe.test@gmail.com', |
|||
subject: 'ATTENTION', |
|||
text: 'Humidity decreased alot!' |
|||
}; |
|||
|
|||
transporter.sendMail(mailOptions, function(err, data) { //sending the email
|
|||
if (err){ |
|||
console.log('Error Occurs'); |
|||
} else { |
|||
console.log('Email sent (for air humidity).'); |
|||
} |
|||
}); |
|||
} |
|||
|
|||
} |
|||
} else if (request.body[2]) { |
|||
ground_list[ground_count] = parseInt(request.body[2]); //inserting the new value to list ground_list at ground_count position
|
|||
console.log('List of air humidity:',ground_list); //for better understanding
|
|||
ground_count +=1; //increasing the air_count counter
|
|||
|
|||
if(ground_count == 10){ //if we have 10 values in the list then insert at the 11th position the correct id (2 for ground humidity)
|
|||
ground_list[ground_count] = 2; //inserting the correct id
|
|||
ground_count = 0; //start from the begining and update the values
|
|||
|
|||
io.on('connection', socket => { //then send the list to client
|
|||
console.log('We have a connection'); |
|||
socket.emit('graph', ground_list); |
|||
}); |
|||
} |
|||
console.log('Ground humidity value: ',request.body[2]); |
|||
database.insert({measure: 'ground humidity',value:parseInt(request.body[2])}); //inserting the new values to database
|
|||
|
|||
} else if (request.body[3]) { |
|||
beauf_list[beauf_count] = parseInt(request.body[3]); //inserting the new value to list beauf_list at beauf_count position
|
|||
console.log('List of beaufort:',beauf_list); //for better understanding
|
|||
beauf_count +=1; //increasing the air_count counter
|
|||
|
|||
if(beauf_count == 10){ //if we have 10 values in the list then insert at the 11th position the correct id (3 for beaufort)
|
|||
beauf_list[beauf_count] = 3; //inserting the correct id
|
|||
beauf_count = 0; //start from the begining and update the values
|
|||
|
|||
io.on('connection', socket => { //then send the list to client
|
|||
console.log('We have a connection'); |
|||
socket.emit('graph', beauf_list); |
|||
}); |
|||
} |
|||
console.log('Ground beaufort value: ',request.body[3]); |
|||
database.insert({measure: 'beaufort',value:parseInt(request.body[3])}); //inserting the new values to database
|
|||
|
|||
} |
|||
|
|||
response.end(); //ending the event
|
|||
|
|||
}); |
|||
|
|||
http.listen(3000, () => { console.log('Server is listening...'); }); //listening at port 3000
|
|||
|
|||
Loading…
Reference in new issue