kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-07-01 21:33:00 +00:00
Code Issues Projects Releases Wiki Activity

[mod_sofia] Send chat message in SIP dialog

Browse Source 
When a SIP MESSAGE is received with to and from tag values we try
to send the message in the existing dialog.
This commit is contained in:
Henrique 2022-12-05 07:35:16 -03:00
parent 13646cc888
commit e0483d9ab8
1 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/mod/endpoints/mod_sofia/sofia_presence.c
View File

@ -134,6 +134,11 @@ switch_status_t sofia_presence_chat_send(switch_event_t *message_event)
int mstatus = 0, sanity = 0; int mstatus = 0, sanity = 0;
const char *blocking; const char *blocking;
int is_blocking = 0; int is_blocking = 0;
switch_core_session_t *session = NULL;
switch_core_session_t *other_session = NULL;
const char *session_uuid;
const char *to_tag = NULL;
const char *from_tag = NULL;
proto = switch_event_get_header(message_event, "proto"); proto = switch_event_get_header(message_event, "proto");
from_proto = switch_event_get_header(message_event, "from_proto"); from_proto = switch_event_get_header(message_event, "from_proto");
@ -149,6 +154,10 @@ switch_status_t sofia_presence_chat_send(switch_event_t *message_event)
network_ip = switch_event_get_header(message_event, "to_sip_ip"); network_ip = switch_event_get_header(message_event, "to_sip_ip");
network_port = switch_event_get_header(message_event, "to_sip_port"); network_port = switch_event_get_header(message_event, "to_sip_port");
from_tag = switch_event_get_header(message_event, "to_tag");
to_tag = switch_event_get_header(message_event, "from_tag");
session_uuid = switch_event_get_header(message_event, "Unique-ID");
extra_headers = sofia_glue_get_extra_headers_from_event(message_event, SOFIA_SIP_HEADER_PREFIX); extra_headers = sofia_glue_get_extra_headers_from_event(message_event, SOFIA_SIP_HEADER_PREFIX);
if (!to) { if (!to) {
@ -203,6 +212,27 @@ switch_status_t sofia_presence_chat_send(switch_event_t *message_event)
goto end; goto end;
} }
if(to_tag && from_tag && (session = switch_core_session_locate(session_uuid))) {
if (switch_core_session_get_partner(session, &other_session) == SWITCH_STATUS_SUCCESS) {
if (switch_core_session_compare(session, other_session)) {
const char *session_id_header = sofia_glue_session_id_header(session, profile);
private_object_t *other_session_tech_pvt = (private_object_t *) switch_core_session_get_private(other_session);
nua_message(other_session_tech_pvt->nh,
SIPTAG_CONTENT_TYPE_STR(ct),
TAG_IF(!zstr(other_session_tech_pvt->user_via), SIPTAG_VIA_STR(other_session_tech_pvt->user_via)),
SIPTAG_PAYLOAD_STR(body),
TAG_IF(!zstr(session_id_header), SIPTAG_HEADER_STR(session_id_header)),
TAG_IF(!zstr(extra_headers), SIPTAG_HEADER_STR(extra_headers)),
TAG_END());
status = SWITCH_STATUS_SUCCESS;
goto end;
}
}
}
if (zstr(host)) { if (zstr(host)) {
host = profile->domain_name; host = profile->domain_name;
if (zstr(host)) { if (zstr(host)) {
@ -404,6 +434,14 @@ switch_status_t sofia_presence_chat_send(switch_event_t *message_event)
switch_thread_rwlock_unlock(profile->rwlock); switch_thread_rwlock_unlock(profile->rwlock);
} }
if (session) {
switch_core_session_rwunlock(session);
}
if (other_session) {
switch_core_session_rwunlock(other_session);
}
return status; return status;
} }
@ -4906,6 +4944,14 @@ void sofia_presence_handle_sip_i_message(int status,
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "subject", "SIMPLE MESSAGE"); switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "subject", "SIMPLE MESSAGE");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "context", profile->context); switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "context", profile->context);
if (sip->sip_to) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to_tag", sip->sip_to->a_tag);
}
if (sip->sip_from) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from_tag", sip->sip_from->a_tag);
}
if (sip->sip_content_type && sip->sip_content_type->c_subtype) { if (sip->sip_content_type && sip->sip_content_type->c_subtype) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "type", sip->sip_content_type->c_type); switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "type", sip->sip_content_type->c_type);
} else { } else {