From de9e304c724b5de421a231bcc449a6f3dd0eb48b Mon Sep 17 00:00:00 2001 From: Minijackson Date: Mon, 30 Apr 2018 13:48:50 +0200 Subject: Add replay of events --- examples/caldavresource/tests/caldavtest.cpp | 250 +++++++++++++++++++++++---- 1 file changed, 218 insertions(+), 32 deletions(-) (limited to 'examples/caldavresource/tests') diff --git a/examples/caldavresource/tests/caldavtest.cpp b/examples/caldavresource/tests/caldavtest.cpp index 584e288..35ab033 100644 --- a/examples/caldavresource/tests/caldavtest.cpp +++ b/examples/caldavresource/tests/caldavtest.cpp @@ -1,5 +1,14 @@ #include +#include +#include +#include +#include +#include + +#include +#include + #include "../caldavresource.h" #include "common/resourcecontrol.h" @@ -8,6 +17,8 @@ #include "common/test.h" #include "tests/testutils.h" +#include + using Sink::ApplicationDomain::Calendar; using Sink::ApplicationDomain::DummyResource; using Sink::ApplicationDomain::Event; @@ -20,16 +31,17 @@ class CalDavTest : public QObject SinkResource createResource() { auto resource = Sink::ApplicationDomain::CalDavResource::create("account1"); - resource.setProperty("server", "http://localhost/dav/calendars/users/doe"); - resource.setProperty("username", "doe"); - Sink::SecretStore::instance().insert(resource.identifier(), "doe"); + resource.setProperty("server", "http://localhost:5232"); + resource.setProperty("username", "test1"); + Sink::SecretStore::instance().insert(resource.identifier(), "test1"); resource.setProperty("testmode", true); return resource; } - QByteArray mResourceInstanceIdentifier; + QString addedEventUid; + private slots: void initTestCase() @@ -51,34 +63,208 @@ private slots: VERIFYEXEC(Sink::ResourceControl::start(mResourceInstanceIdentifier)); } - // void testSyncCal() - // { - // VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); - // // Check in the logs that it doesn't synchronize events again because same CTag - // VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); - // } - - // void testSyncCalEmpty() - // { - // VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); - - // auto eventJob = - // Sink::Store::fetchAll(Sink::Query().request()).then([](const QList &events) { - // QCOMPARE(events.size(), 14); - // }); - // VERIFYEXEC(eventJob); - - // auto calendarJob = - // Sink::Store::fetchAll(Sink::Query().request()).then([](const QList &calendars) { - // QCOMPARE(calendars.size(), 2); - // for (const auto &calendar : calendars) { - // QVERIFY(calendar->getName() == "Calendar" || calendar->getName() == "Tasks"); - // } - // }); - // VERIFYEXEC(calendarJob); - - // SinkLog() << "Finished"; - // } + void testSyncCal() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + // Check in the logs that it doesn't synchronize events again because same CTag + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + } + + void testSyncCalEmpty() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + auto eventJob = Sink::Store::fetchAll(Sink::Query().request()) + .then([](const QList &events) { QCOMPARE(events.size(), 1); }); + VERIFYEXEC(eventJob); + + auto calendarJob = Sink::Store::fetchAll(Sink::Query().request()) + .then([](const QList &calendars) { + QCOMPARE(calendars.size(), 1); + for (const auto &calendar : calendars) { + QVERIFY(calendar->getName() == "MyCalendar"); + } + }); + VERIFYEXEC(calendarJob); + + SinkLog() << "Finished"; + } + + void testAddEvent() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + auto job = Sink::Store::fetchOne({}).exec(); + job.waitForFinished(); + QVERIFY2(!job.errorCode(), "Fetching Calendar failed"); + auto calendar = job.value(); + + auto event = QSharedPointer::create(); + event->setSummary("Hello"); + event->setDtStart(QDateTime::currentDateTime()); + event->setDtEnd(QDateTime::currentDateTime().addSecs(3600)); + event->setCreated(QDateTime::currentDateTime()); + addedEventUid = QUuid::createUuid().toString(); + event->setUid(addedEventUid); + + auto ical = KCalCore::ICalFormat().toICalString(event); + Event sinkEvent(mResourceInstanceIdentifier); + sinkEvent.setIcal(ical.toUtf8()); + sinkEvent.setCalendar(calendar); + + SinkLog() << "Adding event"; + VERIFYEXEC(Sink::Store::create(sinkEvent)); + VERIFYEXEC(Sink::ResourceControl::flushReplayQueue(mResourceInstanceIdentifier)); + + auto verifyEventCountJob = + Sink::Store::fetchAll(Sink::Query().request()).then([](const QList &events) { + QCOMPARE(events.size(), 2); + }); + VERIFYEXEC(verifyEventCountJob); + + auto verifyEventJob = + Sink::Store::fetchOne(Sink::Query().filter("uid", Sink::Query::Comparator(addedEventUid))) + .then([](const Event &event) { QCOMPARE(event.getSummary(), "Hello"); }); + VERIFYEXEC(verifyEventJob); + } + + void testModifyEvent() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + auto job = Sink::Store::fetchOne( + Sink::Query().filter("uid", Sink::Query::Comparator(addedEventUid))) + .exec(); + job.waitForFinished(); + QVERIFY2(!job.errorCode(), "Fetching Event failed"); + auto event = job.value(); + + auto incidence = KCalCore::ICalFormat().readIncidence(event.getIcal()); + auto calevent = incidence.dynamicCast(); + QVERIFY2(calevent, "Cannot convert to KCalCore event"); + + calevent->setSummary("Hello World!"); + auto dummy = QSharedPointer(calevent); + auto newical = KCalCore::ICalFormat().toICalString(dummy); + + event.setIcal(newical.toUtf8()); + + VERIFYEXEC(Sink::Store::modify(event)); + + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + auto verifyEventCountJob = Sink::Store::fetchAll({}).then( + [](const QList &events) { QCOMPARE(events.size(), 2); }); + VERIFYEXEC(verifyEventCountJob); + + auto verifyEventJob = + Sink::Store::fetchOne(Sink::Query().filter("uid", Sink::Query::Comparator(addedEventUid))) + .then([](const Event &event) { QCOMPARE(event.getSummary(), "Hello World!"); }); + VERIFYEXEC(verifyEventJob); + } + + void testSneakyModifyEvent() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + // Change the item without sink's knowledge + { + qWarning() << 1; + auto collection = ([]() -> KDAV2::DavCollection { + KDAV2::DavUrl davurl({ "http://test1:test1@localhost:5232" }, KDAV2::CalDav); + KDAV2::DavCollectionsFetchJob collectionsJob(davurl); + collectionsJob.exec(); + Q_ASSERT(collectionsJob.error() == 0); + return collectionsJob.collections()[0]; + })(); + + auto itemList = ([&collection]() -> KDAV2::DavItem::List { + auto cache = std::make_shared(); + KDAV2::DavItemsListJob itemsListJob(collection.url(), cache); + itemsListJob.exec(); + Q_ASSERT(itemsListJob.error() == 0); + return itemsListJob.items(); + })(); + auto hollowDavItemIt = + std::find_if(itemList.begin(), itemList.end(), [this](const KDAV2::DavItem &item) { + return item.url().url().path().endsWith(addedEventUid); + }); + + auto davitem = ([this, &collection, &hollowDavItemIt]() -> KDAV2::DavItem { + QString itemUrl = collection.url().url().toEncoded() + addedEventUid; + KDAV2::DavItemFetchJob itemFetchJob(*hollowDavItemIt); + itemFetchJob.exec(); + Q_ASSERT(itemFetchJob.error() == 0); + return itemFetchJob.item(); + })(); + + qWarning() << 3; + auto incidence = KCalCore::ICalFormat().readIncidence(davitem.data()); + auto calevent = incidence.dynamicCast(); + QVERIFY2(calevent, "Cannot convert to KCalCore event"); + + qWarning() << 4; + calevent->setSummary("Manual Hello World!"); + auto newical = KCalCore::ICalFormat().toICalString(calevent); + + qWarning() << 5; + davitem.setData(newical.toUtf8()); + KDAV2::DavItemModifyJob itemModifyJob(davitem); + itemModifyJob.exec(); + QVERIFY2(itemModifyJob.error() == 0, "Cannot modify item"); + + qWarning() << 6; + } + + // Try to change the item with sink + { + auto job = Sink::Store::fetchOne( + Sink::Query().filter("uid", Sink::Query::Comparator(addedEventUid))) + .exec(); + job.waitForFinished(); + QVERIFY2(!job.errorCode(), "Fetching Event failed"); + auto event = job.value(); + + auto incidence = KCalCore::ICalFormat().readIncidence(event.getIcal()); + auto calevent = incidence.dynamicCast(); + QVERIFY2(calevent, "Cannot convert to KCalCore event"); + + calevent->setSummary("Sink Hello World!"); + auto dummy = QSharedPointer(calevent); + auto newical = KCalCore::ICalFormat().toICalString(dummy); + + event.setIcal(newical.toUtf8()); + + // TODO: make that fail + VERIFYEXEC(Sink::Store::modify(event)); + VERIFYEXEC(Sink::ResourceControl::flushReplayQueue(mResourceInstanceIdentifier)); + } + } + + void testRemoveEvent() + { + VERIFYEXEC(Sink::Store::synchronize(Sink::Query().resourceFilter(mResourceInstanceIdentifier))); + VERIFYEXEC(Sink::ResourceControl::flushMessageQueue(mResourceInstanceIdentifier)); + + auto job = Sink::Store::fetchOne( + Sink::Query().filter("uid", Sink::Query::Comparator(addedEventUid))) + .exec(); + job.waitForFinished(); + QVERIFY2(!job.errorCode(), "Fetching Event failed"); + auto event = job.value(); + + VERIFYEXEC(Sink::Store::remove(event)); + VERIFYEXEC(Sink::ResourceControl::flushReplayQueue(mResourceInstanceIdentifier)); + + auto verifyEventCountJob = Sink::Store::fetchAll({}).then( + [](const QList &events) { QCOMPARE(events.size(), 1); }); + VERIFYEXEC(verifyEventCountJob); + } }; QTEST_MAIN(CalDavTest) -- cgit v1.2.3