#include <QtTest>

#include <QString>
#include <iostream>

#include "dummyresource/resourcefactory.h"
#include "clientapi.h"
#include "commands.h"
#include "resourceconfig.h"
#include "log.h"
#include "modelresult.h"

static int blockingTime;

class TimeMeasuringApplication : public QCoreApplication
{
    QElapsedTimer t;
public:
    TimeMeasuringApplication(int& argc, char ** argv) : QCoreApplication(argc, argv) { }
    virtual ~TimeMeasuringApplication() { }

    virtual bool notify(QObject* receiver, QEvent* event)
    {
        t.start();
        const bool ret = QCoreApplication::notify(receiver, event);
        if(t.elapsed() > 1)
            std::cout << QString("processing event type %1 for object %2 took %3ms")
                .arg((int)event->type())
                .arg(""/* receiver->objectName().toLocal8Bit().data()*/)
                .arg((int)t.elapsed())
                .toStdString() << std::endl;
        blockingTime += t.elapsed();
        return ret;
    }
};

/**
 * Ensure that queries don't block the system for an extended period of time.
 *
 * This is done by ensuring that the event loop is never blocked.
 */
class ModelinteractivityTest : public QObject
{
    Q_OBJECT
private Q_SLOTS:
    void initTestCase()
    {
        Akonadi2::Log::setDebugOutputLevel(Akonadi2::Log::Warning);
        DummyResource::removeFromDisk("org.kde.dummy.instance1");
        ResourceConfig::addResource("org.kde.dummy.instance1", "org.kde.dummy");
    }

    void cleanup()
    {
        Akonadi2::Store::shutdown(QByteArray("org.kde.dummy.instance1")).exec().waitForFinished();
        DummyResource::removeFromDisk("org.kde.dummy.instance1");
        Akonadi2::Store::start(QByteArray("org.kde.dummy.instance1")).exec().waitForFinished();
    }

    void init()
    {
    }

    void testSingle()
    {
        //Setup
        {
            Akonadi2::ApplicationDomain::Mail mail("org.kde.dummy.instance1");
            for (int i = 0; i < 1000; i++) {
                Akonadi2::Store::create<Akonadi2::ApplicationDomain::Mail>(mail).exec().waitForFinished();
            }
        }

        Akonadi2::Query query;
        query.resources << "org.kde.dummy.instance1";
        query.syncOnDemand = false;
        query.processAll = true;
        query.liveQuery = true;

        Akonadi2::Store::synchronize(query).exec().waitForFinished();

        //Test
        QTime time;
        time.start();
        auto model = Akonadi2::Store::loadModel<Akonadi2::ApplicationDomain::Mail>(query);
        blockingTime += time.elapsed();
        QTRY_VERIFY(model->data(QModelIndex(), Akonadi2::Store::ChildrenFetchedRole).toBool());
        //Never block longer than 10 ms
        QVERIFY2(blockingTime < 10, QString("Total blocking time: %1").arg(blockingTime).toLatin1().data());
    }
};

int main(int argc, char *argv[])
{
    blockingTime = 0;
    TimeMeasuringApplication app(argc, argv);
    ModelinteractivityTest tc;
    return QTest::qExec(&tc, argc, argv);
}

#include "modelinteractivitytest.moc"