5 changed files with 161 additions and 1 deletions
After Width: | Height: | Size: 588 B |
@ -0,0 +1,154 @@ |
|||
# coding=utf-8 |
|||
# URL: http://code.google.com/p/sickbeard |
|||
# |
|||
# This file is part of SickGear. |
|||
# |
|||
# SickGear 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 3 of the License, or |
|||
# (at your option) any later version. |
|||
# |
|||
# SickGear 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 SickGear. If not, see <http://www.gnu.org/licenses/>. |
|||
|
|||
import urllib |
|||
import requests |
|||
import generic |
|||
from sickbeard import logger |
|||
from sickbeard import tvcache |
|||
from sickbeard.helpers import mapIndexersToShow |
|||
from sickbeard.exceptions import AuthException |
|||
|
|||
|
|||
class ToTVProvider(generic.TorrentProvider): |
|||
def __init__(self): |
|||
generic.TorrentProvider.__init__(self, 'ToTV') |
|||
|
|||
self.supportsBacklog = True |
|||
self.supportsAbsoluteNumbering = True |
|||
|
|||
self.enabled = False |
|||
self.api_key = None |
|||
self.ratio = None |
|||
|
|||
self.cache = ToTVCache(self) |
|||
|
|||
self.url = 'https://titansof.tv/api/torrents' |
|||
self.download_url = 'http://titansof.tv/api/torrents/%s/download?apikey=%s' |
|||
self.session = requests.Session() |
|||
|
|||
def isEnabled(self): |
|||
return self.enabled |
|||
|
|||
def imageName(self): |
|||
return 'totv.png' |
|||
|
|||
def _checkAuth(self): |
|||
if not self.api_key: |
|||
raise AuthException('Your authentication credentials for ' + self.name + ' are missing, check your config.') |
|||
|
|||
return True |
|||
|
|||
def _checkAuthFromData(self, data): |
|||
|
|||
if 'error' in data: |
|||
logger.log(u'Incorrect authentication credentials for ' + self.name + ' : ' + data['error'], |
|||
logger.DEBUG) |
|||
raise AuthException( |
|||
'Your authentication credentials for ' + self.name + ' are incorrect, check your config.') |
|||
|
|||
return True |
|||
|
|||
def _doSearch(self, search_params, search_mode='eponly', epcount=0, age=0): |
|||
self._checkAuth() |
|||
results = [] |
|||
params = {} |
|||
self.headers.update({'X-Authorization': self.api_key}) |
|||
|
|||
if search_params: |
|||
params.update(search_params) |
|||
|
|||
search_url = self.url + '?' + urllib.urlencode(params) |
|||
logger.log(u'Search url: %s' % search_url) |
|||
|
|||
parsedJSON = self.getURL(search_url, json=True) # do search |
|||
|
|||
if not parsedJSON: |
|||
logger.log(u'No data returned from ' + self.name, logger.ERROR) |
|||
return results |
|||
|
|||
if self._checkAuthFromData(parsedJSON): |
|||
|
|||
try: |
|||
found_torrents = parsedJSON['results'] |
|||
except: |
|||
found_torrents = {} |
|||
|
|||
for result in found_torrents: |
|||
(title, url) = self._get_title_and_url(result) |
|||
|
|||
if title and url: |
|||
results.append(result) |
|||
|
|||
return results |
|||
|
|||
def _get_title_and_url(self, parsedJSON): |
|||
|
|||
title = parsedJSON['release_name'] |
|||
id = parsedJSON['id'] |
|||
url = self.download_url % (id, self.api_key) |
|||
|
|||
return title, url |
|||
|
|||
def _get_season_search_strings(self, ep_obj): |
|||
search_params = {'limit': 100} |
|||
|
|||
search_params['season'] = 'Season %02d' % ep_obj.scene_season |
|||
|
|||
if ep_obj.show.indexer == 1: |
|||
search_params['series_id'] = ep_obj.show.indexerid |
|||
elif ep_obj.show.indexer == 2: |
|||
tvdbid = mapIndexersToShow(ep_obj.show)[1] |
|||
if tvdbid: |
|||
search_params['series_id'] = tvdbid |
|||
|
|||
return [search_params] |
|||
|
|||
def _get_episode_search_strings(self, ep_obj, add_string=''): |
|||
|
|||
if not ep_obj: |
|||
return [{}] |
|||
|
|||
search_params = {'limit': 100} |
|||
|
|||
# Do a general name search for the episode, formatted like SXXEYY |
|||
search_params['episode'] = 'S%02dE%02d' % (ep_obj.scene_season, ep_obj.scene_episode) |
|||
|
|||
if ep_obj.show.indexer == 1: |
|||
search_params['series_id'] = ep_obj.show.indexerid |
|||
elif ep_obj.show.indexer == 2: |
|||
tvdbid = mapIndexersToShow(ep_obj.show)[1] |
|||
if tvdbid: |
|||
search_params['series_id'] = tvdbid |
|||
|
|||
return [search_params] |
|||
|
|||
|
|||
class ToTVCache(tvcache.TVCache): |
|||
def __init__(self, provider): |
|||
tvcache.TVCache.__init__(self, provider) |
|||
|
|||
# At least 10 minutes between queries |
|||
self.minTime = 10 |
|||
|
|||
def _getRSSData(self): |
|||
search_params = {'limit': 100} |
|||
return self.provider._doSearch(search_params) |
|||
|
|||
|
|||
provider = ToTVProvider() |
Loading…
Reference in new issue