/*

 * 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:

 *

 */

#include <msgitem.h>

#include <ccsdefs.h>

#include <ccsconversationentry.h>

#include <ccsclientconversation.h>

#include <conversationsenginedefines.h>

#include "testconversationenginestub.h"

#include "testconversationnotifier.h"

#include "convergedmessage.h"

TestConversationEngineStub* TestConversationEngineStub::Instance()

{

    static TestConversationEngineStub* iStubEngine 

                                = new TestConversationEngineStub();

    return iStubEngine;

}

void TestConversationEngineStub::InitL()

{

    iNotifier = new TestConversationNotifier();

    iConversationID = 1234;

    iTimeStamp = 123456789;

    iMsgType = ECsSMS;

    iUnReadCount = 3;

    _LIT(Kname , "9343434343");

    _LIT(KDescription , "This is the test msg.");

    iContactID = Kname;

    iDescription = KDescription;

    iDeletedEntry = NULL;

}

TestConversationEngineStub::TestConversationEngineStub()

{

    TRAP_IGNORE(InitL());

}

TestConversationEngineStub::~TestConversationEngineStub()

{

    iConversationClientList.ResetAndDestroy();

    iConversationEntryList.ResetAndDestroy();

    delete iNotifier;

}

void TestConversationEngineStub

::SetResultObserver(MCsResultsObserver *aResultObserver)

{

    iNotifier->SetResultNotifier(aResultObserver);

}

void TestConversationEngineStub::RemoveResultObserver()

{

    iNotifier->RemoveResultNotifier();

}

void TestConversationEngineStub

::SetConversationChangeObserver(MCsConversationChangeObserver* aObserver,

            CCsClientConversation* /*aClientConversation*/)

{

    iNotifier->SetConversationChangeNotifier(aObserver);

}

void TestConversationEngineStub::RemoveConversationChangeObserver()

{

    iNotifier->RemoveConversationChangeNotifier();

}

void TestConversationEngineStub

::SetConversationListChangeObserver(MCsConversationListChangeObserver* 

                                        aConversationListChangeObserver)

{

    iNotifier->SetConversationListNotifier(aConversationListChangeObserver);

}

void TestConversationEngineStub::RemoveConversationListChangeObserver()

{

    iNotifier->RemoveConversationListNotifier();

}

void TestConversationEngineStub

::MarkConversationRead(const TInt aConversationId)

{

    for (TInt i = 0; i < iConversationEntryList.Count(); ++i)

         {

             if (iConversationEntryList[i]->EntryId() == aConversationId)

                 {

                     iConversationEntryList[i]->

                         ChangeAttributes(ECsAttributeNone, ECsAttributeUnread);

                     break;

                 }

          }

}

void TestConversationEngineStub

::DeleteConversation(const TInt aConversationId)

{

    for (TInt i = 0; i < iConversationEntryList.Count(); ++i)

         {

             if (iConversationEntryList[i]->EntryId() == aConversationId)

                 {

                     iDeletedEntry  = iConversationEntryList[i];

                     iConversationEntryList.Remove(i);

                 }

          }

}

TInt TestConversationEngineStub::GetConvListSize()

{

    return iConversationEntryList.Count();

}

TInt TestConversationEngineStub::GetUnreadCount()

{

    TInt unRead = 0;

    for (TInt i = 0; i < iConversationEntryList.Count(); ++i)

     {

         if (iConversationEntryList[i]->IsAttributeSet(ECsAttributeUnread))

             {

                 unRead++;

             }

      }

    return unRead;

}

TInt TestConversationEngineStub::GetConversationID()

{

    return iConversationID;

}

TInt TestConversationEngineStub::GetTimeStamp()

{

    return iTimeStamp;

}

TInt TestConversationEngineStub::GetMsgType()

{

    return iMsgType;

}

TDesC& TestConversationEngineStub::GetContactID()

{

    return iContactID;

}

TDesC& TestConversationEngineStub::GetDescription()

{

    return iDescription;

}

RPointerArray<CCsClientConversation>& 

TestConversationEngineStub::GetConversationClientList()

{

    return iConversationClientList;

}

CCsConversationEntry*

TestConversationEngineStub

::CreateConversationEntryL(TInt aConvID, bool aUnread)

{

    CCsConversationEntry* conversationEntry = CCsConversationEntry::NewL();

    CleanupStack::PushL(conversationEntry);

    conversationEntry->SetType(iMsgType);

    conversationEntry->SetEntryId(aConvID);

    conversationEntry->SetTimeStampL(iTimeStamp);

    conversationEntry->SetContactL(iContactID);

    conversationEntry->SetDescriptionL(iDescription);

    if (aUnread)

        {

        conversationEntry->ChangeAttributes(ECsAttributeUnread, 

                                                ECsAttributeNone);

        conversationEntry->SetConversationDir(0/*MsgDirectionIncoming*/);

        }

    else

        {

        conversationEntry->SetConversationDir(1/*MsgDirectionOutgoing*/);

        conversationEntry->ChangeAttributes(ECsAttributeSent, 

                                                ECsAttributeNone);

        }

    CleanupStack::Pop(conversationEntry);

    return conversationEntry;

}

void TestConversationEngineStub

::PrepareConversationListL(TInt aConvID, TInt aToatalCnt, TInt aUnreadCnt)

{

    // create conversation entries

    for ( TInt iloop = 0; iloop < aToatalCnt; iloop++ )

        {

        CCsConversationEntry* conversationEntry 

                = CreateConversationEntryL(aConvID++, (aUnreadCnt-- > 0));

        CleanupStack::PushL(conversationEntry);

        // append conversation entries to list

        iConversationEntryList.AppendL(conversationEntry);

        CleanupStack::Pop(conversationEntry);

        }

}

//Prerae a list with : conv id, no of unread msgs, 

void TestConversationEngineStub::UpdateConversationList()

{

    TInt error;

    TInt totalCount = 5;

    TRAP(error, PrepareConversationListL(iConversationID, totalCount, iUnReadCount));    

    iNotifier->SendListResultUpdate(iConversationEntryList,totalCount);

}

void TestConversationEngineStub::UpdateConvEntry(TInt aConversationId)

{

    for (TInt i = 0; i < iConversationEntryList.Count(); ++i)

     {

         if (iConversationEntryList[i]->EntryId() == aConversationId)

         {

             iNotifier->

             UpdateConversationEntryModify(*iConversationEntryList[i]);

             break;

         }

      }

}

void TestConversationEngineStub::UpdateDeletedConvEntry()

{

    if (iDeletedEntry)

    {

        iNotifier->UpdateConversationEntryDelete(*iDeletedEntry);

        delete iDeletedEntry;

        iDeletedEntry = NULL;

    }

}

void TestConversationEngineStub::UpdateAddConvEntryL()

{

    CCsConversationEntry*

    conversationEntry = CreateConversationEntryL(9999/*iConversationID - 1*/, true);

    CleanupStack::PushL(conversationEntry);

    iConversationEntryList.AppendL(conversationEntry);

    CleanupStack::Pop(conversationEntry);

    iNotifier->UpdateConversationEntryAdd(*conversationEntry);

}

void TestConversationEngineStub::UpdateAddConvEntry()

{

    TInt error;

    TRAP(error, UpdateAddConvEntryL());

}

void TestConversationEngineStub::UpdateAddConvClientL()

{

    _LIT(KFName , "New User");

    //need to free alloced descriptor

    TBuf<10>  BufName(KFName);

    HBufC * fname = BufName.AllocL();

    CleanupStack::PushL(fname);

    CCsConversationEntry* 

    convEntry = CreateConversationEntryL(iConversationID - 1, true);

    CleanupStack::PushL(convEntry);

    CCsClientConversation* 

    convClient = CreateConversationClientL(fname,4000, 2, *convEntry);

    CleanupStack::PushL(convClient);

    iConversationClientList.AppendL(convClient);

    CleanupStack::Pop(convClient);

    CleanupStack::PopAndDestroy(convEntry);

    CleanupStack::PopAndDestroy(fname);

    iNotifier->UpdateConversationClientAdd(*convClient);

}

void TestConversationEngineStub::UpdateAddConvClient()

{

    TInt error;

    TRAP(error, UpdateAddConvClientL());

}

void TestConversationEngineStub::UpdateDeletedConvClient()

{

    CCsClientConversation* convClient = iConversationClientList[0];

    iConversationClientList.Remove(0);

    if (convClient)

    {

        iNotifier->UpdateConversationClientDelete(*convClient);

        delete convClient;

    }

}

void TestConversationEngineStub::UpdateConvClient(TInt aConversationId)

{

    for (TInt i = 0; i < iConversationClientList.Count(); ++i)

     {

         if (iConversationClientList[i]->GetConversationEntryId() 

                                                 == aConversationId)

         {

             iConversationClientList[i]->

             GetConversationEntry()->

             ChangeAttributes(ECsAttributeNone, ECsAttributeUnread);

             iConversationClientList[i]->SetUnreadMessageCount(0);

             iNotifier->

             UpdateConversationClientModify(*iConversationClientList[i]);

             break;

         }

      }

}

CCsClientConversation* 

TestConversationEngineStub::

CreateConversationClientL(const HBufC* aDispName, TInt aContactID,

                          TInt aUnreadCnt,

                          CCsConversationEntry& aConvEntry)

{

    CCsClientConversation* conversationClient = CCsClientConversation::NewL();

    CleanupStack::PushL(conversationClient);

    conversationClient->SetContactId(aContactID);

    conversationClient->SetUnreadMessageCount(aUnreadCnt);

    conversationClient->SetDisplayNameL(aDispName);

    conversationClient->SetConversationEntryL(&aConvEntry);

    conversationClient->SetConversationEntryId(aConvEntry.EntryId());

    CleanupStack::Pop(conversationClient);

    return conversationClient;

}

void TestConversationEngineStub

::PrepareConversationClientListL(TInt aContactID, TInt aListSize, 

                                TInt aUnRead, TInt aUnReadCnt)

{

    TInt convID = iConversationID;

    _LIT(KFName , "abc");

    //need to free alloced descriptor

    TBufC<10>  BufName(KFName);

    HBufC * fname = BufName.AllocL();

    CleanupStack::PushL(fname);

    for (TInt loop = 0; loop < aListSize; loop++)

        {

            CCsConversationEntry* 

            convEntry = CreateConversationEntryL(convID++,

                                  (aUnRead-- > 0 ? true : false));

            CleanupStack::PushL(convEntry);

            CCsClientConversation* 

            convClient = CreateConversationClientL(fname, aContactID++, aUnReadCnt++,

                                              *convEntry);

            CleanupStack::PushL(convClient);

            iConversationClientList.AppendL(convClient);

            CleanupStack::Pop(convClient);

            CleanupStack::PopAndDestroy(convEntry);

        }

    CleanupStack::Pop(fname);

}

//conversation client notifications

void TestConversationEngineStub::UpdateConversationClientList()

{

    TInt error;

    TRAP(error, PrepareConversationClientListL(2000, 5, 3, 0));

    if (error == KErrNone)

    {

        iNotifier->SendClientListUpdate(iConversationClientList);

    }

}

TInt TestConversationEngineStub

::GetClientConversationID(const TInt aContactId)

{

    for (TInt i = 0; i < iConversationClientList.Count(); ++i)

     {

         if (iConversationClientList[i]->GetContactId() ==  aContactId)

         {

             return iConversationClientList[i]->GetConversationEntryId();

         }

      }

    return -1;

}

TInt TestConversationEngineStub

::GetClientConversationID(const TDesC& aContactAddress)

{

    for (TInt i = 0; i < iConversationClientList.Count(); ++i)

     {

         if (iConversationClientList[i]->

                 GetConversationEntry()->

                 Contact()->Compare(aContactAddress) == 0)

         {

             return iConversationClientList[i]->GetConversationEntryId();

         }

      }

    return -1;

}