Ported more actions to the fabric

3 files changed, 142 insertions, 0 deletions

diff --git a/framework/src/CMakeLists.txt b/framework/src/CMakeLists.txt
index 39f17c32..cf971497 100644
--- a/framework/src/CMakeLists.txt
+++ b/framework/src/CMakeLists.txt
@@ -50,6 +50,7 @@ set(SRCS
     accounts/accountsmodel.cpp
     notifications/notificationhandler.cpp
     fabric.cpp
+    sinkfabric.cpp
 )
 
 add_library(frameworkplugin SHARED ${SRCS})
diff --git a/framework/src/sinkfabric.cpp b/framework/src/sinkfabric.cpp
new file mode 100644
index 00000000..68a75a86
--- /dev/null
+++ b/framework/src/sinkfabric.cpp
@@ -0,0 +1,141 @@
+/*
+    Copyright (c) 2016 Christian Mollekopf <mollekopf@kolabsys.com>
+
+    This library is free software; you can redistribute it and/or modify it
+    under the terms of the GNU Library General Public License as published by
+    the Free Software Foundation; either version 2 of the License, or (at your
+    option) any later version.
+
+    This library is distributed in the hope that it will be useful, but WITHOUT
+    ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+    FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Library General Public
+    License for more details.
+
+    You should have received a copy of the GNU Library General Public License
+    along with this library; see the file COPYING.LIB.  If not, write to the
+    Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+    02110-1301, USA.
+*/
+
+#include <actions/actionhandler.h>
+
+#include <QFile>
+
+#include <sink/store.h>
+#include <sink/log.h>
+#include <sink/notification.h>
+#include <sink/notifier.h>
+
+#include "fabric.h"
+
+SINK_DEBUG_AREA("sinkactions")
+
+using namespace Kube;
+using namespace Sink;
+using namespace Sink::ApplicationDomain;
+
+class SinkListener : public Kube::Fabric::Listener
+{
+public:
+    SinkListener() = default;
+
+    void notify(const QString &id, const QVariantMap &message)
+    {
+        SinkLog() << "Received message: " << id << message;
+        if (id == "synchronize"/*Kube::Messages::synchronize*/) {
+            if (auto folder = message["folder"].value<ApplicationDomain::Folder::Ptr>()) {
+                SinkLog() << "Synchronizing folder " << folder->resourceInstanceIdentifier() << folder->identifier();
+                auto scope = SyncScope().resourceFilter(folder->resourceInstanceIdentifier()).filter<Mail::Folder>(QVariant::fromValue(folder->identifier()));
+                scope.setType<ApplicationDomain::Mail>();
+                Store::synchronize(scope).exec();
+            } else {
+                SinkLog() << "Synchronizing all";
+                Store::synchronize(SyncScope()).exec();
+            }
+        }
+        if (id == "markAsRead"/*Kube::Messages::synchronize*/) {
+            if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
+                mail->setUnread(false);
+                Store::modify(*mail).exec();
+            }
+        }
+        if (id == "markAsUnread"/*Kube::Messages::synchronize*/) {
+            if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
+                mail->setUnread(true);
+                Store::modify(*mail).exec();
+            }
+        }
+        if (id == "toggleImportant"/*Kube::Messages::synchronize*/) {
+            if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
+                mail->setImportant(message["important"].toBool());
+                Store::modify(*mail).exec();
+            }
+        }
+        if (id == "moveToTrash"/*Kube::Messages::synchronize*/) {
+            if (auto mail = message["mail"].value<ApplicationDomain::Mail::Ptr>()) {
+                mail->setTrash(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>();
+                mail->setFolder(*folder);
+                Store::modify(*mail).exec();
+            }
+        }
+
+    }
+
+};
+
+static SinkListener sinkListener;
+
+class NotificationListener {
+    NotificationListener()
+        : mNotifier{Sink::Query{Sink::Query::LiveQuery}}
+    {
+        mNotifier.registerHandler([this] (const Sink::Notification &notification) {
+            Notification n;
+            qWarning() << "Received notification: " << notification;
+            QVariantMap message;
+            if (notification.type == Sink::Notification::Warning) {
+                message["type"] = Notification::Warning;
+                if (notification.code == Sink::ApplicationDomain::TransmissionError) {
+                    message["message"] = "Failed to send message.";
+                } else {
+                    return;
+                }
+            } else if (notification.type == Sink::Notification::Status) {
+                if (notification.code == Sink::ApplicationDomain::ErrorStatus) {
+                    //A resource entered error status
+                    message["type"] = Notification::Warning;
+                    message["message"] = "A resource experienced an error.";
+                } else {
+                    return;
+                }
+            } else if (notification.type == Sink::Notification::Error) {
+                if (notification.code == Sink::ApplicationDomain::ConnectionError) {
+                    message["type"] = Notification::Warning;
+                    message["message"] = "Failed to connect to server.";
+                } else {
+                    return;
+                }
+            } else if (notification.type == Sink::Notification::Info) {
+                if (notification.code == Sink::ApplicationDomain::TransmissionSuccess) {
+                    message["type"] = Notification::Info;
+                    message["message"] = "A message has been sent.";
+                } else {
+                    return;
+                }
+            } else {
+                return;
+            }
+        });
+
+    }
+
+    Sink::Notifier mNotifier;
+
+};
+
diff --git a/framework/src/sinkfabric.h b/framework/src/sinkfabric.h
new file mode 100644
index 00000000..e69de29b
--- /dev/null
+++ b/framework/src/sinkfabric.h