/*

 * Copyright (c) 2007 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:  This class helps CS Cache in processing the data.

 *

 */

// INCLUDE FILES

// SYSTEM INCLUDE FILES

#include <ccsdefs.h>

#include <ccsconversationentry.h>

#include <ccsclientconversation.h>

// USER INCLUDE FILES

#include "ccsconversationcachehelper.h"

#include "ccsconversationcache.h"

#include "ccsconversation.h"

#include "ccsconversationentry.h"

#include "ccsconversationevent.h"

#include "ccscontactsmanager.h"

#include "ccscontactsresolver.h"

#include <xqconversions.h>

#include "ccsdebug.h"

// ============================== MEMBER FUNCTIONS ============================

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

// CCsConversationCacheHelper::NewL

// Two Phase Construction

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

CCsConversationCacheHelper*

CCsConversationCacheHelper::NewL(CCsConversationCache* aConversationCache)

{

    PRINT ( _L("Enter CCsConversationCacheHelper::NewL") );

    CCsConversationCacheHelper* self =

            new (ELeave) CCsConversationCacheHelper(aConversationCache);

    CActiveScheduler::Add(self);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    PRINT ( _L("End CCsConversationCacheHelper::NewL") );

    return self;

}

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

// CCsConversationCacheHelper::CCsConversationCacheHelper

// Construtor

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

CCsConversationCacheHelper::CCsConversationCacheHelper(

                                                       CCsConversationCache* aConversationCache) :

    CActive(EPriorityLow), iConversationCache(aConversationCache)

{

}

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

// CCsConversationCacheHelper::ConstructL

// Second phase constructor

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

void CCsConversationCacheHelper::ConstructL()

{

    iConversationEvent = NULL;

    iConversationIndex = KErrNotFound;

    iCurrentConversationIndex = KErrNotFound;

    //initialize the event list

    iConversationEventList

            = new (ELeave) RPointerArray<CCsConversationEvent> ();

    // now create all special type of conversations

    // like BT, IRDA, Unknown Drafts etc.

    TInt loop = 0;

    for (loop = 0; loop < KMaxSpecialConversations; loop++)

    {

        CreateSpecialConversationL();

    }

}

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

// CCsConversationCache::CreateSpecialConversationL

// Second part of constructL

// This shall create all special type of messages like BT, Unknown Draft, IRDA etc.

// Pls note this shall be placed by order at starting of cache

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

void CCsConversationCacheHelper::CreateSpecialConversationL()

{

    // Create a conversation for Drafts Unknown case and set it in

    // 0th position and the conversation Id for drafts unknown case is

    // KDratsUnknownConversationId

    CCsConversation* conversation = CCsConversation::NewL();

    conversation->SetConversationId(GetNextRowId());

    // add into the list

    iConversationCache->ConversationList()->AppendL(conversation);

}

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

// CCsConversationCacheHelper::CCsConversationCacheHelper

// Destructor

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

CCsConversationCacheHelper::~CCsConversationCacheHelper()

{

    Cancel();

    // delete the event list

    if (iConversationEventList)

    {

        iConversationEventList->ResetAndDestroy();

        iConversationEventList->Close();

        delete iConversationEventList;

        iConversationEventList = NULL;

    }

}

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

// CCsConversationCacheHelper::DoCancel()

// DoCancel implementation from CActive Object

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

//

void CCsConversationCacheHelper::DoCancel()

{

    // do nothing    

}

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

// CCsConversationCacheHelper::Run

// Called from the scheduler

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

void CCsConversationCacheHelper::RunL()

{

    switch (iState)

    {

        case ECsProcessConversation:

        {

            HandleProcessConversationL();

        }

            break;

        case ECsSpecialConversation:

        {

            HandleSpecialConversationL();

        }

            break;

        case ECsConversationFoundInCache:

        {

            HandleConversationInCacheL();

        }

            break;

        case ECsResolveConversation:

        {

            ResolveContact(iConversationEvent);

        }

            break;

    }

}

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

// CCsConversationCacheHelper::StartCacheUpdate

// this shall start looking at cache data and update if entry already exist

// shall put request to phonebook in case new data

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

void CCsConversationCacheHelper::StartCacheUpdate()

{

    iState = ECsProcessConversation;

    IssueRequest();

}

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

// CCsConversationCacheHelper::HandleProcessConversationL()

// Process Conversation and update cache

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

//

void CCsConversationCacheHelper::HandleProcessConversationL()

{

    iConversationEvent = GetNextEvent();

    // check to see if all the events are consumed

    // then mark cache as caching done..

    if (!iConversationEvent)

    {

        iConversationCache->CachingCompletedL();

        return;

    }

    CCsConversationEntry* conEntry =

            iConversationEvent->ClientConversation()->GetConversationEntry();

    //handle add, modify events

    if (iConversationEvent->Event() != KConversationEventDelete)

    {

        TUint8 SpecialId = NeedsSpecialProcessing(conEntry);

        if (SpecialId)

        {

            // this is for draft(unlnown)/BT/IR processing            

            iState = ECsSpecialConversation;

        }

        // check only if contact is a valid address

        else if (conEntry->Contact())

        {

            iCurrentConversationIndex

                    = iConversationCache->FindConversation(* (conEntry->Contact()));

            if (iCurrentConversationIndex != KErrNotFound)

            {

                iState = ECsConversationFoundInCache;

            }

            else

            {

                iState = ECsResolveConversation;

            }

        }

        else

        {

            // this is when contact number is NULL

            // delete the entry from temp list

            DeleteEvent(*iConversationEvent);

            iState = ECsProcessConversation;

        }

    }

    else

    {

        //handle delete event

        DeleteConversationEntryL(conEntry);

        DeleteEvent(*iConversationEvent);

        iState = ECsProcessConversation;

    }

    //move to other state

    IssueRequest();

}

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

// CCsConversationCacheHelper::HandleSpecialConversationL()

// Hnadle the case when the conversation has no contact,

// BlueTooth/IrDa messages

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

//

void CCsConversationCacheHelper::HandleSpecialConversationL()

{

    CCsConversationEntry* conEntry =

        iConversationEvent->ClientConversation()->GetConversationEntry();

    if (ECsBlueTooth == conEntry->GetType()|| ECsBlueTooth_VCard == conEntry->GetType()|| ECsBlueTooth_VCal == conEntry->GetType())

    {

        AddConversationEntryL(conEntry, KBluetoothMsgsConversationId);

    }

    else

    {

        AddConversationEntryL(conEntry, KUnknownConversationId);

    }

    DeleteEvent(*iConversationEvent);

    iState = ECsProcessConversation;

    IssueRequest();

    PRINT ( _L("CCsConversationCacheHelper::HandleSpecialConversationL") );

}

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

// CCsConversationCacheHelper::HandleConversationInCacheL()

// Handle the case when the conversation is found in the cache

// so there is no need for resolving the contact

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

//

void CCsConversationCacheHelper::HandleConversationInCacheL()

{

    CCsConversationEntry* conEntry =

            iConversationEvent->ClientConversation()->GetConversationEntry();

    AddConversationEntryL(conEntry, iCurrentConversationIndex);

    DeleteEvent(*iConversationEvent);

    // reset back the conversation index

    iCurrentConversationIndex = KErrNotFound;

    iState = ECsProcessConversation;

    IssueRequest();

}

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

// This function identifies if the conentry needs special processing

// Drafts message with NULL contact/Bluetooth/IRDA etc

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

TUint8 CCsConversationCacheHelper::NeedsSpecialProcessing(

                                                          CCsConversationEntry* aConversationEntry)

{

    if (ECsBlueTooth == aConversationEntry->GetType() || ECsBlueTooth_VCard == aConversationEntry->GetType() || ECsBlueTooth_VCal == aConversationEntry->GetType())

    {

        return 1;

    }

    return 0;

}

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

// Move to next state

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

//

void CCsConversationCacheHelper::IssueRequest()

{

    if (!IsActive())

    {

        iStatus = KRequestPending;

        TRequestStatus* status = &iStatus;

        SetActive();

        User::RequestComplete(status, KErrNone);

    }

}

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

// CCsConversationCacheHelper::ContactResolved

// Handle a contact resolved in the contact database

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

void CCsConversationCacheHelper::ResolveContact(

                                                CCsConversationEvent* aConverastionEvent)

{

    CCsContactDetail contactDetail;

    //get contact from event

    CCsConversationEntry* ConvEntry =

            aConverastionEvent->ClientConversation()->GetConversationEntry();

    if (ConvEntry)

    {

        HBufC* Contact = ConvEntry->Contact();

        if (Contact)

        {

            QString contactAddress =

                    XQConversions::s60DescToQString(Contact->Des());

            iConversationCache->ContactsManager()->resolver()->resolveContact(contactAddress,

                                                                              contactDetail);

            int contactId = contactDetail.contactId;

            TInt cIndex = iConversationCache->FindConversation(contactId);

            if (cIndex == KErrNotFound)

            {

                // Add as new conversation

                HBufC* displayName = NULL;

                if(!contactDetail.displayName.isEmpty())

                {

                    displayName=XQConversions::qStringToS60Desc(contactDetail.displayName);

                }

                TRAPD(error, AddNewConversationL( aConverastionEvent->

                                ClientConversation()->GetConversationEntry(),

                                contactId,

                                displayName));

                if (displayName) delete displayName;                

                if (error != KErrNone)

                {

                    // handle error

                }

            }

            else

            {

                // this is when two contacts are having same contact Id,

                // in that case it should add into an existing conversation

                TRAPD(error, AddConversationEntryL( 

                        aConverastionEvent->ClientConversation(

                                )->GetConversationEntry(), cIndex));

                if (error != KErrNone)

                {

                    // handle error

                }

            }

            // now remove the entry from event list

            DeleteEvent(*aConverastionEvent);

            // call start update cache

            StartCacheUpdate();

        }

    }

}

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

// Handles the case where conversation is already in cache

// This will add new conversation entry into the corresponding conversation

// pls note there is already a conversation exist for this entry

// hence this entry gets appended inside conversation list

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

void CCsConversationCacheHelper::AddConversationEntryL(

                                                       CCsConversationEntry *aConEntry,

                                                       TInt aConversationIndex)

{

    RPointerArray<CCsConversation>* conversationList =

            iConversationCache->ConversationList();

    CCsConversation* conversation = (*conversationList)[aConversationIndex];

    CCsConversationEntry* prevLatestEntry = conversation->GetLatestEntryL();

    if (prevLatestEntry)

    {

        prevLatestEntry = prevLatestEntry->CloneL();

    }

    else

    {

        prevLatestEntry = aConEntry->CloneL();

    }

    CleanupStack::PushL(prevLatestEntry);

    // save the previous unread message count

    TUint16 prevUnreadCount = conversation->GetUnreadMessageCount();

    TUint32 event;

    conversation->UpdateEntryL(aConEntry, event);

    // Send update notify to conversation list

    if (IsNotifyRequiredL(conversation,

                          prevLatestEntry,

                          KConversationListEventUpdate,

                          prevUnreadCount))

    {

        CCsConversationEntry* convEntry = conversation->GetLatestEntryL();

        CCsClientConversation* clientConvLatest =

                iConversationCache->CreateClientConvLC(conversation, convEntry);

        // THIS IS USED FOR SHOWING NOTIFICATIONS. NOTIFICATION IS SHOWN ONLY

        // WHEN ECsAttributeNewEntryAdded IS SET. 

        if(iConversationEvent->IsUpdateConversationEventSet() 

                && event == KConversationEventNew)

            {

            clientConvLatest->GetConversationEntry()->

            ChangeAttributes(ECsAttributeNewEntryAdded,ECsAttributeNone);

            }

        iConversationCache->NotifyL(clientConvLatest,

                                    KConversationListEventUpdate);

        CleanupStack::PopAndDestroy(clientConvLatest);

    }

    // Send update notify to conversations

    CCsClientConversation* clientConv =

            iConversationCache->CreateClientConvLC(conversation, aConEntry);

    iConversationCache->NotifyL(clientConv, event);

    // Cleanup

    CleanupStack::PopAndDestroy(clientConv);

    CleanupStack::PopAndDestroy(prevLatestEntry);

}

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

// CCsConversationCache::DeleteConversationL

// Delete conversation entry from conversation list

// there are few checks of how to notify the UI about the changes 

// for the various use cases. 

// Delete requires the conversation Id and type (SMS, MMS etc.)

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

void CCsConversationCacheHelper::DeleteConversationEntryL(

                                                          CCsConversationEntry* aConversationEntry)

{

    // For MMS, search the entry inside all conversations and delete.

    // For SMS, stop on first match.

    TBool stopOnFirstMatch = ETrue;

    RPointerArray<CCsConversation>* conversationList =

            iConversationCache->ConversationList();

    // the deletion needs search the entryId inside whole conversation

    // search the entry id and delete the entry

    for (TInt loop = 0; loop < iConversationCache->ConversationList()->Count(); loop++)

    {

        CCsConversation* conversation =

                static_cast<CCsConversation*> ( (*conversationList)[loop]);

        TInt indexDeletion = conversation->FindEntry(aConversationEntry);

        if (indexDeletion != KErrNotFound)

        {

            // Get the entry from cache to check the type

            CCsConversationEntry* cacheEntry =

                    conversation->GetEntryL(indexDeletion);

            if (cacheEntry->GetType() == ECsMMS || cacheEntry->GetType()

                    == ECsAudio)

            {

                stopOnFirstMatch = EFalse;

            }

            TUint16 prevUnreadCount = conversation->GetUnreadMessageCount();

            // Delete the conversation entry from this conversation

            conversation->DeleteEntryL(indexDeletion);

            // Notify client of conversation list change.

            if (IsNotifyRequiredL(conversation,

                                  aConversationEntry,

                                  KConversationListEventDelete,

                                  prevUnreadCount))

            {

                // Delete

                CCsClientConversation

                        * clientConv =

                                iConversationCache->CreateClientConvLC(conversation,

                                                                       aConversationEntry);

                iConversationCache->NotifyL(clientConv,

                                            KConversationListEventDelete);

                CleanupStack::PopAndDestroy(clientConv);

                // Update with latest entry

                CCsConversationEntry* conEntry =

                        conversation->GetLatestEntryL();

                if (conEntry)

                {

                    CCsClientConversation

                            * clientConv =

                                    iConversationCache->CreateClientConvLC(conversation,

                                                                           conEntry);

                    iConversationCache->NotifyL(clientConv,

                                                KConversationListEventNew);

                    CleanupStack::PopAndDestroy(clientConv);

                }

            }

            // Notify client of conversation change

            if (!conversation->IsDeleted())

            {

                CCsClientConversation

                        * clientConv =