diff -r 000000000000 -r 094583676ce7 presadap12/impsplugin/src/presencepublishing/csubscribepresencewatcherlistrequest.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/presadap12/impsplugin/src/presencepublishing/csubscribepresencewatcherlistrequest.cpp Thu Dec 17 08:41:52 2009 +0200 @@ -0,0 +1,338 @@ +/* +* 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 +#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 +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#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