File indexing completed on 2024-11-10 04:40:11

 /*
   SPDX-FileCopyrightText: 2013 Christian Mollekopf <mollekopf@kolabsys.com>
 
   SPDX-License-Identifier: LGPL-2.0-or-later
 */
 
 #include "gidtest.h"
 
 #include "agentinstance.h"
 #include "agentmanager.h"
 #include "collectionfetchjob.h"
 #include "control.h"
 #include "itemcreatejob.h"
 #include "itemdeletejob.h"
 #include "itemfetchjob.h"
 #include "itemfetchscope.h"
 #include "itemmodifyjob.h"
 #include "qtest_akonadi.h"
 #include "testattribute.h"
 
 using namespace Akonadi;
 
 QTEST_AKONADIMAIN(GidTest)
 
 bool TestSerializer::deserialize(Akonadi::Item &item, const QByteArray &label, QIODevice &data, int version)
 {
     qDebug() << item.id();
     if (label != Akonadi::Item::FullPayload) {
         return false;
     }
     Q_UNUSED(version)
 
     item.setPayload(data.readAll());
     return true;
 }
 
 void TestSerializer::serialize(const Akonadi::Item &item, const QByteArray &label, QIODevice &data, int &version)
 {
     qDebug();
     Q_ASSERT(label == Akonadi::Item::FullPayload);
     Q_UNUSED(label)
     Q_UNUSED(version)
     data.write(item.payload<QByteArray>());
 }
 
 QString TestSerializer::extractGid(const Akonadi::Item &item) const
 {
     if (item.gid().isEmpty()) {
         return item.url().url();
     }
     return item.gid();
 }
 
 void GidTest::initTestCase()
 {
     AkonadiTest::checkTestIsIsolated();
     Control::start();
 
     ItemSerializer::overridePluginLookup(new TestSerializer);
 }
 
 void GidTest::testSetAndFetch_data()
 {
     QTest::addColumn<Akonadi::Item::List>("input");
     QTest::addColumn<Akonadi::Item>("toFetch");
     QTest::addColumn<Akonadi::Item::List>("expected");
 
     Item item1(1);
     item1.setGid(QStringLiteral("gid1"));
     Item item2(2);
     item2.setGid(QStringLiteral("gid2"));
     Item toFetch;
     toFetch.setGid(QStringLiteral("gid1"));
     QTest::newRow("single") << (Item::List() << item1) << toFetch << (Item::List() << item1);
     QTest::newRow("multi") << (Item::List() << item1 << item2) << toFetch << (Item::List() << item1);
     {
         Item item3(3);
         item2.setGid(QStringLiteral("gid1"));
         QTest::newRow("multi") << (Item::List() << item1 << item2 << item3) << toFetch << (Item::List() << item1 << item3);
     }
 }
 
 static void fetchAndSetGid(const Item &item)
 {
     auto prefetchjob = new ItemFetchJob(item);
     prefetchjob->fetchScope().fetchFullPayload();
     AKVERIFYEXEC(prefetchjob);
     Item fetchedItem = prefetchjob->items()[0];
 
     // Write the gid to the db
     fetchedItem.setGid(item.gid());
     auto store = new ItemModifyJob(fetchedItem);
     store->setUpdateGid(true);
     AKVERIFYEXEC(store);
 }
 
 void GidTest::testSetAndFetch()
 {
     QFETCH(Item::List, input);
     QFETCH(Item, toFetch);
     QFETCH(Item::List, expected);
 
     for (const Item &item : std::as_const(input)) {
         fetchAndSetGid(item);
     }
 
     auto fetch = new ItemFetchJob(toFetch, this);
     fetch->fetchScope().setFetchGid(true);
     AKVERIFYEXEC(fetch);
     Item::List fetched = fetch->items();
     QCOMPARE(fetched.count(), expected.size());
     for (const Item &item : std::as_const(expected)) {
         QVERIFY(expected.removeOne(item));
     }
     QVERIFY(expected.isEmpty());
 }
 
 void GidTest::testCreate()
 {
     const int colId = AkonadiTest::collectionIdFromPath(QStringLiteral("res1/foo/bar"));
     QVERIFY(colId > -1);
 
     Item item;
     item.setMimeType(QStringLiteral("application/octet-stream"));
     item.setPayload<QByteArray>(QByteArray("test"));
     item.setGid(QStringLiteral("createGid"));
     auto createJob = new ItemCreateJob(item, Collection(colId), this);
     AKVERIFYEXEC(createJob);
     auto fetch = new ItemFetchJob(item, this);
     AKVERIFYEXEC(fetch);
     Item::List fetched = fetch->items();
     QCOMPARE(fetched.count(), 1);
 }
 
 void GidTest::testSetWithIgnorePayload()
 {
     Item item(5);
     auto prefetchjob = new ItemFetchJob(item);
     prefetchjob->fetchScope().fetchFullPayload();
     AKVERIFYEXEC(prefetchjob);
     Item fetchedItem = prefetchjob->items()[0];
     QVERIFY(fetchedItem.gid().isEmpty());
 
     // Write the gid to the db
     fetchedItem.setGid(QStringLiteral("gid5"));
     auto store = new ItemModifyJob(fetchedItem);
     store->setIgnorePayload(true);
     store->setUpdateGid(true);
     AKVERIFYEXEC(store);
     Item toFetch;
     toFetch.setGid(QStringLiteral("gid5"));
     auto fetch = new ItemFetchJob(toFetch, this);
     AKVERIFYEXEC(fetch);
     Item::List fetched = fetch->items();
     QCOMPARE(fetched.count(), 1);
     QCOMPARE(fetched.at(0).id(), Item::Id(5));
 }
 
 void GidTest::testFetchScope()
 {
     const int colId = AkonadiTest::collectionIdFromPath(QStringLiteral("res1/foo/bar"));
     QVERIFY(colId > -1);
 
     Item item;
     item.setMimeType(QStringLiteral("application/octet-stream"));
     item.setPayload<QByteArray>(QByteArray("test"));
     item.setGid(QStringLiteral("createGid2"));
     auto createJob = new ItemCreateJob(item, Collection(colId), this);
     AKVERIFYEXEC(createJob);
     {
         auto fetch = new ItemFetchJob(item, this);
         AKVERIFYEXEC(fetch);
         Item::List fetched = fetch->items();
         QCOMPARE(fetched.count(), 1);
         QVERIFY(fetched.at(0).gid().isNull());
     }
     {
         auto fetch = new ItemFetchJob(item, this);
         fetch->fetchScope().setFetchGid(true);
         AKVERIFYEXEC(fetch);
         Item::List fetched = fetch->items();
         QCOMPARE(fetched.count(), 1);
         QVERIFY(!fetched.at(0).gid().isNull());
     }
 }
 
 #include "moc_gidtest.cpp"