1 files changed, 23 insertions, 38 deletions
diff --git a/module/plugins/hooks/RestartFailed.py b/module/plugins/hooks/RestartFailed.py
index 85553d738..3aef6f8cd 100644
--- a/module/plugins/hooks/RestartFailed.py
+++ b/module/plugins/hooks/RestartFailed.py
@@ -1,57 +1,42 @@
 # -*- coding: utf-8 -*-
 
-"""
-    This program is free software; you can redistribute it and/or modify
-    it under the terms of the GNU General Public License as published by
-    the Free Software Foundation; either version 3 of the License,
-    or (at your option) any later version.
-
-    This program is distributed in the hope that it will be useful,
-    but WITHOUT ANY WARRANTY; without even the implied warranty of
-    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
-    See the GNU General Public License for more details.
-
-    You should have received a copy of the GNU General Public License
-    along with this program; if not, see <http://www.gnu.org/licenses/>.
-
-    @author: Walter Purcaro
-"""
-
 from module.plugins.Hook import Hook
 
 
 class RestartFailed(Hook):
     __name__ = "RestartFailed"
-    __version__ = "1.53"
-    __description__ = """Periodically restart all failed downloads in queue"""
+    __type__ = "hook"
+    __version__ = "1.55"
+
     __config__ = [("activated", "bool", "Activated", False),
-                  ("interval", "int", "Interval in minutes", 90)]
+                  ("interval", "int", "Check interval in minutes", 90)]
+
+    __description__ = """Periodically restart all failed downloads in queue"""
     __author_name__ = "Walter Purcaro"
     __author_mail__ = "vuolter@gmail.com"
 
-    event_list = ["pluginConfigChanged"]
-
-    MIN_INTERVAL = 15 * 60  # seconds
+    MIN_INTERVAL = 15 * 60  #: 15m minimum check interval (value is in seconds)
 
-    def periodical(self):
-        self.logDebug("Restart all failed downloads now")
-        self.core.api.restartFailed()
+    event_list = ["pluginConfigChanged"]
 
-    def restartPeriodical(self, interval):
-        self.logDebug("Set periodical interval to %s seconds" % interval)
-        if self.cb:
-            self.core.scheduler.removeJob(self.cb)
-        self.interval = interval
-        self.cb = self.core.scheduler.addJob(interval, self._periodical, threaded=False)
 
     def pluginConfigChanged(self, plugin, name, value):
-        value *= 60
         if name == "interval":
-            if self.interval != value > self.MIN_INTERVAL:
-                self.restartPeriodical(value)
+            interval = value * 60
+            if self.MIN_INTERVAL <= interval != self.interval:
+                self.core.scheduler.removeJob(self.cb)
+                self.interval = interval
+                self.initPeriodical()
             else:
-                self.logWarning("Cannot change interval: given value is equal to the current or \
-                                 smaller than %s seconds" % self.MIN_INTERVAL)
+                self.logDebug("Invalid interval value, kept current")
+
+    def periodical(self):
+        self.logInfo("Restart failed downloads")
+        self.api.restartFailed()
+
+    def setup(self):
+        self.api = self.core.api
+        self.interval = self.MIN_INTERVAL
 
     def coreReady(self):
-        self.pluginConfigChanged(plugin="RestartFailed", name="interval", value=self.getConfig("interval"))
+        self.pluginConfigChanged(self.__name__, "interval", self.getConfig("interval"))