summaryrefslogtreecommitdiff
path: root/mail/src
diff options
context:
space:
mode:
authorKali Kaneko <kali@leap.se>2015-01-27 14:13:55 -0400
committerKali Kaneko <kali@leap.se>2015-02-11 14:05:44 -0400
commit7dcd1e22428197436a2f92586e50e8c71ac45adb (patch)
tree17b44a1e77d350c9bfa0252d8aee65d59b07b3c2 /mail/src
parent66f98fbb58d73a14db9f081bf636c53dddb77b1b (diff)
implement copy interface
Diffstat (limited to 'mail/src')
-rw-r--r--mail/src/leap/mail/adaptors/soledad.py28
-rw-r--r--mail/src/leap/mail/imap/mailbox.py4
-rw-r--r--mail/src/leap/mail/mail.py18
3 files changed, 34 insertions, 16 deletions
diff --git a/mail/src/leap/mail/adaptors/soledad.py b/mail/src/leap/mail/adaptors/soledad.py
index 4dc02a11..721f25e2 100644
--- a/mail/src/leap/mail/adaptors/soledad.py
+++ b/mail/src/leap/mail/adaptors/soledad.py
@@ -16,6 +16,7 @@
"""
Soledadad MailAdaptor module.
"""
+import logging
import re
from collections import defaultdict
from email import message_from_string
@@ -512,15 +513,30 @@ class MessageWrapper(object):
d.append(self.fdoc.delete(store))
return defer.gatherResults(d)
- def copy(self, store, newmailbox):
+ def copy(self, store, new_mbox_uuid):
"""
Return a copy of this MessageWrapper in a new mailbox.
+
+ :param store: an instance of Soledad, or anything that behaves alike.
+ :param new_mbox_uuid: the uuid of the mailbox where we are copying this
+ message to.
+ :type new_mbox_uuid: str
+ :rtype: MessageWrapper
"""
- # 1. copy the fdoc, mdoc
- # 2. remove the doc_id of that fdoc
- # 3. create it (with new doc_id)
- # 4. return new wrapper (new meta too!)
- raise NotImplementedError()
+ new_mdoc = self.mdoc.serialize()
+ new_fdoc = self.fdoc.serialize()
+
+ # the future doc_ids is properly set because we modified
+ # the pointers in mdoc, which has precedence.
+ new_wrapper = MessageWrapper(new_mdoc, new_fdoc, None, None)
+ new_wrapper.hdoc = self.hdoc
+ new_wrapper.cdocs = self.cdocs
+ new_wrapper.set_mbox_uuid(new_mbox_uuid)
+
+ # XXX could flag so that it only creates mdoc/fdoc...
+ d = new_wrapper.create(store)
+ d.addCallback(lambda result: new_wrapper)
+ return d
def set_mbox_uuid(self, mbox_uuid):
"""
diff --git a/mail/src/leap/mail/imap/mailbox.py b/mail/src/leap/mail/imap/mailbox.py
index c91f1272..1bc530e3 100644
--- a/mail/src/leap/mail/imap/mailbox.py
+++ b/mail/src/leap/mail/imap/mailbox.py
@@ -880,8 +880,8 @@ class IMAPMailbox(object):
#deferLater(self.reactor, 0, self._do_copy, message, d)
#return d
- # FIXME not implemented !!! ---
- return self.collection.copy_msg(message, self.mbox_name)
+ return self.collection.copy_msg(message.message,
+ self.collection.mbox_uuid)
# convenience fun
diff --git a/mail/src/leap/mail/mail.py b/mail/src/leap/mail/mail.py
index 4306ec3d..b46d223f 100644
--- a/mail/src/leap/mail/mail.py
+++ b/mail/src/leap/mail/mail.py
@@ -509,25 +509,27 @@ class MessageCollection(object):
return d
- def copy_msg(self, msg, newmailbox):
+ def copy_msg(self, msg, new_mbox_uuid):
"""
Copy the message to another collection. (it only makes sense for
mailbox collections)
"""
- # TODO currently broken ------------------FIXME-
if not self.is_mailbox_collection():
raise NotImplementedError()
- def insert_copied_mdoc_id(wrapper):
- # TODO this needs to be implemented before the copy
- # interface works.
- newmailbox_uuid = get_mbox_uuid_from_msg_wrapper(wrapper)
+ def insert_copied_mdoc_id(wrapper_new_msg):
return self.mbox_indexer.insert_doc(
- newmailbox_uuid, wrapper.mdoc.doc_id)
+ new_mbox_uuid, wrapper.mdoc.doc_id)
wrapper = msg.get_wrapper()
- d = wrapper.copy(self.store, newmailbox)
+
+ def print_result(result):
+ print "COPY CALLBACK:>>>", result
+ return result
+
+ d = wrapper.copy(self.store, new_mbox_uuid)
d.addCallback(insert_copied_mdoc_id)
+ d.addCallback(print_result)
return d
def delete_msg(self, msg):