aboutsummaryrefslogtreecommitdiff
path: root/lib/python/Tools/Downloader.py
diff options
context:
space:
mode:
authorFelix Domke <tmbinc@elitedvb.net>2009-05-16 19:04:44 +0200
committerFelix Domke <tmbinc@elitedvb.net>2009-05-16 19:04:44 +0200
commit34bb54f1a28201b896c06c6b4aedf11a1b25f6d2 (patch)
tree5191729c40d0708d00254740c610bf7a4dff3059 /lib/python/Tools/Downloader.py
parent1bba7d19f64a7a2896bdb54a1c54c585f591cc8c (diff)
parent9f2d37189bea613bb562a4e8b69121572d8efe5f (diff)
downloadenigma2-34bb54f1a28201b896c06c6b4aedf11a1b25f6d2.tar.gz
enigma2-34bb54f1a28201b896c06c6b4aedf11a1b25f6d2.zip
Merge branch 'master' of /home/tmbinc/enigma2-git
Diffstat (limited to 'lib/python/Tools/Downloader.py')
-rw-r--r--lib/python/Tools/Downloader.py53
1 files changed, 53 insertions, 0 deletions
diff --git a/lib/python/Tools/Downloader.py b/lib/python/Tools/Downloader.py
new file mode 100644
index 00000000..ffc24c1c
--- /dev/null
+++ b/lib/python/Tools/Downloader.py
@@ -0,0 +1,53 @@
+from twisted.web import client
+from twisted.internet import reactor, defer
+from twisted.python import failure
+
+class HTTPProgressDownloader(client.HTTPDownloader):
+ def __init__(self, url, outfile, headers=None):
+ client.HTTPDownloader.__init__(self, url, outfile, headers=headers, agent="Dreambox HTTP Downloader")
+ self.status = None
+ self.progress_callback = None
+ self.deferred = defer.Deferred()
+
+ def noPage(self, reason):
+ if self.status == "304":
+ print reason.getErrorMessage()
+ client.HTTPDownloader.page(self, "")
+ else:
+ client.HTTPDownloader.noPage(self, reason)
+
+ def gotHeaders(self, headers):
+ if self.status == "200":
+ if headers.has_key("content-length"):
+ self.totalbytes = int(headers["content-length"][0])
+ else:
+ self.totalbytes = 0
+ self.currentbytes = 0.0
+ return client.HTTPDownloader.gotHeaders(self, headers)
+
+ def pagePart(self, packet):
+ if self.status == "200":
+ self.currentbytes += len(packet)
+ if self.totalbytes and self.progress_callback:
+ self.progress_callback(self.currentbytes, self.totalbytes)
+ return client.HTTPDownloader.pagePart(self, packet)
+
+ def pageEnd(self):
+ return client.HTTPDownloader.pageEnd(self)
+
+class downloadWithProgress:
+ def __init__(self, url, outputfile, contextFactory=None, *args, **kwargs):
+ scheme, host, port, path = client._parse(url)
+ self.factory = HTTPProgressDownloader(url, outputfile, *args, **kwargs)
+ self.connection = reactor.connectTCP(host, port, self.factory)
+
+ def start(self):
+ return self.factory.deferred
+
+ def stop(self):
+ print "[stop]"
+ self.connection.disconnect()
+
+ def addProgress(self, progress_callback):
+ print "[addProgress]"
+ self.factory.progress_callback = progress_callback