--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/imservices/ossprotocoladaptation/src/presentitygroups/ccontactsynchandler.cpp	Thu Dec 17 08:54:49 2009 +0200
@@ -0,0 +1,212 @@
+/*
+* 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