2018-11-13 21:55:59 +01:00
|
|
|
"""WordOps download core classes."""
|
|
|
|
|
import os
|
2019-10-28 14:53:15 +01:00
|
|
|
import requests
|
2019-09-04 20:36:15 +02:00
|
|
|
|
2018-11-13 21:55:59 +01:00
|
|
|
from wo.core.logging import Log
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class WODownload():
|
|
|
|
|
"""Method to download using urllib"""
|
|
|
|
|
def __init__():
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
def download(self, packages):
|
2019-10-28 14:53:15 +01:00
|
|
|
"""Download packages, packages must be list in format of
|
2018-11-13 21:55:59 +01:00
|
|
|
[url, path, package name]"""
|
|
|
|
|
for package in packages:
|
|
|
|
|
url = package[0]
|
|
|
|
|
filename = package[1]
|
|
|
|
|
pkg_name = package[2]
|
|
|
|
|
try:
|
|
|
|
|
directory = os.path.dirname(filename)
|
|
|
|
|
if not os.path.exists(directory):
|
|
|
|
|
os.makedirs(directory)
|
|
|
|
|
Log.info(self, "Downloading {0:20}".format(pkg_name), end=' ')
|
2019-10-23 14:08:54 +02:00
|
|
|
with open(filename, "wb") as out_file:
|
2019-10-28 14:53:15 +01:00
|
|
|
req = requests.get(url, timeout=(5, 30))
|
2019-10-23 14:08:54 +02:00
|
|
|
if req.encoding is None:
|
|
|
|
|
req.encoding = 'utf-8'
|
|
|
|
|
out_file.write(req.content)
|
2018-11-13 21:55:59 +01:00
|
|
|
Log.info(self, "{0}".format("[" + Log.ENDC + "Done"
|
|
|
|
|
+ Log.OKBLUE + "]"))
|
2019-10-28 14:53:15 +01:00
|
|
|
except requests.RequestException as e:
|
2018-11-13 21:55:59 +01:00
|
|
|
Log.debug(self, "[{err}]".format(err=str(e.reason)))
|
|
|
|
|
Log.error(self, "Unable to download file, {0}"
|
|
|
|
|
.format(filename))
|
|
|
|
|
return False
|
2019-10-28 06:52:23 +01:00
|
|
|
return 0
|
2019-10-28 14:53:15 +01:00
|
|
|
|
|
|
|
|
def latest_release(self, repository):
|
|
|
|
|
"""Get the latest release number of a GitHub repository.\n
|
|
|
|
|
repository format should be: \"user/repo\""""
|
|
|
|
|
try:
|
|
|
|
|
req = requests.get(
|
|
|
|
|
'https://api.github.com/repos/{0}/releases/latest'
|
|
|
|
|
.format(repository),
|
|
|
|
|
timeout=(5, 30))
|
|
|
|
|
except requests.RequestException as e:
|
|
|
|
|
Log.debug(self, str(e))
|
|
|
|
|
Log.error(self, "Unable to query GitHub API")
|
|
|
|
|
else:
|
|
|
|
|
github_json = req.json()
|
|
|
|
|
github_release = github_json["tag_name"]
|
|
|
|
|
return github_release
|