1 files changed, 15 insertions, 0 deletions

diff --git a/framework/src/sinkfabric.cpp b/framework/src/sinkfabric.cpp
index 68a75a86..5e209526 100644
--- a/framework/src/sinkfabric.cpp
+++ b/framework/src/sinkfabric.cpp
@@ -53,6 +53,15 @@ public:
                 Store::synchronize(SyncScope()).exec();
             }
         }
+        if (id == "sendOutbox"/*Kube::Messages::synchronize*/) {
+            Query query;
+            query.containsFilter<SinkResource::Capabilities>(ResourceCapabilities::Mail::transport);
+            auto job = Store::fetchAll<SinkResource>(query)
+                .each([=](const SinkResource::Ptr &resource) -> KAsync::Job<void> {
+                    return Store::synchronize(SyncScope{}.resourceFilter(resource->identifier()));
+                });
+            job.exec();
+        }
         if (id == "markAsRead"/*Kube::Messages::synchronize*/) {
             if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
                 mail->setUnread(false);
@@ -77,6 +86,12 @@ public:
                 Store::modify(*mail).exec();
             }
         }
+        if (id == "moveToDrafts"/*Kube::Messages::synchronize*/) {
+            if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
+                mail->setDraft(true);
+                Store::modify(*mail).exec();
+            }
+        }
         if (id == "moveToFolder"/*Kube::Messages::synchronize*/) {
             if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
                 auto folder = message["folder"].value<ApplicationDomain::Folder::Ptr>();