Composer test

4 files changed, 160 insertions, 0 deletions

diff --git a/framework/src/CMakeLists.txt b/framework/src/CMakeLists.txt
index a5b2f6bc..526fbefe 100644
--- a/framework/src/CMakeLists.txt
+++ b/framework/src/CMakeLists.txt
@@ -46,6 +46,7 @@ add_library(kubeframework SHARED
     webengineprofile.cpp
     startupcheck.cpp
     keyring.cpp
+    domainobjectcontroller.cpp
     )
 target_link_libraries(kubeframework
     sink
diff --git a/framework/src/domainobjectcontroller.cpp b/framework/src/domainobjectcontroller.cpp
new file mode 100644
index 00000000..eb1fd417
--- /dev/null
+++ b/framework/src/domainobjectcontroller.cpp
@@ -0,0 +1,109 @@
+/*
+    Copyright (c) 2018 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 "domainobjectcontroller.h"
+
+#include <sink/store.h>
+#include <sink/applicationdomaintype.h>
+#include <kmime/kmime_message.h>
+#include <mailtemplates.h>
+
+using namespace Kube;
+
+DomainObjectController::DomainObjectController(QObject *parent)
+    : QObject(parent)
+{
+
+}
+
+QStringList toStringList(const QVariantList &list)
+{
+    QStringList s;
+    for (const auto &e : list) {
+        s << e.toString();
+    }
+    return s;
+}
+
+void DomainObjectController::create(const QVariantMap &object)
+{
+    using namespace Sink::ApplicationDomain;
+    qWarning() << "Creating " << object;
+    auto type = object["type"].toString();
+    if (type == getTypeName<Mail>()) {
+        auto toAddresses = toStringList(object["to"].toList());
+        auto ccAddresses = toStringList(object["cc"].toList());
+        auto bccAddresses = toStringList(object["bcc"].toList());
+
+        KMime::Types::Mailbox mb;
+        mb.fromUnicodeString("identity@example.org");
+        auto msg = MailTemplates::createMessage({},
+                toAddresses,
+                ccAddresses,
+                bccAddresses,
+                mb,
+                object["subject"].toString(),
+                object["body"].toString(),
+                {},
+                {},
+                {},
+                {});
+
+        Sink::Query query;
+        query.containsFilter<SinkResource::Capabilities>(ResourceCapabilities::Mail::storage);
+        query.filter<SinkResource::Account>("account1");
+        Sink::Store::fetchAll<SinkResource>(query)
+            .then([=](const QList<SinkResource::Ptr> &resources) {
+                if (!resources.isEmpty()) {
+                    auto resourceId = resources[0]->identifier();
+                    qWarning() << "Using resource " << resourceId << " from account " << resources[0]->getAccount();
+                    auto mail = ApplicationDomainType::createEntity<Mail>(resourceId);
+                    mail.setMimeMessage(msg->encodedContent(true));
+                    Sink::Store::create<Mail>(mail).exec();
+                    monitor(QVariant::fromValue(Mail::Ptr::create(mail)));
+                } else {
+                    qWarning() << "No resources found.";
+                }
+            }).exec();
+    }
+
+}
+
+void DomainObjectController::monitor(const QVariant &object)
+{
+    using namespace Sink::ApplicationDomain;
+    qWarning() << "Monitoring " << object;
+    auto mail = object.value<Mail::Ptr>();
+    Q_ASSERT(mail);
+    Sink::Query query{*mail};
+    query.setFlags(Sink::Query::LiveQuery);
+    mModel = Sink::Store::loadModel<Mail>(query);
+    QObject::connect(mModel.data(), &QAbstractItemModel::rowsInserted, [=](const QModelIndex &index, int start, int end) {
+        for (int i = start; i <= end; i++) {
+            auto mail = mModel->index(i, 0, QModelIndex()).data(Sink::Store::DomainObjectRole).value<Mail::Ptr>();
+            mCurrentObject = QVariant::fromValue(mail);
+            emit currentObjectChanged();
+            break;
+        }
+    });
+}
+
+QVariant DomainObjectController::currentObject() const
+{
+    return mCurrentObject;
+}
diff --git a/framework/src/domainobjectcontroller.h b/framework/src/domainobjectcontroller.h
new file mode 100644
index 00000000..5805c5a8
--- /dev/null
+++ b/framework/src/domainobjectcontroller.h
@@ -0,0 +1,48 @@
+/*
+    Copyright (c) 2018 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.
+*/
+#pragma once
+
+#include <QObject>
+#include <QVariant>
+#include <QAbstractItemModel>
+#include <QSharedPointer>
+
+namespace Kube {
+
+class DomainObjectController : public QObject
+{
+    Q_OBJECT
+    Q_PROPERTY(QVariant currentObject READ currentObject NOTIFY currentObjectChanged)
+public:
+    explicit DomainObjectController(QObject *parent = 0);
+
+    QVariant currentObject() const;
+
+    Q_INVOKABLE void create(const QVariantMap &object);
+    Q_INVOKABLE void monitor(const QVariant &object);
+
+signals:
+    void currentObjectChanged();
+
+private:
+    QVariant mCurrentObject;
+    QSharedPointer<QAbstractItemModel> mModel;
+};
+
+}
diff --git a/framework/src/frameworkplugin.cpp b/framework/src/frameworkplugin.cpp
index 1de776a5..f768be1b 100644
--- a/framework/src/frameworkplugin.cpp
+++ b/framework/src/frameworkplugin.cpp
@@ -40,6 +40,7 @@
 #include "startupcheck.h"
 #include "keyring.h"
 #include "controller.h"
+#include "domainobjectcontroller.h"
 
 #include <QtQml>
 #include <QQuickImageProvider>
@@ -133,6 +134,7 @@ void FrameworkPlugin::registerTypes (const char *uri)
     qmlRegisterType<Kube::Settings>(uri, 1, 0, "Settings");
 
     qmlRegisterType<Kube::Fabric::Listener>(uri, 1, 0, "Listener");
+    qmlRegisterType<Kube::DomainObjectController>(uri, 1, 0, "DomainObjectController");
     qmlRegisterSingletonType<Kube::Fabric::Fabric>(uri, 1, 0, "Fabric", fabric_singletontype_provider);
 
     qmlRegisterType<KubeImage>(uri, 1, 0, "KubeImage");