Cleaned up akonadi2_client now that we have akonadish

1 files changed, 25 insertions, 223 deletions

diff --git a/examples/client/main.cpp b/examples/client/main.cpp
index ad65e44..127fd2f 100644
--- a/examples/client/main.cpp
+++ b/examples/client/main.cpp
@@ -20,19 +20,10 @@
 #include <QApplication>
 #include <QCommandLineParser>
 #include <QCommandLineOption>
-#include <QElapsedTimer>
-#include <QDir>
+#include <QTime>
 
 #include "common/clientapi.h"
-#include "common/resource.h"
-#include "common/storage.h"
-#include "common/domain/event.h"
-#include "common/domain/folder.h"
-#include "common/resourceconfig.h"
 #include "common/log.h"
-#include "common/storage.h"
-#include "common/definitions.h"
-#include "console.h"
 
 #include <QWidget>
 #include <QTreeView>
@@ -152,26 +143,6 @@ public:
 
 };
 
-class MyApplication : public QApplication
-{
-    QElapsedTimer t;
-public:
-    MyApplication(int& argc, char ** argv) : QApplication(argc, argv) { }
-    virtual ~MyApplication() { }
-
-    virtual bool notify(QObject* receiver, QEvent* event)
-    {
-        t.start();
-        bool ret = QApplication::notify(receiver, event);
-        if(t.elapsed() > 3)
-            qDebug("processing event type %d for object %s took %dms",
-                (int)event->type(), receiver->objectName().toLocal8Bit().data(),
-                (int)t.elapsed());
-        return ret;
-    }
-};
-
-
 static QSharedPointer<QAbstractItemModel> loadModel(const QString &type, Akonadi2::Query query)
 {
     QTime time;
@@ -204,11 +175,9 @@ QMap<QString, QString> consumeMap(QList<QString> &list)
 
 int main(int argc, char *argv[])
 {
-    MyApplication app(argc, argv);
+    QApplication app(argc, argv);
 
     QCommandLineParser cliOptions;
-    cliOptions.addPositionalArgument(QObject::tr("[command]"),
-                                     QObject::tr("A command"));
     cliOptions.addPositionalArgument(QObject::tr("[type]"),
                                      QObject::tr("A type to work with"));
     cliOptions.addPositionalArgument(QObject::tr("[resource]"),
@@ -217,206 +186,39 @@ int main(int argc, char *argv[])
     cliOptions.addHelpOption();
     cliOptions.process(app);
     QStringList args = cliOptions.positionalArguments();
-    auto command = args.takeFirst();
 
     if (cliOptions.isSet("debuglevel")) {
         Akonadi2::Log::setDebugOutputLevel(static_cast<Akonadi2::Log::DebugLevel>(cliOptions.value("debuglevel").toInt()));
     }
 
-    if (command == "list") {
-        auto type = !args.isEmpty() ? args.takeFirst() : QByteArray();
-        auto resources = args;
-
-        Akonadi2::Query query;
-        for (const auto &res : resources) {
-            query.resources << res.toLatin1();
-        }
-        query.syncOnDemand = false;
-        query.processAll = false;
-        query.liveQuery = false;
+    auto type = !args.isEmpty() ? args.takeFirst() : QByteArray();
+    auto resources = args;
 
-        auto model = loadModel(type, query);
-        qDebug() << "Listing";
-        int colSize = 38; //Necessary to display a complete UUID
-        std::cout << "  Column      ";
-        std::cout << QString("Resource").leftJustified(colSize, ' ', true).toStdString();
-        std::cout << QString("Identifier").leftJustified(colSize, ' ', true).toStdString();
-        for (int i = 0; i < model->columnCount(QModelIndex()); i++) {
-            std::cout << " | " << model->headerData(i, Qt::Horizontal).toString().leftJustified(colSize, ' ', true).toStdString();
-        }
-        std::cout << std::endl;
-        QObject::connect(model.data(), &QAbstractItemModel::rowsInserted, [model, colSize](const QModelIndex &index, int start, int end) {
+    Akonadi2::Query query;
+    for (const auto &res : resources) {
+        query.resources << res.toLatin1();
+    }
+    query.syncOnDemand = false;
+    query.processAll = false;
+    query.liveQuery = true;
+    if (type == "folder") {
+        query.parentProperty = "parent";
+    }
+    auto model = loadModel(type, query);
+    if (type == "folder") {
+        QObject::connect(model.data(), &QAbstractItemModel::rowsInserted, [model](const QModelIndex &index, int start, int end) {
             for (int i = start; i <= end; i++) {
-                std::cout << "  Row " << QString::number(model->rowCount()).rightJustified(4, ' ').toStdString() << ": ";
-                auto object = model->data(model->index(i, 0, index), Akonadi2::Store::DomainObjectBaseRole).value<Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr>();
-                std::cout << "  " << object->resourceInstanceIdentifier().leftJustified(colSize, ' ', true).toStdString();
-                std::cout << object->identifier().leftJustified(colSize, ' ', true).toStdString();
-                for (int col = 0; col < model->columnCount(QModelIndex()); col++) {
-                    std::cout << " | " << model->data(model->index(i, col, index)).toString().leftJustified(colSize, ' ', true).toStdString();
-                }
-                std::cout << std::endl;
+                model->fetchMore(model->index(i, 0, index));
             }
         });
-        QObject::connect(model.data(), &QAbstractItemModel::dataChanged, [model, &app](const QModelIndex &, const QModelIndex &, const QVector<int> &roles) {
-            if (roles.contains(Akonadi2::Store::ChildrenFetchedRole)) {
-                app.quit();
-            }
-        });
-        if (!model->data(QModelIndex(), Akonadi2::Store::ChildrenFetchedRole).toBool()) {
-            return app.exec();
-        }
-    } else if (command == "count") {
-        auto type = !args.isEmpty() ? args.takeFirst() : QByteArray();
-        auto resources = args;
-
-        Akonadi2::Query query;
-        for (const auto &res : resources) {
-            query.resources << res.toLatin1();
-        }
-        query.syncOnDemand = false;
-        query.processAll = false;
-        query.liveQuery = false;
-        auto model = loadModel(type, query);
-        QObject::connect(model.data(), &QAbstractItemModel::dataChanged, [model, &app](const QModelIndex &, const QModelIndex &, const QVector<int> &roles) {
-            if (roles.contains(Akonadi2::Store::ChildrenFetchedRole)) {
-                std::cout << "\tCounted results " << model->rowCount(QModelIndex()) << std::endl;
-                app.quit();
-            }
-        });
-        return app.exec();
-    } else if (command == "synchronize") {
-        auto resources = args;
-        Akonadi2::Query query;
-        for (const auto &res : resources) {
-            query.resources << res.toLatin1();
-        }
-        query.syncOnDemand = true;
-        query.processAll = true;
-        Akonadi2::Store::synchronize(query).then<void>([&app]() {
-            app.quit();
-        }).exec();
+        auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Folder> >::create(model.data());
+        app.exec();
+    } else if (type == "mail") {
+        auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Mail> >::create(model.data());
+        app.exec();
+    } else if (type == "event") {
+        auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Event> >::create(model.data());
         app.exec();
-    } else if (command == "show") {
-        auto type = !args.isEmpty() ? args.takeFirst() : QByteArray();
-        auto resources = args;
-
-        Akonadi2::Query query;
-        for (const auto &res : resources) {
-            query.resources << res.toLatin1();
-        }
-        query.syncOnDemand = false;
-        query.processAll = false;
-        query.liveQuery = true;
-        if (type == "folder") {
-            query.parentProperty = "parent";
-        }
-        auto model = loadModel(type, query);
-        if (type == "folder") {
-            QObject::connect(model.data(), &QAbstractItemModel::rowsInserted, [model](const QModelIndex &index, int start, int end) {
-                for (int i = start; i <= end; i++) {
-                    model->fetchMore(model->index(i, 0, index));
-                }
-            });
-            auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Folder> >::create(model.data());
-            app.exec();
-        } else if (type == "mail") {
-            auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Mail> >::create(model.data());
-            app.exec();
-        } else if (type == "event") {
-            auto view = QSharedPointer<View<Akonadi2::ApplicationDomain::Event> >::create(model.data());
-            app.exec();
-        }
-    } else if (command == "clear") {
-        auto resources = args;
-
-        qDebug() << "Clearing";
-        for (const auto &resource : resources) {
-            Akonadi2::Store::removeFromDisk(resource.toLatin1());
-        }
-    } else if (command == "create") {
-        auto type = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-        auto &store = getStore(type);
-        Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr object;
-        if (type == "resource") {
-            auto resourceType = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject("");
-            object->setProperty("type", resourceType);
-        } else {
-            auto resource = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject(resource);
-        }
-        auto map = consumeMap(args);
-        for (auto i = map.begin(); i != map.end(); ++i) {
-            object->setProperty(i.key().toLatin1(), i.value());
-        }
-        auto result = store.create(*object).exec();
-        result.waitForFinished();
-        if (result.errorCode()) {
-            std::cout << "An error occurred while creating the entity: " << result.errorMessage().toStdString();
-        }
-    } else if (command == "modify") {
-        auto type = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-        auto &store = getStore(type);
-        Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr object;
-        if (type == "resource") {
-            auto identifier = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject("", identifier);
-        } else {
-            auto resource = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            auto identifier = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject(resource, identifier);
-        }
-        auto map = consumeMap(args);
-        for (auto i = map.begin(); i != map.end(); ++i) {
-            object->setProperty(i.key().toLatin1(), i.value());
-        }
-        auto result = store.modify(*object).exec();
-        result.waitForFinished();
-        if (result.errorCode()) {
-            std::cout << "An error occurred while modifying the entity: " << result.errorMessage().toStdString();
-        }
-    } else if (command == "remove") {
-        auto type = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-        auto &store = getStore(type);
-        Akonadi2::ApplicationDomain::ApplicationDomainType::Ptr object;
-        if (type == "resource") {
-            auto identifier = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject("", identifier);
-        } else {
-            auto resource = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            auto identifier = !args.isEmpty() ? args.takeFirst().toLatin1() : QByteArray();
-            object = store.getObject(resource, identifier);
-        }
-        auto result = store.remove(*object).exec();
-        result.waitForFinished();
-        if (result.errorCode()) {
-            std::cout << "An error occurred while removing the entity: " << result.errorMessage().toStdString();
-        }
-    } else if (command == "stat") {
-        auto resources = args;
-        for (const auto &resource : resources) {
-            Akonadi2::Storage storage(Akonadi2::storageLocation(), resource, Akonadi2::Storage::ReadOnly);
-            auto transaction = storage.createTransaction(Akonadi2::Storage::ReadOnly);
-
-            QList<QByteArray> databases = transaction.getDatabaseNames();
-            qint64 total = 0;
-            for (const auto &databaseName : databases) {
-                std::cout << "Database: " << databaseName.toStdString() << std::endl;
-                auto db = transaction.openDatabase(databaseName);
-                auto size = db.getSize();
-                std::cout << "\tSize [kb]: " << size / 1024 << std::endl;
-                total += size;
-            }
-            std::cout << "Total [kb]: " << total / 1024 << std::endl;
-            int diskUsage = 0;
-            QDir dir(Akonadi2::storageLocation());
-            for (const auto &folder : dir.entryList(QStringList() << resource + "*")) {
-                diskUsage += Akonadi2::Storage(Akonadi2::storageLocation(), folder, Akonadi2::Storage::ReadOnly).diskUsage();
-            }
-            std::cout << "Disk usage [kb]: " << diskUsage / 1024 << std::endl;
-        }
-    } else {
-        qWarning() << "Unknown command " << command;
     }
     return 0;
 }