/*

 * 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: 

 *

 */

//SYSTEM INCLUDES

#include <e32cmn.h>

#include <mtclreg.h>

#include <mtclbase.h>

#include <msvids.h>

#include <txtetext.h>

#include <txtrich.h>

#include <txtfmlyr.h>

#include <smsclnt.h>

#include <bioscmds.h>

#include <biocmtm.h>

#include "debugtraces.h"

#include <QDateTime>

#include <s60qconversions.h>

#include <mmsvattachmentmanager.h>

#include "convergedmessage.h"

#include "convergedmessageaddress.h"

#include "univcaldataplugin_p.h"

#include "sessioneventhandler.h"

#define KBioUidValue  0x10001262

const TUid KBioUidValueUid =

{KBioUidValue};

_LIT(KUnixEpoch, "19700000:000000.000000");

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

// UniVCalDataPluginPrivate::~UniVCalDataPluginPrivate

// @see header

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

UniVCalDataPluginPrivate::~UniVCalDataPluginPrivate()

{

    q_ptr = NULL;

    if (iMsvEntry)

    {

        delete iMsvEntry;

    }

    delete iBioClientMtm;

    delete iMtmReg;

    delete iSessionHandler;

    delete iMSession;

}

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

// UniVCalDataPluginPrivate::UniVCalDataPluginPrivate

// @see header

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

UniVCalDataPluginPrivate::UniVCalDataPluginPrivate(UniVCalDataPlugin* plugin) :

    q_ptr(plugin), iMSession(NULL), iMtmReg(NULL), iBioClientMtm(NULL),

            iMsvEntry(NULL), iSessionHandler(NULL)

{

    iSessionHandler = new SessionEventHandler();

    // Create a new messaging server session..

    iMSession = CMsvSession::OpenSyncL(*iSessionHandler);

    iSessionHandler->start();

    done = EFalse;

}

void UniVCalDataPluginPrivate::initL()

{

    iMtmReg = CClientMtmRegistry::NewL(*iMSession);

    iBioClientMtm = (CBIOClientMtm*) iMtmReg->NewMtmL(KBioUidValueUid);

    attachmentProcessed = EFalse;

    done = ETrue;

}

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

// UniVCalDataPluginPrivate::reset

// @see header

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

void UniVCalDataPluginPrivate::reset()

{

}

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

// UniVCalDataPluginPrivate::setMessageId

// @see header

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

int UniVCalDataPluginPrivate::setMessageId(int mId)

{

    TInt error = KErrNone;

    TRAP(error, setMessageIdL(mId));

    return error;

}

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

// UniVCalDataPluginPrivate::setMessageIdL

// @see header

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

void UniVCalDataPluginPrivate::setMessageIdL(int mId)

{

    if (done == EFalse)

    {

        initL();

    }

    iMessageId = (TMsvId) mId;

    iBioClientMtm->SwitchCurrentEntryL(iMessageId);

    iMsvEntry = CMsvEntry::NewL(iBioClientMtm->Session(),

                                iMessageId,

                                TMsvSelectionOrdering());

    iBioClientMtm->LoadMessageL();

}

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

// UniVCalDataPluginPrivate::body

// @see header

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

void UniVCalDataPluginPrivate::body(QString& aBodyText)

{

    CRichText& textBody = iBioClientMtm->Body();

    TInt len = textBody.DocumentLength();

    HBufC* buf = HBufC::NewL(len);

    TPtr bufPtr = buf->Des();

    textBody.ExtractSelectively(bufPtr, 0, len, CPlainText::EExtractAll);

    aBodyText = S60QConversions::s60DescToQString(*buf);

    delete buf;

}

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

// UniVCalDataPluginPrivate::messageSize

// @see header

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

qint32 UniVCalDataPluginPrivate::messageSize()

{

    return iBioClientMtm->Entry().Entry().iSize;

}

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

// UniVCalDataPluginPrivate::toRecipientList

// @see header

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

void UniVCalDataPluginPrivate::toRecipientList(

                                               ConvergedMessageAddressList& mAddressList)

{

    TPtrC name;

    TPtrC address;

    CPlainText* pText = CPlainText::NewL();

    CleanupStack::PushL(pText);

    CSmsHeader* smsHeader = CSmsHeader::NewL(CSmsPDU::ESmsSubmit, *pText);

    CleanupStack::PushL(smsHeader);

    CMsvStore* store = iMsvEntry->ReadStoreL();

    CleanupStack::PushL(store);

    smsHeader->RestoreL(*store);

    for (TInt id = 0; id < smsHeader->Recipients().Count(); ++id)

    {

        CSmsNumber* rcpt = smsHeader->Recipients()[id];

        name.Set(rcpt->Name());

        address.Set(rcpt->Address());

        ConvergedMessageAddress

                * messageAddress =

                        new ConvergedMessageAddress(S60QConversions::s60DescToQString(address),

                                                    S60QConversions::s60DescToQString(name));

        mAddressList.append(messageAddress);

    }

    CleanupStack::PopAndDestroy(3, pText);

}

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

// UniVCalDataPluginPrivate::fromAddress

// @see header

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

void UniVCalDataPluginPrivate::fromAddress(QString& messageAddress)

{

    CPlainText* pText = CPlainText::NewL();

    CleanupStack::PushL(pText);

    CSmsHeader* smsHeader = CSmsHeader::NewL(CSmsPDU::ESmsDeliver, *pText);

    CleanupStack::PushL(smsHeader);

    CMsvStore* store = iMsvEntry->ReadStoreL();

    CleanupStack::PushL(store);

    smsHeader->RestoreL(*store);

    messageAddress

            = S60QConversions::s60DescToQString(smsHeader->FromAddress());

    CleanupStack::PopAndDestroy(3, pText);

}

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

// UniVCalDataPluginPrivate::timeStamp

// @see header

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

int UniVCalDataPluginPrivate::timeStamp()

{

    QDateTime retTimeStamp;

    TTime timeStamp = iBioClientMtm->Entry().Entry().iDate;

    TTime unixEpoch(KUnixEpoch);

    TTimeIntervalSeconds seconds;

    timeStamp.SecondsFrom(unixEpoch, seconds);

    return seconds.Int();

}

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

// UniVCalDataPluginPrivate::attachmentList

// @see header

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

RFile UniVCalDataPluginPrivate::attachmentL()

{

    if (attachmentProcessed)

    {

        CMsvStore* store1 = iMsvEntry->ReadStoreL();

        CleanupStack::PushL(store1);

        MMsvAttachmentManager& attachMan = store1->AttachmentManagerL();

        RFile file = attachMan.GetAttachmentFileL(0);

        CleanupStack::PopAndDestroy(store1);

        return file;

    }

    CMsvEntrySelection* selection = new (ELeave) CMsvEntrySelection;

    CleanupStack::PushL(selection);

    selection->AppendL(iMessageId);

    TBuf8<1> aParameter;

    CMsvOperationWait* wait = CMsvOperationWait::NewLC();

    wait->iStatus = KRequestPending;

    wait->Start();

    CMsvOperation* operation =

            iBioClientMtm->InvokeAsyncFunctionL(KBiosMtmParse,

                                                *selection,

                                                aParameter,

                                                wait->iStatus);

    CActiveScheduler::Start();

    CMsvStore* store = iMsvEntry->ReadStoreL();

    CleanupStack::PushL(store);

    MMsvAttachmentManager& attachMan = store->AttachmentManagerL();

    RFile file = attachMan.GetAttachmentFileL(0);

    delete operation;

    CleanupStack::PopAndDestroy(3,selection);

    attachmentProcessed = ETrue;

    return file;

}

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

// UniVCalDataPluginPrivate::attachmentCount

// @see header

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

int UniVCalDataPluginPrivate::attachmentCount()

{

    if (!attachmentProcessed)

    {

        RFile file = attachmentL();

        file.Close();

    }

    CMsvStore* store = iMsvEntry->ReadStoreL();

    CleanupStack::PushL(store);

    MMsvAttachmentManager& attachMan = store->AttachmentManagerL();

    int count = attachMan.AttachmentCount();

    CleanupStack::PopAndDestroy(store);

    return count;

}

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

// UniVCalDataPluginPrivate::messagePriority

// @see header

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

MsgPriority UniVCalDataPluginPrivate::messagePriority()

{

    MsgPriority priority = (MsgPriority) iMsvEntry->Entry().Priority();

    return priority;

}

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

// UniVCalDataPluginPrivate::session

// @see header

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

CMsvSession* UniVCalDataPluginPrivate::session()

{

    return iMSession;

}