doubango/trunk/tinySIP/src/dialogs/tsip_dialog_layer.c

/*
* Copyright (C) 2009 Mamadou Diop.
*
* Contact: Mamadou Diop <diopmamadou@yahoo.fr>
*	
* This file is part of Open Source Doubango Framework.
*
* DOUBANGO is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*	
* DOUBANGO is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU General Public License for more details.
*	
* You should have received a copy of the GNU General Public License
* along with DOUBANGO.
*
*/

/**@file tsip_dialog_layer.c
 * @brief SIP dialog layer.
 *
 * @author Mamadou Diop <diopmamadou(at)yahoo.fr>
 *
 * @date Created: Sat Nov 8 16:54:58 2009 mdiop
 */
#include "tinysip/dialogs/tsip_dialog_layer.h"

#include "tinysip/dialogs/tsip_dialog_register.h"
#include "tinysip/dialogs/tsip_dialog_message.h"

#include "tinysip/transactions/tsip_transac_layer.h"
#include "tinysip/transports/tsip_transport_layer.h"

tsip_dialog_t* tsip_dialog_layer_find_by_op(tsip_dialog_layer_t *self, const tsip_operation_handle_t *operation)
{
	tsip_dialog_t *ret = 0;
	tsip_dialog_t *dialog;
	tsk_list_item_t *item;

	tsk_safeobj_lock(self);

	tsk_list_foreach(item, self->dialogs)
	{
		dialog = item->data;
		if( tsip_operation_get_id(dialog->operation) == tsip_operation_get_id(operation) ){
			ret = dialog;
			break;
		}
	}

	tsk_safeobj_unlock(self);

	return ret;
}

const tsip_dialog_t* tsip_dialog_layer_find(const tsip_dialog_layer_t *self, const char* callid, const char* to_tag, const char* from_tag, TSIP_BOOLEAN *cid_matched)
{
	tsip_dialog_t *ret = 0;
	tsip_dialog_t *dialog;
	tsk_list_item_t *item;

	*cid_matched = TSIP_FALSE;

	tsk_safeobj_lock(self);

	tsk_list_foreach(item, self->dialogs)
	{
		dialog = item->data;
		if(tsk_strequals(dialog->callid, callid)){
			*cid_matched = TSIP_TRUE;
			if(tsk_strequals(dialog->tag_local, from_tag) && tsk_strequals(dialog->tag_remote, to_tag)){
				ret = dialog;
				break;
			}
		}
	}

	tsk_safeobj_unlock(self);

	return ret;
}

int tsip_dialog_layer_shutdownAllExceptRegister(tsip_dialog_layer_t *self)
{
	if(self)
	{
		tsk_list_item_t *item;
		tsip_dialog_t *dialog;
		tsk_list_foreach(item, self->dialogs)
		{
			dialog = item->data;
			if(dialog->type != tsip_dialog_REGISTER){
				tsip_dialog_shutdown(dialog);
			}
		}
		return 0;
	}
	return -1;
}

int tsip_dialog_layer_hangupAll(tsip_dialog_layer_t *self)
{
	if(self)
	{
		tsk_list_item_t *item = 0;
		tsip_dialog_t *dialog;

		tsk_safeobj_lock(self);

		tsk_list_foreach(item, self->dialogs)
		{
			dialog = item->data;
			tsip_dialog_hangup(dialog);
		}

		tsk_safeobj_unlock(self);
		return 0;
	}
	return -1;
}

int tsip_dialog_layer_remove(tsip_dialog_layer_t *self, const tsip_dialog_t *dialog)
{
	if(dialog && self)
	{
		tsk_safeobj_lock(self);
		tsk_list_remove_item_by_data(self->dialogs, dialog);
		tsk_safeobj_unlock(self);

		return 0;
	}

	return -1;
}

int tsip_dialog_layer_handle_incoming_msg(const tsip_dialog_layer_t *self, const tsip_message_t* message)
{
	int ret = -1;
	TSIP_BOOLEAN cid_matched;
	const tsip_dialog_t* dialog;
	tsip_transac_t* transac = 0;
	const tsip_transac_layer_t *layer_transac = tsip_stack_get_transac_layer(self->stack);

	if(!layer_transac){
		goto bail;
	}

	//tsk_safeobj_lock(self);
	dialog = tsip_dialog_layer_find(self, message->Call_ID->value, 
		TSIP_MESSAGE_IS_RESPONSE(message) ? message->To->tag : message->From->tag, 
		TSIP_MESSAGE_IS_RESPONSE(message) ? message->From->tag : message->To->tag, &cid_matched);
	//tsk_safeobj_unlock(self);
	
	if(dialog){
		dialog->callback(dialog, tsip_dialog_i_msg, message);
		if((transac = tsip_transac_layer_new(layer_transac, TSIP_FALSE, message))){
			TSIP_TRANSAC(transac)->dialog = dialog;
		}
	}
	else{		
		if(TSIP_MESSAGE_IS_REQUEST(message))
		{
			tsip_operation_handle_t* op = tsip_operation_createex(message);

			switch(message->request_type){
				case tsip_MESSAGE:
					{
						tsip_dialog_message_t *dlg_msg = TSIP_DIALOG_MESSAGE_CREATE(self->stack, op);
						if((transac = tsip_transac_layer_new(layer_transac, TSIP_FALSE, message))){
							TSIP_TRANSAC(transac)->dialog = TSIP_DIALOG(dlg_msg);
						}
						tsk_list_push_back_data(self->dialogs, (void**)&dlg_msg);
						break;
					}

				case tsip_INVITE:
					{
						break;
					}

				default:
					{
						break;
					}
			}

			TSK_OBJECT_SAFE_FREE(op);
		}
	}

	if(transac){
		ret = tsip_transac_start(transac, message);
	}
	else{
		const tsip_transport_layer_t *layer;
		tsip_response_t* response;

		if((layer = layer = tsip_stack_get_transport_layer(self->stack)))
		{	
			if(cid_matched){ /* We are receiving our own message. */
				response = tsip_response_new(482, "Loop Detected (Check your iFCs)", message);
				if(response && !response->To->tag){/* Early dialog? */
					response->To->tag = tsk_strdup("doubango");
				}
			}
			else{
				response = tsip_response_new(481, "Dialog/Transaction Does Not Exist", message);
			}
			if(response){
				ret = tsip_transport_layer_send(layer, response->firstVia ? response->firstVia->branch : "no-branch", response);
				TSK_OBJECT_SAFE_FREE(response);
			}
		}
	}
	
bail:
	return ret;
}





//========================================================
//	Dialog layer object definition
//
static void* tsip_dialog_layer_create(void * self, va_list * app)
{
	tsip_dialog_layer_t *layer = self;
	if(layer)
	{
		layer->stack = va_arg(*app, const tsip_stack_handle_t *);
		layer->dialogs = TSK_LIST_CREATE();

		tsk_safeobj_init(layer);
	}
	return self;
}

static void* tsip_dialog_layer_destroy(void * self)
{ 
	tsip_dialog_layer_t *layer = self;
	if(layer)
	{
		TSK_OBJECT_SAFE_FREE(layer->dialogs);

		tsk_safeobj_deinit(layer);
	}
	return self;
}

static int tsip_dialog_layer_cmp(const void *obj1, const void *obj2)
{
	return -1;
}

static const tsk_object_def_t tsip_dialog_layer_def_s = 
{
	sizeof(tsip_dialog_layer_t),
	tsip_dialog_layer_create, 
	tsip_dialog_layer_destroy,
	tsip_dialog_layer_cmp, 
};
const void *tsip_dialog_layer_def_t = &tsip_dialog_layer_def_s;