summaryrefslogtreecommitdiffstats
path: root/module/plugins
diff options
context:
space:
mode:
Diffstat (limited to 'module/plugins')
-rw-r--r--module/plugins/internal/Hoster.py13
-rw-r--r--module/plugins/internal/Plugin.py8
-rw-r--r--module/plugins/internal/SimpleHoster.py4
-rw-r--r--module/plugins/internal/XFSHoster.py2
4 files changed, 14 insertions, 13 deletions
diff --git a/module/plugins/internal/Hoster.py b/module/plugins/internal/Hoster.py
index a77ef05dd..bdb5c4746 100644
--- a/module/plugins/internal/Hoster.py
+++ b/module/plugins/internal/Hoster.py
@@ -106,7 +106,7 @@ class Hoster(Plugin):
def _log(self, level, plugintype, pluginname, messages):
log = getattr(self.pyload.log, level)
- msg = " | ".join(decode(a).strip() for a in messages if a)
+ msg = u" | ".join(decode(a).strip() for a in messages if a)
log("%(plugintype)s %(pluginname)s[%(id)s]: %(msg)s"
% {'plugintype': plugintype.upper(),
'pluginname': pluginname,
@@ -207,12 +207,13 @@ class Hoster(Plugin):
def set_reconnect(self, reconnect):
- reconnect = bool(reconnect)
+ if reconnect:
+ self.log_info(_("Requesting line reconnection...")
+ else:
+ self.log_debug("Reconnect: %s" % reconnect)
- self.log_info(_("RECONNECT ") + ("enabled" if reconnect else "disabled"))
self.log_debug("Previous wantReconnect: %s" % self.wantReconnect)
-
- self.wantReconnect = reconnect
+ self.wantReconnect = bool(reconnect)
def set_wait(self, seconds, reconnect=None):
@@ -225,7 +226,7 @@ class Hoster(Plugin):
wait_time = max(int(seconds), 1)
wait_until = time.time() + wait_time + 1
- self.log_info(_("WAIT %d seconds") % wait_time)
+ self.log_info(_("Waiting %d seconds...") % wait_time)
self.log_debug("Previous waitUntil: %f" % self.pyfile.waitUntil)
self.pyfile.waitUntil = wait_until
diff --git a/module/plugins/internal/Plugin.py b/module/plugins/internal/Plugin.py
index 47648e2fb..f6f7258fa 100644
--- a/module/plugins/internal/Plugin.py
+++ b/module/plugins/internal/Plugin.py
@@ -90,11 +90,11 @@ def which(program):
return exe_file
-def seconds_to_midnight(gmt=None):
- if gmt is None:
+def seconds_to_midnight(utc=None):
+ if utc is None:
now = datetime.datetime.today()
else:
- now = datetime.datetime.utcnow() + datetime.timedelta(hours=gmt)
+ now = datetime.datetime.utcnow() + datetime.timedelta(hours=utc)
midnight = now.replace(hour=0, minute=10, second=0, microsecond=0) + datetime.timedelta(days=1)
@@ -212,7 +212,7 @@ class Plugin(object):
def _log(self, level, plugintype, pluginname, messages):
log = getattr(self.pyload.log, level)
- msg = " | ".join(encode(a).strip() for a in messages if a)
+ msg = u" | ".join(decode(a).strip() for a in messages if a)
log("%(plugintype)s %(pluginname)s: %(msg)s"
% {'plugintype': plugintype.upper(),
'pluginname': pluginname,
diff --git a/module/plugins/internal/SimpleHoster.py b/module/plugins/internal/SimpleHoster.py
index fb55ef762..365fad35e 100644
--- a/module/plugins/internal/SimpleHoster.py
+++ b/module/plugins/internal/SimpleHoster.py
@@ -368,7 +368,7 @@ class SimpleHoster(Hoster):
self.log_warning(self.info['error'])
if re.search('da(il)?y|today', errmsg, re.I):
- wait_time = seconds_to_midnight(gmt=2)
+ wait_time = seconds_to_midnight()
else:
wait_time = sum(int(v) * {'hr': 3600, 'hour': 3600, 'min': 60, 'sec': 1, "": 1}[u.lower()] for v, u in
re.findall(r'(\d+)\s*(hr|hour|min|sec|)', errmsg, re.I))
@@ -393,7 +393,7 @@ class SimpleHoster(Hoster):
if re.search('limit|wait|slot', errmsg, re.I):
if re.search("da(il)?y|today", errmsg):
- wait_time = seconds_to_midnight(gmt=2)
+ wait_time = seconds_to_midnight()
else:
wait_time = sum(int(v) * {'hr': 3600, 'hour': 3600, 'min': 60, 'sec': 1, "": 1}[u.lower()] for v, u in
re.findall(r'(\d+)\s*(hr|hour|min|sec|)', errmsg, re.I))
diff --git a/module/plugins/internal/XFSHoster.py b/module/plugins/internal/XFSHoster.py
index 145efcd8e..d83e3cb78 100644
--- a/module/plugins/internal/XFSHoster.py
+++ b/module/plugins/internal/XFSHoster.py
@@ -163,7 +163,7 @@ class XFSHoster(SimpleHoster):
self.retry(20, 3 * 60, _("Can not leech file"))
elif 'today' in stmsg:
- self.retry(delay=seconds_to_midnight(gmt=2), msg=_("You've used all Leech traffic today"))
+ self.retry(delay=seconds_to_midnight(), msg=_("You've used all Leech traffic today"))
else:
self.fail(stmsg)