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-19 15:06:26 +03:00
parent b6863af73e
commit e6de177361
1 changed files with 22 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
index.js
View File

@ -428,10 +428,6 @@ client.on('complete', function (metadata, infohash, rinfo) {
filesCount = metadata.info.files.length; filesCount = metadata.info.files.length;
size = 0; size = 0;
pushDatabaseBalance();
listenerMysql.query('DELETE FROM files WHERE hash = ?', hash, function (err, result) {
popDatabaseBalance();
})
for(let i = 0; i < metadata.info.files.length; i++) for(let i = 0; i < metadata.info.files.length; i++)
{ {
let file = metadata.info.files[i]; let file = metadata.info.files[i];
@ -442,15 +438,6 @@ client.on('complete', function (metadata, infohash, rinfo) {
size: file.length, size: file.length,
}; };
filesArray.push(fileQ); filesArray.push(fileQ);
pushDatabaseBalance();
let query = listenerMysql.query('INSERT INTO files SET ?', fileQ, function(err, result) {
popDatabaseBalance();
if(!result) {
console.log(fileQ);
console.error(err);
}
});
size += file.length; size += file.length;
} }
} }
@ -462,16 +449,30 @@ client.on('complete', function (metadata, infohash, rinfo) {
size: size, size: size,
}; };
filesArray.push(fileQ); filesArray.push(fileQ);
pushDatabaseBalance();
let query = listenerMysql.query('INSERT INTO files SET ?', fileQ, function(err, result) {
popDatabaseBalance();
if(!result) {
console.log(fileQ);
console.error(err);
}
});
} }
listenerMysql.query('SELECT count(*) as files_count FROM files WHERE hash = ?', [hash], function(err, rows) {
const db_files = rows[0]['files_count'];
if(db_files !== filesCount)
{
pushDatabaseBalance();
listenerMysql.query('DELETE FROM files WHERE hash = ?', hash, function (err, result) {
popDatabaseBalance();
filesArray.forEach((file) => {
pushDatabaseBalance();
listenerMysql.query('INSERT INTO files SET ?', file, function(err, result) {
popDatabaseBalance();
if(!result) {
console.log(fileQ);
console.error(err);
}
});
});
})
}
})
var torrentQ = { var torrentQ = {
hash: hash, hash: hash,
name: metadata.info.name, name: metadata.info.name,