/*

 * 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 <ccsconversationentry.h>

#include "conversationsengine.h"

#include "conversationsenginedefines.h"

#include "convergedmessage.h"

#include "conversationmsgstorehandler.h"

#include "conversationssummarymodel.h"

#include "conversationsmodel.h"

#include "conversationsengine_p.h"

#include "debugtraces.h"

#include <msghistory.h>

#include <msgitem.h>

const int ViewableLimit = 160;

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

// ConversationsEngine::instance

// @see header

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

ConversationsEngine* ConversationsEngine::instance()

{

    static ConversationsEngine* conversationsEngine = new ConversationsEngine();

    return conversationsEngine;

}

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

// ConversationsEngine::ConversationsEngine

// @see header

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

ConversationsEngine::ConversationsEngine(QObject* parent) :

    QObject(parent)

{

    mConversationMsgStoreHandler = new ConversationMsgStoreHandler;

    mConversationsSummaryModel = new ConversationsSummaryModel(this);

    mConversationsModel = new ConversationsModel(mConversationMsgStoreHandler,

                                                 this);

    d_ptr = new ConversationsEnginePrivate(mConversationMsgStoreHandler,

                                           mConversationsSummaryModel,

                                           mConversationsModel);

    mMsgHistory = new MsgHistory(this);

}

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

// ConversationsEngine::~ConversationsEngine

// @see header

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

ConversationsEngine::~ConversationsEngine()

{

    delete mConversationMsgStoreHandler;

    delete d_ptr;

}

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

// ConversationsEngine::getConversationsSummaryModel

// @see header

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

QStandardItemModel* ConversationsEngine::getConversationsSummaryModel()

{

    return mConversationsSummaryModel;

}

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

// ConversationsEngine::getConversationsModel

// @see header

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

QStandardItemModel* ConversationsEngine::getConversationsModel()

{

    return mConversationsModel;

}

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

// ConversationsEngine::getConversations

// @see header

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

void ConversationsEngine::getConversations(qint64 conversationId)

{

    int error;

    mContactId = conversationId;

    mMsgHistory->getMessages(conversationId);

    mMsgHistory->subscribe(conversationId);

    //connect to the signals

    connect(mMsgHistory, SIGNAL(messagesReady(QList<MsgItem>&)),

    this, SLOT(onMessagesReady(QList<MsgItem>&)));

    connect(mMsgHistory, SIGNAL(messageAdded(MsgItem&)), this, SLOT(onMessageAdded(MsgItem&)));

    connect(mMsgHistory, SIGNAL(messageChanged(MsgItem&)), this, SLOT(onMessageChanged(MsgItem&)));

    connect(mMsgHistory, SIGNAL(messageDeleted(MsgItem&)), this, SLOT(onMessageDeleted(MsgItem&)));    

    //TRAP(error,d_ptr->getConversationsL(conversationId));   

}

void ConversationsEngine::onMessagesReady(QList<MsgItem>& msgs)

{

    for (int i = 0; i < msgs.count(); i++)

    {

        MsgItem item = msgs.at(i);

        CCsConversationEntry* entry = CCsConversationEntry::NewL();

        populateEntry(item, entry);

        mConversationsModel->addRow(*entry);

        delete entry;

    }

    mMsgHistory->markRead(mContactId);

}

void ConversationsEngine::populateEntry(MsgItem& item,

                                        CCsConversationEntry* entry)

{

    // id             

    entry->SetEntryId(item.id());

    // message type. 

    entry->SetType(item.type());

    // description

    QString descr = item.body();

    entry->SetDescriptionL(description->Des());

    delete description;

    // time stamp 

    QString tt = item.timeStamp().toString();

    entry->SetTimeStampL(tt.toInt());

    //contact details

    QString details = item.phoneNumber();

    entry->SetContactL(d_details->Des());

    delete d_details;

    //sending state

    entry->SetSendState(item.state());

    // direction

    entry->SetConversationDir(item.direction());

    //attributes

    if (item.isAttributeSet(MsgItem::MsgAttributeUnread))

    {

        entry->ChangeAttributes(ECsAttributeUnread, ECsAttributeNone);

    }

    if (item.isAttributeSet(MsgItem::MsgAttributeSent))

    {

        entry->ChangeAttributes(ECsAttributeNew, ECsAttributeNone);

    }

    if (item.isAttributeSet(MsgItem::MsgAttributeNew))

    {

        entry->ChangeAttributes(ECsAttributeNew, ECsAttributeNone);

    }

    if (item.isAttributeSet(MsgItem::MsgAttributeAttachment))

    {

        entry->ChangeAttributes(ECsAttributeAttachment, ECsAttributeNone);

    }

    if (item.isAttributeSet(MsgItem::MsgAttributeHighPriority))

    {

        entry->ChangeAttributes(ECsAttributeHighPriority, ECsAttributeNone);

    }

}

void ConversationsEngine::onMessageAdded(MsgItem& item)

{

    CCsConversationEntry* entry = CCsConversationEntry::NewL();

    populateEntry(item, entry);

    mConversationsModel->addRow(*entry);

    delete entry;

}

void ConversationsEngine::onMessageChanged(MsgItem& item)

{

    CCsConversationEntry* entry = CCsConversationEntry::NewL();

    populateEntry(item, entry);

    mConversationsModel->addRow(*entry);

    delete entry;

}

void ConversationsEngine::onMessageDeleted(MsgItem& item)

{

    mConversationsModel->deleteRow(item.id());

}

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

// ConversationsEngine::clearConversations

// @see header

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

void ConversationsEngine::clearConversations()

{

    int error;

    //TRAP(error,d_ptr->clearConversationsL());

    //clear model

    mConversationsModel->clear();

    mMsgHistory->unSubscribe(mContactId);

    mContactId = -1;

}

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

// ConversationsEngine::deleteConversations

// @see header

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

void ConversationsEngine::deleteConversations(qint64 conversationId)

{

    int error;

    //TRAP(error,d_ptr->deleteConversationL(conversationId));  

    mMsgHistory->clearMessages(conversationId);

}

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

// ConversationsEngine::deleteMessages

// @see header

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

void ConversationsEngine::deleteMessages(QList<int>& msgIdList)

{

    RArray<TInt> idArray;

    for (int i = 0; i < msgIdList.count(); ++i)

    {

        idArray.Append(msgIdList[i]);

    }

    if (msgIdList.count() > 0)

    {

        d_ptr->deleteMessages(idArray);

    }

}

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

// ConversationsEngine::getUnReadMessages

// @see header

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

void ConversationsEngine::getUnReadMessages(QList<int>& msgIdList)

{

    QModelIndexList indexList =

            mConversationsModel->match(mConversationsModel->index(0, 0),

                                       UnReadStatus,

                                       true,

                                       -1, // all matching hits 

                                       Qt::MatchExactly);

    int count = indexList.count();

    for (int i = 0; i < count; ++i)

    {

        if ( (indexList[i].data(MessageType).toInt() == ConvergedMessage::Sms)

                && (indexList[i].data(BodyText).toString().count()

                        < ViewableLimit))

        {

            msgIdList.append(indexList[i].data(ConvergedMsgId).toInt());

        }

    }

}

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

// ConversationsEngine::markMessagesRead

// @see header

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

void ConversationsEngine::markMessagesRead(QList<int>& msgIdList)

{

    RArray<TInt> idArray;

    int error;

    for (int i = 0; i < msgIdList.count(); ++i)

    {

        idArray.Append(msgIdList[i]);

    }

    if (msgIdList.count() > 0)

    {

        TRAP(error,d_ptr->markMessagesReadL(idArray));

    }

}

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

// ConversationsEngine::getContactDetails

// @see header

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

void ConversationsEngine::getContactDetails(qint64 conversationId,

                                            QString& firstName,

                                            QString& lastName)

{

    QModelIndexList

            indexList =

                    mConversationsSummaryModel->match(mConversationsSummaryModel->index(0,

                                                                                        0),

                                                      ConversationId,

                                                      conversationId,

                                                      1, // One match 

                                                      Qt::MatchExactly);

    if (indexList.count() > 0)

    {

        firstName = indexList[0].data(FirstName).toString();

        lastName = indexList[0].data(LastName).toString();

    }

}

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

// ConversationsEngine::getConversationIdFromAddress

// @see header

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

qint64 ConversationsEngine::getConversationIdFromAddress(QString address)

{

    QModelIndexList

            indexList =

                    mConversationsSummaryModel->match(mConversationsSummaryModel->index(0,

                                                                                        0),

                                                      ConversationAddress,

                                                      address,

                                                      1, // One match 

                                                      Qt::MatchExactly); //TODO phonebook matching logic to be taken care

    qint64 conversationId = -1;

    if (indexList.count() > 0)

    {

        conversationId = indexList[0].data(ConversationId).toLongLong();

    }

    return conversationId;

}

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

// ConversationsEngine::getCurrentConversationId

// @see header

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

qint64 ConversationsEngine::getCurrentConversationId()

{

    return d_ptr->getConversationCurrentId();

}

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

// ConversationsEngine::getConversationIdFromContactId

// @see header

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

qint64 ConversationsEngine::getConversationIdFromContactId(qint32 contactId)

{

    /*QModelIndexList indexList = mConversationsSummaryModel->match(

     mConversationsSummaryModel->index(0, 0), 

     ContactId, 

     contactId, 

     1, // One match 

     Qt::MatchExactly); //TODO 

     qint64 conversationId = -1;

     if(indexList.count() > 0)

     {    

     conversationId = indexList[0].data(ConversationId).toLongLong();

     }         

     return conversationId;*/

    qint64 conversationId = -1;

    int error;

    TRAP(error,conversationId =

            d_ptr->getConversationIdFromContactIdL(contactId));

    return conversationId;

}