7 files changed, 64 insertions, 70 deletions

diff --git a/framework/domain/accountfactory.cpp b/framework/domain/accountfactory.cpp
index ab1a09e5..10f01f65 100644
--- a/framework/domain/accountfactory.cpp
+++ b/framework/domain/accountfactory.cpp
@@ -25,20 +25,29 @@
 #include <KPluginMetaData>
 
 #include "settings/settings.h"
+#include <sink/store.h>
 
 AccountFactory::AccountFactory(QObject *parent)
     : QObject(parent)
 {
 }
 
+QString AccountFactory::name() const
+{
+    if (mName.isEmpty()) {
+        return tr("Account");
+    }
+    return mName;
+}
+
 void AccountFactory::setAccountId(const QString &accountId)
 {
     mAccountId = accountId;
-
-    Kube::Account account(mAccountId.toUtf8());
-    mAccountType = account.type();
-
-    loadPackage();
+    Sink::Store::fetchOne<Sink::ApplicationDomain::SinkAccount>(Sink::Query::IdentityFilter(accountId.toUtf8()))
+        .then<void, Sink::ApplicationDomain::SinkAccount>([this](const Sink::ApplicationDomain::SinkAccount &account) {
+            mAccountType = account.getProperty("type").toByteArray();
+            loadPackage();
+        }).exec();
 }
 
 void AccountFactory::loadPackage()
diff --git a/framework/domain/accountfactory.h b/framework/domain/accountfactory.h
index ed3c21d9..047454ae 100644
--- a/framework/domain/accountfactory.h
+++ b/framework/domain/accountfactory.h
@@ -29,13 +29,14 @@ class AccountFactory : public QObject
 {
     Q_OBJECT
     Q_PROPERTY(QString accountId MEMBER mAccountId WRITE setAccountId);
-    Q_PROPERTY(QString name MEMBER mName NOTIFY accountLoaded);
+    Q_PROPERTY(QString name MEMBER mName READ name NOTIFY accountLoaded);
     Q_PROPERTY(QString icon MEMBER mIcon NOTIFY accountLoaded);
     Q_PROPERTY(QString uiPath MEMBER mUiPath NOTIFY accountLoaded);
 public:
     explicit AccountFactory(QObject *parent = Q_NULLPTR);
 
     void setAccountId(const QString &);
+    QString name() const;
 
 signals:
     void accountLoaded();
diff --git a/framework/domain/accountscontroller.cpp b/framework/domain/accountscontroller.cpp
index 1be03ba9..b5e7e9ca 100644
--- a/framework/domain/accountscontroller.cpp
+++ b/framework/domain/accountscontroller.cpp
@@ -21,6 +21,7 @@
 #include "accountscontroller.h"
 
 #include <settings/settings.h>
+#include <sink/store.h>
 
 #include <QVariant>
 #include <QUuid>
@@ -28,27 +29,17 @@
 
 AccountsController::AccountsController(QObject *parent) : QObject(parent)
 {
-    Kube::Settings settings("accounts");
-    mAccounts = settings.property("accounts").toStringList();
-    qWarning() << "Loaded accounts" << mAccounts;
 }
 
 void AccountsController::createAccount(const QString &accountType)
 {
-    auto identifier = QUuid::createUuid().toByteArray();
-    Kube::Account accountSettings(identifier);
-    accountSettings.setProperty("type", accountType);
-    accountSettings.save();
-
-    Kube::Settings settings("accounts");
-    auto accounts = settings.property("accounts").toStringList();
-    accounts.append(identifier);
-    settings.setProperty("accounts", accounts);
-    settings.save();
-
-    //TODO setup sink resources etc via plugin
-
-    qWarning() << "Created account " << identifier;
-    mAccounts.append(identifier);
-    emit accountsChanged();
+    const auto identifier = QUuid::createUuid().toByteArray();
+    Sink::ApplicationDomain::SinkAccount account;
+    account.setProperty("identifier", identifier);
+    account.setProperty("type", accountType);
+    Sink::Store::create(account).then<void>([]() {},
+    [](int errorCode, const QString &errorMessage) {
+        qWarning() << "Error while creating account: " << errorMessage;
+    })
+    .exec();
 }
diff --git a/framework/domain/accountscontroller.h b/framework/domain/accountscontroller.h
index 9d98de71..a4421de8 100644
--- a/framework/domain/accountscontroller.h
+++ b/framework/domain/accountscontroller.h
@@ -21,23 +21,13 @@
 
 #include <QObject>
 #include <QString>
-#include <QStringList>
-#include <QVariant>
 
 class AccountsController : public QObject
 {
     Q_OBJECT
-    Q_PROPERTY (QStringList accounts MEMBER mAccounts NOTIFY accountsChanged)
-
 public:
     explicit AccountsController(QObject *parent = Q_NULLPTR);
 
-signals:
-    void accountsChanged();
-
 public slots:
     void createAccount(const QString &accountId);
-
-private:
-    QStringList mAccounts;
 };
diff --git a/framework/domain/accountsmodel.cpp b/framework/domain/accountsmodel.cpp
index b5eafd53..8a3ab317 100644
--- a/framework/domain/accountsmodel.cpp
+++ b/framework/domain/accountsmodel.cpp
@@ -17,15 +17,14 @@
     02110-1301, USA.
 */
 #include "accountsmodel.h"
+#include <sink/store.h>
 
-#include <settings/settings.h>
-
-#include <QVariant>
-
-AccountsModel::AccountsModel(QObject *parent) : QAbstractListModel()
+AccountsModel::AccountsModel(QObject *parent) : QIdentityProxyModel()
 {
-    Kube::Settings settings("accounts");
-    mAccounts = settings.property("accounts").toStringList();
+    Sink::Query query;
+    query.liveQuery = true;
+    query.requestedProperties << "name" << "icon";
+    runQuery(query);
 }
 
 AccountsModel::~AccountsModel()
@@ -46,20 +45,20 @@ QHash< int, QByteArray > AccountsModel::roleNames() const
 
 QVariant AccountsModel::data(const QModelIndex &idx, int role) const
 {
-    const auto identifier = mAccounts.at(idx.row());
-    Kube::Account accountSettings(identifier.toLatin1());
+    auto srcIdx = mapToSource(idx);
     switch (role) {
         case Name:
-            return accountSettings.property("accountName").toString();
+            return srcIdx.sibling(srcIdx.row(), 0).data(Qt::DisplayRole).toString();
         case Icon:
-            return accountSettings.property("icon").toString();
+            return srcIdx.sibling(srcIdx.row(), 1).data(Qt::DisplayRole).toString();
         case AccountId:
-            return identifier;
+            return srcIdx.data(Sink::Store::DomainObjectBaseRole).value<Sink::ApplicationDomain::ApplicationDomainType::Ptr>()->identifier();
     }
-    return QVariant();
+    return QIdentityProxyModel::data(idx, role);
 }
 
-int AccountsModel::rowCount(const QModelIndex &idx) const
+void AccountsModel::runQuery(const Sink::Query &query)
 {
-    return mAccounts.size();
+    mModel = Sink::Store::loadModel<Sink::ApplicationDomain::SinkAccount>(query);
+    setSourceModel(mModel.data());
 }
diff --git a/framework/domain/accountsmodel.h b/framework/domain/accountsmodel.h
index a50c2e4a..9180bc09 100644
--- a/framework/domain/accountsmodel.h
+++ b/framework/domain/accountsmodel.h
@@ -20,11 +20,15 @@
 #pragma once
 
 #include <QObject>
-#include <QAbstractListModel>
+#include <QIdentityProxyModel>
 #include <QSharedPointer>
 #include <QStringList>
 
-class AccountsModel : public QAbstractListModel
+namespace Sink {
+    class Query;
+}
+
+class AccountsModel : public QIdentityProxyModel
 {
     Q_OBJECT
 
@@ -32,8 +36,7 @@ public:
     AccountsModel(QObject *parent = Q_NULLPTR);
     ~AccountsModel();
 
-    int rowCount(const QModelIndex &parent = QModelIndex()) const Q_DECL_OVERRIDE;
-    QVariant data(const QModelIndex &index, int role = Qt::DisplayRole) const Q_DECL_OVERRIDE;
+    QVariant data(const QModelIndex &index, int role = Qt::DisplayRole) const;
 
     enum Roles {
         Name  = Qt::UserRole + 1,
@@ -42,7 +45,9 @@ public:
     };
     Q_ENUMS(Roles)
 
-    QHash<int, QByteArray> roleNames() const Q_DECL_OVERRIDE;
+    QHash<int, QByteArray> roleNames() const;
+
 private:
-    QStringList mAccounts;
+    void runQuery(const Sink::Query &query);
+    QSharedPointer<QAbstractItemModel> mModel;
 };
diff --git a/framework/domain/folderlistmodel.cpp b/framework/domain/folderlistmodel.cpp
index f212e336..14d3d5a7 100644
--- a/framework/domain/folderlistmodel.cpp
+++ b/framework/domain/folderlistmodel.cpp
@@ -72,20 +72,19 @@ void FolderListModel::runQuery(const Sink::Query &query)
 
 void FolderListModel::setAccountId(const QVariant &accountId)
 {
-    const auto account = accountId.toString();
-    Kube::Account accountSettings(account.toUtf8());
-    //FIXME maildirResource is obviously not good. We need a way to find resources that belong to the account and provide folders.
-    const auto resourceId = accountSettings.property("maildirResource").toString();
-    qDebug() << "Running query for account " << account;
-    qDebug() << "Found resources " << resourceId;
-
-    Sink::Query query;
-    query.liveQuery = true;
-    query.requestedProperties << "name" << "icon" << "parent";
-    query.parentProperty = "parent";
-    query.resources << resourceId.toUtf8();
-
-    runQuery(query);
+    const auto account = accountId.toString().toUtf8();
+    Sink::Store::fetchAll<Sink::ApplicationDomain::SinkResource>(Sink::Query::PropertyFilter("account", QVariant::fromValue(account)))
+        .then<void, QList<Sink::ApplicationDomain::SinkResource::Ptr>>([this, account](const QList<Sink::ApplicationDomain::SinkResource::Ptr> &resources) {
+            Sink::Query query;
+            query.liveQuery = true;
+            query.requestedProperties << "name" << "icon" << "parent";
+            query.parentProperty = "parent";
+            for (const auto &r : resources) {
+                qDebug() << "Found resources for account: " << r->identifier() << account;
+                query.resources << r->identifier();
+            }
+            runQuery(query);
+        }).exec();
 }
 
 QVariant FolderListModel::accountId() const