isolationserver/isoserver/src/isogetsearchkeys.c
changeset 0 d0f3a028347a
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/isolationserver/isoserver/src/isogetsearchkeys.c	Tue Feb 02 01:10:06 2010 +0200
@@ -0,0 +1,318 @@
+/*
+* ============================================================================
+*  Name        : isogetsearchkeys.c
+*  Part of     : isolation server.
+*  Version     : %version: 7 %
+*
+*  Copyright © 2007-2008 Nokia.  All rights reserved.
+*  Redistribution and use in source and binary forms, with or without modification, 
+*  are permitted provided that the following conditions are met:
+*  Redistributions of source code must retain the above copyright notice, this list 
+*  of conditions and the following disclaimer.Redistributions in binary form must 
+*  reproduce the above copyright notice, this list of conditions and the following 
+*  disclaimer in the documentation and/or other materials provided with the distribution.
+*  Neither the name of the Nokia Corporation nor the names of its contributors may be used 
+*  to endorse or promote products derived from this software without specific prior written 
+*  permission.
+*  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY 
+*  EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 
+*  OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT 
+*  SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 
+*  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT 
+*  OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 
+*  HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 
+*  (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 
+*  EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+* ============================================================================
+* Template version: 1.0
+*/
+
+/*!	\file 
+*	Impliments the functions in isosearch.h
+*/
+
+/*! \def For malloc
+*/
+#include <stdlib.h>
+
+/*! \def For string operations
+*/
+#include <string.h>
+
+
+/*! \def For search related declarations
+*/
+#include "isosearch.h"
+
+/*! \def For globalCon
+*/
+#include "isoservermain.h"
+
+/*! \def For tp_chan_type_search_async
+*/
+#include "tp-chan-type-search-gen.h"
+
+/*! \def For MSG_PRI_NORMAL
+*/
+#include "msgqlib.h"
+
+/*! \def For message_hdr_req
+*/
+#include "isoutils.h"
+
+/*! \def For RESPONSE_QUEUE
+*/
+#include "msgliterals.h"
+
+#include "isogetsearchkeys.h"
+
+/*!	\struct key_value_struct isoserach.h
+*	\brief This struct is used for to form the msg buffer that will be sent to client
+*	\var msg As the key/value pairs are read those will be appended to msg
+* 	\var len is the no. of bytes appended to msg
+*/
+struct key_value_struct 
+	{
+	gchar* msg;
+	gint len;		
+	};
+	
+/*! \typedef struct key_value_struct to key_value_struct
+*/	
+typedef struct key_value_struct key_value_struct;
+
+/*! \struct get_search_keys_cb_struct isosearch.h
+*	\brief This struct bundles multiple(two ?) pointers to be passed
+*	to getsearch keys callback
+*	\var search_chan which should be closed when search keys are recieved
+*	\var hdr_req message header request
+*/	
+struct get_search_keys_cb_struct 
+	{
+	TpChan* search_chan;
+	message_hdr_req* hdr_req;	
+	};
+	
+/*! \typedef struct get_search_keys_cb_struct to get_search_keys_cb_struct 
+*/		
+typedef struct get_search_keys_cb_struct get_search_keys_cb_struct;	
+
+
+static void getsearchkeys_cb( DBusGProxy *proxy,  gchar *instr,
+  gchar **keys, GError *error, gpointer userdata );
+  
+/*!	\brief get_search_keys_reply is called as a callback to get_search_keys
+*	This function creates a new channel and requests telepathy for the 	
+*	search keys
+*
+*	\param userdata message header request
+*
+*	\remark calling tp_conn_new_channel results into esock_client 8 panic
+*	Instead of calling function tp_conn_new_channel which makes a 
+*	a call to tp_conn_request_channel, tp_conn_request_channel_async is 
+*	called directly. 
+*/	
+
+static void get_search_keys_reply( DBusGProxy *proxy, char *chan_object_path, 
+ 			GError *error, gpointer user_data )
+	{
+		                               
+	
+	TpChan *search_chan = NULL;
+	DBusGProxy *search_iface = NULL;
+	get_search_keys_cb_struct* chan_struct = NULL;
+	message_hdr_resp* hdr_req = ( message_hdr_resp* )user_data;
+	
+	UNUSED_FORMAL_PARAM( proxy );
+	iso_logger( "in get_search_keys" );
+	
+	if ( error )
+		{
+		send_response_to_client( (message_hdr_req*)hdr_req, error->code, 0 );	
+		free ( hdr_req );
+		return;			
+		}
+		
+	//Create new channel for the search
+	search_chan = tp_chan_new( globalCon.dbusConn, globalCon.connmgr_bus, chan_object_path, 
+	TP_IFACE_CHANNEL_TYPE_CONTACT_SEARCH, TP_CONN_HANDLE_TYPE_NONE, 0 );
+
+	
+	if ( NULL == search_chan ) 
+		{
+		free ( hdr_req );
+		return ;			
+		}							
+	//Get chan interface					
+	search_iface = tp_chan_get_interface( search_chan, 
+		TELEPATHY_CHAN_IFACE_CONTACTSEARCH_QUARK );	
+					
+	if ( NULL == search_iface ) 
+		{
+		tp_chan_close_async( DBUS_G_PROXY( search_chan ), 
+					search_chan_closed_cb, NULL );
+		free ( hdr_req );			
+		return ;			
+		}
+	
+	chan_struct = ( get_search_keys_cb_struct* ) malloc ( 
+			sizeof ( get_search_keys_cb_struct ) );
+			
+	chan_struct->search_chan = search_chan;
+	chan_struct->hdr_req = ( message_hdr_req* ) malloc ( 
+							sizeof( message_hdr_req ) );
+	if ( NULL == chan_struct->hdr_req ) 
+		{
+		tp_chan_close_async( DBUS_G_PROXY( search_chan ), 
+					search_chan_closed_cb, NULL );
+		free ( hdr_req );			
+		return ;			
+		}							
+	//memset( chan_struct->hdr_req, )
+	memcpy( chan_struct->hdr_req, hdr_req, sizeof( message_hdr_req ) );
+		
+	
+	//Ownership of search_chan and chan_struct->hdr_req, 
+	//chan_struct is passed to getsearchkeys_cb
+	free ( hdr_req );
+	
+	tp_chan_type_search_get_search_keys_async( search_iface, 
+				getsearchkeys_cb, chan_struct );		
+		
+	iso_logger( "out get_search_keys" );
+	
+		
+	}
+
+/*!	\brief Function to get the search keys(fields on which to
+*	search ) supported by server
+* 	
+*	\param hdr_req message header request
+*	
+*	\return gint MEM_ALLOCATION_ERROR
+*/
+gint get_search_keys( message_hdr_resp* hdr_req ) 
+	{
+	
+	message_hdr_resp* hdr_resp = ( message_hdr_resp* ) 
+						malloc ( sizeof ( message_hdr_resp ) );
+						
+	if ( NULL == hdr_resp )
+		{
+		return MEM_ALLOCATION_ERROR;		
+		}
+	
+	memcpy( hdr_resp, hdr_req, sizeof ( message_hdr_resp ) );
+	//ownership hdr_resp transfered
+	tp_conn_request_channel_async( DBUS_G_PROXY( globalCon.conn ),
+	                               TP_IFACE_CHANNEL_TYPE_CONTACT_SEARCH, 
+	                               TP_CONN_HANDLE_TYPE_NONE, 0, TRUE,
+	                               get_search_keys_reply, (gpointer)hdr_resp ) ;
+	
+	return 0;			
+	}
+
+
+/*!	\brief This is a callback to get_search_keys. The search keys
+*	are sent to the requested client
+*
+*	\param proxy unused
+*	\param instr instruction on search keys
+*	\param keys 2D string array of search keys supported by server
+*	\param error Error from server, if any
+*	\param userdata get_search_keys_cb_struct 
+*/	
+
+static void getsearchkeys_cb( DBusGProxy *proxy,  gchar *instr,
+  gchar **keys, GError *error, gpointer userdata )
+	{
+	
+	get_search_keys_cb_struct * search_struct = ( 
+				get_search_keys_cb_struct* )userdata;
+				
+	message_hdr_resp hdr_resp;
+	gchar* msg = NULL;
+	gint i = 0;
+	gint len = 0;
+	
+	gint pri = MSG_PRI_NORMAL;
+	gint result = 0;
+	gint timeout = NO_WAIT;
+	gint err = 0;
+	
+	
+	UNUSED_FORMAL_PARAM( proxy );
+	UNUSED_FORMAL_PARAM( instr );
+	iso_logger( "in getsearchkeys_cb" );
+	
+	
+	tp_chan_close_async( DBUS_G_PROXY( search_struct->search_chan ), 
+					search_chan_closed_cb, NULL );
+	
+	if ( error ) 
+		{
+		send_response_to_client( search_struct->hdr_req, error->code, 0 );	
+		
+		free ( search_struct->hdr_req );
+		free ( search_struct );
+		
+		return;
+		}
+		
+	//Create the response header to be sent to client
+	//Copy the message header request
+	hdr_resp.hdr_req.message_type = ESearch_Get_Keys;
+	hdr_resp.hdr_req.protocol_id = search_struct->hdr_req->protocol_id;
+	hdr_resp.hdr_req.request_id = search_struct->hdr_req->request_id;
+	hdr_resp.hdr_req.session_id = search_struct->hdr_req->session_id;
+	//set continue flag
+	hdr_resp.continue_flag = 0;
+	hdr_resp.error_type = 0;
+	hdr_resp.response = 1;	
+	
+	free ( search_struct->hdr_req );
+	free ( search_struct );
+	
+	//Allocate memory for the message and set memory to '\0'	
+	msg = ( gchar* ) malloc ( MAX_PARAM_LEN );
+	if ( NULL == msg ) 
+		{
+		iso_logger( "malloc error @ pairs.msg" );
+		return ;			
+		}
+	memset( msg, '\0', MAX_PARAM_LEN );
+	len = 0;
+	//Copy the response
+	memcpy( msg, &hdr_resp, sizeof ( message_hdr_resp ) );
+	len += sizeof( message_hdr_resp );
+	
+	
+	iso_logger( "Get search keys : Keys are" );
+	
+	while ( keys[i] )
+		{
+		strcpy( msg + len, keys[i] );
+		iso_logger( "Key %d : %s", i, keys[i] );
+		len += 	strlen( keys[i] ) + 1;
+		i++;
+		}
+		
+	iso_logger( "Get search keys : Keys End" );
+	
+	//End the message with a '\0'
+	len++;
+	msg[len] = '\0';
+	//Send the message to client
+	result = MsgQSend( RESPONSE_QUEUE, msg, len, 
+						pri, timeout, &err );
+	
+	
+	
+	if ( result )
+		{
+			
+		}
+	
+	iso_logger( "out getsearchkeys_cb" );	
+	
+	}