mirror of
https://github.com/corpnewt/gibMacOS.git
synced 2025-01-23 21:11:22 +01:00
Update downloader.py from pymodules
This commit is contained in:
corpnewt
parent
fdfe3126d1
commit
fc7da4b8e5
260
Scripts/downloader.py
Normal file → Executable file
260
Scripts/downloader.py
Normal file → Executable file
@ -1,130 +1,130 @@
|
|||||||
import sys, os, time, ssl
|
import sys, os, time, ssl
|
||||||
# Python-aware urllib stuff
|
# Python-aware urllib stuff
|
||||||
if sys.version_info >= (3, 0):
|
if sys.version_info >= (3, 0):
|
||||||
from urllib.request import urlopen
|
from urllib.request import urlopen
|
||||||
else:
|
else:
|
||||||
# Import urllib2 to catch errors
|
# Import urllib2 to catch errors
|
||||||
import urllib2
|
import urllib2
|
||||||
from urllib2 import urlopen
|
from urllib2 import urlopen
|
||||||
|
|
||||||
class Downloader:
|
class Downloader:
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
return
|
return
|
||||||
|
|
||||||
def open_url(self, url):
|
def open_url(self, url):
|
||||||
# Wrap up the try/except block so we don't have to do this for each function
|
# Wrap up the try/except block so we don't have to do this for each function
|
||||||
try:
|
try:
|
||||||
response = urlopen(url)
|
response = urlopen(url)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
if sys.version_info >= (3, 0) or not (isinstance(e, urllib2.URLError) and "CERTIFICATE_VERIFY_FAILED" in str(e)):
|
if sys.version_info >= (3, 0) or not (isinstance(e, urllib2.URLError) and "CERTIFICATE_VERIFY_FAILED" in str(e)):
|
||||||
# Either py3, or not the right error for this "fix"
|
# Either py3, or not the right error for this "fix"
|
||||||
return None
|
return None
|
||||||
# Py2 and a Cert verify error - let's set the unverified context
|
# Py2 and a Cert verify error - let's set the unverified context
|
||||||
context = ssl._create_unverified_context()
|
context = ssl._create_unverified_context()
|
||||||
try:
|
try:
|
||||||
response = urlopen(url, context=context)
|
response = urlopen(url, context=context)
|
||||||
except:
|
except:
|
||||||
# No fixing this - bail
|
# No fixing this - bail
|
||||||
return None
|
return None
|
||||||
return response
|
return response
|
||||||
|
|
||||||
def get_size(self, size, suff=None):
|
def get_size(self, size, suff=None):
|
||||||
if size == -1:
|
if size == -1:
|
||||||
return "Unknown"
|
return "Unknown"
|
||||||
ext = ["B","KB","MB","GB","PB"]
|
ext = ["B","KB","MB","GB","PB"]
|
||||||
s = float(size)
|
s = float(size)
|
||||||
s_dict = {}
|
s_dict = {}
|
||||||
# Iterate the ext list, and divide by 1000 each time
|
# Iterate the ext list, and divide by 1000 each time
|
||||||
for e in ext:
|
for e in ext:
|
||||||
s_dict[e] = s
|
s_dict[e] = s
|
||||||
s /= 1000
|
s /= 1000
|
||||||
if suff and suff.upper() in s_dict:
|
if suff and suff.upper() in s_dict:
|
||||||
# We supplied the suffix - use it \o/
|
# We supplied the suffix - use it \o/
|
||||||
bval = round(s_dict[suff.upper()], 2)
|
bval = round(s_dict[suff.upper()], 2)
|
||||||
biggest = suff.upper()
|
biggest = suff.upper()
|
||||||
else:
|
else:
|
||||||
# Get the maximum >= 1 type
|
# Get the maximum >= 1 type
|
||||||
biggest = next((x for x in ext[::-1] if s_dict[x] >= 1), "B")
|
biggest = next((x for x in ext[::-1] if s_dict[x] >= 1), "B")
|
||||||
# Round to 2 decimal places
|
# Round to 2 decimal places
|
||||||
bval = round(s_dict[biggest], 2)
|
bval = round(s_dict[biggest], 2)
|
||||||
return "{:,.2f} {}".format(bval, biggest)
|
return "{:,.2f} {}".format(bval, biggest)
|
||||||
|
|
||||||
def _progress_hook(self, response, bytes_so_far, total_size):
|
def _progress_hook(self, response, bytes_so_far, total_size):
|
||||||
if total_size > 0:
|
if total_size > 0:
|
||||||
percent = float(bytes_so_far) / total_size
|
percent = float(bytes_so_far) / total_size
|
||||||
percent = round(percent*100, 2)
|
percent = round(percent*100, 2)
|
||||||
t_s = self.get_size(total_size)
|
t_s = self.get_size(total_size)
|
||||||
try:
|
try:
|
||||||
b_s = self.get_size(bytes_so_far, t_s.split(" ")[1])
|
b_s = self.get_size(bytes_so_far, t_s.split(" ")[1])
|
||||||
except:
|
except:
|
||||||
b_s = self.get_size(bytes_so_far)
|
b_s = self.get_size(bytes_so_far)
|
||||||
sys.stdout.write("Downloaded {} of {} ({:.2f}%)\r".format(b_s, t_s, percent))
|
sys.stdout.write("Downloaded {} of {} ({:.2f}%)\r".format(b_s, t_s, percent))
|
||||||
else:
|
else:
|
||||||
sys.stdout.write("Downloaded {}\r".format(b_s))
|
sys.stdout.write("Downloaded {:,}\r".format(bytes_so_far))
|
||||||
|
|
||||||
def get_string(self, url, progress = True):
|
def get_string(self, url, progress = True):
|
||||||
response = self.open_url(url)
|
response = self.open_url(url)
|
||||||
if not response:
|
if not response:
|
||||||
return None
|
return None
|
||||||
CHUNK = 16 * 1024
|
CHUNK = 16 * 1024
|
||||||
bytes_so_far = 0
|
bytes_so_far = 0
|
||||||
try:
|
try:
|
||||||
total_size = int(response.headers['Content-Length'])
|
total_size = int(response.headers['Content-Length'])
|
||||||
except:
|
except:
|
||||||
total_size = -1
|
total_size = -1
|
||||||
chunk_so_far = "".encode("utf-8")
|
chunk_so_far = "".encode("utf-8")
|
||||||
while True:
|
while True:
|
||||||
chunk = response.read(CHUNK)
|
chunk = response.read(CHUNK)
|
||||||
bytes_so_far += len(chunk)
|
bytes_so_far += len(chunk)
|
||||||
if progress:
|
if progress:
|
||||||
self._progress_hook(response, bytes_so_far, total_size)
|
self._progress_hook(response, bytes_so_far, total_size)
|
||||||
if not chunk:
|
if not chunk:
|
||||||
break
|
break
|
||||||
chunk_so_far += chunk
|
chunk_so_far += chunk
|
||||||
return chunk_so_far.decode("utf-8")
|
return chunk_so_far.decode("utf-8")
|
||||||
|
|
||||||
def get_bytes(self, url, progress = True):
|
def get_bytes(self, url, progress = True):
|
||||||
response = self.open_url(url)
|
response = self.open_url(url)
|
||||||
if not response:
|
if not response:
|
||||||
return None
|
return None
|
||||||
CHUNK = 16 * 1024
|
CHUNK = 16 * 1024
|
||||||
bytes_so_far = 0
|
bytes_so_far = 0
|
||||||
try:
|
try:
|
||||||
total_size = int(response.headers['Content-Length'])
|
total_size = int(response.headers['Content-Length'])
|
||||||
except:
|
except:
|
||||||
total_size = -1
|
total_size = -1
|
||||||
chunk_so_far = "".encode("utf-8")
|
chunk_so_far = "".encode("utf-8")
|
||||||
while True:
|
while True:
|
||||||
chunk = response.read(CHUNK)
|
chunk = response.read(CHUNK)
|
||||||
bytes_so_far += len(chunk)
|
bytes_so_far += len(chunk)
|
||||||
if progress:
|
if progress:
|
||||||
self._progress_hook(response, bytes_so_far, total_size)
|
self._progress_hook(response, bytes_so_far, total_size)
|
||||||
if not chunk:
|
if not chunk:
|
||||||
break
|
break
|
||||||
chunk_so_far += chunk
|
chunk_so_far += chunk
|
||||||
return chunk_so_far
|
return chunk_so_far
|
||||||
|
|
||||||
def stream_to_file(self, url, file, progress = True):
|
def stream_to_file(self, url, file, progress = True):
|
||||||
response = self.open_url(url)
|
response = self.open_url(url)
|
||||||
if not response:
|
if not response:
|
||||||
return None
|
return None
|
||||||
CHUNK = 16 * 1024
|
CHUNK = 16 * 1024
|
||||||
bytes_so_far = 0
|
bytes_so_far = 0
|
||||||
try:
|
try:
|
||||||
total_size = int(response.headers['Content-Length'])
|
total_size = int(response.headers['Content-Length'])
|
||||||
except:
|
except:
|
||||||
total_size = -1
|
total_size = -1
|
||||||
with open(file, 'wb') as f:
|
with open(file, 'wb') as f:
|
||||||
while True:
|
while True:
|
||||||
chunk = response.read(CHUNK)
|
chunk = response.read(CHUNK)
|
||||||
bytes_so_far += len(chunk)
|
bytes_so_far += len(chunk)
|
||||||
if progress:
|
if progress:
|
||||||
self._progress_hook(response, bytes_so_far, total_size)
|
self._progress_hook(response, bytes_so_far, total_size)
|
||||||
if not chunk:
|
if not chunk:
|
||||||
break
|
break
|
||||||
f.write(chunk)
|
f.write(chunk)
|
||||||
if os.path.exists(file):
|
if os.path.exists(file):
|
||||||
return file
|
return file
|
||||||
else:
|
else:
|
||||||
return None
|
return None
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user