/*
* 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