Merge branch 'refs/heads/develop'
This commit is contained in:
@@ -127,7 +127,7 @@ class Plugin(object):
|
|||||||
return False
|
return False
|
||||||
|
|
||||||
# http request
|
# http request
|
||||||
def urlopen(self, url, timeout = 30, data = None, headers = None, files = None, show_error = True, return_raw = False):
|
def urlopen(self, url, timeout = 30, data = None, headers = None, files = None, show_error = True):
|
||||||
url = urllib2.quote(ss(url), safe = "%/:=&?~#+!$,;'@()*[]")
|
url = urllib2.quote(ss(url), safe = "%/:=&?~#+!$,;'@()*[]")
|
||||||
|
|
||||||
if not headers: headers = {}
|
if not headers: headers = {}
|
||||||
@@ -172,7 +172,7 @@ class Plugin(object):
|
|||||||
log.info('Opening url: %s %s, data: %s', (method, url, [x for x in data.iterkeys()] if isinstance(data, dict) else 'with data'))
|
log.info('Opening url: %s %s, data: %s', (method, url, [x for x in data.iterkeys()] if isinstance(data, dict) else 'with data'))
|
||||||
response = r.request(method, url, verify = False, **kwargs)
|
response = r.request(method, url, verify = False, **kwargs)
|
||||||
|
|
||||||
data = response.content if return_raw else response.text
|
data = response.content
|
||||||
|
|
||||||
self.http_failed_request[host] = 0
|
self.http_failed_request[host] = 0
|
||||||
except (IOError, MaxRetryError, Timeout):
|
except (IOError, MaxRetryError, Timeout):
|
||||||
|
|||||||
@@ -93,7 +93,7 @@ class FileManager(Plugin):
|
|||||||
return dest
|
return dest
|
||||||
|
|
||||||
try:
|
try:
|
||||||
filedata = self.urlopen(url, return_raw = True, **urlopen_kwargs)
|
filedata = self.urlopen(url, **urlopen_kwargs)
|
||||||
except:
|
except:
|
||||||
log.error('Failed downloading file %s: %s', (url, traceback.format_exc()))
|
log.error('Failed downloading file %s: %s', (url, traceback.format_exc()))
|
||||||
return False
|
return False
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ class IMDBBase(Automation, RSS):
|
|||||||
interval = 1800
|
interval = 1800
|
||||||
|
|
||||||
def getInfo(self, imdb_id):
|
def getInfo(self, imdb_id):
|
||||||
return fireEvent('movie.info', identifier = imdb_id, merge = True)
|
return fireEvent('movie.info', identifier = imdb_id, extended = False, merge = True)
|
||||||
|
|
||||||
|
|
||||||
class IMDBWatchlist(IMDBBase):
|
class IMDBWatchlist(IMDBBase):
|
||||||
|
|||||||
@@ -164,7 +164,7 @@ class YarrProvider(Provider):
|
|||||||
try:
|
try:
|
||||||
if not self.login():
|
if not self.login():
|
||||||
log.error('Failed downloading from %s', self.getName())
|
log.error('Failed downloading from %s', self.getName())
|
||||||
return self.urlopen(url, return_raw = True)
|
return self.urlopen(url)
|
||||||
except:
|
except:
|
||||||
log.error('Failed downloading from %s: %s', (self.getName(), traceback.format_exc()))
|
log.error('Failed downloading from %s: %s', (self.getName(), traceback.format_exc()))
|
||||||
|
|
||||||
@@ -173,7 +173,7 @@ class YarrProvider(Provider):
|
|||||||
|
|
||||||
def download(self, url = '', nzb_id = ''):
|
def download(self, url = '', nzb_id = ''):
|
||||||
try:
|
try:
|
||||||
return self.urlopen(url, headers = {'User-Agent': Env.getIdentifier()}, show_error = False, return_raw = True)
|
return self.urlopen(url, headers = {'User-Agent': Env.getIdentifier()}, show_error = False)
|
||||||
except:
|
except:
|
||||||
log.error('Failed getting nzb from %s: %s', (self.getName(), traceback.format_exc()))
|
log.error('Failed getting nzb from %s: %s', (self.getName(), traceback.format_exc()))
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
from couchpotato.core.event import addEvent
|
from couchpotato.core.event import addEvent
|
||||||
from couchpotato.core.helpers.encoding import simplifyString, toUnicode
|
from couchpotato.core.helpers.encoding import simplifyString, toUnicode
|
||||||
|
from couchpotato.core.helpers.variable import tryInt
|
||||||
from couchpotato.core.logger import CPLog
|
from couchpotato.core.logger import CPLog
|
||||||
from couchpotato.core.providers.info.base import MovieProvider
|
from couchpotato.core.providers.info.base import MovieProvider
|
||||||
import tmdb3
|
import tmdb3
|
||||||
@@ -66,7 +67,7 @@ class TheMovieDb(MovieProvider):
|
|||||||
if not identifier:
|
if not identifier:
|
||||||
return {}
|
return {}
|
||||||
|
|
||||||
cache_key = 'tmdb.cache.%s' % identifier
|
cache_key = 'tmdb.cache.%s%s' % (identifier, '.ex' if extended else '')
|
||||||
result = self.getCache(cache_key)
|
result = self.getCache(cache_key)
|
||||||
|
|
||||||
if not result:
|
if not result:
|
||||||
@@ -88,7 +89,7 @@ class TheMovieDb(MovieProvider):
|
|||||||
|
|
||||||
def parseMovie(self, movie, extended = True):
|
def parseMovie(self, movie, extended = True):
|
||||||
|
|
||||||
cache_key = 'tmdb.cache.%s' % movie.id
|
cache_key = 'tmdb.cache.%s%s' % (movie.id, '.ex' if extended else '')
|
||||||
movie_data = self.getCache(cache_key)
|
movie_data = self.getCache(cache_key)
|
||||||
|
|
||||||
if not movie_data:
|
if not movie_data:
|
||||||
@@ -137,7 +138,7 @@ class TheMovieDb(MovieProvider):
|
|||||||
'imdb': movie.imdb,
|
'imdb': movie.imdb,
|
||||||
'runtime': movie.runtime,
|
'runtime': movie.runtime,
|
||||||
'released': str(movie.releasedate),
|
'released': str(movie.releasedate),
|
||||||
'year': year,
|
'year': tryInt(year, None),
|
||||||
'plot': movie.overview,
|
'plot': movie.overview,
|
||||||
'genres': genres,
|
'genres': genres,
|
||||||
'collection': getattr(movie.collection, 'name', None),
|
'collection': getattr(movie.collection, 'name', None),
|
||||||
|
|||||||
Reference in New Issue
Block a user