#if HAVE_CRT #define _CRTDBG_MAP_ALLOC #include #include #endif //HAVE_CRT /* * Copyright (C) 2020, University of the Basque Country (UPV/EHU) * Contact for licensing options: * * The original file was part of Open Source Doubango Framework * Copyright (C) 2010-2011 Mamadou Diop. * Copyright (C) 2012 Doubango Telecom * * 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_api_message.c * @brief Public short messaging (MESSAGE) functions. * * @author Mamadou Diop * */ #include #include "tinysip/api/tsip_api_message.h" #include "tinysip/dialogs/tsip_dialog_layer.h" #include "tinysip/dialogs/tsip_dialog_message.h" #include "tinymedia/content/tmedia_content_multipart.h" #include "tinysip/headers/tsip_header_Dummy.h" #include "tinysip/tsip_message.h" #include "tsip.h" #include "tsk_memory.h" #include "tsk_runnable.h" #include "tsk_debug.h" #define TSIP_MESSAGE_EVENT_CREATE( type) (tsip_message_event_t*)tsk_object_new(tsip_message_event_def_t, type) #define VALUE_CONTENT_TYPE_MESSAGE_LOCATION "application/vnd.3gpp.mcptt-location-info+xml" #define VALUE_CONTENT_TYPE_MESSAGE_AFFILIATION "application/vnd.3gpp.mcptt-affiliation-command+xml" #define VALUE_CONTENT_TYPE_MESSAGE_MBMS "application/vnd.3gpp.mcptt-mbms-usage-info+xml" #define VALUE_P_ASSERTED_SERVICE_MESSAGE_AFFILIATION "urn:urn-7:3gpp-service.ims.icsi.mcptt" #define VALUE_P_ASSERTED_SERVICE_MESSAGE_MBMS "urn:urn-7:3gpp-service.ims.icsi.mcptt" #define VALUE_CONTENT_TYPE_MULTIPART "multipart/mixed" extern tsip_action_t* _tsip_action_create(tsip_action_type_t type, va_list* app); #if HAVE_LIBXML2 static int register_xml_namespaces(xmlXPathContextPtr xpathCtx, const xmlChar* nsList) { xmlChar* nsListDup; xmlChar* prefix; xmlChar* href; xmlChar* next; nsListDup = xmlStrdup(nsList); if(nsListDup == NULL) { return(-1); } next = nsListDup; while(next != NULL) { /* skip spaces */ while((*next) == ' ') next++; if((*next) == '\0') break; /* find prefix */ prefix = next; next = (xmlChar*)xmlStrchr(next, '='); if(next == NULL) { xmlFree(nsListDup); return(-1); } *(next++) = '\0'; /* find href */ href = next; next = (xmlChar*)xmlStrchr(next, ' '); if(next != NULL) { *(next++) = '\0'; } if(href[0] == '\"' || href[0] == '\'') { href = href + 1; if(href[strlen(href) - 1] == '\"' || href[strlen(href) - 1] == '\'') href[strlen(href) - 1] = '\0'; } /* do register namespace */ if(xmlXPathRegisterNs(xpathCtx, prefix, href) != 0) { xmlFree(nsListDup); return(-1); } } xmlFree(nsListDup); return(0); } #endif int tsip_message_event_signal(tsip_message_event_type_t type, tsip_ssession_handle_t* ss, short status_code, const char *phrase, const tsip_message_t* sipmessage) { tsip_message_event_t* sipevent = TSIP_MESSAGE_EVENT_CREATE(type); tmedia_content_multipart_t* mp_content = tsk_null; tmedia_content_multipart_t* mp_content_sdp = tsk_null; tmedia_multipart_body_t* mp_body = tsk_null; char* boundary = tsk_null; const tsip_header_t* header =tsk_null; char* hdr_value=tsk_null; uint32_t local_ssrc = 0; char* psi_mbms_value=tsk_null; //tmedia_session_t* audio_session; //tsdp_message_t* sdp_ro = tsk_null; int con=0; char* sdp=tsk_null; tsip_message_t* sipmessage2=tsk_null; //if the messager is send if((((tsip_ssession_t*)ss)->media.type & tmedia_mcptt_location) == tmedia_mcptt_location){ tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_location); }else if(tsk_strcmp(TSIP_MESSAGE_CONTENT_TYPE(sipmessage),VALUE_CONTENT_TYPE_MESSAGE_LOCATION)==0){//it receive message tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_location); }else if( tsk_strcmp(TSIP_MESSAGE_CONTENT_TYPE(sipmessage),VALUE_CONTENT_TYPE_MESSAGE_AFFILIATION)==0){//it receive message for(con=0; (header = tsip_message_get_headerAt(sipmessage, tsip_htype_Dummy, con)); con++) { const tsip_header_Dummy_t* dummy_hdr = (const tsip_header_Dummy_t*)header; if(tsk_strcmp(dummy_hdr->name, "P-Asserted-Service") == 0) { #if HAVE_CRT //Debug memory hdr_value = (char *)malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #else hdr_value = (char *)tsk_malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #endif //HAVE_CRT hdr_value=strdup(dummy_hdr->value); break; } /* else if(tsk_strcmp(dummy_hdr->name, "User-Agent") == 0) { len = tsk_strlen(dummy_hdr->value) + 19; hdr_value = (char *)malloc(len * sizeof(char)); tsk_sprintf(&hdr_value, "PoC-client/OMA_PCPS_1.0 %s", dummy_hdr->value); tsk_object_delete(dummy_hdr->value); }*/ } if((hdr_value)!=tsk_null && tsk_strcmp(hdr_value,VALUE_P_ASSERTED_SERVICE_MESSAGE_AFFILIATION)==0 ){ tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_affiliation); } TSK_FREE(hdr_value); }else if(tsk_striequals(VALUE_CONTENT_TYPE_MULTIPART, TSIP_MESSAGE_CONTENT_TYPE(sipmessage))){ //multipart/mixed boundary = tsip_header_get_param_value((tsip_header_t*)sipmessage->Content_Type, "boundary"); if(boundary != tsk_null) { mp_body = tmedia_content_multipart_body_parse(TSIP_MESSAGE_CONTENT_DATA(sipmessage), TSIP_MESSAGE_CONTENT_DATA_LENGTH(sipmessage), VALUE_CONTENT_TYPE_MULTIPART, boundary); if(mp_body != tsk_null) { mp_content = tmedia_content_multipart_body_get_content(mp_body,VALUE_CONTENT_TYPE_MESSAGE_LOCATION); if(mp_content != tsk_null)//Location { //change de content for format location TSK_FREE(sipmessage->Content->data); if ((sipmessage->Content->data = (char*)tsk_calloc((mp_content->data_size) + 1, sizeof(uint8_t)))) { memcpy(sipmessage->Content->data, mp_content->data, mp_content->data_size); ((char *)sipmessage->Content->data)[mp_content->data_size]='\0'; } sipmessage->Content->size=mp_content->data_size; tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_location); }else if(1){ mp_content = tmedia_content_multipart_body_get_content(mp_body,VALUE_CONTENT_TYPE_MESSAGE_AFFILIATION); if(mp_content != tsk_null )//Affiliation { for(con=0; (header = tsip_message_get_headerAt(sipmessage, tsip_htype_Dummy, con)); con++) { const tsip_header_Dummy_t* dummy_hdr = (const tsip_header_Dummy_t*)header; if(tsk_strcmp(dummy_hdr->name, "P-Asserted-Service") == 0) { #if HAVE_CRT //Debug memory hdr_value = (char *)malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #else hdr_value = (char *)tsk_malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #endif //HAVE_CRT hdr_value=strdup(dummy_hdr->value); break; } } if((hdr_value)!=tsk_null && tsk_strcmp(hdr_value,VALUE_P_ASSERTED_SERVICE_MESSAGE_AFFILIATION)==0 ){ //change de content for format affiliation //tsk_realloc(sipmessage->Content->data,mp_content->data_size); TSK_FREE(sipmessage->Content->data) sipmessage->Content->data=tsk_strndup(mp_content->data,mp_content->data_size); sipmessage->Content->size=mp_content->data_size; tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_affiliation); } } else{ tmedia_multipart_body_t* body = tsk_null; char* content_type_hdr = tsk_null; char* body_string = tsk_null; //mp_content is xml of MBMS mp_content = tmedia_content_multipart_body_get_content(mp_body,VALUE_CONTENT_TYPE_MESSAGE_MBMS); //mp_content_sdp is the data in char* of SDP mp_content_sdp = tmedia_content_multipart_body_get_content(mp_body, "application/sdp"); if(mp_content != tsk_null && mp_content_sdp!=tsk_null)//MBMS service { for(con=0; (header = tsip_message_get_headerAt(sipmessage, tsip_htype_Dummy, con)); con++) { const tsip_header_Dummy_t* dummy_hdr = (const tsip_header_Dummy_t*)header; if(tsk_strcmp(dummy_hdr->name, "P-Asserted-Service") == 0) { #if HAVE_CRT //Debug memory hdr_value = (char *)malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #else hdr_value = (char *)tsk_malloc(tsk_strlen(dummy_hdr->value) * sizeof(char)); #endif //HAVE_CRT hdr_value=strdup(dummy_hdr->value); break; } } //SDP of MBMS message if(mp_content_sdp == tsk_null){ TSK_DEBUG_ERROR("content-type is not supportted"); return -3; } if((hdr_value)!=tsk_null && tsk_strcmp(hdr_value,VALUE_P_ASSERTED_SERVICE_MESSAGE_MBMS)==0 ){ body = tmedia_content_multipart_body_create("multipart/mixed", tsk_null); if(body) { tmedia_content_multipart_body_add_content(body, mp_content_sdp); tmedia_content_multipart_body_add_content(body, mp_content); body_string =tmedia_content_multipart_body_tostring(body); content_type_hdr = tmedia_content_multipart_body_get_header(body); sipmessage2=tsip_message_create(); tsip_message_add_content(sipmessage2, content_type_hdr, body_string, tsk_strlen(body_string)); } /* //change de content for format MBMS tsk_realloc(sipmessage->Content->data,mp_content->data_size); strcpy(sipmessage->Content->data, mp_content->data); sipmessage->Content->size=mp_content->data_size; */ tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message_mbms); } }else{ TSK_DEBUG_ERROR("The new message isn't valid."); tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message); } } } } }else{ tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message); } }else tsip_event_init(TSIP_EVENT(sipevent), ss, status_code, phrase, sipmessage, tsip_event_message); if(hdr_value) TSK_FREE(hdr_value); TSK_RUNNABLE_ENQUEUE_OBJECT(TSK_RUNNABLE(TSIP_SSESSION(ss)->stack), sipevent); return 0; } int tsip_api_message_send_message(const tsip_ssession_handle_t *ss, ...) { const tsip_ssession_t* _ss; va_list ap; tsip_action_t* action; tsip_dialog_t* dialog; int ret = -1; if(!(_ss = ss) || !_ss->stack){ TSK_DEBUG_ERROR("Invalid parameter."); return ret; } /* Checks if the stack has been started */ if(!TSK_RUNNABLE(_ss->stack)->started){ TSK_DEBUG_ERROR("Stack not started."); return -2; } /* action */ va_start(ap, ss); if((action = _tsip_action_create(tsip_atype_message_send, &ap))){ if(!(dialog = tsip_dialog_layer_find_by_ss(_ss->stack->layer_dialog, ss))){ dialog = tsip_dialog_layer_new(_ss->stack->layer_dialog, tsip_dialog_MESSAGE, ss); } ret = tsip_dialog_fsm_act(dialog, action->type, tsk_null, action); tsk_object_unref(dialog); TSK_OBJECT_SAFE_FREE(action); } va_end(ap); return ret; } //Location int tsip_api_message_send_message_location(const tsip_ssession_handle_t *ss, ...) { const tsip_ssession_t* _ss; va_list ap; tsip_action_t* action; tsip_dialog_t* dialog; int ret = -1; if(!(_ss = ss) || !_ss->stack){ TSK_DEBUG_ERROR("Invalid parameter."); return ret; } /* Checks if the stack has been started */ if(!TSK_RUNNABLE(_ss->stack)->started){ TSK_DEBUG_ERROR("Stack not started."); return -2; } //This session is type MCPTT location ((tsip_ssession_t*)ss)->media.type=tmedia_mcptt_location; /* action */ va_start(ap, ss); if((action = _tsip_action_create(tsip_atype_message_send, &ap))){ if(!(dialog = tsip_dialog_layer_find_by_ss(_ss->stack->layer_dialog, ss))){ dialog = tsip_dialog_layer_new(_ss->stack->layer_dialog, tsip_dialog_MESSAGE, ss); } ret = tsip_dialog_fsm_act(dialog, action->type, tsk_null, action); tsk_object_unref(dialog); TSK_OBJECT_SAFE_FREE(action); } va_end(ap); return ret; } //MBMS int tsip_api_message_send_message_mbms(const tsip_ssession_handle_t *ss, ...) { const tsip_ssession_t* _ss; va_list ap; tsip_action_t* action; tsip_dialog_t* dialog; int ret = -1; if(!(_ss = ss) || !_ss->stack){ TSK_DEBUG_ERROR("Invalid parameter."); return ret; } /* Checks if the stack has been started */ if(!TSK_RUNNABLE(_ss->stack)->started){ TSK_DEBUG_ERROR("Stack not started."); return -2; } //This session is type MCPTT MBMS ((tsip_ssession_t*)ss)->media.type=tmedia_mcptt_mbms; /* action */ va_start(ap, ss); if((action = _tsip_action_create(tsip_atype_message_send, &ap))){ if(!(dialog = tsip_dialog_layer_find_by_ss(_ss->stack->layer_dialog, ss))){ dialog = tsip_dialog_layer_new(_ss->stack->layer_dialog, tsip_dialog_MESSAGE, ss); } ret = tsip_dialog_fsm_act(dialog, action->type, tsk_null, action); tsk_object_unref(dialog); TSK_OBJECT_SAFE_FREE(action); } va_end(ap); return ret; } //======================================================== // SIP MESSAGE event object definition // static tsk_object_t* tsip_message_event_ctor(tsk_object_t * self, va_list * app) { tsip_message_event_t *sipevent = self; if(sipevent){ sipevent->type = va_arg(*app, tsip_message_event_type_t); } return self; } static tsk_object_t* tsip_message_event_dtor(tsk_object_t * self) { tsip_message_event_t *sipevent = self; if(sipevent){ tsip_event_deinit(TSIP_EVENT(sipevent)); } return self; } static int tsip_message_event_cmp(const tsk_object_t *obj1, const tsk_object_t *obj2) { return -1; } static const tsk_object_def_t tsip_message_event_def_s = { sizeof(tsip_message_event_t), tsip_message_event_ctor, tsip_message_event_dtor, tsip_message_event_cmp, }; const tsk_object_def_t *tsip_message_event_def_t = &tsip_message_event_def_s;