/*
 * Copyright (c) 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:  This Class handles Add, Delete & Modify conversation list client events.
 *
 */

#include "conversationlistchangehandler.h"

// SYSTEM INCLUDES
#include <ccsconversationentry.h>
#include <ccsclientconversation.h>
// USER INCLUDE
#include "conversationsengine_p.h"
#include "conversationsengine.h"
#include "conversationssummarymodel.h"

TInt ListWindowSize = 7;
// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
ConversationsListChangeHandler::ConversationsListChangeHandler(
    ConversationsEnginePrivate* convEnginePrivate,
    ConversationsSummaryModel* conversationsSummaryModel) :
    CActive(EPriorityStandard), 
    mCurrentState(EInit),
    mFirstWindowCached(EFalse),
    mCurrentIndex(-1),     
    mConvSummaryModel(conversationsSummaryModel), 
    mConvEnginePrivate(convEnginePrivate)
{
    CActiveScheduler::Add(this);
}

// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
ConversationsListChangeHandler::~ConversationsListChangeHandler()
{
    mClientConversationList.ResetAndDestroy();
    // Cancel the active object
    Cancel();
}

//-----------------------------------------------------------------------
// From CActive class.
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::RunL()
{
    if (iStatus != KErrNone)
    {
        // Reading events has failed
        return;
    }
    else
    {
        switch (mCurrentState)
        {
            case EInitialCache:
            {
                HandleConversationListL();
                break;
            }
        }
    }
}

//-----------------------------------------------------------------------
// From CActive class.
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::DoCancel()
{
    mCurrentState = EListenToEvents;
}

//-----------------------------------------------------------------------
// From CActive class.
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::ConversationListL(RPointerArray<
        CCsClientConversation>& aClientConversationList)
{
    mClientConversationList.ResetAndDestroy();
    
    for (TInt i = 0; i < aClientConversationList.Count(); ++i)
    {        
        CCsClientConversation *entry = aClientConversationList[i]->CloneL();
        mClientConversationList.InsertInOrderAllowRepeats( entry,
                ConversationsListChangeHandler::CompareByConvTimeStamp );
    }

    if (aClientConversationList.Count() > 0)
    {
        mCurrentIndex = 0;
        mFirstWindowCached = EFalse;
        mCurrentState = EInitialCache;
        IssueRequest();
    }
    else
    {
        mConvEnginePrivate->registerForConversationListUpdatesL();
        mCurrentState = EListenToEvents;
    }
}

//-----------------------------------------------------------------------
// This is for handling new conversation event asynchronusly from the server
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::AddConversationList(
    const CCsClientConversation& aClientConversation)
{
    mConvSummaryModel->addRow(aClientConversation);
}

//-----------------------------------------------------------------------
// This is for handling delete conversation event asynchronusly from the server
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::DeleteConversationList(
    const CCsClientConversation& aClientConversation)
{
    mConvSummaryModel->deleteRow(aClientConversation.GetConversationEntryId());
}

//-----------------------------------------------------------------------
// This is for handling partial delete conversation event asynchronusly from the server
//-----------------------------------------------------------------------
//

void ConversationsListChangeHandler::PartialDeleteConversationList(
            const CCsClientConversation& aClientConversation)
{
    ConversationsEngine::instance()->emitConversationListModelEntryDeleted( aClientConversation.GetConversationEntryId() );
}

//-----------------------------------------------------------------------
// This is for handling modify conversation event asynchronusly from the server
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::ModifyConversationList(
    const CCsClientConversation& aClientConversation)
{
    mConvSummaryModel->addRow(aClientConversation);
}

//-----------------------------------------------------------------------
// This is for handling refresh conversation event asynchronusly from the server
//-----------------------------------------------------------------------
//
void ConversationsListChangeHandler::RefreshConversationList()
{
}

// ---------------------------------------------------------------------------
// Make the active object alive.
// ---------------------------------------------------------------------------
//
void ConversationsListChangeHandler::IssueRequest()
{
    if (!IsActive())
    {
        iStatus = KRequestPending;
        TRequestStatus* status = &iStatus;
        SetActive();
        User::RequestComplete(status, KErrNone);
    }
}

// ---------------------------------------------------------------------------
// Handles Conversation List received from server and updates into model
// ---------------------------------------------------------------------------
//
void ConversationsListChangeHandler::HandleConversationListL()
{
    for (int i = 0; i < ListWindowSize; ++i)
    {
        if (mCurrentIndex < mClientConversationList.Count())
        {
            mConvSummaryModel->addRow(
                * (mClientConversationList[mCurrentIndex]),true);
            mCurrentIndex++;
        }
        else
        {
            break;
        }
    }
    if (mCurrentIndex < mClientConversationList.Count())
    {
        if (!mFirstWindowCached)
        {
            ConversationsEngine::instance()->
                                           emitConversationListModelPopulated();
            mFirstWindowCached = ETrue;
        }
        IssueRequest();
    }
    else
    {
        if (!mFirstWindowCached)
        {
            ConversationsEngine::instance()->
                                           emitConversationListModelPopulated();
            mFirstWindowCached = ETrue;
        }
        mClientConversationList.ResetAndDestroy();
        mConvEnginePrivate->registerForConversationListUpdatesL();
        mCurrentState = EListenToEvents;
    }

}

// ----------------------------------------------------------------------------
// ConversationsListChangeHandler::CompareByConvTimeStamp
// ---------------------------------------------------------------------------
TInt ConversationsListChangeHandler::CompareByConvTimeStamp(const CCsClientConversation& aObj1,
        const CCsClientConversation& aObj2)
    {
    TInt64 timestamp1 = aObj1.GetConversationEntry()->TimeStamp();
    TInt64 timestamp2 = aObj2.GetConversationEntry()->TimeStamp();

    if (timestamp1 == timestamp2)
        {
        return 0;
        }
    else if (timestamp1 < timestamp2)
        {
        return 1;
        }
    return -1;
    }

// EOF