evan/rats-search
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

перенос обновление статистики в листенер

Browse Source
This commit is contained in:
Alexey Kasyanchuk 2017-01-03 06:25:25 +03:00
parent d8239466ce
commit 253162dca8
1 changed files with 31 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
index.js
View File

@ -77,29 +77,6 @@ app.get('*', function(req, res)
// start
// обновление статистики
setInterval(() => {
let stats = {};
socketMysql.query('SELECT COUNT(*) as tornum FROM `torrents`', function (error, rows, fields) {
stats.torrents = rows[0].tornum;
socketMysql.query('SELECT COUNT(*) as filesnum, SUM(`size`) as filesizes FROM `files`', function (error, rows, fields) {
stats.files = rows[0].filesnum;
stats.size = rows[0].filesizes;
io.sockets.emit('newStatistic', stats);
socketMysql.query('DELETE FROM `statistic`', function (err, result) {
if(!result) {
console.error(err);
}
socketMysql.query('INSERT INTO `statistic` SET ?', stats, function(err, result) {
if(!result) {
console.error(err);
}
});
})
});
});
}, 60 * 1000)
io.on('connection', function(socket)
{
function baseRowData(row)
@ -222,6 +199,37 @@ let popDatabaseBalance = () => {
}
};
// обновление статистики
setInterval(() => {
let stats = {};
pushDatabaseBalance();
listenerMysql.query('SELECT COUNT(*) as tornum FROM `torrents`', function (error, rows, fields) {
popDatabaseBalance();
stats.torrents = rows[0].tornum;
pushDatabaseBalance();
listenerMysql.query('SELECT COUNT(*) as filesnum, SUM(`size`) as filesizes FROM `files`', function (error, rows, fields) {
popDatabaseBalance();
stats.files = rows[0].filesnum;
stats.size = rows[0].filesizes;
io.sockets.emit('newStatistic', stats);
pushDatabaseBalance();
listenerMysql.query('DELETE FROM `statistic`', function (err, result) {
popDatabaseBalance();
if(!result) {
console.error(err);
}
pushDatabaseBalance();
listenerMysql.query('INSERT INTO `statistic` SET ?', stats, function(err, result) {
popDatabaseBalance();
if(!result) {
console.error(err);
}
});
})
});
});
}, 60 * 1000)
client.on('complete', function (metadata, infohash, rinfo) {
console.log('writing torrent to db');
const hash = infohash.toString('hex');