}
introducer_furl = "None"
introducer_client = FakeIntroducerClient()
+ _all_uploads = [upload.UploadStatus()]
+ _all_downloads = [download.DownloadStatus()]
+
def connected_to_introducer(self):
return False
return d
def list_all_uploads(self):
- return [upload.UploadStatus()]
+ return self._all_uploads
def list_all_downloads(self):
- return [download.DownloadStatus()]
+ return self._all_downloads
def list_recent_uploads(self):
- return [upload.UploadStatus()]
+ return self._all_uploads
def list_recent_downloads(self):
- return [download.DownloadStatus()]
+ return self._all_downloads
class WebMixin(object):
return d
def test_status(self):
+ dl_num = self.s.list_recent_downloads()[0].get_counter()
+ ul_num = self.s.list_recent_uploads()[0].get_counter()
d = self.GET("/status", followRedirect=True)
def _check(res):
self.failUnless('Upload and Download Status' in res)
+ self.failUnless('"down-%d"' % dl_num in res)
+ self.failUnless('"up-%d"' % ul_num in res)
d.addCallback(_check)
+ d.addCallback(lambda res: self.GET("/status/down-%d" % dl_num))
+ def _check_dl(res):
+ self.failUnless("File Download Status" in res)
+ d.addCallback(_check_dl)
+ d.addCallback(lambda res: self.GET("/status/up-%d" % ul_num))
+ def _check_ul(res):
+ self.failUnless("File Upload Status" in res)
+ d.addCallback(_check_ul)
return d
def test_GET_FILEURL(self):
--- /dev/null
+<html xmlns:n="http://nevow.com/ns/nevow/0.1">
+ <head>
+ <title>AllMyData - Tahoe - File Upload Status</title>
+ <!-- <link href="http://www.allmydata.com/common/css/styles.css"
+ rel="stylesheet" type="text/css"/> -->
+ <link href="/webform_css" rel="stylesheet" type="text/css"/>
+ <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
+ </head>
+ <body>
+
+<h1>File Upload Status</h1>
+
+<ul>
+ <li>Storage Index: <span n:render="si"/></li>
+ <li>Helper?: <span n:render="helper"/></li>
+ <li>Total Size: <span n:render="total_size"/></li>
+ <li>Progress (Hash): <span n:render="progress_hash"/></li>
+ <li>Progress (Ciphertext): <span n:render="progress_ciphertext"/></li>
+ <li>Progress (Encode+Push): <span n:render="progress_encode_push"/></li>
+ <li>Status: <span n:render="status"/></li>
+</ul>
+
+<div>Return to the <a href="/">Welcome Page</a></div>
+
+ </body>
+</html>
d.addCallback(lambda dirnode: dirnode.get_uri())
return d
+class UploadStatusPage(rend.Page):
+ docFactory = getxmlfile("upload-status.xhtml")
+
+ def render_si(self, ctx, data):
+ si_s = base32.b2a_or_none(data.get_storage_index())
+ if si_s is None:
+ si_s = "(None)"
+ return si_s
+
+ def render_helper(self, ctx, data):
+ return {True: "Yes",
+ False: "No"}[data.using_helper()]
+
+ def render_total_size(self, ctx, data):
+ size = data.get_size()
+ if size is None:
+ size = "(unknown)"
+ return size
+
+ def render_progress_hash(self, ctx, data):
+ progress = data.get_progress()[0]
+ # TODO: make an ascii-art bar
+ return "%.1f%%" % (100.0 * progress)
+
+ def render_progress_ciphertext(self, ctx, data):
+ progress = data.get_progress()[1]
+ # TODO: make an ascii-art bar
+ return "%.1f%%" % (100.0 * progress)
+
+ def render_progress_encode_push(self, ctx, data):
+ progress = data.get_progress()[2]
+ # TODO: make an ascii-art bar
+ return "%.1f%%" % (100.0 * progress)
+
+ def render_status(self, ctx, data):
+ return data.get_status()
+
+class DownloadStatusPage(rend.Page):
+ docFactory = getxmlfile("download-status.xhtml")
+
+ def render_si(self, ctx, data):
+ si_s = base32.b2a_or_none(data.get_storage_index())
+ if si_s is None:
+ si_s = "(None)"
+ return si_s
+
+ def render_helper(self, ctx, data):
+ return {True: "Yes",
+ False: "No"}[data.using_helper()]
+
+ def render_total_size(self, ctx, data):
+ size = data.get_size()
+ if size is None:
+ size = "(unknown)"
+ return size
+
+ def render_progress(self, ctx, data):
+ progress = data.get_progress()
+ # TODO: make an ascii-art bar
+ return "%.1f%%" % (100.0 * progress)
+
+ def render_status(self, ctx, data):
+ return data.get_status()
+
class Status(rend.Page):
docFactory = getxmlfile("status.xhtml")
addSlash = True
return [d for d in IClient(ctx).list_recent_downloads()
if not d.get_active()]
+ def childFactory(self, ctx, name):
+ client = IClient(ctx)
+ stype,count_s = name.split("-")
+ count = int(count_s)
+ if stype == "up":
+ for s in client.list_recent_uploads():
+ if s.get_counter() == count:
+ return UploadStatusPage(s)
+ for s in client.list_all_uploads():
+ if s.get_counter() == count:
+ return UploadStatusPage(s)
+ if stype == "down":
+ for s in client.list_recent_downloads():
+ if s.get_counter() == count:
+ return DownloadStatusPage(s)
+ for s in client.list_all_downloads():
+ if s.get_counter() == count:
+ return DownloadStatusPage(s)
+
def _render_common(self, ctx, data):
s = data
si_s = base32.b2a_or_none(s.get_storage_index())
else:
assert IDownloadStatus.providedBy(data)
link = "down-%d" % data.get_counter()
- #ctx.fillSlots("status", T.a(href=link)[s.get_status()])
- ctx.fillSlots("status", s.get_status())
+ ctx.fillSlots("status", T.a(href=link)[s.get_status()])
def render_row_upload(self, ctx, data):
self._render_common(ctx, data)
projects / tahoe-lafs / tahoe-lafs.git / commitdiff