diff --git a/serwer/app/index.js b/serwer/app/index.js
index 61a4108..f8c10dd 100644
--- a/serwer/app/index.js
+++ b/serwer/app/index.js
@@ -12,6 +12,17 @@ var con = mysql.createConnection({
insecureAuth: true
});
+var pool = mysql.createPool({
+ host: process.env.MYSQLHOST,
+ user: process.env.MYSQLUSER,
+ password: process.env.MYSQLPASS,
+ port: process.env.MYSQLPORT,
+ database: process.env.MYSQLDB,
+ waitForConnections: true,
+ connectionLimit: 10,
+ queueLimit: 0
+});
+
let attempts = 0;
const maxAttempts = 5;
@@ -105,13 +116,13 @@ function tryConnect() {
var login = req.body.login;
var password = req.body.password;
//sprawdź czy istnieje taki login i hasło
- con.query('SELECT * FROM login WHERE login = ? AND haslo = SHA1(?) AND aktywne = 1', [login, password], function(err, result) {
+ pool.query('SELECT * FROM login WHERE login = ? AND haslo = SHA1(?) AND aktywne = 1', [login, password], function(err, result) {
if (err) throw err;
if (result.length > 0) {
//utwórz token
var token = makeid(32);
//zapisz token do bazy
- con.query('INSERT INTO tokeny (token, typ, userId) VALUES (?, 1, ?)', [token, result[0].id], function(err, result) {
+ pool.query('INSERT INTO tokeny (token, typ, userId) VALUES (?, 1, ?)', [token, result[0].id], function(err, result) {
if (err) throw err;
//ustaw ciasteczko
res.setHeader('Set-Cookie', cookie.serialize('token', token, {
@@ -145,13 +156,13 @@ function tryConnect() {
app.post('/loginliczacy', function(req, res) {
var password = req.body.password;
//sprawdź czy istnieje taki login i hasło
- con.query('SELECT * FROM liczacy WHERE qr = ? AND aktywne = 1', [password], function(err, result) {
+ pool.query('SELECT * FROM liczacy WHERE qr = ? AND aktywne = 1', [password], function(err, result) {
if (err) throw err;
if (result.length > 0) {
//utwórz token
var token = makeid(32);
//zapisz token do bazy
- con.query('INSERT INTO tokenyLiczacy (token, typ, userId) VALUES (?, 1, ?)', [token, result[0].id], function(err, result) {
+ pool.query('INSERT INTO tokenyLiczacy (token, typ, userId) VALUES (?, 1, ?)', [token, result[0].id], function(err, result) {
if (err) throw err;
//ustaw ciasteczko
res.setHeader('Set-Cookie', cookie.serialize('liczacy', token, {
@@ -204,7 +215,7 @@ function tryConnect() {
toReturn += '
';
//wypisz sumę zebranych pieniędzy, sumę poszczególnych nominałów
//pobierz wszystkie rozliczenia
- con.query('SELECT * FROM rozliczenie WHERE aktywne = 1', function(err, result) {
+ pool.query('SELECT * FROM rozliczenie WHERE aktywne = 1', function(err, result) {
if (err) throw err;
var suma = 0;
var sumaTerminal = 0;
@@ -266,7 +277,7 @@ function tryConnect() {
//SELECT * FROM `SumaZebranaPrzezWolontariuszy` ORDER BY `SumaZebranaPrzezWolontariuszy`.`suma` ASC LIMIT 10;
toReturn += '';
toReturn += 'Wolontariusz | Suma |
';
- con.query('SELECT numerIdentyfikatora, imie, nazwisko, suma FROM `SumaZebranaPrzezWolontariuszy` ORDER BY `SumaZebranaPrzezWolontariuszy`.`suma` ASC LIMIT 10;', function(err, result) {
+ pool.query('SELECT numerIdentyfikatora, imie, nazwisko, suma FROM `SumaZebranaPrzezWolontariuszy` ORDER BY `SumaZebranaPrzezWolontariuszy`.`suma` ASC LIMIT 10;', function(err, result) {
if (err) throw err;
result.forEach(function(row) {
toReturn += '' + row.numerIdentyfikatora + ' | ' + row.suma + ' |
';
@@ -278,7 +289,7 @@ function tryConnect() {
toReturn += 'Najwięcej puszek przeliczonych
';
toReturn += '';
toReturn += 'Liczący | Suma |
';
- con.query("SELECT idLiczacego, imie, nazwisko, sumaPrzeliczona FROM `sumaPrzeliczona` ORDER BY `sumaPrzeliczona`.`sumaPrzeliczona` DESC LIMIT 10;", function(err, result) {
+ pool.query("SELECT idLiczacego, imie, nazwisko, sumaPrzeliczona FROM `sumaPrzeliczona` ORDER BY `sumaPrzeliczona`.`sumaPrzeliczona` DESC LIMIT 10;", function(err, result) {
if (err) throw err;
result.forEach(function(row) {
toReturn += '' + row.idLiczacego + ' | ' + row.sumaPrzeliczona + ' |
';
@@ -298,7 +309,7 @@ function tryConnect() {
//sprawdź czy token istnieje i jest aktywny
var cookies = cookie.parse(req.headers.cookie || '');
var token = cookies.token;
- con.query('UPDATE tokeny SET aktywny = 0 WHERE token = ?', [token], function(err, result) {
+ pool.query('UPDATE tokeny SET aktywny = 0 WHERE token = ?', [token], function(err, result) {
if (err) throw err;
res.redirect('/panel/login');
loger(fs, 'Wylogowano użytkownika ' + req.user.kto, 'info');