/*

* 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:  handles synchronisation of contacts

*

*/

#include <ximpprotocolconnectionhost.h>

#include <ximpobjectfactory.h>

#include <protocolpresentitygroupsdatahost.h>

#include <presentitygroupinfo.h>

#include <presentitygroupmemberinfo.h>

#include <ximpidentity.h>

#include <protocolpresencedatahost.h>

#include <presenceobjectfactory.h>

#include <ximpcontext.h>

#include <devicepresenceinfo.h>

#include <e32des16.h>

#include <string.h>

#include <sys/types.h>

#include <stdio.h>

#include <stdlib.h>

#include "msgliterals.h"

#include "ccontactsynchandler.h"

#include "mossprotocolconnectionmanager.h"

#include "ossprotocolpluginlogger.h"

#include "waittimer.h"

#include "cossprotocolconnectionmanager.h"

#include "ossprotocoladaptationuids.h"

#include "ossprotocoladaptutils.h"

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

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

// CContactSyncHandler::CContactSyncHandler

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

//

CContactSyncHandler::CContactSyncHandler (

    MOSSProtocolConnectionManager& aConnMan ) :

		CActive ( EPriorityNormal ),

		iConnMan ( aConnMan )

	{

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

	CActiveScheduler::Add ( this );

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

	}

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

// CContactSyncHandler::NewL

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

//

CContactSyncHandler* CContactSyncHandler::NewL (

    MOSSProtocolConnectionManager& aConnMan )

	{

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

	CContactSyncHandler* self = new ( ELeave ) CContactSyncHandler ( aConnMan );

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

	return self;

	}

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

// CContactSyncHandler::~CContactSyncHandler

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

//

CContactSyncHandler::~CContactSyncHandler()

	{

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

	Cancel();

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

	}

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

// CContactSyncHandler::DoCancel()

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

//

void CContactSyncHandler::DoCancel()

	{

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

	iConnMan.DataHandler().CancelContactsChangeListening();

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

	}

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

// CContactSyncHandler::RunL()

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

//

void CContactSyncHandler::RunL()

	{

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

	// something is coming from the xmpp server

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

	ProcessAndSendL();

	StartListening();

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

	}

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

// CContactSyncHandler::ProcessAndSendL()

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

void CContactSyncHandler::ProcessAndSendL()

	{	

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

    char* pResponse = NULL, *pOrigResponse = NULL;  

    message_hdr_resp* msg_struct = NULL;

    while( iConnMan.DataHandler().ContactsChangeResponseCount() ) // process all responses

    	{

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

		CleanupStack::PushL(pOrigResponse) ;

	 	msg_struct = ( message_hdr_resp* )pResponse;

		char* contact= pResponse + sizeof ( message_hdr_resp );

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

		switch ( msg_struct->hdr_req.message_type )

			{

            case ESubscribe_Remote_Pending:

                {                

                break;

                }

            case ETrying_To_Add_Contact_Known:

                {

                iConnMan.GetContactManager().AddContactToLocalL(*contactName);               

                iConnMan.GetContactManager().RemoveInvitationFromLocalL(*contactName);

                break;

                }

            case ESubscribe_RP_Accepted:

                {                

                break;

                }

            case EPublish_RP_Accepted:

                {                

                break;

                }            

            case ESubscribe_Removed_Or_Rejected:

                {

                //removing from the local copy of the contacts

                iConnMan.GetContactManager().RemoveContactFromLocalL(*contactName);                                     

                break;                                              	

                }           

            case EPublish_Removed_Or_Rejected:

                {

                iConnMan.GetContactManager().RemoveInvitationFromLocalL(*contactName);                    

                break;     

                }

            }        

        CleanupStack::PopAndDestroy ( 2 );//pOrigResponse, contactName 

    	}    

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

	}

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

// CContactSyncHandler::RunError

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

//

TInt CContactSyncHandler::RunError ( TInt  aError )

	{

	LOGGER ( TXT ( "CContactSyncHandler::RunError Start %d" ), aError );

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

	return KErrNone;

	}

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

// CContactSyncHandler::StartListeningL

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

//

void CContactSyncHandler::StartListening()

	{

	LOGGER ( TXT ( "CContactSyncHandler::StartListeningL Start" ) );

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

		{

		iConnMan.DataHandler().ListenContactsChange( iStatus );

		SetActive();

		}

	LOGGER ( TXT ( "CContactSyncHandler::StartListeningL End" ) );

	}

// End of file