/*

* 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 Contact management(add/delete etc) related Test Cases

*

*/

//Include files

#include <e32err.h>

#include <e32const.h>

#include <e32base.h>

#include <glib.h>

#include <StifLogger.h>

#include "telepathygabbleutils.h"

#include "telepathygabbleadddeletecontact.h"

#include "telepathygabblelogintest.h"

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

// function_name	: CTelepathyGabbleAddDeleteContact

// description     	: constructor

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

CTelepathyGabbleAddDeleteContact::CTelepathyGabbleAddDeleteContact()

{

}

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

// function_name	: ConstructL

// description     	: constructor

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

void CTelepathyGabbleAddDeleteContact::ConstructL()

{

	//do nothing

}

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

// function_name	: NewL

// description     	: constructor

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

CTelepathyGabbleAddDeleteContact* CTelepathyGabbleAddDeleteContact::NewL()

{

	CTelepathyGabbleAddDeleteContact* self = new(ELeave) CTelepathyGabbleAddDeleteContact;

    CleanupStack::PushL( self );

    self->ConstructL();    

    CleanupStack::Pop();

    return self;

}

// Destructor

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

// function_name	: ~CTelepathyGabbleAddDeleteContact

// description     	: Destructor

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

CTelepathyGabbleAddDeleteContact::~CTelepathyGabbleAddDeleteContact()

{

}

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

// function_name	: add_contact

// description     	: adding a contact

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

TInt CTelepathyGabbleAddDeleteContact::add_contact ( const gchar  *contact_id, 

													 const gchar *message,

													 CTestData* aTestData )

{

  	guint     handle;

	GArray    *handles = NULL;

	//gpointer userdata = (gpointer)contact_id;

	//first check the contact_id.

	if( contact_id == NULL )

	{

		return CTestData::EADD_FAIL;

	}

	aTestData->SetAddDeleteContactStatus(CTestData::EADD_FAIL);

	//acess the utils class function to get the contact handle.	

	handle = CTelepathyGabbleUtils::get_handle_from_contact ( contact_id, aTestData );

	if ( handle == KErrNotFound )

		{

		return CTestData::EADD_FAIL;	

		}

	handles = g_array_new (FALSE, FALSE, sizeof (guint));

	g_array_append_val (handles, handle);

	DBusGProxy *group_iface_subscribe = aTestData->GetGroupSubscribeInterface();

	DBusGProxy *group_iface_publish = aTestData->GetGroupPublishInterface();

	DBusGProxy *group_iface_known = aTestData->GetGroupKnownInterface();

	//register the callback, commented for now.

	dbus_g_proxy_connect_signal (group_iface_subscribe, "MembersChanged",

					     G_CALLBACK (roster_members_changed_cb ),

					     aTestData, NULL); 

	dbus_g_proxy_connect_signal (group_iface_publish, "MembersChanged",

					     G_CALLBACK (roster_members_changed_cb ),

					     aTestData, NULL); 

	dbus_g_proxy_connect_signal (group_iface_known, "MembersChanged",

					     G_CALLBACK (roster_members_changed_cb ),

					     aTestData, NULL); 					     

	tp_chan_iface_group_add_members_async ( group_iface_subscribe, handles, message, add_contact_cb, aTestData );

	//Start the main loop

	g_main_loop_run (aTestData->GetMainLoop());

	g_array_free (handles, TRUE);

	//return the status was updated in the callback.

	return aTestData->GetAddDeleteContactStatus(); 

}

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

// function_name	: remove_contact

// description     	: remove the contact.

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

TInt CTelepathyGabbleAddDeleteContact::remove_contact ( const gchar  *contact_id, 

														const gchar *message,

													    CTestData* aTestData

													  )

{

	guint     handle;

	GArray    *handles = NULL;

	//first check the contact_id.

	if( contact_id == NULL )

	{

		return CTestData::EDELETE_FAIL;

	}

	aTestData->SetAddDeleteContactStatus( CTestData::EDELETE_FAIL );

	handle = CTelepathyGabbleUtils::get_handle_from_contact ( contact_id, aTestData);

	if ( handle == KErrNotFound )

		{

		return CTestData::EDELETE_FAIL;	

		}

	DBusGProxy *group_iface_known = aTestData->GetGroupKnownInterface();

	handles = g_array_new (FALSE, FALSE, sizeof (guint));

	g_array_append_val (handles, handle);

	tp_chan_iface_group_remove_members_async ( group_iface_known, handles, message, remove_contact_cb, aTestData );

	//Start the main loop

	g_main_loop_run (aTestData->GetMainLoop());

	g_array_free (handles, TRUE);

	return (aTestData->GetAddDeleteContactStatus());

}

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

// function_name	: add_contact_cb

// description     	:Callback for add contact

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

void CTelepathyGabbleAddDeleteContact::add_contact_cb( DBusGProxy* /*proxy*/, GError* error, gpointer userdata )

{

		CTestData* testdata = static_cast<CTestData*> (userdata);

		if ( !error )

		{

			testdata->SetAddDeleteContactStatus(CTestData::EADD_SUCCESS);

		}

		else

		{

			testdata->SetAddDeleteContactStatus(CTestData::EADD_FAIL);

		}

		//Quit the main loop

		g_main_loop_quit(testdata->GetMainLoop());

}

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

// function_name	: remove_contact_cb

// description     	: Callback for remove contact.

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

void CTelepathyGabbleAddDeleteContact::remove_contact_cb( DBusGProxy* proxy, GError *error, gpointer userdata )

{

		CTestData* testdata = static_cast<CTestData*> (userdata);

		if ( error )

		{

		testdata->GetStifLogger()->Log( _L("CTelepathyGabbleTest::deleting already removed contact,it should give some error \n") );

		testdata->SetAddDeleteContactStatus( CTestData::EDELETE_FAIL );

		}

		else

		{

		testdata->GetStifLogger()->Log( _L("CTelepathyGabbleTest::deleted successfully \n") );

		testdata->SetAddDeleteContactStatus( CTestData::EDELETE_SUCCESS );

		}

	  //Quit the main loop started in Delete contact.

	  g_main_loop_quit(testdata->GetMainLoop());

}

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

// function_name	: roster_members_changed_cb

// description     	: Callback for change in the contacts.

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

void CTelepathyGabbleAddDeleteContact::roster_members_changed_cb (DBusGProxy*   /*group_iface*/,

									    gchar*                /*message */,

									    GArray               *added,

									    GArray               *removed,

									    GArray               *local_pending,

									    GArray               *remote_pending,

									    guint                 /*actor*/,

									    guint                 /*reason*/,

									    gpointer  			  userdata)

{

	gchar **contact_name = NULL;

	CTestData* atestData = static_cast<CTestData*> (userdata);

	//TInt return_value = KErrNone;

	if (added->len > 0)

	{

		//this is not working, use async api later

	    /*tp_conn_inspect_handles( DBUS_G_PROXY(atestData->GetTpConn()),

						       TP_CONN_HANDLE_TYPE_CONTACT ,added,

						       &contact_name,NULL);*/

		if(contact_name)				       

		{

			//The contact has been added.

			// Must verify this against the contact_name for which the request was sent?

			// This will depend on whether we will hit callback for one contact at a time

			// or multiple callbacks for all contacts at a single time. ?

			//return_value = KErrNone;

			//atestData->SetAddDeleteContactStatus(CTestData::EADD_SUCCESS);

		}

	}

	if (removed->len > 0)

	{

		/*tp_conn_inspect_handles( DBUS_G_PROXY(atestData->GetTpConn()),

						       TP_CONN_HANDLE_TYPE_CONTACT ,removed,

						       &contact_name,NULL);*/

		if(contact_name)					       

		{

			//The contact_name was deleted

			//Must verify this against the contact_name for which the request was sent?

			//return_value == KErrNone;

		}

	}

	if (local_pending->len > 0) 

	{

		/*tp_conn_inspect_handles( DBUS_G_PROXY(atestData->GetTpConn()),

						       TP_CONN_HANDLE_TYPE_CONTACT ,local_pending,

						       &contact_name,NULL);*/

		if(contact_name)				       

		{

			//what should be tested here ? 

			//like what is next action expected ?

			//since the contact is still local_pending, is the test case failed ?

			//return_value = KErrNone;	

			//atestData->GetAddDeleteContactStatus();

		}

	}

	if (remote_pending->len > 0) 

	{

		/*tp_conn_inspect_handles( DBUS_G_PROXY(atestData->GetTpConn()),

						       TP_CONN_HANDLE_TYPE_CONTACT ,remote_pending,

						       &contact_name,NULL);*/

		if(contact_name)					       

		{

			//return_value = KErrNone;		

			//atestData->GetAddDeleteContactStatus();

		}

	}

	//dont quit from here right now.

}

//  End of File