# Copyright 2004-2022 Davide Alberani # 2008 H. Turgut Uyar # # 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 2 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, write to the Free Software # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA """ This package provides the IMDbHTTPAccessSystem class used to access IMDb's data through the web interface. The :func:`imdb.IMDb` function will return an instance of this class when called with the ``accessSystem`` argument is set to "http" or "web" or "html" (this is the default). """ import ssl import warnings from codecs import lookup from urllib.parse import quote_plus from urllib.request import ( HTTPRedirectHandler, HTTPSHandler, ProxyHandler, build_opener, ) from imdb import IMDbBase from imdb._exceptions import IMDbDataAccessError, IMDbParserError from imdb.parser.http.logging import logger from imdb.utils import analyze_title from . import ( companyParser, listParser, movieParser, personParser, searchCompanyParser, searchKeywordParser, searchMovieAdvancedParser, searchMovieParser, searchPersonParser, showtimesParser, topBottomParser, ) # Logger for miscellaneous functions. _aux_logger = logger.getChild('aux') class _ModuleProxy: """A proxy to instantiate and access parsers.""" def __init__(self, module, defaultKeys=None): """Initialize a proxy for the given module; defaultKeys, if set, muste be a dictionary of values to set for instanced objects.""" if defaultKeys is None: defaultKeys = {} self._defaultKeys = defaultKeys self._module = module def __getattr__(self, name): """Called only when no look-up is found.""" _sm = self._module # Read the _OBJECTS dictionary to build the asked parser. if name in _sm._OBJECTS: _entry = _sm._OBJECTS[name] # Initialize the parser. kwds = {} parserClass = _entry[0][0] obj = parserClass(**kwds) attrsToSet = self._defaultKeys.copy() attrsToSet.update(_entry[1] or {}) # Set attribute to the object. for key in attrsToSet: setattr(obj, key, attrsToSet[key]) setattr(self, name, obj) return obj return getattr(_sm, name) class _FakeURLOpener: """Fake URLOpener object, used to return empty strings instead of errors. """ def __init__(self, url, headers): self.url = url self.headers = headers def read(self, *args, **kwds): return '' def close(self, *args, **kwds): pass def info(self, *args, **kwds): return self.headers class IMDbHTTPSHandler(HTTPSHandler, object): """HTTPSHandler that ignores the SSL certificate.""" def __init__(self, logger=None, *args, **kwds): self._logger = logger context = ssl.create_default_context() context.check_hostname = False context.verify_mode = ssl.CERT_NONE super().__init__(context=context) def http_error_default(self, url, fp, errcode, errmsg, headers): if errcode == 404: if self._logger: self._logger.warn('404 code returned for %s: %s (headers: %s)', url, errmsg, headers) return _FakeURLOpener(url, headers) raise IMDbDataAccessError( {'url': 'http:%s' % url, 'errcode': errcode, 'errmsg': errmsg, 'headers': headers, 'error type': 'http_error_default', 'proxy': self.get_proxy()} ) def open_unknown(self, fullurl, data=None): raise IMDbDataAccessError( {'fullurl': fullurl, 'data': str(data), 'error type': 'open_unknown', 'proxy': self.get_proxy()} ) def open_unknown_proxy(self, proxy, fullurl, data=None): raise IMDbDataAccessError( {'proxy': str(proxy), 'fullurl': fullurl, 'error type': 'open_unknown_proxy', 'data': str(data)} ) class IMDbHTTPRedirectHandler(HTTPRedirectHandler): """Custom handler to support redirect 308.""" def http_error_308(self, req, fp, code, msg, headers): # force handling of redirect 308 req.code = 302 code = 302 return super().http_error_302(req, fp, code, msg, headers) class IMDbURLopener: """Fetch web pages and handle errors.""" _logger = logger.getChild('urlopener') def __init__(self, *args, **kwargs): self._last_url = '' self.https_handler = IMDbHTTPSHandler(logger=self._logger) self.redirect_handler = IMDbHTTPRedirectHandler() self.proxies = {} self.addheaders = [] for header in ('User-Agent', 'User-agent', 'user-agent'): self.del_header(header) self.set_header('User-Agent', 'Mozilla/5.0 (X11; CrOS armv6l 13597.84.0) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36 Edg/107.0.1418.56') # noqa: E501 lang = kwargs.get('languages', 'en-us,en;q=0.5') self.set_header('Accept-Language', lang) def get_proxy(self): """Return the used proxy, or an empty string.""" return self.proxies.get('http', '') def set_proxy(self, proxy): """Set the proxy.""" if not proxy: if 'http' in self.proxies: del self.proxies['http'] else: if not proxy.lower().startswith('http://'): proxy = 'http://%s' % proxy self.proxies['http'] = proxy def set_header(self, header, value, _overwrite=True): """Set a default header.""" if _overwrite: self.del_header(header) self.addheaders.append((header, value)) def get_header(self, header): """Return the first value of a header, or None if not present.""" for index in range(len(self.addheaders)): if self.addheaders[index][0] == header: return self.addheaders[index][1] return None def del_header(self, header): """Remove a default header.""" for index in range(len(self.addheaders)): if self.addheaders[index][0] == header: del self.addheaders[index] break def retrieve_unicode(self, url, size=-1, timeout=None): """Retrieves the given URL, and returns a unicode string, trying to guess the encoding of the data (assuming utf8 by default)""" encode = None try: if size != -1: self.set_header('Range', 'bytes=0-%d' % size) handlers = [] if 'http' in self.proxies: proxy_handler = ProxyHandler({ 'http': self.proxies['http'], 'https': self.proxies['http'] }) handlers.append(proxy_handler) handlers.append(self.redirect_handler) handlers.append(self.https_handler) uopener = build_opener(*handlers) uopener.addheaders = list(self.addheaders) response = uopener.open(url, timeout=timeout) content = response.read() self._last_url = response.url # Maybe the server is so nice to tell us the charset... server_encode = response.headers.get_content_charset(None) # Otherwise, look at the content-type HTML meta tag. if server_encode is None and content: begin_h = content.find(b'text/html; charset=') if begin_h != -1: end_h = content[19 + begin_h:].find('"') if end_h != -1: server_encode = content[19 + begin_h:19 + begin_h + end_h] if server_encode: try: if lookup(server_encode): encode = server_encode except (LookupError, ValueError, TypeError): pass if size != -1: self.del_header('Range') response.close() except IOError as e: if size != -1: # Ensure that the Range header is removed. self.del_header('Range') raise IMDbDataAccessError( {'errcode': e.errno, 'errmsg': str(e.strerror), 'url': url, 'proxy': self.get_proxy(), 'exception type': 'IOError', 'original exception': e} ) if encode is None: encode = 'utf8' # The detection of the encoding is error prone... self._logger.warn('Unable to detect the encoding of the retrieved page [%s];' ' falling back to default utf8.', encode) if isinstance(content, str): return content return str(content, encode, 'replace') class IMDbHTTPAccessSystem(IMDbBase): """The class used to access IMDb's data through the web.""" accessSystem = 'http' _http_logger = logger def __init__(self, adultSearch=True, proxy=-1, cookie_id=-1, timeout=30, cookie_uu=None, *arguments, **keywords): """Initialize the access system.""" IMDbBase.__init__(self, *arguments, **keywords) self.urlOpener = IMDbURLopener(*arguments, **keywords) self._getRefs = True self._mdparse = False self.timeout = timeout if proxy != -1: self.set_proxy(proxy) _def = {'_modFunct': self._defModFunct, '_as': self.accessSystem} # Proxy objects. self.smProxy = _ModuleProxy(searchMovieParser, defaultKeys=_def) self.smaProxy = _ModuleProxy(searchMovieAdvancedParser, defaultKeys=_def) self.spProxy = _ModuleProxy(searchPersonParser, defaultKeys=_def) self.scompProxy = _ModuleProxy(searchCompanyParser, defaultKeys=_def) self.skProxy = _ModuleProxy(searchKeywordParser, defaultKeys=_def) self.mProxy = _ModuleProxy(movieParser, defaultKeys=_def) self.pProxy = _ModuleProxy(personParser, defaultKeys=_def) self.compProxy = _ModuleProxy(companyParser, defaultKeys=_def) self.topBottomProxy = _ModuleProxy(topBottomParser, defaultKeys=_def) self.listProxy = _ModuleProxy(listParser, defaultKeys=_def) self.stimesProxy = _ModuleProxy(showtimesParser, defaultKeys=_def) def _normalize_movieID(self, movieID): """Normalize the given movieID.""" try: return '%07d' % int(movieID) except ValueError as e: raise IMDbParserError('invalid movieID "%s": %s' % (movieID, e)) def _normalize_personID(self, personID): """Normalize the given personID.""" try: return '%07d' % int(personID) except ValueError as e: raise IMDbParserError('invalid personID "%s": %s' % (personID, e)) def _normalize_companyID(self, companyID): """Normalize the given companyID.""" try: return '%07d' % int(companyID) except ValueError as e: raise IMDbParserError('invalid companyID "%s": %s' % (companyID, e)) def get_imdbMovieID(self, movieID): """Translate a movieID in an imdbID; in this implementation the movieID _is_ the imdbID. """ return movieID def get_imdbPersonID(self, personID): """Translate a personID in an imdbID; in this implementation the personID _is_ the imdbID. """ return personID def get_imdbCompanyID(self, companyID): """Translate a companyID in an imdbID; in this implementation the companyID _is_ the imdbID. """ return companyID def get_proxy(self): """Return the used proxy or an empty string.""" return self.urlOpener.get_proxy() def set_proxy(self, proxy): """Set the web proxy to use. It should be a string like 'http://localhost:8080/'; if the string is empty, no proxy will be used. If set, the value of the environment variable HTTP_PROXY is automatically used. """ self.urlOpener.set_proxy(proxy) def set_cookies(self, cookie_id, cookie_uu): """Set a cookie to access an IMDb's account.""" warnings.warn("set_cookies has been deprecated") def del_cookies(self): """Remove the used cookie.""" warnings.warn("del_cookies has been deprecated") def do_adult_search(self, doAdult, cookie_id=None, cookie_uu=None): """If doAdult is true, 'adult' movies are included in the search results; cookie_id and cookie_uu are optional parameters to select a specific account (see your cookie or cookies.txt file.""" return def _retrieve(self, url, size=-1, _noCookies=False): """Retrieve the given URL.""" self._http_logger.debug('fetching url %s (size: %d)', url, size) ret = self.urlOpener.retrieve_unicode(url, size=size, timeout=self.timeout) return ret def _get_search_content(self, kind, ton, results): """Retrieve the web page for a given search. kind can be 'tt' (for titles), 'nm' (for names), or 'co' (for companies). ton is the title or the name to search. results is the maximum number of results to be retrieved.""" params = 'q=%s&s=%s' % (quote_plus(ton, safe=''), kind) if kind == 'ep': params = params.replace('s=ep&', 's=tt&ttype=ep&', 1) cont = self._retrieve(self.urls['find'] % params) # print 'URL:', imdbURL_find % params if cont.find('Your search returned more than') == -1 or \ cont.find("displayed the exact matches") == -1: return cont # The retrieved page contains no results, because too many # titles or names contain the string we're looking for. params = 'q=%s&ls=%s&lm=0' % (quote_plus(ton, safe=''), kind) size = 131072 + results * 512 return self._retrieve(self.urls['find'] % params, size=size) def _search_movie(self, title, results): cont = self._get_search_content('tt', title, results) return self.smProxy.search_movie_parser.parse(cont, results=results)['data'] def _get_list_content(self, list_, page): """Retrieve a list by it's id""" if list_.startswith('ls'): imdbUrl = self.urls['movie_list'] + list_ + '?page=' + str(page) else: warnings.warn("list type not recognized make sure it starts with 'ls'") return return self._retrieve(url=imdbUrl) def _get_movie_list(self, list_, results): page = 1 result_list = [] while True: cont = self._get_list_content(list_, page=page) result_part = self.listProxy.list_parser.parse(cont, results=results)['data'] if result_part: page += 1 result_list.extend(result_part) else: break return result_list def _get_search_movie_advanced_content(self, title=None, adult=None, results=None, sort=None, sort_dir=None): """Retrieve the web page for a given search. results is the maximum number of results to be retrieved.""" criteria = {} if title is not None: criteria['title'] = quote_plus(title, safe='') if adult: criteria['adult'] = 'include' if results is not None: criteria['count'] = str(results) if sort is not None: criteria['sort'] = sort if sort_dir is not None: criteria['sort'] = sort + ',' + sort_dir params = '&'.join(['%s=%s' % (k, v) for k, v in criteria.items()]) return self._retrieve(self.urls['search_movie_advanced'] % params) def _search_movie_advanced(self, title=None, adult=None, results=None, sort=None, sort_dir=None): cont = self._get_search_movie_advanced_content(title=title, adult=adult, results=results, sort=sort, sort_dir=sort_dir) return self.smaProxy.search_movie_advanced_parser.parse(cont, results=results)['data'] def _get_top_movies_or_tv_by_genres(self, genres, filter_content): cont = self._retrieve(self.urls['search_movie_advanced'] % 'genres=' + genres + filter_content) return self.smaProxy.search_movie_advanced_parser.parse(cont)['data'] def _search_episode(self, title, results): t_dict = analyze_title(title) if t_dict['kind'] == 'episode': title = t_dict['title'] cont = self._get_search_content('ep', title, results) return self.smProxy.search_movie_parser.parse(cont, results=results)['data'] def get_movie_main(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'reference') return self.mProxy.movie_parser.parse(cont, mdparse=self._mdparse) def get_movie_recommendations(self, movieID): # for some reason /tt0133093 is okay, but /tt0133093/ is not cont = self._retrieve((self.urls['movie_main'] % movieID).strip('/')) r = {'info sets': ('recommendations',), 'data': {}} ret = self.mProxy.movie_parser.parse(cont, mdparse=self._mdparse) if 'data' in ret and 'recommendations' in ret['data'] and ret['data']['recommendations']: r['data']['recommendations'] = ret['data']['recommendations'] return r def get_movie_full_credits(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'fullcredits') return self.mProxy.full_credits_parser.parse(cont) def get_movie_plot(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'plotsummary') ret = self.mProxy.plot_parser.parse(cont, getRefs=self._getRefs) ret['info sets'] = ('plot', 'synopsis') return ret def get_movie_awards(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'awards') return self.mProxy.movie_awards_parser.parse(cont) def get_movie_taglines(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'taglines') return self.mProxy.taglines_parser.parse(cont) def get_movie_keywords(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'keywords') return self.mProxy.keywords_parser.parse(cont) def get_movie_alternate_versions(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'alternateversions') return self.mProxy.alternateversions_parser.parse(cont, getRefs=self._getRefs) def get_movie_crazy_credits(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'crazycredits') return self.mProxy.crazycredits_parser.parse(cont, getRefs=self._getRefs) def get_movie_goofs(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'goofs') return self.mProxy.goofs_parser.parse(cont, getRefs=self._getRefs) def get_movie_quotes(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'quotes') return self.mProxy.quotes_parser.parse(cont, getRefs=self._getRefs) def get_movie_release_dates(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'releaseinfo') ret = self.mProxy.releasedates_parser.parse(cont) ret['info sets'] = ('release dates', 'akas') return ret get_movie_akas = get_movie_release_dates get_movie_release_info = get_movie_release_dates def get_movie_vote_details(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'ratings') return self.mProxy.ratings_parser.parse(cont) def get_movie_trivia(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'trivia') return self.mProxy.trivia_parser.parse(cont, getRefs=self._getRefs) def get_movie_connections(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'movieconnections') return self.mProxy.connections_parser.parse(cont) def get_movie_technical(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'technical') return self.mProxy.tech_parser.parse(cont) def get_movie_locations(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'locations') return self.mProxy.locations_parser.parse(cont) def get_movie_soundtrack(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'soundtrack') return self.mProxy.soundtrack_parser.parse(cont) def get_movie_reviews(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'reviews?count=9999999&start=0') return self.mProxy.reviews_parser.parse(cont) def get_movie_critic_reviews(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'criticreviews') return self.mProxy.criticrev_parser.parse(cont) def get_movie_external_reviews(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'externalreviews') return self.mProxy.externalrev_parser.parse(cont) def get_movie_external_sites(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'externalsites') ret = self.mProxy.externalsites_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_official_sites(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'officialsites') ret = self.mProxy.officialsites_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_misc_sites(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'miscsites') ret = self.mProxy.misclinks_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_sound_clips(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'soundsites') ret = self.mProxy.soundclips_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_video_clips(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'videosites') ret = self.mProxy.videoclips_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_photo_sites(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'photosites') ret = self.mProxy.photosites_parser.parse(cont) ret['info sets'] = ('external sites', 'misc sites', 'sound clips', 'video sites', 'photo sites', 'official sites') return ret def get_movie_news(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'news') return self.mProxy.news_parser.parse(cont, getRefs=self._getRefs) def _purge_seasons_data(self, data_d): if '_current_season' in data_d['data']: del data_d['data']['_current_season'] if '_seasons' in data_d['data']: del data_d['data']['_seasons'] return data_d def get_movie_episodes(self, movieID, season_nums='all'): cont = self._retrieve(self.urls['movie_main'] % movieID + 'episodes') temp_d = self.mProxy.season_episodes_parser.parse(cont) if isinstance(season_nums, int): season_nums = {season_nums} elif (isinstance(season_nums, (list, tuple)) or not hasattr(season_nums, '__contains__')): season_nums = set(season_nums) if not temp_d and 'data' in temp_d: return {} _seasons = temp_d['data'].get('_seasons') or [] nr_eps = 0 data_d = dict() for season in _seasons: if season_nums != 'all' and season not in season_nums: continue # Prevent Critical error if season is not found #330 try: cont = self._retrieve( self.urls['movie_main'] % movieID + 'episodes?season=' + str(season) ) except Exception: pass other_d = self.mProxy.season_episodes_parser.parse(cont) other_d = self._purge_seasons_data(other_d) other_d['data'].setdefault('episodes', {}) # Prevent Critical error if season is not found #330 try: if not (other_d and other_d['data'] and other_d['data']['episodes'][season]): continue except Exception: pass nr_eps += len(other_d['data']['episodes'].get(season) or []) if data_d: data_d['data']['episodes'][season] = other_d['data']['episodes'][season] else: data_d = other_d if not data_d: data_d['data'] = dict() data_d['data']['number of episodes'] = nr_eps return data_d def get_movie_faqs(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'faq') return self.mProxy.movie_faqs_parser.parse(cont, getRefs=self._getRefs) def get_movie_airing(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'tvschedule') return self.mProxy.airing_parser.parse(cont) get_movie_tv_schedule = get_movie_airing def get_movie_synopsis(self, movieID): return self.get_movie_plot(movieID) def get_movie_parents_guide(self, movieID): cont = self._retrieve(self.urls['movie_main'] % movieID + 'parentalguide') return self.mProxy.parentsguide_parser.parse(cont) def _search_person(self, name, results): cont = self._get_search_content('nm', name, results) return self.spProxy.search_person_parser.parse(cont, results=results)['data'] def get_person_main(self, personID): cont = self._retrieve(self.urls['person_main'] % personID) ret = self.pProxy.maindetails_parser.parse(cont) return ret def get_person_filmography(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'fullcredits') return self.pProxy.filmo_parser.parse(cont, getRefs=self._getRefs) def get_person_biography(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'bio') return self.pProxy.bio_parser.parse(cont, getRefs=self._getRefs) def get_person_awards(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'awards') return self.pProxy.person_awards_parser.parse(cont) def get_person_other_works(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'otherworks') return self.pProxy.otherworks_parser.parse(cont, getRefs=self._getRefs) def get_person_publicity(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'publicity') return self.pProxy.publicity_parser.parse(cont) def get_person_official_sites(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'officialsites') return self.pProxy.person_officialsites_parser.parse(cont) def get_person_news(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'news') return self.pProxy.news_parser.parse(cont) def get_person_genres_links(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'filmogenre') return self.pProxy.person_genres_parser.parse(cont) def get_person_keywords_links(self, personID): cont = self._retrieve(self.urls['person_main'] % personID + 'filmokey') return self.pProxy.person_keywords_parser.parse(cont) def _search_company(self, name, results): cont = self._get_search_content('co', name, results) url = self.urlOpener._last_url return self.scompProxy.search_company_parser.parse(cont, url=url, results=results)['data'] def get_company_main(self, companyID): cont = self._retrieve(self.urls['company_main'] % companyID) ret = self.compProxy.company_main_parser.parse(cont) return ret def _search_keyword(self, keyword, results): # XXX: the IMDb web server seems to have some serious problem with # non-ascii keyword. # E.g.: http://www.imdb.com/keyword/fianc%E9/ # will return a 500 Internal Server Error: Redirect Recursion. try: cont = self._get_search_content('kw', keyword, results) except IMDbDataAccessError: self._http_logger.warn('unable to search for keyword %s', keyword, exc_info=True) return [] return self.skProxy.search_keyword_parser.parse(cont, results=results)['data'] def _get_keyword(self, keyword, results, page=None): try: url = self.urls['keyword_main'] % keyword if page is not None: url = url + "&page=" + str(page) cont = self._retrieve(url) except IMDbDataAccessError: self._http_logger.warn('unable to get keyword %s', keyword, exc_info=True) return [] return self.skProxy.search_moviekeyword_parser.parse(cont, results=results)['data'] def _get_top_bottom_movies(self, kind): if kind == 'top': parser = self.topBottomProxy.top250_parser url = self.urls['top250'] elif kind == 'bottom': parser = self.topBottomProxy.bottom100_parser url = self.urls['bottom100'] elif kind == 'moviemeter': parser = self.topBottomProxy.moviemeter100_parser url = self.urls['moviemeter100'] elif kind == 'toptv': parser = self.topBottomProxy.toptv250_parser url = self.urls['toptv250'] elif kind == 'tvmeter': parser = self.topBottomProxy.tvmeter100_parser url = self.urls['tvmeter100'] elif kind == 'topindian250': parser = self.topBottomProxy.topindian250_parser url = self.urls['topindian250'] elif kind == 'boxoffice': parser = self.topBottomProxy.boxoffice_parser url = self.urls['boxoffice'] else: return [] cont = self._retrieve(url) return parser.parse(cont)['data'] def _get_showtimes(self): cont = self._retrieve(self.urls['showtimes']) return self.stimesProxy.showtime_parser.parse(cont)['data']