A generic mailtest that can be applied to all resources that support

mails.

5 files changed, 309 insertions, 4 deletions

diff --git a/examples/imapresource/tests/CMakeLists.txt b/examples/imapresource/tests/CMakeLists.txt
index 8482720..b10adcd 100644
--- a/examples/imapresource/tests/CMakeLists.txt
+++ b/examples/imapresource/tests/CMakeLists.txt
@@ -16,8 +16,10 @@ endmacro(auto_tests)
 auto_tests (
     imapresourcetest
     imapserverproxytest
+    imapmailtest
 )
 target_link_libraries(imapresourcetest sink_resource_imap)
 target_link_libraries(imapserverproxytest sink_resource_imap)
+target_link_libraries(imapmailtest sink_test sink_resource_imap)
 
 install(FILES ${CMAKE_CURRENT_SOURCE_DIR}/resetmailbox.sh DESTINATION bin PERMISSIONS OWNER_EXECUTE OWNER_WRITE OWNER_READ GROUP_EXECUTE GROUP_READ)
diff --git a/examples/imapresource/tests/imapmailtest.cpp b/examples/imapresource/tests/imapmailtest.cpp
new file mode 100644
index 0000000..82324af
--- /dev/null
+++ b/examples/imapresource/tests/imapmailtest.cpp
@@ -0,0 +1,45 @@
+#include <QtTest>
+
+#include <tests/mailtest.h>
+#include "../imapresource.h"
+
+#include "common/test.h"
+#include "common/domain/applicationdomaintype.h"
+
+using namespace Sink;
+using namespace Sink::ApplicationDomain;
+
+/**
+ * Test of complete system using the imap resource.
+ *
+ * This test requires the imap resource installed.
+ */
+class ImapMailTest : public Sink::MailTest
+{
+    Q_OBJECT
+
+protected:
+    void resetTestEnvironment() Q_DECL_OVERRIDE
+    {
+        system("resetmailbox.sh");
+    }
+
+    Sink::ApplicationDomain::SinkResource createResource() Q_DECL_OVERRIDE
+    {
+        auto resource = ApplicationDomain::ImapResource::create("account1");
+        resource.setProperty("server", "localhost");
+        resource.setProperty("port", 993);
+        resource.setProperty("user", "doe");
+        resource.setProperty("password", "doe");
+        return resource;
+    }
+
+    void removeResourceFromDisk(const QByteArray &identifier) Q_DECL_OVERRIDE
+    {
+        ::ImapResource::removeFromDisk(identifier);
+    }
+};
+
+QTEST_MAIN(ImapMailTest)
+
+#include "imapmailtest.moc"
diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt
index c9f7591..9de6ffa 100644
--- a/tests/CMakeLists.txt
+++ b/tests/CMakeLists.txt
@@ -10,22 +10,28 @@ include_directories(
 
 add_definitions(-DTESTDATAPATH="${CMAKE_CURRENT_SOURCE_DIR}/data")
 
+find_package(KF5 COMPONENTS REQUIRED Mime)
+
+add_library(sink_test SHARED testimplementations.cpp getrssusage.cpp mailtest.cpp)
+qt5_use_modules(sink_test Core Test Concurrent)
+target_link_libraries(sink_test sink libhawd KF5::Mime)
+
 macro(manual_tests)
     foreach(_testname ${ARGN})
-        add_executable(${_testname} ${_testname}.cpp testimplementations.cpp getrssusage.cpp)
+        add_executable(${_testname} ${_testname}.cpp)
         generate_flatbuffers(${_testname} calendar)
         qt5_use_modules(${_testname} Core Test Concurrent)
-        target_link_libraries(${_testname} sink libhawd)
+        target_link_libraries(${_testname} sink libhawd sink_test)
     endforeach(_testname)
 endmacro(manual_tests)
 
 macro(auto_tests)
     foreach(_testname ${ARGN})
-        add_executable(${_testname} ${_testname}.cpp testimplementations.cpp getrssusage.cpp)
+        add_executable(${_testname} ${_testname}.cpp)
         generate_flatbuffers(${_testname} calendar)
         add_test(${_testname} ${_testname})
         qt5_use_modules(${_testname} Core Test Concurrent)
-        target_link_libraries(${_testname} sink libhawd)
+        target_link_libraries(${_testname} sink libhawd  sink_test)
     endforeach(_testname)
 endmacro(auto_tests)
 
diff --git a/tests/mailtest.cpp b/tests/mailtest.cpp
new file mode 100644
index 0000000..79a077c
--- /dev/null
+++ b/tests/mailtest.cpp
@@ -0,0 +1,183 @@
+/*
+ *   Copyright (C) 2016 Christian Mollekopf <chrigi_1@fastmail.fm>
+ *
+ *   This program is free software; you can redistribute it and/or modify
+ *   it under the terms of the GNU General Public License as published by
+ *   the Free Software Foundation; either version 2 of the License, or
+ *   (at your option) any later version.
+ *
+ *   This program 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 General Public License for more details.
+ *
+ *   You should have received a copy of the GNU General Public License
+ *   along with this program; if not, write to the
+ *   Free Software Foundation, Inc.,
+ *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA.
+ */
+#include "mailtest.h"
+
+#include <QtTest>
+
+#include <QString>
+#include <KMime/Message>
+
+#include "store.h"
+#include "resourcecontrol.h"
+#include "log.h"
+#include "test.h"
+
+using namespace Sink;
+using namespace Sink::ApplicationDomain;
+
+void MailTest::initTestCase()
+{
+    Test::initTest();
+    Log::setDebugOutputLevel(Sink::Log::Trace);
+    resetTestEnvironment();
+    auto resource = createResource();
+    QVERIFY(!resource.identifier().isEmpty());
+
+    VERIFYEXEC(Store::create(resource));
+
+    mResourceInstanceIdentifier = resource.identifier();
+}
+
+void MailTest::cleanup()
+{
+    VERIFYEXEC(ResourceControl::shutdown(mResourceInstanceIdentifier));
+    removeResourceFromDisk(mResourceInstanceIdentifier);
+}
+
+void MailTest::init()
+{
+    qDebug();
+    qDebug() << "-----------------------------------------";
+    qDebug();
+    VERIFYEXEC(ResourceControl::start(mResourceInstanceIdentifier));
+}
+
+void MailTest::testCreateModifyDeleteFolder()
+{
+    QString name = "name";
+    QByteArray icon = "icon";
+
+    auto folder = Folder::create(mResourceInstanceIdentifier);
+    folder.setName(name);
+    folder.setIcon(icon);
+
+    VERIFYEXEC(Store::create(folder));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
+    {
+        auto job = Store::fetchAll<Folder>(Query::RequestedProperties(QByteArrayList() << Folder::Name::name << Folder::Icon::name))
+            .then<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) {
+                QCOMPARE(folders.size(), 1);
+                auto folder = *folders.first();
+                QCOMPARE(folder.getName(), name);
+                QCOMPARE(folder.getIcon(), icon);
+            });
+        VERIFYEXEC(job);
+    }
+
+    QString name2 = "name2";
+    QByteArray icon2 = "icon2";
+    folder.setName(name2);
+    folder.setIcon(icon2);
+
+    VERIFYEXEC(Store::modify(folder));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
+    {
+        auto job = Store::fetchAll<Folder>(Query::RequestedProperties(QByteArrayList() << Folder::Name::name << Folder::Icon::name))
+            .then<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) {
+                QCOMPARE(folders.size(), 1);
+                auto folder = *folders.first();
+                QCOMPARE(folder.getName(), name2);
+                QCOMPARE(folder.getIcon(), icon2);
+            });
+        VERIFYEXEC(job);
+    }
+
+    VERIFYEXEC(Store::remove(folder));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
+    {
+        auto job = Store::fetchAll<Folder>(Query::RequestedProperties(QByteArrayList() << Folder::Name::name << Folder::Icon::name))
+            .then<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) {
+                QCOMPARE(folders.size(), 0);
+            });
+        VERIFYEXEC(job);
+    }
+}
+
+void MailTest::testCreateModifyDeleteMail()
+{
+
+    const auto subject = QString::fromLatin1("Foobar");
+
+    Query query;
+    query.resources << mResourceInstanceIdentifier;
+    query.request<Mail::Folder>().request<Mail::Subject>();
+
+    auto folder = Folder::create(mResourceInstanceIdentifier);
+    folder.setName("folder");
+    VERIFYEXEC(Store::create(folder));
+
+    auto message = KMime::Message::Ptr::create();
+    message->subject(true)->fromUnicodeString(subject, "utf8");
+    message->assemble();
+
+    auto mail = Mail::create(mResourceInstanceIdentifier);
+    mail.setMimeMessage(message->encodedContent());
+    mail.setFolder(folder);
+
+    VERIFYEXEC(Store::create(mail));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(query.resources));
+    {
+        auto job = Store::fetchAll<Mail>(Query::RequestedProperties(QByteArrayList() << Mail::Folder::name << Mail::Subject::name))
+            .then<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) {
+                QCOMPARE(mails.size(), 1);
+                auto mail = *mails.first();
+                // QCOMPARE(mail.getSubject(), subject);
+                QCOMPARE(mail.getFolder(), folder.identifier());
+                // TODO test access to mime message
+
+                // return Store::remove(*mail)
+                //     .then(ResourceControl::flushReplayQueue(query.resources)) // The change needs to be replayed already
+                //     .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::ExistenceInspection(*mail, false)));
+            });
+        VERIFYEXEC(job);
+    }
+
+    const auto subject2 = QString::fromLatin1("Foobar2");
+    auto message2 = KMime::Message::Ptr::create();
+    message2->subject(true)->fromUnicodeString(subject2, "utf8");
+    message2->assemble();
+    mail.setMimeMessage(message2->encodedContent());
+
+    VERIFYEXEC(Store::modify(mail));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(query.resources));
+    {
+        auto job = Store::fetchAll<Mail>(Query::RequestedProperties(QByteArrayList() << Mail::Folder::name << Mail::Subject::name))
+            .then<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) {
+                QCOMPARE(mails.size(), 1);
+                auto mail = *mails.first();
+                QCOMPARE(mail.getFolder(), folder.identifier());
+                // QCOMPARE(mail.getSubject(), subject);
+                // TODO test access to modified mime message
+
+            });
+        VERIFYEXEC(job);
+    }
+
+    VERIFYEXEC(Store::remove(mail));
+    VERIFYEXEC(ResourceControl::flushMessageQueue(query.resources));
+    {
+        auto job = Store::fetchAll<Mail>(Query::RequestedProperties(QByteArrayList() << Mail::Folder::name << Mail::Subject::name))
+            .then<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) {
+                QCOMPARE(mails.size(), 0);
+            });
+        VERIFYEXEC(job);
+    }
+}
+
+#include "mailtest.moc"
diff --git a/tests/mailtest.h b/tests/mailtest.h
new file mode 100644
index 0000000..0729a91
--- /dev/null
+++ b/tests/mailtest.h
@@ -0,0 +1,69 @@
+/*
+ *   Copyright (C) 2016 Christian Mollekopf <chrigi_1@fastmail.fm>
+ *
+ *   This program is free software; you can redistribute it and/or modify
+ *   it under the terms of the GNU General Public License as published by
+ *   the Free Software Foundation; either version 2 of the License, or
+ *   (at your option) any later version.
+ *
+ *   This program 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 General Public License for more details.
+ *
+ *   You should have received a copy of the GNU General Public License
+ *   along with this program; if not, write to the
+ *   Free Software Foundation, Inc.,
+ *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA.
+ */
+#pragma once
+
+#include <QObject>
+#include <QByteArray>
+
+#include <applicationdomaintype.h>
+
+#define ASYNCCOMPARE(actual, expected) \
+do {\
+    if (!QTest::qCompare(actual, expected, #actual, #expected, __FILE__, __LINE__))\
+        return KAsync::error<void>(1, "Comparison failed.");\
+} while (0)
+
+#define ASYNCVERIFY(statement) \
+do {\
+    if (!QTest::qVerify((statement), #statement, "", __FILE__, __LINE__))\
+        return KAsync::error<void>(1, "Verify failed.");\
+} while (0)
+
+#define VERIFYEXEC(statement) \
+do {\
+    auto result = statement.exec(); \
+    result.waitForFinished(); \
+    if (!QTest::qVerify(!result.errorCode(), #statement, "", __FILE__, __LINE__))\
+        return;\
+} while (0)
+
+namespace Sink {
+
+class MailTest : public QObject
+{
+    Q_OBJECT
+
+protected:
+    QByteArray mResourceInstanceIdentifier;
+
+    virtual void resetTestEnvironment() = 0;
+    virtual Sink::ApplicationDomain::SinkResource createResource() = 0;
+    virtual void removeResourceFromDisk(const QByteArray &mResourceInstanceIdentifier) = 0;
+
+private slots:
+    void initTestCase();
+    void init();
+    void cleanup();
+
+    void testCreateModifyDeleteFolder();
+    void testCreateModifyDeleteMail();
+};
+
+}
+