/*

* Copyright (c) 2006 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:  IMPS Protocol implementation for Presence Framework

*

*/

#include <ximpprotocolconnectionhost.h>

#include "CSubscribePresenceWatcherListRequest.h"

#include "impsconnectionmanagercontrolif.h"

#include "impsdebugprint.h"

#include "CImpsPluginAccessHandler.h"

#include "CImpsPluginPureDataHandler.h"

#include "impsplugintags.h"

#include "CPEngXMLParser.h"

#include "MPEngXMLParser.h"

#include "CPEngXmlSerializer.h"

#include "MPEngXmlSerializer.h"

#include "CImpsPluginConnectionManager.h"

#include "PEngXMLTags.h"

#include <ximpobjectfactory.h>

#include <protocolpresencedatahost.h>

#include <presenceobjectfactory.h>

#include <ximpobjectcollection.h>

#include <protocolpresentitygroupsdatahost.h>

#include <presentitygroupinfo.h>

#include <presentitygroupmemberinfo.h>

#include <ximpidentity.h>

#include <protocolpresencepublishingdatahost.h>

#include <presencewatcherinfo.h>

#include <ximpdatasubscriptionstate.h>

#include "PImpsAdapXMLTools.h"

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

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

// CSubscribePresenceWatcherListRequest::CSubscribePresenceWatcherListRequest

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

//

CSubscribePresenceWatcherListRequest::CSubscribePresenceWatcherListRequest(

    MImpsPrtPluginConnectionManager& aConnMan,

    TXIMPRequestId aRequestId ) :

        CActive( EPriorityNormal ),

        iRequestId( aRequestId ),

        iConnMan( aConnMan )

    {

    IMPS_DP( D_IMPS_LIT( "::CSubscribePresenceWatcherListRequest Start" ) );

    CActiveScheduler::Add( this );

    IMPS_DP( D_IMPS_LIT( "::CSubscribePresenceWatcherListRequest End" ) );

    }

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

// CSubscribePresenceWatcherListRequest::ConstructL

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

//

void CSubscribePresenceWatcherListRequest::ConstructL()

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::ConstructL Start-End" ) );

    iParser = CreateXMLParserL();

    }

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

// CSubscribePresenceWatcherListRequest::NewL

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

//

CSubscribePresenceWatcherListRequest* CSubscribePresenceWatcherListRequest::NewL(

    MImpsPrtPluginConnectionManager& aConnMan,

    TXIMPRequestId aRequestId )

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::NewL Start" ) );

    CSubscribePresenceWatcherListRequest* self = new( ELeave )

    CSubscribePresenceWatcherListRequest( aConnMan, aRequestId );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::NewL End" ) );

    return self;

    }

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

// CSubscribePresenceWatcherListRequest::NewLC

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

//

CSubscribePresenceWatcherListRequest* CSubscribePresenceWatcherListRequest::NewLC(

    MImpsPrtPluginConnectionManager& aConnMan,

    TXIMPRequestId aRequestId )

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::NewLC Start" ) );

    CSubscribePresenceWatcherListRequest* self =

        CSubscribePresenceWatcherListRequest::NewL( aConnMan, aRequestId );

    CleanupStack::PushL( self );

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::NewLC End" ) );

    return self;

    }

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

// CSubscribePresenceWatcherListRequest::~CSubscribePresenceWatcherListRequest

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

//

CSubscribePresenceWatcherListRequest::~CSubscribePresenceWatcherListRequest()

    {

    IMPS_DP( D_IMPS_LIT( "::~CSubscribePresenceWatcherListRequest Start" ) );

    delete iResponse;

    delete iWatcherId;

    delete iWatcherStatus;

    CActive::Cancel();

    iConnMan.Remove( this );

    delete iParser;

    IMPS_DP( D_IMPS_LIT( "::~CSubscribePresenceWatcherListRequest End" ) );

    }

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

// CSubscribePresenceWatcherListRequest::DoCancel()

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

//

void CSubscribePresenceWatcherListRequest::DoCancel()

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::DoCancel Start" ) );

    iConnMan.DataHandler().CancelSending( iSendId );

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::DoCancel End" ) );

    }

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

// CSubscribePresenceWatcherListRequest::RunL()

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

//

void CSubscribePresenceWatcherListRequest::RunL()

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunL Start" ) );

    User::LeaveIfError( iStatus.Int() );

    iResponse = iConnMan.DataHandler().ResponseL( iSendId );

    TPtrC8 resultBlock( NULL, 0 );

    TInt wvErrorCode = KErrNone;

    /* parse the watcherlist content.

         in watcherlist response there is no status of 200 */

    TInt countResults = 0;

    if ( iParser->DecodeL( *iResponse, KWatcherTag, ETrue ) )

        {

        IMPS_DP( D_IMPS_LIT( "PresenceWatcherListRequest Server did not send the Watcher Tag:" ) );

        countResults = iParser->Count();

        }

    if ( iParser->DecodeL( *iResponse, KUserTag, EFalse ) )

        {

        IMPS_DP( D_IMPS_LIT( " Serever did send user tag in response" ) );

        countResults = iParser->Count();

        }

    MXIMPObjectFactory& prfwObjFact = iConnMan.HandleToHost().ObjectFactory();

    MPresenceObjectFactory& prObjFact =

        iConnMan.HandleToHost().ProtocolPresenceDataHost().PresenceObjectFactory();

    MXIMPObjectCollection* listOfWatchers = prfwObjFact.NewObjectCollectionLC();

    IMPS_DP( D_IMPS_LIT( "------------------------------------------------------------------" ) );

    IMPS_DP( D_IMPS_LIT( "---------------------Data from presadap1.2 to PresenceFramework-----------" ) );

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunL:Total Watcher:%d " ), countResults );

    for ( TInt i = 0 ; i < countResults; ++i )

        {

        MXIMPIdentity* watcherIdentity = prfwObjFact.NewIdentityLC();

        MPresenceWatcherInfo* watcherInfo = prObjFact.NewPresenceWatcherInfoLC();

        // check user tag

        if ( iParser->DecodeL( *iResponse, KUserTag, EFalse ) )

            {

            if ( iParser->DecodeL( *iResponse, KUserIDXMLTag, EFalse ) )

                {

                iWatcherId = iParser->ResultAsUnicodeTextL( i );

                iWatcherId->Des().Fold();

                watcherIdentity->SetIdentityL( *iWatcherId );

                watcherInfo->SetWatcherIdL( watcherIdentity );

                IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunL:wather id:%S " ), iWatcherId );

                IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunL:watherIdentity:%S " ), & watcherIdentity->Identity() );

                IMPS_DP( D_IMPS_LIT( "------------------------------------------------------------------" ) );

                }

            // check clientID tag

            if ( iParser->DecodeL( *iResponse, KClientIdTag, EFalse ) )

                {

                // check url

                if ( iParser->DecodeL( *iResponse, KURLTag, EFalse ) )

                    {

                    // where do we store in the watcher info object?

                    // either parse and store this object locally in the class

                    }

                }

            }

        // check watcher status

        if ( iParser->DecodeL( *iResponse, KWatcherStatusTag, EFalse ) )

            {

            iWatcherStatus = iParser->ResultAsUnicodeTextL( i );

            iWatcherStatus->Des().Fold();

            // compare the string with current subscriber and set type

            _LIT16( KCurrentSubscriber, "CURRENT_SUBSCRIBER" );

            // check if the string contains the above substring

            TInt value = iWatcherStatus->CompareF( KCurrentSubscriber ) ;

            if ( KErrNone == value )

                {// current subscriber

                watcherInfo->SetWatcherTypeL( MPresenceWatcherInfo::EPresenceSubscriber );

                }

            else

                {

                // other type of subscriber

                watcherInfo->SetWatcherTypeL( MPresenceWatcherInfo::EUnknown );

                }

            }

        listOfWatchers->AddObjectL( watcherInfo );

        delete iWatcherId;

        iWatcherId = NULL;

        delete iWatcherStatus;

        iWatcherStatus = NULL;

        CleanupStack::Pop( 2 ); // watcherIdentity, watcherInfo

        } // for loop end

    // issue internal request to the prfw.

    iConnMan.HandleToHost().ProtocolPresenceDataHost().PublishingDataHost().HandlePresenceWatcherListL( listOfWatchers );

    MXIMPDataSubscriptionState* dataSubscriptionState = prfwObjFact.NewDataSubscriptionStateLC();

    dataSubscriptionState->SetDataStateL( MXIMPDataSubscriptionState::EDataAvailable );

    dataSubscriptionState->SetSubscriptionStateL( MXIMPDataSubscriptionState::ESubscriptionActive );

    iConnMan.HandleToHost().ProtocolPresenceDataHost().PublishingDataHost().SetPresenceWatcherListDataSubscriptionStateL(

        dataSubscriptionState, NULL );

    CleanupStack::Pop(); // listOfWatchers

    CleanupStack::Pop(); // dataSubscriptionState

    IMPS_DP( D_IMPS_LIT( " SubscribePresenceWatcherListL wvErrorCode::%d" ), wvErrorCode );

    // complete the request from prfw

    iConnMan.HandleToHost().HandleRequestCompleted( iRequestId, wvErrorCode );

    delete this;

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunL End" ) );

    }

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

// CSubscribePresenceWatcherListRequest::RunError

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

//

TInt CSubscribePresenceWatcherListRequest::RunError( TInt  aError )

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunError Start" ) );

    iConnMan.HandleToHost().HandleRequestCompleted( iRequestId, aError );

    delete this;

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::RunError End" ) );

    return KErrNone;

    }

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

// CSubscribePresenceWatcherListRequest::SubscribePresenceWatcherListL

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

//

void CSubscribePresenceWatcherListRequest::SubscribePresenceWatcherListL()

    {

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::SubscribePresenceWatcherListL Start" ) );

    TPtr8 ptrbuffer( iConnMan.DataHandler().TransferBufferL() );

    MPEngXMLSerializer* serializer = CreateXmlSerializerLC( ptrbuffer );

    IMPS_DP( D_IMPS_LIT( "SubscribePresenceWatcherListL Manufacture XML " ) );

    NImpsAdapXMLTools::AppendTransactionContentTagXmlL( *serializer, iConnMan.GetVersion() );

    serializer->StartTagL( KGetWatchers );

    serializer->StartTagL( KHistoryPeriod ).NarrowTextL( KHistoryPeriodValue ).EndTagL( KHistoryPeriod );

    serializer->StartTagL( KMaxWatcherList ).NarrowTextL( KMaxWatcherListValue ).EndTagL( KMaxWatcherList );

    serializer->EndTagL( KGetWatchers );

    serializer->EndTagL( KTransactionContent );

    CleanupStack::PopAndDestroy(); //serializer

    iSendId = iConnMan.DataHandler().SendDataL( iStatus );

    IMPS_DP( D_IMPS_LIT( " SendData Request id %d " ), iSendId );

    // signal the scheduler

    SetActive();

    IMPS_DP( D_IMPS_LIT( "CSubscribePresenceWatcherListRequest::SubscribePresenceWatcherListL End" ) );

    }

// End of file