/*

* Copyright (c) 2010 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 "emailtrace.h"

#include "nmmailagentheaders.h"

#include "nmmailagent.h"

#include <xqsystemtoneservice.h>

// CONSTS

const int NmAgentIndicatorNotSet = -1;

const int NmAgentAlertToneTimer = 60000; // 60s

static const QString NmMailboxIndicatorType = "com.nokia.nmail.indicatorplugin_%1/1.0";

static const QString NmSendIndicatorName = "com.nokia.nmail.indicatorplugin.send/1.0";

static const QString NmUnreadIndicatorName = "com.nokia.nmail.indicatorplugin.unread/1.0";

/*!

    \class NmMailAgent

    \brief Main class for receiving email events and passing them to the HbIndicator

*/

NmMailboxInfo::NmMailboxInfo()

{

    NM_FUNCTION;

    mId = 0;

    mIndicatorIndex = NmAgentIndicatorNotSet;

    mSyncState = SyncComplete;

    mConnectState = Disconnected;

    mOutboxMails = 0;

    mInboxFolderId = 0;

    mOutboxFolderId = 0;

    mInboxCreatedMessages = 0;

    mInboxChangedMessages = 0;

    mInboxDeletedMessages = 0;

    mActive = false;

}

NmMailAgent::NmMailAgent() :

 mIndicator(NULL),

 mSystemTone(NULL),

 mPluginFactory(NULL),

 mAlertToneAllowed(true),

 mLastOutboxCount(0),

 mUnreadIndicatorActive(false)

{

    NM_FUNCTION;

}

/*!

    Delayed start

*/

void NmMailAgent::delayedStart()

{

    NM_FUNCTION;

	if (!init()) {

		// Initialisation failed. Quit the agent.

		QCoreApplication::exit(1);

	}

}

/*!

    Initialise the agent. \return true if succesfully started.

*/

bool NmMailAgent::init()

{

    NM_FUNCTION;

    mPluginFactory = NmDataPluginFactory::instance();

    if (!mPluginFactory) {

        NM_ERROR(1,"NmMailAgent::init(): PluginFactory not created");

        return false;

    }

    //mSystemTone = new XQSystemToneService();

    mIndicator = new HbIndicator();

    connect(mIndicator,SIGNAL(userActivated(const QString &, const QVariantMap&)),

        this, SLOT(indicatorActivated(const QString&, const QVariantMap&)));

    QList<QObject*> *plugins = mPluginFactory->pluginInstances();

    foreach (QObject *plugin, *plugins) {

    	if (plugin) {

			// Start listening events

			connect(plugin, SIGNAL(mailboxEvent(NmMailboxEvent, const QList<NmId>&)),

				this, SLOT(handleMailboxEvent(NmMailboxEvent, const QList<NmId> &)),

				Qt::UniqueConnection);

			connect(plugin, SIGNAL(messageEvent(

					NmMessageEvent, const NmId &, const QList<NmId> &, const NmId&)),

				this, SLOT(handleMessageEvent(

					NmMessageEvent, const NmId &, const QList<NmId> &, const NmId&)),

				Qt::UniqueConnection);

			connect(plugin, SIGNAL(syncStateEvent(NmSyncState, const NmOperationCompletionEvent&)),

				this, SLOT(handleSyncStateEvent(NmSyncState, const NmOperationCompletionEvent&)),

				Qt::UniqueConnection);

			connect(plugin, SIGNAL(connectionEvent(NmConnectState, const NmId, int)),

				this, SLOT(handleConnectionEvent(NmConnectState, const NmId, int)),

				Qt::UniqueConnection);

    	}

    }

    // load all current mailboxes

    initMailboxStatus();

    return true;

}

NmMailAgent::~NmMailAgent()

{

    NM_FUNCTION;

    qDeleteAll(mMailboxes);

    //delete mSystemTone;

    NmDataPluginFactory::releaseInstance(mPluginFactory);

}

/*!

    Initialize the mailbox list with the current state

*/

void NmMailAgent::initMailboxStatus()

{

    NM_FUNCTION;

    QList<NmMailbox*> mailboxes;

    QList<QObject*> *plugins = mPluginFactory->pluginInstances();

    foreach(QObject* pluginObject, *plugins) {

        NmDataPluginInterface *plugin =

            mPluginFactory->interfaceInstance(pluginObject);

        if (plugin) {

            plugin->listMailboxes(mailboxes);

        }

        // Add the indicators

        // Must be made in reverse order to show them properly in

        // HbIndicator menu

        QListIterator<NmMailbox *> i(mailboxes);

        i.toBack();

        while (i.hasPrevious()) {

            const NmMailbox *mailbox = i.previous();

            if (mailbox) {

                NmMailboxInfo *mailboxInfo = createMailboxInfo(*mailbox,plugin);

                if (mailboxInfo) {

                    bool activate = updateUnreadCount(mailbox->id(), *mailboxInfo);

                    mailboxInfo->mOutboxMails = getOutboxCount(mailbox->id());

                        activate = true;

                    }

                }

            }

        }

        qDeleteAll(mailboxes);

    }

    updateSendIndicator();

}

/*!

    Get mailbox unread count in inbox folder

    \param mailboxId id of the mailbox

    \param mailboxInfo contains the list of unread messages

    \return true if new unread mails was found

*/

bool NmMailAgent::updateUnreadCount(const NmId &mailboxId, NmMailboxInfo &mailboxInfo)

{

    NM_FUNCTION;

    int newUnreadMessages(0);

    NmDataPluginInterface *plugin = mPluginFactory->interfaceInstance(mailboxId);

    if (plugin) {

		// get inbox folder ID

		NmId inboxId = plugin->getStandardFolderId(

				mailboxId, NmFolderInbox );

		// get list of messages in inbox

		QList<NmMessageEnvelope*> messageList;

		plugin->listMessages(mailboxId, inboxId, messageList);

		QList<NmId> newUnreadMessageIdList;

		foreach (const NmMessageEnvelope* envelope, messageList) {

		    // if the message is not read, it is "unread"

			if (!envelope->isRead()) {

		        quint64 messageId = envelope->messageId().id();

			    newUnreadMessageIdList.append(envelope->messageId());

			    bool found(false);

			    // Iterate through all known ids. If the id can't be found the mail is new.

			    foreach (const NmId id, mailboxInfo.mUnreadMailIdList) {

			        if (id.id() == messageId) {

			            found = true;

			            break;

			        }

			    }

			    if (!found) {

			        newUnreadMessages++;

			    }

			}

		}

		qDeleteAll(messageList);

		// Save updated list of unread message IDs

        mailboxInfo.mUnreadMailIdList = newUnreadMessageIdList;

    }

    NM_COMMENT(QString("NmMailAgent::getUnreadCount(): count=%1, new=%2").

        arg(mailboxInfo.mUnreadMailIdList.count()).arg(newUnreadMessages));

    return (newUnreadMessages > 0);

}

/*!

    Get mailbox count in outbox folder

    \param mailboxId id of the mailbox

    \param maxCount max number of outbox mails that is needed

    \return number of mails in the outbox

*/

int NmMailAgent::getOutboxCount(const NmId &mailboxId)

{

    NM_FUNCTION;

    int count(0);

    NmDataPluginInterface *plugin = mPluginFactory->interfaceInstance(mailboxId);

    if (plugin) {

		// get outbox folder ID

		NmId outboxId = plugin->getStandardFolderId( mailboxId, NmFolderOutbox );

		// get list of messages in outbox

		QList<NmMessageEnvelope*> messageList;

		plugin->listMessages(mailboxId, outboxId, messageList);

		count = messageList.count();

		qDeleteAll(messageList);

    }

    NM_COMMENT(QString("NmMailAgent::getOutboxCount(): count=%1").arg(count));

    return count;

}

/*!

    Get list of unread counts in active mailboxes

	\returns total number of unread mails

*/

int NmMailAgent::getTotalUnreadCount() const

{

    int unreads = 0;

    foreach (const NmMailboxInfo *mailbox, mMailboxes) {

            unreads += mailbox->mUnreadMailIdList.count();

        }

    }

    return unreads;

}

/*!

    Update the "@" indicator state according to unread state

    \return true if the indicator was activated

*/

bool NmMailAgent::updateUnreadIndicator()

{

    int unreads = getTotalUnreadCount();

    return updateUnreadIndicator(unreads>0);

}

/*!

    Update the mailbox visibility and status

    \param mailboxId id of the mailbox

    \param active visibility state of the mailbox

    \param refreshAlways true when the indicator should be always updated

    \return true if the mailbox state was changed

*/

bool NmMailAgent::updateMailboxState(const NmId &mailboxId,

    bool active, bool refreshAlways)

{

    NM_FUNCTION;

    NmMailboxInfo *mailboxInfo = getMailboxInfo(mailboxId);

    bool changed = false;

    if (mailboxInfo->mActive != active ||

        refreshAlways) {

        mailboxInfo->mActive = active;

        changed = true;

        if (active) {

            // Mailbox is not yet assigned to any indicator

            if (mailboxInfo->mIndicatorIndex < 0) {

                mailboxInfo->mIndicatorIndex = getFreeIndicatorIndex();

            }

            updateIndicator(true,*mailboxInfo);

        }

        else {

            // Indicator not anymore active. Release it.

            if (mailboxInfo->mIndicatorIndex>=0) {

                updateIndicator(false,*mailboxInfo);

                mailboxInfo->mIndicatorIndex = NmAgentIndicatorNotSet;

            }

        }

    }

    return changed;

}

/*!

    Updates indicator status

    \param mailboxIndex index of the item shown in indicator menu

    \param active indicator visibility state

    \param mailboxInfo information of the mailbox

    \return true if indicator was updated with no errors

*/

bool NmMailAgent::updateIndicator(bool active,

    const NmMailboxInfo& mailboxInfo)

{

    NM_FUNCTION;

    NM_COMMENT(QString("NmMailAgent::updateIndicator(): index=%1, active=%2").

        arg(mailboxInfo.mIndicatorIndex).arg(active));

    bool ok = false;

    QString name = QString(NmMailboxIndicatorType).

        arg(mailboxInfo.mIndicatorIndex);

    QList<QVariant> list;

    list.append(mailboxInfo.mId.id());

    list.append(mailboxInfo.mName);

    list.append(mailboxInfo.mUnreadMailIdList.count());

    list.append(mailboxInfo.mSyncState);

    list.append(mailboxInfo.mConnectState);

    list.append(mailboxInfo.mOutboxMails);

    list.append(mailboxInfo.mIconName);

    list.append(mLastOutboxCount);

    if (active) {

        ok = mIndicator->activate(name,list);

    }

    else {

        ok = mIndicator->deactivate(name,list);

    }

    updateUnreadIndicator();

    return ok;

}

/*!

    update the unread indicator state

    \return true if the indicator was activated

*/

bool NmMailAgent::updateUnreadIndicator(bool active)

{

    NM_FUNCTION;

    bool activated = false;

            activated = true;

        }

    }

    return activated;

}

/*!

    Opens inbox view to specific mailbox

    \return true if inbox is succesfully opened

*/

bool NmMailAgent::launchMailbox(quint64 mailboxId)

{

    NM_FUNCTION;

    QList<QVariant> list;

    list.append(QVariant(mailboxId));

    return ok;

}

/*!

    Get next free indicator index, starting from 0

    @return index of the indicator that is available

 */

int NmMailAgent::getFreeIndicatorIndex()

{

    NM_FUNCTION;

    int index = 0;

    bool found(false);

    do {

        found = false;

        foreach (NmMailboxInfo *mailbox, mMailboxes) {

            if (mailbox->mIndicatorIndex == index &&

                mailbox->mActive) {

                found = true;

                index++;

            }

        }

    }

    while( found );

    return index;

}

/*!

    Received from NmFrameworkAdapter mailboxEvent signal

    \sa NmFrameworkAdapter

*/

void NmMailAgent::handleMailboxEvent(NmMailboxEvent event, const QList<NmId> &mailboxIds)

{

    NM_FUNCTION;

    NM_COMMENT(QString("NmMailAgent::handleMailboxEvent(): event=%1").arg(event));

    switch(event) {

        case NmMailboxCreated:

            foreach (NmId mailboxId, mailboxIds) {

                getMailboxInfo(mailboxId); // create a new mailbox if needed

            }

            break;

        case NmMailboxChanged:

            // Mailbox name may have been changed

            foreach (NmId mailboxId, mailboxIds) {

                NmMailboxInfo *mailboxInfo = getMailboxInfo(mailboxId);

                NmMailbox *mailbox(NULL);

                NmDataPluginInterface *plugin = mPluginFactory->interfaceInstance(mailboxId);

                if (plugin) {