From ab9c2eccbbc725f48e5eca2675ca31632e6792af Mon Sep 17 00:00:00 2001
From: Alexey Kasyanchuk <degitx@gmail.com>
Date: Sat, 21 Jan 2017 00:16:56 +0300
Subject: [PATCH] =?UTF-8?q?=D0=BC=D0=B8=D0=BD=D0=B8=D1=84=D0=B8=D0=BA?=
 =?UTF-8?q?=D1=81=D1=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/udp-tracker-request.js |  2 +-
 patches/clear.js           | 38 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 39 insertions(+), 1 deletion(-)
 create mode 100644 patches/clear.js

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);
+        });
+});