Move source url to api
This commit is contained in:
@@ -254,8 +254,6 @@ class GitUpdater(BaseUpdater):
|
||||
|
||||
class SourceUpdater(BaseUpdater):
|
||||
|
||||
update_url = 'https://couchpota.to/updates/source.php?repo=%s&name=%s&branch=%s'
|
||||
|
||||
def __init__(self):
|
||||
|
||||
# Create version file in cache
|
||||
@@ -263,13 +261,10 @@ class SourceUpdater(BaseUpdater):
|
||||
if not os.path.isfile(self.version_file):
|
||||
self.createFile(self.version_file, json.dumps(self.latestCommit()))
|
||||
|
||||
addEvent('app.load', self.doUpdate)
|
||||
|
||||
def doUpdate(self):
|
||||
|
||||
try:
|
||||
url = self.update_url % (self.repo_user, self.repo_name, self.branch)
|
||||
download_data = json.loads(self.urlopen(url))
|
||||
download_data = fireEvent('cp.source_url', repo = self.repo_user, repo_name = self.repo_name, branch = self.branch, single = True)
|
||||
destination = os.path.join(Env.get('cache_dir'), self.update_version.get('hash')) + '.' + download_data.get('type')
|
||||
|
||||
extracted_path = os.path.join(Env.get('cache_dir'), 'temp_updater')
|
||||
|
||||
@@ -19,19 +19,27 @@ class CouchPotatoApi(MovieProvider):
|
||||
'is_movie': 'https://couchpota.to/api/ismovie/%s/',
|
||||
'eta': 'https://couchpota.to/api/eta/%s/',
|
||||
'suggest': 'https://couchpota.to/api/suggest/',
|
||||
'updater': 'https://couchpota.to/api/updater/?%s',
|
||||
}
|
||||
http_time_between_calls = 0
|
||||
api_version = 1
|
||||
|
||||
def __init__(self):
|
||||
#addApiView('movie.suggest', self.suggestView)
|
||||
|
||||
addEvent('movie.info', self.getInfo, priority = 1)
|
||||
addEvent('movie.search', self.search, priority = 1)
|
||||
addEvent('movie.release_date', self.getReleaseDate)
|
||||
addEvent('movie.suggest', self.suggest)
|
||||
addEvent('movie.is_movie', self.isMovie)
|
||||
|
||||
addEvent('cp.source_url', self.getSourceUrl)
|
||||
|
||||
def getSourceUrl(self, repo = None, repo_name = None, branch = None):
|
||||
return self.getJsonData(self.urls['updater'] % tryUrlencode({
|
||||
'repo': repo,
|
||||
'name': repo_name,
|
||||
'branch': branch,
|
||||
}), headers = self.getRequestHeaders())
|
||||
|
||||
def search(self, q, limit = 12):
|
||||
return self.getJsonData(self.urls['search'] % tryUrlencode(q), headers = self.getRequestHeaders())
|
||||
|
||||
|
||||
Reference in New Issue
Block a user