/*

* Copyright (c) 2008-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:  active object class for interacting with servicetab for link and Display Name

*

*/

// INCLUDE FILES

#include "cimcvenginestoragelistener.h"

#include "cimcvenginemessagehandler.h"

#include "imcvlogger.h"

//system includes

// ================= MEMBER FUNCTIONS =======================

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

// CIMCVEngineStorageListener::CIMCVEngineStorageListener

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

//

CIMCVEngineStorageListener::CIMCVEngineStorageListener(MIMCVEngineStorageObserver& aObserver )

    : CActive( CActive::EPriorityStandard ),

    iObserver( aObserver )

    {

    CActiveScheduler::Add( this );

    }

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

// CIMCVEngineStorageListener::ConstructL

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

//

void CIMCVEngineStorageListener::ConstructL()

    {

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::ConstructL : start"));

    TInt err = RProperty::Define(KConvViewUID,KXspIdServiceIDKey,RProperty::EText);

    if(KErrAlreadyExists != err && KErrNone != err )

        {

        User::LeaveIfError(err);

        }

    //define properties that engine will publish.

    err = RProperty::Define(KConvViewUID,KContactLinkDisplayNameKey,RProperty::ELargeText);

    if(KErrAlreadyExists != err && KErrNone != err )

        {

        User::LeaveIfError(err);

        }

   //Attaching iProperty with the property published by engine to get contact link and display name.

    err = iProperty.Attach(KConvViewUID,KContactLinkDisplayNameKey);

    User::LeaveIfError(err);

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::ConstructL : end"));

    }

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

// CIMCVEngineStorageListener::NewL

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

//

CIMCVEngineStorageListener* CIMCVEngineStorageListener::NewL(MIMCVEngineStorageObserver& aObserver)

    {

    CIMCVEngineStorageListener* self = new(ELeave) CIMCVEngineStorageListener( aObserver );

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// CIMCVEngineStorageListener::GetContactLinkInfoL

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

//

void CIMCVEngineStorageListener::GetContactLinkInfoL(TInt aServiceId, const TDesC& aXspID)

    {

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::GetContactLinkInfoL : start"));

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::GetContactLinkInfoL aServiceId= %d"),aServiceId );

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::GetContactLinkInfoL aXspID= %S"),&aXspID );

    StartListening();

    TInt length = KMaxServiceIdLength + aXspID.Length() + KDelimiter().Length();

    HBufC* userDetails = HBufC::NewLC(length);

    TPtr userDetailsPtr = userDetails->Des();

    userDetailsPtr.Zero();

    userDetailsPtr.AppendNum(aServiceId);

    userDetailsPtr.Append(KDelimiter());

    userDetailsPtr.Append(aXspID);

    RProperty::Set(KConvViewUID,KXspIdServiceIDKey,userDetails->Des());

    if( !iWait.IsStarted() )

      {

      // codescanner warning can be ignored, we are not starting an active object but 

      // CActiveSchedulerWait.

      iWait.Start();

      }

    CleanupStack::PopAndDestroy(userDetails);

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::GetContactLinkInfoL : end"));

    }

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

// CIMCVEngineStorageListener::~CIMCVEngineStorageListener()

// C++ Destructor 

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

//

CIMCVEngineStorageListener::~CIMCVEngineStorageListener()

    {

    if( iWait.IsStarted() )

         {

         // codescanner warning can be ignored, we are not starting an active object but 

         // this is CActiveSchedulerWait.

         iWait.AsyncStop();  

         }

    StopListening(); // Cancel any request, if outstanding

    // delete the earlier defined property

    RProperty::Delete(KConvViewUID,KXspIdServiceIDKey);

    RProperty::Delete(KConvViewUID,KContactLinkDisplayNameKey);

    iProperty.Close(); // Destroy the property object

    }

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

// CIMCVEngineStorageListener::RunL()

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

//

void CIMCVEngineStorageListener::RunL()

    {

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::RunL : start"));

    if( iStatus.Int() == KErrNone )

        {

        // TBuf <KMaxDisplayNameContactLinkLength> servId_usrId_name_link;

        HBufC16* servId_usrId_name_link = HBufC16::New(KMaxDisplayNameContactLinkLength);

        TPtr servId_usrId_name_linkPtr( servId_usrId_name_link->Des() );

        //Get the property in "ServiceId:UserId:Name:ContactLink" formate

        iProperty.Get(KConvViewUID,KContactLinkDisplayNameKey,servId_usrId_name_linkPtr );

        IM_CV_LOGS(TXT("CIMCVEngineStorageListener::RunL received property = %S"),&servId_usrId_name_linkPtr );

        TInt posOfDelimiter  = servId_usrId_name_link->Find(KDelimiter);

        if(KErrNotFound != posOfDelimiter )

            {

            TInt serviceId;

            HBufC16* userID = NULL;

            HBufC16* contactLink = NULL;

            HBufC16* displayName = NULL;

            TBuf<KMaxServiceIdLength> serviceIdBuf;

            TPtrC ptr(servId_usrId_name_link->Left(posOfDelimiter));

            serviceIdBuf = ptr;

            TLex16 lex(serviceIdBuf);

            lex.Val(serviceId);

            TPtrC usrId_name_link = servId_usrId_name_link->Right(servId_usrId_name_link->Length() - (posOfDelimiter+ 1) );

            posOfDelimiter = usrId_name_link.Find(KDelimiter);

            //extracting user id

            if(KErrNotFound != posOfDelimiter )

                {

                userID = (usrId_name_link.Left(posOfDelimiter)).AllocLC();

                }

            //extracting display name.

            TPtrC name_link = usrId_name_link.Right(usrId_name_link.Length() - (posOfDelimiter+ 1) );

            posOfDelimiter = name_link.Find(KDelimiter);

            if(KErrNotFound != posOfDelimiter   )

                {

                displayName = (name_link.Left(posOfDelimiter)).AllocLC();

                }

            //extracting contact link

            TPtrC link = name_link.Right(name_link.Length() - (posOfDelimiter+ 1) );

            contactLink = link.AllocLC();

            HBufC8* convertedLink = NULL;

            if(contactLink)

                {

                convertedLink = HBufC8::NewLC(contactLink->Length());

                TPtr8 convertedLinkPtr = convertedLink->Des();

                convertedLinkPtr.Copy(*contactLink);

                }

            if( !convertedLink )

                {

                convertedLink = KNullDesC8().AllocLC();

                }

            if(convertedLink && userID && displayName)

                {

                iObserver.HandleServiceBuddyDetailsFetchedL( serviceId,*userID,*convertedLink,*displayName);

                IM_CV_LOGS(TXT("storage listener RunL userID = %S"),&(*userID) );

                IM_CV_LOGS(TXT("storage listener RunL convertedLink = %S"),&(*convertedLink) );

                IM_CV_LOGS(TXT("storage listener RunL displayName = %S"),&(*displayName) );

                }

            delete (servId_usrId_name_link);

            //delete all alocated memory

            if(convertedLink)

                {

                CleanupStack::PopAndDestroy(convertedLink);

                }

            if(contactLink)

                {

                CleanupStack::PopAndDestroy(contactLink);

                }

            if(displayName)

                {

                CleanupStack::PopAndDestroy(displayName);

                }

            if(userID)

                {

                CleanupStack::PopAndDestroy(userID);

                }

            }

        }

    if( iWait.IsStarted() )

          {

          // codescanner warning can be ignored, we are not starting an active object but 

          // this is CActiveSchedulerWait.

          iWait.AsyncStop();  

          }

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::RunL : end"));

    }

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

// CIMCVEngineStorageListener::RunL()

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

//

void CIMCVEngineStorageListener::DoCancel()

    {    

    iProperty.Cancel();

    }

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

// CIMCVEngineStorageListener::StartListening()

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

//

void CIMCVEngineStorageListener::StartListening()

    {

    if( !IsActive() )

        {

        iProperty.Subscribe(iStatus);

        SetActive(); // Tell scheduler a request is active  

        }

    }

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

// CIMCVEngineStorageListener::StopListening()

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

//

void CIMCVEngineStorageListener::StopListening()

    {

    if( IsActive() )

        {

        Cancel(); // Cancel any request, if outstanding

        }

    }

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

// CIMCVEngineStorageListener::StopListening()

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

//

TInt CIMCVEngineStorageListener::RunError( TInt aError )

    {

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::RunError : start"));

    IM_CV_LOGS(TXT("CIMCVEngineStorageListener::RunError : end"));

    if( iWait.IsStarted() )

         {

         // codescanner warning can be ignored, we are not starting an active object but 

         // this is CActiveSchedulerWait.

         iWait.AsyncStop();  

         }

    return aError;

    }

//  End of File