79 lines
2.5 KiB
Python
79 lines
2.5 KiB
Python
# Copyright: Damien Elmes <anki@ichi2.net>
|
|
# -*- coding: utf-8 -*-
|
|
# License: GNU AGPL, version 3 or later; http://www.gnu.org/licenses/agpl.html
|
|
|
|
import time, re, traceback
|
|
from aqt.qt import *
|
|
from anki.sync import httpCon
|
|
from aqt.utils import showWarning
|
|
from anki.hooks import addHook, remHook
|
|
import aqt.sync # monkey-patches httplib2
|
|
|
|
def download(mw, code):
|
|
"Download addon/deck from AnkiWeb. On success caller must stop progress diag."
|
|
# check code is valid
|
|
try:
|
|
code = int(code)
|
|
except ValueError:
|
|
showWarning(_("Invalid code."))
|
|
return
|
|
# create downloading thread
|
|
thread = Downloader(code)
|
|
def onRecv():
|
|
mw.progress.update(label="%dKB downloaded" % (thread.recvTotal/1024))
|
|
mw.connect(thread, SIGNAL("recv"), onRecv)
|
|
thread.start()
|
|
mw.progress.start(immediate=True)
|
|
while not thread.isFinished():
|
|
mw.app.processEvents()
|
|
thread.wait(100)
|
|
if not thread.error:
|
|
# success
|
|
return thread.data, thread.fname
|
|
else:
|
|
mw.progress.finish()
|
|
showWarning(_("Download failed: %s") % thread.error)
|
|
|
|
class Downloader(QThread):
|
|
|
|
def __init__(self, code):
|
|
QThread.__init__(self)
|
|
self.code = code
|
|
self.error = None
|
|
|
|
def run(self):
|
|
# setup progress handler
|
|
self.byteUpdate = time.time()
|
|
self.recvTotal = 0
|
|
def canPost():
|
|
if (time.time() - self.byteUpdate) > 0.1:
|
|
self.byteUpdate = time.time()
|
|
return True
|
|
def recvEvent(bytes):
|
|
self.recvTotal += bytes
|
|
if canPost():
|
|
self.emit(SIGNAL("recv"))
|
|
addHook("httpRecv", recvEvent)
|
|
con = httpCon()
|
|
try:
|
|
resp, cont = con.request(
|
|
aqt.appShared + "download/%d" % self.code)
|
|
except Exception, e:
|
|
exc = traceback.format_exc()
|
|
try:
|
|
self.error = unicode(e[0], "utf8", "ignore")
|
|
except:
|
|
self.error = exc
|
|
return
|
|
finally:
|
|
remHook("httpRecv", recvEvent)
|
|
if resp['status'] == '200':
|
|
self.error = None
|
|
self.fname = re.match("attachment; filename=(.+)",
|
|
resp['content-disposition']).group(1)
|
|
self.data = cont
|
|
elif resp['status'] == '403':
|
|
self.error = _("Invalid code.")
|
|
else:
|
|
self.error = _("Error downloading: %s") % resp['status']
|