ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-13 13:53:07 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Log downloads

Browse Source
This commit is contained in:
Jean-Paul Calderone 2019-02-28 20:57:09 -05:00
parent ae59679875
commit 807568e09f
1 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/allmydata/frontends/magic_folder.py
View File

@ -1110,6 +1110,13 @@ PROCESS_ITEM = ActionType(
u"A path which was found wanting of an update is receiving an update.",
)
DOWNLOAD_BEST_VERSION = ActionType(
u"magic-folder:download-best-version",
[],
[],
u"The content of a file in the Magic Folder is being downloaded.",
)
class Uploader(QueueMixin):
def __init__(self, client, local_path_u, db, upload_dirnode, pending_delay, clock):
@ -1958,14 +1965,19 @@ class Downloader(QueueMixin, WriteFileMixin):
if item.metadata.get('deleted', False):
d.addCallback(lambda ign: self._rename_deleted_file(abspath_u))
else:
d.addCallback(lambda ign: item.file_node.download_best_version(progress=item.progress))
d.addCallback(
lambda contents: self._write_downloaded_file(
self._local_path_u, abspath_u, contents,
is_conflict=is_conflict,
mtime=item.metadata.get('user_mtime', item.metadata.get('tahoe', {}).get('linkmotime')),
)
)
@eliotutil.inline_callbacks
def download_best_version(ignored):
with DOWNLOAD_BEST_VERSION():
contents = yield item.file_node.download_best_version(progress=item.progress)
defer.returnValue(
self._write_downloaded_file(
self._local_path_u, abspath_u, contents,
is_conflict=is_conflict,
mtime=item.metadata.get('user_mtime', item.metadata.get('tahoe', {}).get('linkmotime')),
)
)
d.addCallback(download_best_version)
d.addCallback(do_update_db)
d.addErrback(failed)