/*
* 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 "t_caclient.h"
#include "caservice.h"
#include "canotifier.h"
#include "canotifierfilter.h"
#include "t_caclientNotifier.h"

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

// ---------------------------------------------------------------------------
// ---------------------------------------------------------------------------
//
void TestCaClient::TestAddItemChangeTypeNotifier3Clients()
{
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARK;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
    {
        QSharedPointer<CaService> service = CaService::instance();
        TestCaClientNotifier *clientNotifier_1 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_1 = clientNotifier_1->getNotifier();

        TestCaClientNotifier *clientNotifier_2 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_2 = clientNotifier_2->getNotifier();

        TestCaClientNotifier *clientNotifier_3 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_3 = clientNotifier_3->getNotifier();

        connect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        connect(notifier_2, SIGNAL(entryChanged(CaEntry,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(CaEntry,ChangeType)));
        connect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime1sec);

        clientNotifier_1->mChangeType = RemoveChangeType;
        clientNotifier_2->mChangeType = RemoveChangeType;
        clientNotifier_3->mChangeType = RemoveChangeType;
        terminatServer();
        CaEntry item;
        item.setText("Text");
        item.setEntryTypeName("TypeName");
        QSharedPointer<CaEntry> entry = service->createEntry(item);
        QTest::qWait(waitTime1sec);

        QCOMPARE(clientNotifier_1->mChangeType, AddChangeType);
        QVERIFY(clientNotifier_1->mEntryId > 0);
        QCOMPARE(clientNotifier_1->mEntryId, entry->id());
        QCOMPARE(clientNotifier_1->mEntryId, clientNotifier_2->mEntryId);
        QCOMPARE(clientNotifier_3->mEntryId, clientNotifier_2->mEntryId);
        QCOMPARE(clientNotifier_2->mChangeType, AddChangeType);
        QCOMPARE(entry->text(), clientNotifier_2->mEntry->text());
        QCOMPARE(clientNotifier_3->mChangeType, AddChangeType);


        // cleanup
        disconnect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        disconnect(notifier_2, SIGNAL(entryChanged(CaEntry,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(CaEntry,ChangeType)));
        disconnect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime1sec);
        delete clientNotifier_1;
        delete clientNotifier_2;
        delete clientNotifier_3;
        service->removeEntry(entry->id());
    }
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARKEND;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
}
// ---------------------------------------------------------------------------
//
void TestCaClient::TestRemoveEntryChangeTypeNotifier3Clients()
{
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARK;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
    {
        QSharedPointer<CaService> service = CaService::instance();
        TestCaClientNotifier *clientNotifier_1 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_1 = clientNotifier_1->getNotifier();

        TestCaClientNotifier *clientNotifier_2 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_2 = clientNotifier_2->getNotifier();

        TestCaClientNotifier *clientNotifier_3 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_3 = clientNotifier_3->getNotifier();

        connect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        connect(notifier_2, SIGNAL(entryChanged(CaEntry,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(CaEntry,ChangeType)));
        connect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime1sec);
        terminatServer();
        CaEntry item;
        item.setText("Text");
        item.setEntryTypeName("TypeName");

        QSharedPointer<CaEntry> entry = service->createEntry(item);
        QTest::qWait(waitTime1sec);

        QCOMPARE(clientNotifier_1->mChangeType, AddChangeType);
        QVERIFY(clientNotifier_2->mEntryId > 0);
        QCOMPARE(clientNotifier_3->mEntryId, entry->id());

        int entryId_1 = clientNotifier_1->mEntryId;
        clientNotifier_1->mEntryId = 0;
        int entryId_2 = clientNotifier_2->mEntryId;
        clientNotifier_2->mEntryId = 0;
        int entryId_3 = clientNotifier_3->mEntryId;
        clientNotifier_3->mEntryId = 0;

        bool removed = service->removeEntry(*entry);
        QTest::qWait(waitTime1sec);

        QCOMPARE(clientNotifier_1->mChangeType, RemoveChangeType);
        QCOMPARE(clientNotifier_2->mChangeType, RemoveChangeType);
        QCOMPARE(clientNotifier_3->mChangeType, RemoveChangeType);
        QVERIFY(clientNotifier_1->mEntryId > 0);
        QCOMPARE(clientNotifier_1->mEntryId, entryId_1);
        QCOMPARE(clientNotifier_2->mEntryId, entryId_2);
        QCOMPARE(clientNotifier_3->mEntryId, entryId_3);
        QCOMPARE(entryId_1, entryId_3);
        QCOMPARE(entryId_2, entryId_3);
        QCOMPARE(removed, TRUE);

        // cleanup
        disconnect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        disconnect(notifier_2, SIGNAL(entryChanged(const CaEntry &,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(const CaEntry &,ChangeType)));
        disconnect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime500ms);
        delete clientNotifier_1;
        delete clientNotifier_2;
        delete clientNotifier_3;
        service->removeEntry(entry->id());
    }
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARKEND;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
}
// ---------------------------------------------------------------------------
//
void TestCaClient::TestRemoveEntriesChangeTypeNotifier3Clients()
{
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARK;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
    {
        QSharedPointer<CaService> service = CaService::instance();
        TestCaClientNotifier *clientNotifier_1 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_1 = clientNotifier_1->getNotifier();

        TestCaClientNotifier *clientNotifier_2 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_2 = clientNotifier_2->getNotifier();

        TestCaClientNotifier *clientNotifier_3 = new TestCaClientNotifier(*service);
        CaNotifier *notifier_3 = clientNotifier_3->getNotifier();

        connect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        connect(notifier_2, SIGNAL(entryChanged(CaEntry,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(CaEntry,ChangeType)));
        connect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime1sec);

        CaEntry item1;
        item1.setText("Text1");
        item1.setEntryTypeName("TypeName1");
        QSharedPointer<CaEntry> entry1 = service->createEntry(item1);
        QTest::qWait(waitTime1sec);
        CaEntry item2;
        item2.setText("Text2");
        item2.setEntryTypeName("TypeName2");
        QSharedPointer<CaEntry> entry2 = service->createEntry(item2);
        QTest::qWait(waitTime1sec);
        CaEntry item3;
        item3.setText("Text3");
        item3.setEntryTypeName("TypeName3");
        QSharedPointer<CaEntry> entry3 = service->createEntry(item3);
        QTest::qWait(waitTime1sec);
        CaEntry item4;
        item4.setText("Text4");
        item4.setEntryTypeName("TypeName4");
        QSharedPointer<CaEntry> entry4 = service->createEntry(item4);
        QTest::qWait(waitTime1sec);

        QList<QSharedPointer<CaEntry> > entriesList;
        entriesList.append(entry1);
        entriesList.append(entry2);
        entriesList.append(entry3);
        entriesList.append(entry4);

        clientNotifier_1->mEntryId = clientNotifier_2->mEntryId =
        clientNotifier_3->mEntryId = 0;

        bool removed = service->removeEntries(entriesList);
        QTest::qWait(waitTime1sec);

        QCOMPARE(clientNotifier_1->mChangeType, RemoveChangeType);
        QCOMPARE(clientNotifier_2->mChangeType, RemoveChangeType);
        QCOMPARE(clientNotifier_3->mChangeType, RemoveChangeType);
        QVERIFY(clientNotifier_1->mEntryId > 0);
        QCOMPARE(clientNotifier_1->mEntryId, clientNotifier_2->mEntryId);
        QCOMPARE(clientNotifier_1->mEntryId, clientNotifier_3->mEntryId);
        QCOMPARE(removed, TRUE);

        // cleanup
        disconnect(notifier_1, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_1, SLOT(entryChanged(int,ChangeType)));
        disconnect(notifier_2, SIGNAL(entryChanged(CaEntry,ChangeType)),
        clientNotifier_2, SLOT(entryChanged(CaEntry,ChangeType)));
        disconnect(notifier_3, SIGNAL(entryChanged(int,ChangeType)),
        clientNotifier_3, SLOT(entryChanged(int,ChangeType)));
        QTest::qWait(waitTime1sec);

        delete clientNotifier_1;
        delete clientNotifier_2;
        delete clientNotifier_3;
        service->removeEntries(entriesList);
        QTest::qWait(waitTime500ms);
        entriesList.clear();
    }
#ifdef Q_OS_SYMBIAN
#ifdef UT_MEMORY_CHECK
// __UHEAP_MARKEND;
#endif//UT_MEMORY_CHECK
#endif//Q_OS_SYMBIAN
}