From fa3429f1ccaf275872ceb66d9d032abfd32a6743 Mon Sep 17 00:00:00 2001 From: Jean-Paul Calderone Date: Mon, 4 Mar 2019 10:47:05 -0500 Subject: [PATCH] Serialize queue items using their path and type --- src/allmydata/frontends/magic_folder.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/allmydata/frontends/magic_folder.py b/src/allmydata/frontends/magic_folder.py index 851e271c7..0fb7b93f9 100644 --- a/src/allmydata/frontends/magic_folder.py +++ b/src/allmydata/frontends/magic_folder.py @@ -773,7 +773,7 @@ ALL_FILES = MessageType( _ITEMS = Field( u"items", - lambda deque: list(deque), + lambda deque: list(dict(relpath=item.relpath_u, kind=item.kind) for item in deque), u"Items in a processing queue.", ) @@ -1055,6 +1055,8 @@ class IQueuedItem(Interface): @implementer(IQueuedItem) class QueuedItem(object): + kind = None + def __init__(self, relpath_u, progress, size): self.relpath_u = relpath_u self.progress = progress @@ -1096,7 +1098,7 @@ class UploadItem(QueuedItem): """ Represents a single item the _deque of the Uploader """ - pass + kind = u"upload" _ITEM = Field( @@ -1611,6 +1613,8 @@ class DownloadItem(QueuedItem): """ Represents a single item in the _deque of the Downloader """ + kind = u"download" + def __init__(self, relpath_u, progress, filenode, metadata, size): super(DownloadItem, self).__init__(relpath_u, progress, size) self.file_node = filenode