FS-9668 #resolve [Add proxy-info feature]

diff --git a/src/mod/endpoints/mod_sofia/mod_sofia.h b/src/mod/endpoints/mod_sofia/mod_sofia.h
index d8b475e23649623d71669d1e3fd9e1785c2f7f88..badf7c4fa0168ff56edba2efff5c63223a217293 100644 (file)
--- a/src/mod/endpoints/mod_sofia/mod_sofia.h
+++ b/src/mod/endpoints/mod_sofia/mod_sofia.h
@@ -295,6 +295,7 @@ typedef enum {
        PFLAG_FIRE_TRANFER_EVENTS,
        PFLAG_BLIND_AUTH_ENFORCE_RESULT,
        PFLAG_PROXY_HOLD,
+       PFLAG_PROXY_INFO,
 
        /* No new flags below this line */
        PFLAG_MAX
@@ -935,6 +936,8 @@ uint8_t sofia_media_negotiate_sdp(switch_core_session_t *session, const char *r_
 void sofia_handle_sip_i_refer(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip,
                                                                sofia_dispatch_event_t *de, tagi_t tags[]);
 
+switch_status_t sofia_proxy_sip_i_info(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip,
+                                                               sofia_dispatch_event_t *de, tagi_t tags[]);
 void sofia_handle_sip_i_info(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip,
                                                                sofia_dispatch_event_t *de, tagi_t tags[]);
 

diff --git a/src/mod/endpoints/mod_sofia/sofia.c b/src/mod/endpoints/mod_sofia/sofia.c
index e8dd3af76e9444414e130a4df377078ed495f05f..4120447ddca73965997430208d399859e025acc7 100644 (file)
--- a/src/mod/endpoints/mod_sofia/sofia.c
+++ b/src/mod/endpoints/mod_sofia/sofia.c
@@ -1713,7 +1713,26 @@ static void our_sofia_event_callback(nua_event_t event,
                sofia_presence_handle_sip_i_message(status, phrase, nua, profile, nh, session, sofia_private, sip, de, tags);
                break;
        case nua_i_info:
-               sofia_handle_sip_i_info(nua, profile, nh, session, sip, de, tags);
+               {
+                       int handle_info = 1;
+                       int proxy_info = sofia_test_pflag(profile, PFLAG_PROXY_INFO);
+
+                       if (!proxy_info && session) {
+                               switch_channel_t *channel = switch_core_session_get_channel(session);
+                               proxy_info = switch_channel_var_true(channel, "sip_proxy_info");
+                       }
+
+                       if (proxy_info) {
+                               if (sofia_proxy_sip_i_info(nua, profile, nh, session, sip, de, tags) == SWITCH_STATUS_SUCCESS) {
+                                       handle_info = 0;
+                               }
+                       }
+
+                       if (handle_info) {
+                               sofia_handle_sip_i_info(nua, profile, nh, session, sip, de, tags);
+                       }
+
+               }
                break;
        case nua_i_update:
                if (session) {
@@ -5645,6 +5664,12 @@ switch_status_t config_sofia(sofia_config_t reload, char *profile_name)
                                                }  else {
                                                        sofia_clear_pflag(profile, PFLAG_PROXY_HOLD);
                                                }
+                                       } else if (!strcasecmp(var, "proxy-info")) {
+                                               if(switch_true(val)) {
+                                                       sofia_set_pflag(profile, PFLAG_PROXY_INFO);
+                                               }  else {
+                                                       sofia_clear_pflag(profile, PFLAG_PROXY_INFO);
+                                               }
                                        } else if (!strcasecmp(var, "proxy-notify-events")) {
                                                profile->proxy_notify_events = switch_core_strdup(profile->pool, val);
                                        } else if (!strcasecmp(var, "proxy-info-content-types")) {
@@ -9092,6 +9117,46 @@ static switch_status_t create_info_event(sip_t const *sip,
        return SWITCH_STATUS_SUCCESS;
 }
 
+switch_status_t sofia_proxy_sip_i_info(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip,
+                                                               sofia_dispatch_event_t *de, tagi_t tags[])
+{
+       switch_core_session_t *other_session = NULL;
+
+       if (session && switch_core_session_get_partner(session, &other_session) == SWITCH_STATUS_SUCCESS) {
+               if (switch_core_session_compare(session, other_session)) {
+                       private_object_t *other_tech_pvt = NULL;
+                       const char *ct = NULL;
+                       char *pl = NULL;
+
+
+                       if (sip && sip->sip_payload && sip->sip_payload->pl_data) {
+                               pl = sip->sip_payload->pl_data;
+                       }
+
+                       other_tech_pvt = (private_object_t *) switch_core_session_get_private(other_session);
+                       
+                       if (sip->sip_content_type->c_type && sip->sip_content_type->c_subtype) {
+                               ct = sip->sip_content_type->c_type;
+                       }
+                       
+                       nua_info(other_tech_pvt->nh,
+                                        TAG_IF(ct, SIPTAG_CONTENT_TYPE_STR(su_strdup(other_tech_pvt->nh->nh_home, ct))),
+                                        TAG_IF(!zstr(other_tech_pvt->user_via), SIPTAG_VIA_STR(other_tech_pvt->user_via)),
+                                        TAG_IF(pl, SIPTAG_PAYLOAD_STR(su_strdup(other_tech_pvt->nh->nh_home, pl))),
+                                        TAG_END());
+               }
+
+               switch_core_session_rwunlock(other_session);
+
+               nua_respond(nh, SIP_200_OK, NUTAG_WITH_THIS_MSG(de->data->e_msg), TAG_END());
+
+               return SWITCH_STATUS_SUCCESS;
+       }
+
+       return SWITCH_STATUS_FALSE;
+}
+
+
 void sofia_handle_sip_i_info(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip,
                                                                sofia_dispatch_event_t *de, tagi_t tags[])
 {