/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:  Main test class for hspluginmodel library.
*
*/

#include <QScopedPointer>
#include <qservicemanager.h>

#include "t_caclient.h"
#include "caservice.h"
#include "canotifier.h"
#include "canotifierfilter.h"
#include "caquery.h"
#include "t_caclientNotifier.h"

const int entryIdFake(-1);
const int waitTime500ms(500);
const int waitTime1sec(1000);

QTM_USE_NAMESPACE

QStringList pluginPaths;
QString xmlName("caapphandlerplugin.xml");

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::initTestCase()
{
#ifdef Q_OS_SYMBIAN
    startThread();
#endif //Q_OS_SYMBIAN
    mService = CaService::instance();
}

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::cleanupTestCase()
{
#ifdef Q_OS_SYMBIAN
    stopThread();
#endif //Q_OS_SYMBIAN
    QSharedPointer<CaService> serviceNull(NULL);
    mService = serviceNull;
    QTest::qWait(5000);
}


// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
int threadFunction(void */*params*/)
{
#ifdef Q_OS_SYMBIAN
    while (ETrue) {
        User::ResetInactivityTime();//it should help for Viewserver11 panic
        User::After(5000000);
    }
#endif //Q_OS_SYMBIAN
    return 0;
}

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::startThread()
{
#ifdef Q_OS_SYMBIAN
    User::LeaveIfError(iThread.Create(
                           _L("thread_kill_viewsrv11"),
                           threadFunction,
                           16384,
                           4000,
                           4000,
                           NULL));
    iThread.Resume();
#endif //Q_OS_SYMBIAN
}

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::stopThread()
{
#ifdef Q_OS_SYMBIAN
    iThread.Close();
#endif //Q_OS_SYMBIAN
}

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::Test_createNotifier()
{
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARK;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
    {

        CaNotifierFilter *filter = new CaNotifierFilter();
        filter->setEntryRole(GroupEntryRole);
        filter->setTypeNames(QStringList() << "TypeName");
        TestCaClientNotifier *clientNotifier = new TestCaClientNotifier(*mService, filter);
        CaNotifier *notifier = clientNotifier->getNotifier();

        connect(notifier, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime500ms);
        CaEntry group(GroupEntryRole);
        group.setText("Text");
        group.setEntryTypeName("TypeName");

        QSharedPointer<CaEntry> entry = mService->createEntry(group);
        QTest::qWait(waitTime1sec);

        QCOMPARE(clientNotifier->mChangeType, AddChangeType);
        QVERIFY(clientNotifier->mEntryId > 0);
        QCOMPARE(clientNotifier->mEntryId, entry->id());

        // cleanup
        disconnect(notifier, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime500ms);
        delete clientNotifier;
        mService->removeEntry(entry->id());
    }
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARKEND;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
}

// ---------------------------------------------------------------------------
//
// ---------------------------------------------------------------------------
//
void TestCaClient::Test_touch()
{
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARK;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN

    CaEntry item;
    item.setText("Text");
    item.setEntryTypeName("TypeName");
    QSharedPointer<CaEntry> entry = mService->createEntry(item);
    QTest::qWait(waitTime1sec);

    CaNotifierFilter *filter = new CaNotifierFilter();
    filter->setEntryRole(ItemEntryRole);
    filter->setIds(QList<int>() << entry->id());
    TestCaClientNotifier *clientNotifier = new TestCaClientNotifier(*mService, filter);
    CaNotifier *notifier = clientNotifier->getNotifier();

    connect(notifier, SIGNAL(entryTouched(int)),
            clientNotifier, SLOT(entryTouched(int)));
    QTest::qWait(waitTime500ms);

    bool touched = mService->touch(*entry);
    QTest::qWait(waitTime1sec);

    QVERIFY(clientNotifier->mEntryId > 0);
    QCOMPARE(clientNotifier->mEntryId, entry->id());
    QCOMPARE(touched, TRUE);

    // cleanup
    disconnect(notifier, SIGNAL(entryTouched(int)),
               clientNotifier, SLOT(entryTouched(int)));
    QTest::qWait(waitTime500ms);
    delete clientNotifier;
    delete filter;
    mService->removeEntry(entry->id());
    QTest::qWait(waitTime1sec);

#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARKEND;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
}

//QTEST_MAIN(homescreen::test::TestCaClient)