/*

* Copyright (c) 2007, 2008 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:  Implementation for presence cache reader and writer.

*

*/

#include "entitytests.h"

#include <stdio.h>

#include <qtest.h>

#include <QObject>

#include <prcpresencebuddyinfo_qt.h>

#include <prcpresencereader_qt.h>

#include <prcpresencewriter_qt.h>

    QString EntityTests::K_Buddy = "Buddy";

    QString EntityTests::K_Atext = "Atext";

    QString EntityTests::K_Avalue = "Avalue";

    QString EntityTests::K_Newkey = "Newkey";

    QString EntityTests::K_Newvalue = "Newvalue";

    QString EntityTests::K_Avatar = "Avatar";

    QString EntityTests::K_Statustext =  "Statustext";

const int waitTime = 500;

EntityTests::EntityTests(QObject *parent) :

    QObject(parent)

{

}

void EntityTests::initTestCase()

{

    iWriter = NULL;

    iReader = NULL;

}

void EntityTests::cleanupTestCase()

{

  delete iReader;

  delete iWriter;

}

// -----------------------------------------------------------------------------

// ClientSrvTester::SaveBuddyL

// 

// -----------------------------------------------------------------------------

//

void EntityTests::saveBuddy(QMap<QString,QString>& map)

    {

    PrcPresenceBuddyInfoQt* buddy = createBuddyForWriting(map);

    iWriter->writePresence( *buddy ); 

    }

PrcPresenceBuddyInfoQt* EntityTests::createBuddyForWriting(QMap<QString,QString>& map)

{

    QString buddyId = map.value(K_Buddy);

    QString AText = map.value(K_Atext);

    QString AValue = map.value(K_Avalue); 

    QString avatar = map.value(K_Avatar);

    QString statusText = map.value(K_Statustext);

    QString newKey = map.value(K_Newkey);

    QString newValue = map.value(K_Newvalue);

    // TInt avValue = TesterAtoi( AValue );

    PrcPresenceBuddyInfoQt::AvailabilityValues intAval = getAvailbility(AText)     ;

    if ( !iWriter )

        {

        iWriter = PrcPresenceWriter::createWriter();

        }

    PrcPresenceBuddyInfoQt* buddy = PrcPresenceBuddyInfoQt::createInstance();

    // Another way to initiate buddy info

    // -------------------------------------

    PrcPresenceBuddyInfoQt* buddy2 = iWriter->newBuddyPresenceInfo();

    delete buddy2;

    buddy2 = NULL;    

    // -------------------------------------

    buddy->setIdentity( buddyId );

    buddy->setAvailability( intAval, AText);

    if ( statusText.length() )

        {

        buddy->setStatusMessage( statusText);

        }

    if ( newKey.length() || newValue.length())

        {

        buddy->setAnyField( newKey, newValue );

        } 

    if(avatar.length())

        {

        buddy->setAvatar(avatar);

        }

    return buddy;

}

PrcPresenceBuddyInfoQt::AvailabilityValues EntityTests::getAvailbility(QString aval)

    {

    if(aval == "available")

        return PrcPresenceBuddyInfoQt::PrcAvailable;

    else if(aval == "busy")

        return PrcPresenceBuddyInfoQt::PrcBusy;

    else if(aval == "notavailable")

           return PrcPresenceBuddyInfoQt::PrcNotAvailable;

    else return PrcPresenceBuddyInfoQt::PrcUnknownAvailability;

    }

void EntityTests::fetchAndVerifyBuddy( QMap<QString,QString>& map )

    {

    QString buddyId = map.value(K_Buddy);

    QString AText = map.value(K_Atext);

    QString AValue = map.value(K_Avalue);;

    QString avatar = map.value(K_Avatar);

    QString statusText = map.value(K_Statustext);

  QString newKey = map.value(K_Newkey);

    QString newValue = map.value(K_Newvalue);

    PrcPresenceBuddyInfoQt::AvailabilityValues intAval = getAvailbility (AText)    ;   

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    PrcPresenceBuddyInfoQt* buddy = iReader->presenceInfo(buddyId);   

    QString testbuddyId = buddy->buddyId();

    QVERIFY(testbuddyId == buddyId);

    PrcPresenceBuddyInfoQt::AvailabilityValues testavalibility = buddy->availability();

    QVERIFY (testavalibility == intAval );

    QString testAvalText =  buddy->availabilityText();

    QVERIFY( testAvalText ==AText );

    if ( statusText.length())

        {

        QString testStatusMsg = buddy->statusMessage();

        QVERIFY (testStatusMsg== statusText );

        }  

    if ( newKey.length() || newValue.length())

        {

        QString testnewVal = buddy->getAnyField( newKey );

        QVERIFY ( testnewVal== newValue );

        }

    if(avatar.length())

    {

    QString atr = buddy->avatar();

    }

   }

void  EntityTests::subscribeBuddy( QString& buddyId)

{

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    int error = iReader->subscribePresenceBuddyChange(buddyId);

}

void  EntityTests::unSubscribeBuddy( QString& buddyId)

{

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    iReader->unSubscribePresenceBuddyChange(buddyId);

}

void EntityTests::CheckServices(int nbrServices,int nbrBuddies)

    {

    int  val = 0;    

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    val = iReader->servicesCount();

    QVERIFY ( val == nbrServices );

    val = iReader->buddyCountInAllServices();

    QVERIFY( val == nbrBuddies );

    }

void  EntityTests::CheckOneService(QString service,int buddiesInService)

    {

    // Services: x Buddies: 0 BuddiesInService: 0 Service: sip

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    int val = iReader->buddyCountInService( service );

    QVERIFY( val == buddiesInService );

    }

void EntityTests::fetchAllBuddiesInService(QString service, int numberofbuddies  )

{

    if ( !iReader )

        {

        iReader = PrcPresenceReader::createReader();

        }

    iNumberOfBuddiesInService = numberofbuddies;

    TInt ret = iReader->allBuddiesPresenceInService(service);

}

// Save and Fetch

void EntityTests::test1()

    {

    QMap<QString,QString> map;

    map.insert(K_Buddy,"sip:tester1@test.com");

    map.insert(K_Atext,"avaifsslable");

    map.insert(K_Avalue,"ONLIsfsNE");

    map.insert(K_Newkey,"x-locfsdfation");

    map.insert(K_Avatar,"caland");

    map.insert(K_Newvalue,"kitfsdschen");

    saveBuddy(map);

    fetchAndVerifyBuddy(map);

    //Some other tests

    PrcPresenceBuddyInfoQt* buddy = iReader->presenceInfo("sip:tester1@test.com"); 

    //Equals identity test 

    PrcPresenceBuddyInfoQt* buddy2 = iReader->presenceInfo("sip:tester1@test.com"); 

    bool ret = buddy->equalsIdentity(*buddy2);

    QVERIFY(true == ret);

    QList<QString> qtKeyList;

    buddy->getFieldKeys(qtKeyList);

    int cnt = qtKeyList.count();

    if(cnt > 0)

        {

        QString keyval = qtKeyList.at(0);

        buddy->removeField(keyval);

        }

    qtKeyList.clear();

    buddy->getFieldKeys(qtKeyList);

    if(cnt > 0)

        {

        QVERIFY((qtKeyList.count() )== (cnt - 1  )  );

        }

    delete buddy;

    delete buddy2;

    }

// Save and Subscribe

void EntityTests::test2()

    {

    connect(iReader, SIGNAL(signalPresenceNotification(bool , PrcPresenceBuddyInfoQt* )), 

                       this, SLOT(handlePresenceNotificationInClient(bool , PrcPresenceBuddyInfoQt* )));

      connect(iReader, SIGNAL(signalPresenceRead(bool , QList<PrcPresenceBuddyInfoQt*> )), 

                      this, SLOT( handlePresenceReadInClient(bool,QList<PrcPresenceBuddyInfoQt*>)));

    QString testBuddyID = "sip:tester1@test.com";

    iMapDataForAsyncTest.clear();

    iMapDataForAsyncTest.insert(K_Buddy,testBuddyID);

    iMapDataForAsyncTest.insert(K_Atext,"available");

    iMapDataForAsyncTest.insert(K_Avalue,"OFFLINE");

    iMapDataForAsyncTest.insert(K_Newkey,"x-location");

    iMapDataForAsyncTest.insert(K_Newvalue,"garden");

    saveBuddy(iMapDataForAsyncTest);

    subscribeBuddy(testBuddyID);

    //change some data

    iMapDataForAsyncTest.remove(K_Avalue);

    iMapDataForAsyncTest.remove(K_Newvalue);

    iMapDataForAsyncTest.insert(K_Avalue,"ON_THE_LINE");

    iMapDataForAsyncTest.insert(K_Newvalue,"atdoor");

    saveBuddy(iMapDataForAsyncTest);

    QTest::qWait(waitTime);

    }

//Subscribe and Update partly

void EntityTests::test3()

    {

    connect(iReader, SIGNAL(signalPresenceNotification(bool , PrcPresenceBuddyInfoQt* )), 

                           this, SLOT(handlePresenceNotificationInClient(bool , PrcPresenceBuddyInfoQt* )));

    connect(iReader, SIGNAL(signalPresenceRead(bool , QList<PrcPresenceBuddyInfoQt*> )), 

                           this, SLOT( handlePresenceReadInClient(bool,QList<PrcPresenceBuddyInfoQt*>)));

    QString testBuddyID = "sip:tester1@test.com";

     iNotificationReceived = false;

    //Subscribe

    subscribeBuddy(testBuddyID);

    //Now save and check if notification is received

    iMapDataForAsyncTest.clear();

    iMapDataForAsyncTest.insert(K_Buddy,testBuddyID);

    iMapDataForAsyncTest.insert(K_Atext,"available");

    iMapDataForAsyncTest.insert(K_Avalue,"In Transit");

    iMapDataForAsyncTest.insert(K_Newkey,"Y-location");

    iMapDataForAsyncTest.insert(K_Newvalue,"Gate");

    iMapDataForAsyncTest.insert(K_Statustext,"engaged");

    saveBuddy(iMapDataForAsyncTest);

    QTest::qWait(waitTime);

    QVERIFY(true == iNotificationReceived);

    }

// Subscribe , save, and Unsubscribe ,save

void EntityTests::test4()

    {

    connect(iReader, SIGNAL(signalPresenceNotification(bool , PrcPresenceBuddyInfoQt* )), 

                           this, SLOT(handlePresenceNotificationInClient(bool , PrcPresenceBuddyInfoQt* )));

    connect(iReader, SIGNAL(signalPresenceRead(bool , QList<PrcPresenceBuddyInfoQt*> )), 

                          this, SLOT( handlePresenceReadInClient(bool,QList<PrcPresenceBuddyInfoQt*>)));

    QString testBuddyID = "sip:tester1@test.com";

     iNotificationReceived = false;

    //Subscribe

    subscribeBuddy(testBuddyID);

    //Now save and check if notification is received

    iMapDataForAsyncTest.clear();

    iMapDataForAsyncTest.insert(K_Buddy,testBuddyID);

    iMapDataForAsyncTest.insert(K_Atext,"available");

    iMapDataForAsyncTest.insert(K_Avalue,"In Transit");

    iMapDataForAsyncTest.insert(K_Newkey,"Y-location");

    iMapDataForAsyncTest.insert(K_Newvalue,"Gate");

    iMapDataForAsyncTest.insert(K_Statustext,"engaged");

    //Save the data to cache

    saveBuddy(iMapDataForAsyncTest);

    //We should recive notification after save

    QTest::qWait(waitTime);

    QVERIFY(true == iNotificationReceived);

    //Unsubscribe 

    unSubscribeBuddy(testBuddyID);

    //change some data and re-save

    iNotificationReceived = false;

    iMapDataForAsyncTest.remove(K_Atext);

    iMapDataForAsyncTest.insert(K_Atext,"UN_available");

    saveBuddy(iMapDataForAsyncTest);

    //We should not recive notification since we have unsubscribed

    QTest::qWait(waitTime);

    QVERIFY(false == iNotificationReceived);

    }

//title Subscribe and delete reader

void EntityTests::test5()

    {

    connect(iReader, SIGNAL(signalPresenceNotification(bool , PrcPresenceBuddyInfoQt* )), 

                           this, SLOT(handlePresenceNotificationInClient(bool , PrcPresenceBuddyInfoQt* )));

    connect(iReader, SIGNAL(signalPresenceRead(bool , QList<PrcPresenceBuddyInfoQt*> )), 

                          this, SLOT( handlePresenceReadInClient(bool,QList<PrcPresenceBuddyInfoQt*>)));

    QString testBuddyID = "sip:tester1@test.com";

     iNotificationReceived = false;

    //Subscribe

    subscribeBuddy(testBuddyID);

    //Now save and check if notification is received

    iMapDataForAsyncTest.clear();

    iMapDataForAsyncTest.insert(K_Buddy,testBuddyID);

    iMapDataForAsyncTest.insert(K_Atext,"available");

    iMapDataForAsyncTest.insert(K_Avalue,"In Home ");

    iMapDataForAsyncTest.insert(K_Newkey,"x-location");

    iMapDataForAsyncTest.insert(K_Newvalue,"Restaurant");

    iMapDataForAsyncTest.insert(K_Statustext,"Working hard");

    //Save the data to cache

    saveBuddy(iMapDataForAsyncTest);

    //We should recive notification after save

    QTest::qWait(waitTime);

    QVERIFY(true == iNotificationReceived);

    //Unsubscribe 

    if(iReader)

        {

        delete iReader;

        iReader = NULL;

        }

    //change some data and re-save

    iNotificationReceived = false;

    iMapDataForAsyncTest.remove(K_Atext);

    iMapDataForAsyncTest.insert(K_Atext,"UN_available");

    saveBuddy(iMapDataForAsyncTest);

    //We should not recive notification since we have unsubscribed

    QTest::qWait(waitTime);

    QVERIFY(false == iNotificationReceived);

    }

// Write multiple presence

void EntityTests::test6()

    {

    connect(iWriter, SIGNAL(signalPresenceWrite(bool)), 

            this, SLOT(handlePresencewriteInclient(bool)));

    QMap<QString,QString> map1;

    map1.insert(K_Buddy,"sip:tester1@test.com");

    map1.insert(K_Atext,"available");

    map1.insert(K_Avalue,"ONLINE");

    map1.insert(K_Newkey,"x-location");

    map1.insert(K_Newvalue,"kitchen");

    QMap<QString,QString> map2;

    map2.insert(K_Buddy,"sip:tester2@test.com");

    map2.insert(K_Atext,"huh");

    map2.insert(K_Avalue,"BUSY");

    map2.insert(K_Newkey,"x-location");

    map2.insert(K_Newvalue,"outdoor");

    PrcPresenceBuddyInfoQt* buddy1 = createBuddyForWriting(map1);

    PrcPresenceBuddyInfoQt* buddy2 = createBuddyForWriting(map2);

    iNotificationReceived = false;

    QList<PrcPresenceBuddyInfoQt*> multipleBuddy;

    multipleBuddy.append(buddy1);

    multipleBuddy.append(buddy2);

    if ( !iWriter )

        {

        iWriter = PrcPresenceWriter::createWriter();

        }

    iWriter->writeMultiplePresence(multipleBuddy);

    QTest::qWait(waitTime);

    QVERIFY(true == iNotificationReceived);

    //write and cancel by deleting the writer

    iNotificationReceived = false;

    iWriter->writeMultiplePresence(multipleBuddy);

    iWriter->cancelWrite();

    QTest::qWait(waitTime);

    QVERIFY(false == iNotificationReceived);

    }

//Check services count

void EntityTests::test7()

    {

    //Delete previously created services

    if ( !iWriter )

      {

      iWriter = PrcPresenceWriter::createWriter();

      }

    iWriter->deleteService("sip");

    QMap<QString,QString> map1;

    map1.insert(K_Buddy,"sip:tester1@test.com");

    map1.insert(K_Atext,"available");

    map1.insert(K_Avalue,"ONLINE");

    map1.insert(K_Newkey,"x-location");

    map1.insert(K_Newvalue,"kitchen");

    QMap<QString,QString> map2;

    map2.insert(K_Buddy,"msn:tester2@test.com");

    map2.insert(K_Atext,"huh");

    map2.insert(K_Avalue,"BUSY");

    map2.insert(K_Newkey,"x-location");

    map2.insert(K_Newvalue,"outdoor");

    QMap<QString,QString> map3;

    map3.insert(K_Buddy,"msn:t2@test.com");

    map3.insert(K_Atext,"huh");

    map3.insert(K_Avalue,"BUSY");

    map3.insert(K_Newkey,"x-location");

    map3.insert(K_Newvalue,"outdoor");

    saveBuddy(map1);

    saveBuddy(map2);

    saveBuddy(map3);

    CheckServices(2,3);

    CheckOneService( "sip",1);

    CheckOneService("msn",2);

    if ( !iWriter )

          {

          iWriter = PrcPresenceWriter::createWriter();

          }

    bool ret = iWriter->deletePresence("msn:t2@test.com");

    QVERIFY(true == ret);

    ret = iWriter->deletePresence("msn:tester2@test.com");

    QVERIFY(true == ret);

    ret = iWriter->deletePresence("sip:tester1@test.com");

    QVERIFY(true == ret);

    }

void EntityTests::test8()

    {

    connect(iReader, SIGNAL(signalPresenceRead(bool , QList<PrcPresenceBuddyInfoQt*> )), 

               this, SLOT(handlePresenceReadInClient(bool , QList<PrcPresenceBuddyInfoQt*> )));

    //Delete previously created services

    if ( !iWriter )

      {

      iWriter = PrcPresenceWriter::createWriter();

      }

    iWriter->deleteService("sip");

    iWriter->deleteService("msn");

    QMap<QString,QString> map1;

    map1.insert(K_Buddy,"yahoo:tester123@test.com");

    map1.insert(K_Atext,"available");

    map1.insert(K_Avalue,"ONLINE");

    map1.insert(K_Newkey,"x-location");

    map1.insert(K_Newvalue,"kitchen");

    QMap<QString,QString> map2;

    map2.insert(K_Buddy,"msn:tester232@test.com");

    map2.insert(K_Atext,"huh");