#include <QtTest>

#include <QString>

#include "testimplementations.h"

#include <common/facade.h>
#include <common/domainadaptor.h>
#include <common/resultprovider.h>
#include <common/synclistresult.h>

#include "event_generated.h"



/**
 * Benchmark read performance of the generic facade implementation.
 */
class GenericFacadeBenchmark : public QObject
{
    Q_OBJECT
private Q_SLOTS:

    void initTestCase()
    {
        Akonadi2::Storage store(Akonadi2::storageLocation(), "identifier", Akonadi2::Storage::ReadWrite);
        store.removeFromDisk();
    }

    void testLoad()
    {
        const QByteArray identifier = "identifier";
        const int count = 100000;

        //Setup
        auto domainTypeAdaptorFactory = QSharedPointer<TestEventAdaptorFactory>::create();
        {
            Akonadi2::Storage storage(Akonadi2::storageLocation(), identifier, Akonadi2::Storage::ReadWrite);
            auto transaction = storage.createTransaction(Akonadi2::Storage::ReadWrite);
            auto db = transaction.openDatabase();
            for (int i = 0; i < count; i++) {
                auto domainObject = Akonadi2::ApplicationDomain::Event::Ptr::create();
                domainObject->setProperty("uid", "uid");
                domainObject->setProperty("summary", "summary");

                flatbuffers::FlatBufferBuilder fbb;
                domainTypeAdaptorFactory->createBuffer(*domainObject, fbb);
                db.write(QString::number(i).toLatin1(), QByteArray::fromRawData(reinterpret_cast<const char*>(fbb.GetBufferPointer()), fbb.GetSize()));
            }
        }

        Akonadi2::Query query;
        query.liveQuery = false;

        //Benchmark
        QBENCHMARK {
            auto resultSet = QSharedPointer<Akonadi2::ResultProvider<Akonadi2::ApplicationDomain::Event::Ptr> >::create();
            auto resourceAccess = QSharedPointer<TestResourceAccess>::create();
            auto storage = QSharedPointer<EntityStorage<Akonadi2::ApplicationDomain::Event> >::create("identifier");
            TestResourceFacade facade(identifier, storage, resourceAccess);

            async::SyncListResult<Akonadi2::ApplicationDomain::Event::Ptr> result(resultSet->emitter());

            facade.load(query, resultSet).exec().waitForFinished();
            resultSet->initialResultSetComplete();

            //We have to wait for the events that deliver the results to be processed by the eventloop
            result.exec();

            QCOMPARE(result.size(), count);
        }

        // Print memory layout, RSS is what is in memory
        // std::system("exec pmap -x \"$PPID\"");
    }
};

QTEST_MAIN(GenericFacadeBenchmark)
#include "genericfacadebenchmark.moc"