diff -r 000000000000 -r d0f3a028347a libtelepathy/tsrc/src/telepathygabblefetchcontacts.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/libtelepathy/tsrc/src/telepathygabblefetchcontacts.cpp	Tue Feb 02 01:10:06 2010 +0200
@@ -0,0 +1,246 @@
+/*
+* Copyright (c) 2008 - 2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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:    Used for Fetch contacts related Test Cases
+*
+*/
+
+
+
+
+//Include files
+#include <e32err.h>
+#include <e32const.h>
+#include <e32base.h>
+#include <glib.h>
+
+#include "telepathygabblefetchcontacts.h"
+#include "telepathygabbletestdata.h"
+
+
+
+
+
+//-----------------------------------------------------------------------------
+// function_name	: CTelepathyGabbleFetchContacts
+// description     	: constructor
+//----------------------------------------------------------------------------- 
+CTelepathyGabbleFetchContacts::CTelepathyGabbleFetchContacts()
+{
+}
+
+//-----------------------------------------------------------------------------
+// function_name	: ConstructL
+// description     	: constructor
+//----------------------------------------------------------------------------- 
+void CTelepathyGabbleFetchContacts::ConstructL()
+{
+	//do nothing
+}
+
+//-----------------------------------------------------------------------------
+// function_name	: NewL
+// description     	: constructor
+//----------------------------------------------------------------------------- 
+CTelepathyGabbleFetchContacts* CTelepathyGabbleFetchContacts::NewL()
+    {
+    
+	CTelepathyGabbleFetchContacts* self = new(ELeave) CTelepathyGabbleFetchContacts;
+    CleanupStack::PushL( self );
+    self->ConstructL();    
+    CleanupStack::Pop();
+    return self;
+    }
+
+//-----------------------------------------------------------------------------
+// function_name	: ~CTelepathyGabbleFetchContacts
+// description     	: Destructor
+//----------------------------------------------------------------------------- 
+CTelepathyGabbleFetchContacts::~CTelepathyGabbleFetchContacts()
+    {
+	
+    }
+    
+//-----------------------------------------------------------------------------
+// function_name	: test_request_roster
+// description     	: Function for fetching the contacts.
+//----------------------------------------------------------------------------- 
+TInt CTelepathyGabbleFetchContacts::test_request_roster( CTestData* aTestData )
+{
+	
+	DBusGProxy * group_iface_subscribe = aTestData->GetGroupSubscribeInterface();
+	
+	tp_chan_iface_group_get_all_members_async(group_iface_subscribe, get_roster_member_cb, aTestData);
+
+  	//Run the mainloop
+	g_main_loop_run (aTestData->GetMainLoop());
+
+	//retrun some error code here	
+	if ( aTestData->GetTotalFetchCount() != KErrGeneral )
+	{
+		return KErrNone;
+	}
+	else
+	{
+		return KErrGeneral;
+	}
+}
+
+//-----------------------------------------------------------------------------
+// function_name	: get_roster_member_cb
+// description     	: callback for getting the roster member.
+//----------------------------------------------------------------------------- 
+void  CTelepathyGabbleFetchContacts::get_roster_member_cb( DBusGProxy* /*proxy*/,GArray* current_members, GArray* local_pending_members, GArray* remote_pending_members, GError* /*error*/, gpointer userdata ) 
+{
+	guint fetch_count=0;
+	guint fetch_loop_count=0;	
+	GArray* fetch_members = NULL;
+	guint i;
+	guint total_len =0;
+	CTestData* testData = static_cast<CTestData*> (userdata);
+
+	
+	total_len = current_members->len + local_pending_members->len + remote_pending_members->len;
+
+	testData->SetTotalFetchCount(total_len);
+	
+	if( !total_len )
+		{
+			g_main_loop_quit(testData->GetMainLoop());
+			return;		
+			
+		}
+	
+	fetch_members = g_array_new (FALSE, FALSE, sizeof (guint32));
+
+	
+	if( current_members->len > 0)
+	{
+		fetch_count = 0;
+		fetch_loop_count = (current_members->len) / KMaxContactFetchCount + ( (current_members->len % KMaxContactFetchCount)? 1 : 0);
+		
+		for( i=0; i<fetch_loop_count; i++ )
+		{
+				
+			g_array_remove_range(fetch_members,0,fetch_count);
+			
+			fetch_count = (current_members->len <= KMaxContactFetchCount)? current_members->len : KMaxContactFetchCount;
+			
+			g_array_append_vals (fetch_members,current_members->data,fetch_count);
+			
+			g_array_remove_range(current_members,0,fetch_count);
+			
+			//we will quit the main loop in inspect_handles_cb
+			tp_conn_inspect_handles_async( DBUS_G_PROXY(testData->GetTpConn()),
+					       TP_CONN_HANDLE_TYPE_CONTACT ,fetch_members,
+					       inspect_handles_cb,userdata);
+		}
+	}
+	
+	if( local_pending_members->len > 0)
+	{
+		fetch_count = 0;
+		
+		g_array_remove_range(fetch_members,0,fetch_members->len);
+		
+		fetch_loop_count = (local_pending_members->len) / KMaxContactFetchCount + ( (local_pending_members->len % KMaxContactFetchCount)? 1 : 0);
+		
+		for( i=0; i<fetch_loop_count; i++ )
+		{
+				
+			g_array_remove_range(fetch_members,0,fetch_count);
+			
+			fetch_count = (local_pending_members->len <= KMaxContactFetchCount)? local_pending_members->len : KMaxContactFetchCount;
+			
+			
+			g_array_append_vals (fetch_members,local_pending_members->data,fetch_count);
+			
+			g_array_remove_range(local_pending_members,0,fetch_count);
+			
+			tp_conn_inspect_handles_async( DBUS_G_PROXY(testData->GetTpConn()),
+					       TP_CONN_HANDLE_TYPE_CONTACT ,fetch_members,
+					       inspect_handles_cb,userdata);
+		}
+
+	}
+
+	if( remote_pending_members->len > 0)
+	{
+		fetch_count = 0;
+		g_array_remove_range(fetch_members,0,fetch_members->len);
+		fetch_loop_count = (remote_pending_members->len) / KMaxContactFetchCount + ( (remote_pending_members->len % KMaxContactFetchCount)? 1 : 0);
+		
+		for( i=0; i<fetch_loop_count; i++ )
+		{
+				
+			g_array_remove_range(fetch_members,0,fetch_count);
+			
+			fetch_count = (remote_pending_members->len <= KMaxContactFetchCount)? remote_pending_members->len : KMaxContactFetchCount;
+			
+			g_array_append_vals (fetch_members,remote_pending_members->data,fetch_count);
+			g_array_remove_range(remote_pending_members,0,fetch_count);
+			tp_conn_inspect_handles_async( DBUS_G_PROXY(testData->GetTpConn()),
+					       TP_CONN_HANDLE_TYPE_CONTACT ,fetch_members,
+			  	       inspect_handles_cb,userdata);	
+		}	
+	
+	}
+	return;
+	
+}
+
+//-----------------------------------------------------------------------------
+// function_name	: inspect_handles_cb
+// description     	: inspect the handle for the contact, return the contact handle 
+//----------------------------------------------------------------------------- 
+void CTelepathyGabbleFetchContacts::inspect_handles_cb( DBusGProxy* /*proxy*/,char **handles_names,
+														GError *error, gpointer userdata ) 
+{
+    CTestData* testData = static_cast<CTestData*> (userdata);
+    TInt last_index = testData->GetLastIndexInFetch(); 
+    guint total_len = testData->GetTotalFetchCount();
+    
+	if(!last_index)
+	{
+		//allmembers_names = g_new0 ( char *, total_len + 1);		
+	}
+	
+	if(!handles_names || error )
+		{
+		//error condition in inspect_handles_cb
+		testData->SetTotalFetchCount(KErrGeneral);
+		g_main_loop_quit(testData->GetMainLoop());
+		return;
+		}
+		
+	for( TInt i=0; handles_names[i]; i++ )
+		{
+		
+		//handle_names can be logged to the log file
+		last_index++;
+		}
+		
+	testData->SetLastIndexInFetch(last_index);
+	
+	if (last_index == total_len )
+		{
+			//inspect_handle_cb for all the contacts has been receieved.
+			//Quit the main loop.
+			
+			//Set the flag that inspect_handles_cb has been completed successfully.
+			g_main_loop_quit(testData->GetMainLoop());	
+		}
+	
+	return ;
+}
+//  End of File