summaryrefslogtreecommitdiffstats
path: root/module/plugins/internal/Hook.py
diff options
context:
space:
mode:
authorGravatar Walter Purcaro <vuolter@users.noreply.github.com> 2015-07-19 09:42:34 +0200
committerGravatar Walter Purcaro <vuolter@users.noreply.github.com> 2015-07-19 09:42:34 +0200
commit502517f37c7540b0bddb092e69386d9d6f08800c (patch)
treea90f2143063538f466b0283383a97067f7ea829d /module/plugins/internal/Hook.py
parentImprove fixurl method (diff)
downloadpyload-502517f37c7540b0bddb092e69386d9d6f08800c.tar.xz
Fix addons
Diffstat (limited to 'module/plugins/internal/Hook.py')
-rw-r--r--module/plugins/internal/Hook.py238
1 files changed, 4 insertions, 234 deletions
diff --git a/module/plugins/internal/Hook.py b/module/plugins/internal/Hook.py
index 162c9ecbf..a17037a11 100644
--- a/module/plugins/internal/Hook.py
+++ b/module/plugins/internal/Hook.py
@@ -1,34 +1,14 @@
# -*- coding: utf-8 -*-
-import traceback
+from module.plugins.internal.Addon import Addon
-from module.plugins.internal.Plugin import Plugin
-
-class Expose(object):
- """
- Used for decoration to declare rpc services
- """
- def __new__(cls, f, *args, **kwargs):
- hookManager.addRPC(f.__module__, f.func_name, f.func_doc)
- return f
-
-
-def threaded(fn):
-
- def run(*args, **kwargs):
- hookManager.startThread(fn, *args, **kwargs)
-
- return run
-
-
-class Hook(Plugin):
+class Hook(Addon):
__name__ = "Hook"
__type__ = "hook"
- __version__ = "0.09"
+ __version__ = "0.10"
__config__ = [] #: [("name", "type", "desc", "default")]
- __threaded__ = [] #@TODO: Remove in 0.4.10
__description__ = """Base hook plugin"""
__license__ = "GPLv3"
@@ -38,215 +18,5 @@ class Hook(Plugin):
def __init__(self, core, manager):
- super(Hook, self).__init__(core)
-
- #: `HookManager`
- self.manager = manager
-
- #: Automatically register event listeners for functions, attribute will be deleted dont use it yourself
- self.event_map = {}
-
- #: Deprecated alternative to event_map
- #: List of events the plugin can handle, name the functions exactly like eventname.
- self.event_list = [] #@NOTE: dont make duplicate entries in event_map
-
- #: Callback of periodical job task, used by HookManager
- self.cb = None
- self.interval = 60
-
- self.setup()
- self.init_events()
+ super(Hook, self).__init__(core, manager)
self.init_periodical(10)
-
-
- def init_events(self):
- if self.event_map:
- for event, funcs in self.event_map.iteritems():
- if type(funcs) in (list, tuple):
- for f in funcs:
- self.manager.addEvent(event, getattr(self, f))
- else:
- self.manager.addEvent(event, getattr(self, funcs))
-
- #: Delete for various reasons
- self.event_map = None
-
- if self.event_list:
- self.log_debug("Deprecated method `event_list`, use `event_map` instead")
-
- for f in self.event_list:
- self.manager.addEvent(f, getattr(self, f))
-
- self.event_list = None
-
-
- def init_periodical(self, delay=0, threaded=False):
- self.cb = self.core.scheduler.addJob(max(0, delay), self._periodical, [threaded], threaded=threaded)
-
-
- #: Deprecated method, use `init_periodical` instead
- def initPeriodical(self, *args, **kwargs):
- return self.init_periodical(*args, **kwargs)
-
-
- def _periodical(self, threaded):
- if self.interval < 0:
- self.cb = None
- return
-
- try:
- self.periodical()
-
- except Exception, e:
- self.log_error(_("Error executing hook: %s") % e)
- if self.core.debug:
- traceback.print_exc()
-
- self.cb = self.core.scheduler.addJob(self.interval, self._periodical, [threaded], threaded=threaded)
-
-
- def periodical(self):
- pass
-
-
- def __repr__(self):
- return "<Hook %s>" % self.__name__
-
-
- def setup(self):
- """
- More init stuff if needed
- """
- pass
-
-
- def is_activated(self):
- """
- Checks if hook is activated
- """
- return self.get_config("activated")
-
-
- #: Deprecated method, use `is_activated` instead
- def isActivated(self, *args, **kwargs):
- return self.is_activated(*args, **kwargs)
-
-
- def deactivate(self):
- """
- Called when hook was deactivated
- """
- pass
-
-
- #: Deprecated method, use `deactivate` instead
- def unload(self, *args, **kwargs):
- return self.deactivate(*args, **kwargs)
-
-
- def activate(self):
- """
- Called when hook was activated
- """
- pass
-
-
- #: Deprecated method, use `activate` instead
- def coreReady(self, *args, **kwargs):
- return self.activate(*args, **kwargs)
-
-
- def exit(self):
- """
- Called by core.shutdown just before pyLoad exit
- """
- pass
-
-
- #: Deprecated method, use `exit` instead
- def coreExiting(self, *args, **kwargs):
- return self.exit(*args, **kwargs)
-
-
- def download_preparing(self, pyfile):
- pass
-
-
- #: Deprecated method, use `download_preparing` instead
- def downloadPreparing(self, *args, **kwargs):
- return self.download_preparing(*args, **kwargs)
-
-
- def download_finished(self, pyfile):
- pass
-
-
- #: Deprecated method, use `download_finished` instead
- def downloadFinished(self, *args, **kwargs):
- return self.download_finished(*args, **kwargs)
-
-
- def download_failed(self, pyfile):
- pass
-
-
- #: Deprecated method, use `download_failed` instead
- def downloadFailed(self, *args, **kwargs):
- return self.download_failed(*args, **kwargs)
-
-
- def package_finished(self, pypack):
- pass
-
-
- #: Deprecated method, use `package_finished` instead
- def packageFinished(self, *args, **kwargs):
- return self.package_finished(*args, **kwargs)
-
-
- def before_reconnect(self, ip):
- pass
-
-
- #: Deprecated method, use `before_reconnect` instead
- def beforeReconnecting(self, *args, **kwargs):
- return self.before_reconnect(*args, **kwargs)
-
-
- def after_reconnect(self, ip, oldip):
- pass
-
-
- #: Deprecated method, use `after_reconnect` instead
- def afterReconnecting(self, ip):
- return self.after_reconnect(ip, None)
-
-
- def captcha_task(self, task):
- """
- New captcha task for the plugin, it MUST set the handler and timeout or will be ignored
- """
- pass
-
-
- #: Deprecated method, use `captcha_task` instead
- def newCaptchaTask(self, *args, **kwargs):
- return self.captcha_task(*args, **kwargs)
-
-
- def captcha_correct(self, task):
- pass
-
-
- #: Deprecated method, use `captcha_correct` instead
- def captchaCorrect(self, *args, **kwargs):
- return self.captcha_correct(*args, **kwargs)
-
-
- def captcha_invalid(self, task):
- pass
-
-
- #: Deprecated method, use `captcha_invalid` instead
- def captchaInvalid(self, *args, **kwargs):
- return self.captcha_invalid(*args, **kwargs)