Xefir/PyNyaaTa
Archived
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

Fix double error entry

Browse Source
This commit is contained in:
Michel Roux 2019-12-13 20:10:04 +01:00
parent 1d9e44bca9
commit ee710dff0d
1 changed files with 1 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
connectors.py
View File

@ -49,6 +49,7 @@ class Cache:
if cached_data['timeout'] > timestamp: if cached_data['timeout'] > timestamp:
connector.data = cached_data['data'] connector.data = cached_data['data']
connector.is_more = cached_data['is_more'] connector.is_more = cached_data['is_more']
connector.on_error = False
return return
ret = f(*args, **kwds) ret = f(*args, **kwds)
@ -156,17 +157,6 @@ class Connector(ABC):
return {'http_code': http_code, 'output': output} return {'http_code': http_code, 'output': output}
@staticmethod
def abord_on_success(f):
@wraps(f)
def wrapper(*args, **kwds):
connector = args[0]
if not connector.on_error:
return
return f(*args, **kwds)
return wrapper
@staticmethod @staticmethod
def get_instance(url, query): def get_instance(url, query):
if 'nyaa.si' in url: if 'nyaa.si' in url:
@ -215,7 +205,6 @@ class Nyaa(Connector):
self.search() self.search()
@ConnectorCache.cache_data @ConnectorCache.cache_data
@Connector.abord_on_success
def search(self): def search(self):
response = self.curl_content(self.get_full_search_url()) response = self.curl_content(self.get_full_search_url())
@ -289,7 +278,6 @@ class Pantsu(Connector):
self.search() self.search()
@ConnectorCache.cache_data @ConnectorCache.cache_data
@Connector.abord_on_success
def search(self): def search(self):
response = self.curl_content(self.get_full_search_url()) response = self.curl_content(self.get_full_search_url())
@ -374,7 +362,6 @@ class YggTorrent(Connector):
self.search() self.search()
@ConnectorCache.cache_data @ConnectorCache.cache_data
@Connector.abord_on_success
def search(self): def search(self):
if self.category: if self.category:
response = self.curl_content(self.get_full_search_url()) response = self.curl_content(self.get_full_search_url())
@ -451,7 +438,6 @@ class AnimeUltime(Connector):
return '%s/%s-0-1/%s' % (self.base_url, sort_type, from_date) return '%s/%s-0-1/%s' % (self.base_url, sort_type, from_date)
@ConnectorCache.cache_data @ConnectorCache.cache_data
@Connector.abord_on_success
def search(self): def search(self):
response = self.curl_content(self.get_full_search_url(), {'search': self.query}) response = self.curl_content(self.get_full_search_url(), {'search': self.query})
@ -498,7 +484,6 @@ class AnimeUltime(Connector):
self.on_error = False self.on_error = False
@ConnectorCache.cache_data @ConnectorCache.cache_data
@Connector.abord_on_success
def get_history(self): def get_history(self):
response = self.curl_content(self.get_full_search_url()) response = self.curl_content(self.get_full_search_url())