/*

* Copyright (c) 2007-2008 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:  Subscribe Presentity Group content request to the Network Server.

*

*/

#include <ximpprotocolconnectionhost.h>

#include "csubscribepresentitygroupcontentrequest.h"

#include "cossprotocolconnectionmanager.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 <ximpdatasubscriptionstate.h>

#include "ossprotocolpluginlogger.h"

#include <glib/gstrfuncs.h>

#include <gtypes.h>

#include <stdlib.h>

#include "stringutils.h"

#include <string.h>

#include <sys/types.h>

#include <stdio.h>

#include <glib/gprintf.h>

#include "msgliterals.h"

#include "msg_enums.h"

#include "ossprotocoladaptutils.h"

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

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

// CSubscribePresentityGroupContentRequest::CSubscribePresentityGroupContentRequest()

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

//

CSubscribePresentityGroupContentRequest::CSubscribePresentityGroupContentRequest (

    MOSSProtocolConnectionManager& aConnMan,

    TXIMPRequestId aRequestId ) :

		CActive ( EPriorityNormal ),

		iRequestId ( aRequestId ),

		iConnMan ( aConnMan ),

		iListcount ( 0 )

	{

	LOGGER ( TXT ( "::CSubscribePresentityGroupContentRequest Start" ) );

	CActiveScheduler::Add ( this );

	LOGGER ( TXT ( "::CSubscribePresentityGroupContentRequest End" ) );

	}

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

// CSubscribePresentityGroupContentRequest::ConstructL()

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

//

void CSubscribePresentityGroupContentRequest::ConstructL()

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::ConstructL Start-End" ) );

	iGroupName = NULL;

	}

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

// CSubscribePresentityGroupContentRequest::NewL

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

//

CSubscribePresentityGroupContentRequest* CSubscribePresentityGroupContentRequest::NewL (

    MOSSProtocolConnectionManager& aConnMan,

    TXIMPRequestId aRequestId )

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::NewL Start" ) );

	CSubscribePresentityGroupContentRequest* self = new ( ELeave )

	CSubscribePresentityGroupContentRequest ( aConnMan, aRequestId );

	CleanupStack::PushL ( self );

	self->ConstructL();

	CleanupStack::Pop ( self );

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::NewL End" ) );

	return self;

	}

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

// CSubscribePresentityGroupContentRequest::NewLC()

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

//

CSubscribePresentityGroupContentRequest* CSubscribePresentityGroupContentRequest::NewLC (

    MOSSProtocolConnectionManager& aConnMan,

    TXIMPRequestId aRequestId )

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::NewLC Start" ) );

	CSubscribePresentityGroupContentRequest* self =

	    CSubscribePresentityGroupContentRequest::NewL ( aConnMan, aRequestId );

	CleanupStack::PushL ( self );

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::NewLC End" ) );

	return self;

	}

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

// CSubscribePresentityGroupContentRequest::~CSubscribePresentityGroupContentRequest()

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

//

CSubscribePresentityGroupContentRequest::~CSubscribePresentityGroupContentRequest()

	{

	LOGGER ( TXT ( "::~CSubscribePresentityGroupContentRequest Start" ) );

	delete iGroupName;

	iGroupName = NULL;

    Cancel();

    //iContacts.ResetAndDestroy();

	LOGGER ( TXT ( "::~CSubscribePresentityGroupContentRequest End" ) );

	}

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

// CSubscribePresentityGroupContentRequest::DoCancel()

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

//

void CSubscribePresentityGroupContentRequest::DoCancel()

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::DoCancel Start" ) );

	iConnMan.DataHandler().CancelListening();

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::DoCancel End" ) );

	}

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

// CSubscribePresentityGroupContentRequest::RunL()

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

//

void CSubscribePresentityGroupContentRequest::RunL()

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::RunL Start" ) );

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

    TRAPD( error, ProcessIncomingDataL( ) );

    if ( error != KErrNone )

		{

		Cancel();

		}

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::RunL End" ) );

	}

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

// CSubscribePresentityGroupContentRequest::RunError

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

//

TInt CSubscribePresentityGroupContentRequest::RunError ( TInt  aError )

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::RunError Start" ) );

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

	delete this;

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::RunError End" ) );

	return KErrNone;

	}

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

// CSubscribePresentityGroupContentRequest::SubscribePresentityGroupContentL

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

//

void CSubscribePresentityGroupContentRequest::SubscribePresentityGroupContentL (

    const MXIMPIdentity& aIdentity )

    {

    LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::SubscribePresentityGroupContentL Start" ) );

    if(iGroupName)

        {

        delete iGroupName;

        iGroupName = NULL;

        }

    iGroupName = aIdentity.Identity().AllocL();

    iConnMan.SetGroupIDL( *iGroupName ); // this groupname is used by contactsync class for synchronisation

    if(iConnMan.DataHandler().IsFetchContactsCompleted())

        {

        ProcessIncomingDataL( );

        }

    else

        {

        if ( ! ( this->IsActive() ) )

            {

            iConnMan.DataHandler().ListenIncomingData ( iStatus );

            SetActive();

            }

        }

    LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::SubscribePresentityGroupContentL End" ) );

    }

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

// CSubscribePresentityGroupContentRequest::ProcessIncomingDataL()

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

//

void CSubscribePresentityGroupContentRequest::ProcessIncomingDataL()

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::ProcessIncomingDataL Start" ) );

	PopulateDataL();

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

	MPresenceObjectFactory& prObjFact =

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

	MXIMPIdentity* contactIdentity = NULL;

	MPresentityGroupMemberInfo* groupMemberInfo = NULL;

	MXIMPObjectCollection* listOfContacts = prfwObjFact.NewObjectCollectionLC();

	//get the ref to contacts which was already stored in PopulateDataL

	RPointerArray<HBufC>& contacts =  iConnMan.GetContactManager().GetContactsListL();	

	for(TInt i = 0;i<contacts.Count();i++)

		{

		contactIdentity = prfwObjFact.NewIdentityLC();

		groupMemberInfo = prObjFact.NewPresentityGroupMemberInfoLC();

		contactIdentity->SetIdentityL ( *(contacts[ i ] ));

		groupMemberInfo->SetGroupMemberIdL ( contactIdentity );

		groupMemberInfo->SetGroupMemberDisplayNameL ( *(contacts[ i ] ) );

		listOfContacts->AddObjectL ( groupMemberInfo );	

		CleanupStack::Pop ( 2 );//groupMemberInfo, contactIdentity		

		}

	MXIMPIdentity* groupIdentity = prfwObjFact.NewIdentityLC();

	groupIdentity->SetIdentityL ( *iGroupName );

	iConnMan.HandleToHost().ProtocolPresenceDataHost().GroupsDataHost().HandlePresentityGroupContentL (

	groupIdentity, listOfContacts );

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

	CleanupStack::Pop ( 2 );//groupIdentity,listOfContacts 

	delete this;

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::ProcessIncomingDataL End" ) );

	}

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

// CSubscribePresentityGroupContentRequest::PopulateDataL

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

//

void CSubscribePresentityGroupContentRequest::PopulateDataL()

	{

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::PopulateDataL Start" ) );

	int len = MAX_SIZE_DATA;    

    char* pResponse = NULL, *pOrigResponse = NULL;  

 	TInt datacount = iConnMan.DataHandler().IncomingDataCount();

 	//to keep the local copy of contacts in adaptation till logout

 	RPointerArray<HBufC>& contacts = iConnMan.GetContactManager().GetContactsListL(); 

 	while( datacount )

		{

		// get the incoming response from the server with transaction id equals zero

		pOrigResponse = pResponse = iConnMan.DataHandler().ResponseL ( 0 );

		CleanupStack::PushL(pOrigResponse) ;

		if( pResponse )

			{

			pResponse += sizeof ( message_hdr_resp );

			while(1)

				{

				len = strlen(pResponse) + 1;

				if (1 == len)

					{

					break;

					}

				char* contact = pResponse;	

				pResponse += len;

				HBufC16 *contactName = OssProtocolAdapUtils::ConvertCharToTUint16LC( contact );				

				contacts.AppendL(contactName);

				LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::PopulateDataL:ContactName:%S " ), contactName );

				CleanupStack::Pop ( contactName );				

				}	

			}

		CleanupStack::PopAndDestroy(pOrigResponse) ;//pOrigResponse

		datacount = iConnMan.DataHandler().IncomingDataCount();

		}

	LOGGER ( TXT ( "CSubscribePresentityGroupContentRequest::PopulateDataL End" ) );

	}

// End of file