/*

 * 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: Listen to conversation server events and parse the 

 * events. These parse infomation passed to notifications and indications.

 *

 */

// SYSTEM INCLUDES

#include <msvapi.h>

#include <ccsclientconversation.h>

#include <ccsrequesthandler.h>

#include <ccsconversationentry.h>

//USER INCLUDES

#include "msgnotifier.h"

#include "msgnotifier_p.h"

#include "s60qconversions.h"

#include <QtDebug>

#define QDEBUG_WRITE(str) {qDebug() << str;}

#define QDEBUG_WRITE_FORMAT(str, val) {qDebug() << str << val;}

#define QCRITICAL_WRITE(str) {qCritical() << str;}

#define QCRITICAL_WRITE_FORMAT(str, val) {qCritical() << str << val;}

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

// MsgNotifierPrivate::MsgNotifierPrivate

// @see MsgNotifierPrivate.h

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

MsgNotifierPrivate::MsgNotifierPrivate(MsgNotifier* MsgNotifier):

q_ptr(MsgNotifier),

mCvServer(NULL)

{

QDEBUG_WRITE("MsgNotifierPrivate::MsgNotifierPrivate : Enter")

TRAP_IGNORE(initL());

QDEBUG_WRITE("MsgNotifierPrivate::MsgNotifierPrivate : Exit")

}

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

// MsgNotifierPrivate::~MsgNotifierPrivate

// @see MsgNotifierPrivate.h

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

MsgNotifierPrivate::~MsgNotifierPrivate()

{

QDEBUG_WRITE("MsgNotifierPrivate::~MsgNotifierPrivate : Enter")	

if(mCvServer)

    {

    mCvServer->RemoveConversationListChangeEventL (this);

    delete mCvServer;

    mCvServer = NULL;

    }

QDEBUG_WRITE("MsgNotifierPrivate::~MsgNotifierPrivate : Exit")    

}

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

// MsgNotifierPrivate::initL

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::initL()

    {

    QDEBUG_WRITE("MsgNotifierPrivate::initL : Enter")

    mCvServer = CCSRequestHandler::NewL();

    mCvServer->RequestConversationListChangeEventL(this);

    updateIndications();

    QDEBUG_WRITE("MsgNotifierPrivate::initL : Exit")

    }

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

// MsgNotifierPrivate::AddConversationList

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::AddConversationList(

           const CCsClientConversation& aClientConversation)

    {

    QDEBUG_WRITE("MsgNotifierPrivate::AddConversationList : Enter")

    processListEntry(aClientConversation);

    updateIndications();

    QDEBUG_WRITE("MsgNotifierPrivate::AddConversationList : Exit")

    }

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

// MsgNotifierPrivate::DeleteConversationList

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::DeleteConversationList(

           const CCsClientConversation& /*aClientConversation*/) 

    {

    QDEBUG_WRITE("MsgNotifierPrivate::DeleteConversationList : Enter")	

    updateIndications();

    QDEBUG_WRITE("MsgNotifierPrivate::DeleteConversationList : Exit")

    }

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

// MsgNotifierPrivate::ModifyConversationList

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate:: ModifyConversationList(

           const CCsClientConversation& aClientConversation)

    {

    QDEBUG_WRITE("MsgNotifierPrivate::ModifyConversationList : Enter")

    processListEntry(aClientConversation);

    updateIndications();

    QDEBUG_WRITE("MsgNotifierPrivate::ModifyConversationList : Exit")

    }

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

// MsgNotifierPrivate::RefreshConversationList

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::RefreshConversationList()

    {

    }

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

// MsgNotifierPrivate::processListEntry

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::processListEntry(

        const CCsClientConversation& aClientConversation)

    {

    QDEBUG_WRITE("MsgNotifierPrivate::processListEntry : Enter")

    CCsConversationEntry* convEntry = 

                                 aClientConversation.GetConversationEntry();

    QDEBUG_WRITE_FORMAT("MsgNotifierPrivate::processListEntry Direction",

                                                convEntry->ConversationDir())

    QDEBUG_WRITE_FORMAT("MsgNotifierPrivate::processListEntry New Entry Attribute",

                                                convEntry->IsAttributeSet(ECsAttributeNewEntryAdded))

    QDEBUG_WRITE_FORMAT("MsgNotifierPrivate::processListEntry Unread Attribute",

                                                convEntry->IsAttributeSet(ECsAttributeUnread))

    bool newFlag=convEntry->IsAttributeSet(ECsAttributeNewEntryAdded);

    if((convEntry->ConversationDir() == ECsDirectionIncoming)

            && convEntry->IsAttributeSet(ECsAttributeNewEntryAdded) 

            && convEntry->IsAttributeSet(ECsAttributeUnread))

        {

        QDEBUG_WRITE("processListEntry : Processing data for Notification")

        NotificationData notifData;

        notifData.mConversationId = aClientConversation.GetConversationEntryId();

        notifData.mMsgType = convEntry->GetType();

        HBufC* firstName = aClientConversation.GetFirstName();

        HBufC* lastName =  aClientConversation.GetLastName();

        HBufC* number =  convEntry->Contact();

        HBufC* descrp =  convEntry->Description();

        if(firstName)

            {

            notifData.mFirstName = 

                                S60QConversions::s60DescToQString(*firstName);

            }

        if(lastName)

            {

            notifData.mLastName = S60QConversions::s60DescToQString(*lastName);

            }

        if(number)

            {

            notifData.mContactNum =  S60QConversions::s60DescToQString(*number);

            }

        if(descrp)

            {

            notifData.mDescription = S60QConversions::s60DescToQString(*descrp);

            }

        q_ptr->displayNewMessageNotification(notifData);

        QDEBUG_WRITE("processListEntry : Notification display called")

        }

    QDEBUG_WRITE("MsgNotifierPrivate::processListEntry : Exit")

    }

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

// MsgNotifierPrivate::updateIndications

// @see MsgNotifierPrivate.h

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

void MsgNotifierPrivate::updateIndications()

    {

    QDEBUG_WRITE("MsgNotifierPrivate::updateIndicationsL : Enter")  

    int unreadCount(0); 

    TRAP_IGNORE(unreadCount = mCvServer->GetTotalUnreadCountL());

    QDEBUG_WRITE_FORMAT("MsgNotifierPrivate::"

            "updateIndications unreadCount = ",unreadCount );

    //activate or deactivate indications based on unread count

    q_ptr->updateIndications(unreadCount);

    QDEBUG_WRITE("MsgNotifierPrivate::updateIndicationsL : Exit")

    }

//EOF