diff --git a/lib/udp-tracker-request.js b/lib/udp-tracker-request.js index a54c770..77083be 100644 --- a/lib/udp-tracker-request.js +++ b/lib/udp-tracker-request.js @@ -33,7 +33,7 @@ let connectTracker = function(connection) { // очистка старых соединений for(transaction in requests) { - if((new Date).getTime() - requests[transaction].date.getTime() > 60 * 1000) { + if((new Date).getTime() - requests[transaction].date.getTime() > 3 * 60 * 1000) { delete requests[transaction]; } } diff --git a/patches/clear.js b/patches/clear.js new file mode 100644 index 0000000..f96f49a --- /dev/null +++ b/patches/clear.js @@ -0,0 +1,38 @@ +const mysql = require('mysql'); +const torrentTypeDetect = require('../lib/content'); + +const mysqlSettings = { + host : 'localhost', + user : 'btsearch', + password : 'pirateal100x', + database : 'btsearch' +}; + +socketMysql = mysql.createConnection(mysqlSettings); + +socketMysql.connect(function(mysqlError) { + if (mysqlError) { + console.error('error connecting: ' + mysqlError.stack); + return; + } + + let inc = 0; + socketMysql.query('SELECT * FROM `torrents` WHERE `seeders` IS NULL AND files > 1000', function (error, torrents, fields) { + torrents.forEach(({hash, name}) => { + console.log(name + 'deleted'); + socketMysql.query('DELETE FROM `files` WHERE hash = ?', hash, function (error, files, fields) { + if(!files) + console.log(error); + + console.log(name + ' files deleted') + }); + socketMysql.query('DELETE FROM `torrents` WHERE hash = ?', hash, function (error, files, fields) { + if(!files) + console.log(error); + + console.log(name + ' torrent deleted') + }); + }); + console.log('affected torrents: ' + torrents.length); + }); +});