res_pjsip_messaging.c File Reference

#include "asterisk.h"
#include <pjsip.h>
#include <pjsip_ua.h>
#include "asterisk/message.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/res_pjsip.h"
#include "asterisk/res_pjsip_session.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/test.h"
#include "asterisk/uri.h"

Include dependency graph for res_pjsip_messaging.c:

Go to the source code of this file.

Data Structures
struct	msg_data

Macros
#define	DEBUG_BUF_SIZE   256
#define	MAX_BODY_SIZE   1024
#define	MAX_HDR_SIZE   512
#define	MAX_USER_SIZE   128

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static enum pjsip_status_code	check_content_type (const pjsip_rx_data *rdata)
static enum pjsip_status_code	check_content_type_in_dialog (const pjsip_rx_data *rdata)
static struct ast_sip_endpoint *	get_outbound_endpoint (const char *to, char **uri)
static struct ast_sip_endpoint *	handle_atsign (const char *to, char *destination, char **uri, char *slash, char *atsign, char *scheme)
static struct ast_sip_endpoint *	handle_single_token (const char *to, char *destination, char **uri)
static struct ast_sip_endpoint *	handle_slash (const char *to, char *destination, char **uri, char *slash, char *atsign, char *scheme)
static int	headers_to_vars (const pjsip_rx_data *rdata, struct ast_msg *msg)
static int	incoming_in_dialog_request (struct ast_sip_session *session, struct pjsip_rx_data *rdata)
static int	insert_user_in_contact_uri (const char *to, const char *endpoint_name, const char *aors, const char *user, char **uri)
	Find a contact and insert a "user@" into its URI. More...
static int	is_msg_var_blocked (const char *name)
static int	load_module (void)
static pj_bool_t	module_on_rx_request (pjsip_rx_data *rdata)
static struct msg_data *	msg_data_create (const struct ast_msg *msg, const char *destination, const char *from)
static void	msg_data_destroy (void *obj)
static int	msg_send (void *data)
static int	print_body (pjsip_rx_data *rdata, char *buf, int len)
static enum pjsip_status_code	rx_data_to_ast_msg (pjsip_rx_data *rdata, struct ast_msg *msg)
static pj_status_t	send_response (pjsip_rx_data *rdata, enum pjsip_status_code code, pjsip_dialog *dlg, pjsip_transaction *tsx)
static int	sip_msg_send (const struct ast_msg *msg, const char *destination, const char *from)
static char *	sip_to_pjsip (char *buf, int size, int capacity)
static int	unload_module (void)
static void	update_content_type (pjsip_tx_data *tdata, struct ast_msg *msg, struct ast_sip_body *body)
static int	update_from (pjsip_tx_data *tdata, char *from)
static int	update_to_display_name (pjsip_tx_data *tdata, char *to)
static int	update_to_uri (pjsip_tx_data *tdata, char *to)
static enum pjsip_status_code	vars_to_headers (const struct ast_msg *msg, pjsip_tx_data *tdata)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PJSIP Messaging Support" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_APP_DEPEND, .requires = "res_pjsip,res_pjsip_session", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct ast_taskprocessor *	message_serializer
static pjsip_module	messaging_module
static struct ast_sip_session_supplement	messaging_supplement
static const struct ast_msg_tech	msg_tech
const pjsip_method	pjsip_message_method = {PJSIP_OTHER_METHOD, {"MESSAGE", 7} }

Macro Definition Documentation

DEBUG_BUF_SIZE

#define DEBUG_BUF_SIZE   256

Referenced by update_to_uri().

MAX_BODY_SIZE

#define MAX_BODY_SIZE   1024

Definition at line 137 of file res_pjsip_messaging.c.

Referenced by rx_data_to_ast_msg().

MAX_HDR_SIZE

#define MAX_HDR_SIZE   512

Definition at line 136 of file res_pjsip_messaging.c.

Referenced by headers_to_vars().

MAX_USER_SIZE

#define MAX_USER_SIZE   128

Definition at line 138 of file res_pjsip_messaging.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 1611 of file res_pjsip_messaging.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 1611 of file res_pjsip_messaging.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 1611 of file res_pjsip_messaging.c.

check_content_type()

static enum pjsip_status_code check_content_type ( const pjsip_rx_data *  rdata )

static

Definition at line 151 of file res_pjsip_messaging.c.

References ast_sip_is_content_type().

Referenced by module_on_rx_request().

{
   int res;
   if (rdata->msg_info.msg->body && rdata->msg_info.msg->body->len) {
      res = ast_sip_is_content_type(
         &rdata->msg_info.msg->body->content_type, "text", "plain");
   } else {
      res = rdata->msg_info.ctype &&
         ast_sip_is_content_type(
            &rdata->msg_info.ctype->media, "text", "plain");
   }

   return res ? PJSIP_SC_OK : PJSIP_SC_UNSUPPORTED_MEDIA_TYPE;
}

check_content_type_in_dialog()

static enum pjsip_status_code check_content_type_in_dialog ( const pjsip_rx_data *  rdata )

static

Definition at line 175 of file res_pjsip_messaging.c.

References text.

Referenced by incoming_in_dialog_request().

{
   int res = PJSIP_SC_UNSUPPORTED_MEDIA_TYPE;
   static const pj_str_t text = { "text", 4};
   static const pj_str_t application = { "application", 11};

   if (!(rdata->msg_info.msg->body && rdata->msg_info.msg->body->len > 0)) {
      return res;
   }

   /* We'll accept any text/ or application/ content type */
   if (pj_stricmp(&rdata->msg_info.msg->body->content_type.type, &text) == 0
         || pj_stricmp(&rdata->msg_info.msg->body->content_type.type, &application) == 0) {
      res = PJSIP_SC_OK;
   } else if (rdata->msg_info.ctype
      && (pj_stricmp(&rdata->msg_info.ctype->media.type, &text) == 0
      || pj_stricmp(&rdata->msg_info.ctype->media.type, &application) == 0)) {
      res = PJSIP_SC_OK;
   }

   return res;
}

get_outbound_endpoint()

static struct ast_sip_endpoint* get_outbound_endpoint ( const char *  to, char **  uri  )

static

Definition at line 617 of file res_pjsip_messaging.c.

References ast_debug, ast_malloc, ast_sip_default_outbound_endpoint(), ast_strdup, ast_strdupa, handle_atsign(), handle_single_token(), handle_slash(), NULL, and S_OR.

Referenced by msg_send().

{
   char *destination;
   char *slash = NULL;
   char *atsign = NULL;
   char *scheme = NULL;
   struct ast_sip_endpoint *endpoint = NULL;

   destination = ast_strdupa(to);
   slash = strchr(destination, '/');
   atsign = strchr(destination, '@');
   scheme = S_OR(strstr(destination, "sip:"), strstr(destination, "sips:"));

   if (!slash && !atsign && !scheme) {
      /*
       * If there's only a single token, it can be either...
       *    endpoint
       *    host
       */
      return handle_single_token(to, destination, uri);
   }

   if (slash) {
      /*
       * If there's a '/', then the form must be one of the following...
       *    PJSIP/user@endpoint
       *    endpoint/aor
       *    endpoint/uri
       */
      return handle_slash(to, destination, uri, slash, atsign, scheme);
   }

   if (!endpoint && atsign && !scheme) {
      /*
       * If there's an '@' but no scheme then it's either following an endpoint name
       * and being followed by a domain name (which we discard).
       * OR is's a user@host uri without a scheme.  It's probably the latter but because
       * endpoint@domain looks just like user@host, we'll test for endpoint first.
       */
      return handle_atsign(to, destination, uri, slash, atsign, scheme);
   }

   /*
    * If all else fails, we assume it's a URI or just a hostname.
    */
   if (scheme) {
      *uri = ast_strdup(destination);
      ast_debug(3, "Dest: '%s' Didn't find an endpoint but did find a scheme so using URI '%s' with default endpoint\n",
         to, *uri);
   } else {
      *uri = ast_malloc(strlen(destination) + strlen("sip:") + 1);
      sprintf(*uri, "sip:%s", destination);
      ast_debug(3, "Dest: '%s' Didn't find an endpoint and didn't find scheme so adding scheme and using URI '%s' with default endpoint\n",
         to, *uri);
   }
   endpoint = ast_sip_default_outbound_endpoint();

   return endpoint;
}

handle_atsign()

static struct ast_sip_endpoint* handle_atsign ( const char *  to, char *  destination, char **  uri, char *  slash, char *  atsign, char *  scheme  )

static

Definition at line 505 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_sip_endpoint::aors, ast_debug, ast_log, ast_malloc, ast_sip_default_outbound_endpoint(), ast_sip_get_sorcery(), ast_sip_location_retrieve_contact_from_aor_list(), AST_SIP_USER_OPTIONS_TRUNCATE_CHECK, ast_sorcery_retrieve_by_id(), ast_strdup, ast_sip_contact::endpoint, LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by get_outbound_endpoint().

{
   char *endpoint_name = NULL;
   struct ast_sip_endpoint *endpoint = NULL;
   struct ast_sip_contact *contact = NULL;
   char *afterat = atsign + 1;

   *atsign = '\0';
   endpoint_name = destination;

   /* Apprently there may be ';<user_options>' after the endpoint name ??? */
   AST_SIP_USER_OPTIONS_TRUNCATE_CHECK(endpoint_name);
   endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", endpoint_name);
   if (!endpoint) {
      /*
       * It's probably a uri with a user but without a scheme but we don't have a way to tell.
       * We're going to assume it is and prepend it with a scheme.
       */
      *uri = ast_malloc(strlen(to) + strlen("sip:") + 1);
      sprintf(*uri, "sip:%s", to);
      endpoint = ast_sip_default_outbound_endpoint();
      ast_debug(3, "Dest: '%s' Didn't find endpoint before the '@' so using URI '%s' with default endpoint\n",
         to, *uri);
      return endpoint;
   }

   /*
    * OK, it's an endpoint and a domain (which we ignore)
    */
   contact = ast_sip_location_retrieve_contact_from_aor_list(endpoint->aors);
   if (!contact) {
      /*
       * We're getting the contact using the same method as
       * ast_sip_create_request() so if there's no contact
       * we can never send this message.
       */
      ao2_cleanup(endpoint);
      endpoint = NULL;
      *uri = NULL;
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: Found endpoint '%s' but didn't find contact\n",
         to, endpoint_name);
      return NULL;
   }

   *uri = ast_strdup(contact->uri);
   ao2_cleanup(contact);
   ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s' (discarding domain %s)\n",
      to, endpoint_name, *uri, afterat);

   return endpoint;
}

handle_single_token()

static struct ast_sip_endpoint* handle_single_token ( const char *  to, char *  destination, char **  uri  )

static

Definition at line 288 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_sip_endpoint::aors, ast_debug, ast_log, ast_malloc, ast_sip_default_outbound_endpoint(), ast_sip_get_sorcery(), ast_sip_location_retrieve_contact_from_aor_list(), ast_sorcery_retrieve_by_id(), ast_strdup, ast_sip_contact::endpoint, LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by get_outbound_endpoint().

                                                                                                   {
   char *endpoint_name = NULL;
   struct ast_sip_endpoint *endpoint = NULL;
   struct ast_sip_contact *contact = NULL;

   /*
    * If "to" is just one token, it could be an endpoint name
    * or a hostname without a scheme.
    */

   endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", destination);
   if (!endpoint) {
      /*
       * We can only assume it's a hostname.
       */
      char *temp_uri = ast_malloc(strlen(destination) + strlen("sip:") + 1);
      sprintf(temp_uri, "sip:%s", destination);
      *uri = temp_uri;
      endpoint = ast_sip_default_outbound_endpoint();
      ast_debug(3, "Dest: '%s' Didn't find endpoint so adding scheme and using URI '%s' with default endpoint\n",
         to, *uri);
      return endpoint;
   }

   /*
    * It's an endpoint
    */

   endpoint_name = destination;
   contact = ast_sip_location_retrieve_contact_from_aor_list(endpoint->aors);
   if (!contact) {
      /*
       * We're getting the contact using the same method as
       * ast_sip_create_request() so if there's no contact
       * we can never send this message.
       */
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: Found endpoint '%s' but didn't find an aor/contact for it\n",
         to, endpoint_name);
      ao2_cleanup(endpoint);
      *uri = NULL;
      return NULL;
   }

   *uri = ast_strdup(contact->uri);
   ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s'\n",
      to, endpoint_name, *uri);
   ao2_cleanup(contact);
   return endpoint;

}

handle_slash()

static struct ast_sip_endpoint* handle_slash ( const char *  to, char *  destination, char **  uri, char *  slash, char *  atsign, char *  scheme  )

static

Definition at line 358 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_sip_endpoint::aors, ast_begins_with(), ast_debug, ast_log, ast_malloc, ast_sip_get_sorcery(), ast_sip_location_retrieve_aor(), ast_sip_location_retrieve_first_aor_contact(), ast_sorcery_object_get_id(), ast_sorcery_retrieve_by_id(), ast_strdup, insert_user_in_contact_uri(), LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by get_outbound_endpoint().

{
   char *endpoint_name = NULL;
   struct ast_sip_endpoint *endpoint = NULL;
   struct ast_sip_contact *contact = NULL;
   char *user = NULL;
   char *afterslash = slash + 1;
   struct ast_sip_aor *aor;

   if (ast_begins_with(destination, "PJSIP/")) {
      ast_debug(3, "Dest: '%s' Dialplan format'\n", to);
      /*
       * This has to be the form PJSIP/user@endpoint
       */
      if (!atsign || strchr(afterslash, '/')) {
         /*
          * If there's no "user@" or there's a slash somewhere after
          * "PJSIP/" then we go no further.
          */
         *uri = NULL;
         ast_log(LOG_WARNING,
            "Dest: '%s' MSG SEND FAIL: Destinations beginning with 'PJSIP/' must be in the form of 'PJSIP/user@endpoint'\n",
            to);
         return NULL;
      }
      *atsign = '\0';
      user = afterslash;
      endpoint_name = atsign + 1;
      ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'\n", to, user, endpoint_name);
   } else {
      /*
       * Either...
       * endpoint/aor
       * endpoint/uri
       */
      *slash = '\0';
      endpoint_name = destination;
      ast_debug(3, "Dest: '%s' Endpoint: '%s'\n", to, endpoint_name);
   }

   endpoint = ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "endpoint", endpoint_name);
   if (!endpoint) {
      *uri = NULL;
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: Didn't find endpoint with name '%s'\n",
         to, endpoint_name);
      return NULL;
   }

   if (scheme) {
      /*
       * If we found a scheme, then everything after the slash MUST be a URI.
       * We don't need to do any further modification.
       */
      *uri = ast_strdup(afterslash);
      ast_debug(3, "Dest: '%s' Found endpoint '%s' and found URI '%s' after '/'\n",
         to, endpoint_name, *uri);
      return endpoint;
   }

   if (user) {
      /*
       * This has to be the form PJSIP/user@endpoint
       */
      int rc;

      /*
       * Set the return URI to be the endpoint's contact URI with the user
       * portion set to the user that was specified before the endpoint name.
       */
      rc = insert_user_in_contact_uri(to, endpoint_name, endpoint->aors, user, uri);
      if (rc != 0) {
         /*
          * insert_user_in_contact_uri prints the warning message.
          */
         ao2_cleanup(endpoint);
         endpoint = NULL;
         *uri = NULL;
      }
      ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'  URI: '%s'\n", to, user,
         endpoint_name, *uri);

      return endpoint;
   }

   /*
    * We're now left with two possibilities...
    *    endpoint/aor
    * endpoint/uri-without-scheme
    */
   aor = ast_sip_location_retrieve_aor(afterslash);
   if (!aor) {
      /*
       * It's probably a URI without a scheme but we don't have a way to tell
       * for sure.  We're going to assume it is and prepend it with a scheme.
       */
      *uri = ast_malloc(strlen(afterslash) + strlen("sip:") + 1);
      sprintf(*uri, "sip:%s", afterslash);
      ast_debug(3, "Dest: '%s' Found endpoint '%s' but didn't find aor after '/' so using URI '%s'\n",
         to, endpoint_name, *uri);
      return endpoint;
   }

   /*
    * Only one possibility left... There was an aor name after the slash.
    */
   ast_debug(3, "Dest: '%s' Found endpoint '%s' and found aor '%s' after '/'\n",
      to, endpoint_name, ast_sorcery_object_get_id(aor));

   contact = ast_sip_location_retrieve_first_aor_contact(aor);
   if (!contact) {
      /*
       * An aor without a contact is useless and since
       * ast_sip_create_message() won't be able to find one
       * either, we just need to bail.
       */
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: Found endpoint '%s' but didn't find contact for aor '%s'\n",
         to, endpoint_name, ast_sorcery_object_get_id(aor));
      ao2_cleanup(aor);
      ao2_cleanup(endpoint);
      *uri = NULL;
      return NULL;
   }

   *uri = ast_strdup(contact->uri);
   ast_debug(3, "Dest: '%s' Found endpoint '%s' and found contact with URI '%s' for aor '%s'\n",
      to, endpoint_name, *uri, ast_sorcery_object_get_id(aor));
   ao2_cleanup(contact);
   ao2_cleanup(aor);

   return endpoint;
}

headers_to_vars()

static int headers_to_vars ( const pjsip_rx_data *  rdata, struct ast_msg *  msg  )

static

Definition at line 927 of file res_pjsip_messaging.c.

References ast_copy_pj_str(), ast_copy_string(), ast_msg_set_var(), ast_skip_blanks(), buf, c, end, MAX_HDR_SIZE, and name.

Referenced by rx_data_to_ast_msg().

{
   char *c;
   char name[MAX_HDR_SIZE];
   char buf[MAX_HDR_SIZE];
   int res = 0;
   pjsip_hdr *h = rdata->msg_info.msg->hdr.next;
   pjsip_hdr *end= &rdata->msg_info.msg->hdr;

   while (h != end) {
      if ((res = pjsip_hdr_print_on(h, buf, sizeof(buf)-1)) > 0) {
         buf[res] = '\0';
         if ((c = strchr(buf, ':'))) {
            ast_copy_string(buf, ast_skip_blanks(c + 1), sizeof(buf));
         }

         ast_copy_pj_str(name, &h->name, sizeof(name));
         if ((res = ast_msg_set_var(msg, name, buf)) != 0) {
            break;
         }
      }
      h = h->next;
   }
   return 0;
}

incoming_in_dialog_request()

static int incoming_in_dialog_request ( struct ast_sip_session *  session, struct pjsip_rx_data *  rdata  )

static

Definition at line 1457 of file res_pjsip_messaging.c.

References ast_alloca, ast_channel_caller(), ast_channel_name(), ast_copy_pj_str(), ast_copy_string(), ast_debug, ast_free, ast_malloc, ast_msg_data_alloc(), AST_MSG_DATA_ATTR_BODY, AST_MSG_DATA_ATTR_CONTENT_TYPE, AST_MSG_DATA_ATTR_FROM, AST_MSG_DATA_ATTR_TO, ast_msg_data_get_attribute(), ast_msg_data_queue_frame(), AST_MSG_DATA_SOURCE_TYPE_IN_DIALOG, ast_strlen_zero, ast_sip_session::channel, check_content_type_in_dialog(), ast_party_caller::id, ast_sip_session::inv_session, msg_data::msg, ast_party_id::name, send_response(), ast_party_name::str, ast_msg_data_attribute::type, ast_party_name::valid, msg_data::value, and ast_msg_data_attribute::value.

{
   enum pjsip_status_code code;
   int rc;
   pjsip_dialog *dlg = session->inv_session->dlg;
   pjsip_transaction *tsx = pjsip_rdata_get_tsx(rdata);
   struct ast_msg_data *msg;
   struct ast_party_caller *caller;
   pjsip_name_addr *name_addr;
   size_t from_len;
   size_t to_len;
   struct ast_msg_data_attribute attrs[4];
   int pos = 0;
   int body_pos;

   if (!session->channel) {
      send_response(rdata, PJSIP_SC_NOT_FOUND, dlg, tsx);
      return 0;
   }

   code = check_content_type_in_dialog(rdata);
   if (code != PJSIP_SC_OK) {
      send_response(rdata, code, dlg, tsx);
      return 0;
   }

   caller = ast_channel_caller(session->channel);

   name_addr = (pjsip_name_addr *) rdata->msg_info.from->uri;
   from_len = pj_strlen(&name_addr->display);
   if (from_len) {
      attrs[pos].type = AST_MSG_DATA_ATTR_FROM;
      from_len++;
      attrs[pos].value = ast_alloca(from_len);
      ast_copy_pj_str(attrs[pos].value, &name_addr->display, from_len);
      pos++;
   } else if (caller->id.name.valid && !ast_strlen_zero(caller->id.name.str)) {
      attrs[pos].type = AST_MSG_DATA_ATTR_FROM;
      attrs[pos].value = caller->id.name.str;
      pos++;
   }

   name_addr = (pjsip_name_addr *) rdata->msg_info.to->uri;
   to_len = pj_strlen(&name_addr->display);
   if (to_len) {
      attrs[pos].type = AST_MSG_DATA_ATTR_TO;
      to_len++;
      attrs[pos].value = ast_alloca(to_len);
      ast_copy_pj_str(attrs[pos].value, &name_addr->display, to_len);
      pos++;
   }

   attrs[pos].type = AST_MSG_DATA_ATTR_CONTENT_TYPE;
   attrs[pos].value = ast_alloca(rdata->msg_info.msg->body->content_type.type.slen
      + rdata->msg_info.msg->body->content_type.subtype.slen + 2);
   sprintf(attrs[pos].value, "%.*s/%.*s",
      (int)rdata->msg_info.msg->body->content_type.type.slen,
      rdata->msg_info.msg->body->content_type.type.ptr,
      (int)rdata->msg_info.msg->body->content_type.subtype.slen,
      rdata->msg_info.msg->body->content_type.subtype.ptr);
   pos++;

   body_pos = pos;
   attrs[pos].type = AST_MSG_DATA_ATTR_BODY;
   attrs[pos].value = ast_malloc(rdata->msg_info.msg->body->len + 1);
   if (!attrs[pos].value) {
      send_response(rdata, PJSIP_SC_INTERNAL_SERVER_ERROR, dlg, tsx);
      return 0;
   }
   ast_copy_string(attrs[pos].value, rdata->msg_info.msg->body->data, rdata->msg_info.msg->body->len + 1);
   pos++;

   msg = ast_msg_data_alloc(AST_MSG_DATA_SOURCE_TYPE_IN_DIALOG, attrs, pos);
   if (!msg) {
      ast_free(attrs[body_pos].value);
      send_response(rdata, PJSIP_SC_INTERNAL_SERVER_ERROR, dlg, tsx);
      return 0;
   }

   ast_debug(1, "Received in-dialog MESSAGE from '%s:%s': %s %s\n",
      ast_msg_data_get_attribute(msg, AST_MSG_DATA_ATTR_FROM),
      ast_channel_name(session->channel),
      ast_msg_data_get_attribute(msg, AST_MSG_DATA_ATTR_TO),
      ast_msg_data_get_attribute(msg, AST_MSG_DATA_ATTR_BODY));

   rc = ast_msg_data_queue_frame(session->channel, msg);
   ast_free(attrs[body_pos].value);
   ast_free(msg);
   if (rc != 0) {
      send_response(rdata, PJSIP_SC_INTERNAL_SERVER_ERROR, dlg, tsx);
   } else {
      send_response(rdata, PJSIP_SC_ACCEPTED, dlg, tsx);
   }

   return 0;
}

insert_user_in_contact_uri()

static int insert_user_in_contact_uri ( const char *  to, const char *  endpoint_name, const char *  aors, const char *  user, char **  uri  )

static

Find a contact and insert a "user@" into its URI.

Parameters

to	Original destination (for error messages only)
endpoint_name	Endpoint name (for error messages only)
aors	Command separated list of AORs
user	The user to insert in the contact URI
uri	Pointer to buffer in which to return the URI

Returns

0 Success

-1 Fail

Note

If the contact URI found for the endpoint already has a user in its URI, it will be replaced.

Definition at line 213 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_debug, ast_log, ast_malloc, ast_sip_location_retrieve_contact_from_aor_list(), ast_strdupa, host, LOG_WARNING, NULL, and ast_sip_contact::uri.

Referenced by handle_slash().

{
   char *scheme = NULL;
   char *contact_uri = NULL;
   char *after_scheme = NULL;
   char *host;
   struct ast_sip_contact *contact = NULL;


   contact = ast_sip_location_retrieve_contact_from_aor_list(aors);
   if (!contact) {
      /*
       * We're getting the contact using the same method as
       * ast_sip_create_request() so if there's no contact
       * we can never send this message.
       */
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: Couldn't find contact for endpoint '%s'\n",
         to, endpoint_name);
      return -1;
   }

   contact_uri = ast_strdupa(contact->uri);
   ao2_cleanup(contact);

   ast_debug(3, "Dest: '%s' User: '%s'  Endpoint: '%s'  ContactURI: '%s'\n", to, user, endpoint_name, contact_uri);

   /*
    * Contact URIs must have a scheme so we must insert the user between it and the host.
    */
   scheme = contact_uri;
   after_scheme = strchr(contact_uri, ':');
   if (!after_scheme) {
      /* A contact URI without a scheme?  Something's wrong.  Bail */
      ast_log(LOG_WARNING, "Dest: '%s' MSG SEND FAIL: There was no scheme in the contact URI '%s'\n",
         to, contact_uri);
      return -1;
   }
   /*
    * Terminate the scheme.
    */
   *after_scheme = '\0';
   after_scheme++;

   /*
    * If the contact_uri already has a user, the host starts after the '@', otherwise
    * the host is at after_scheme.
    *
    * We're going to ignore the existing user.
    */
   host = strchr(after_scheme, '@');
   if (host) {
      host++;
   } else {
      host = after_scheme;
   }

   *uri = ast_malloc(strlen(scheme) + strlen(user) + strlen(host) + 3 /* One for the ':', '@' and terminating NULL */);
   sprintf(*uri, "%s:%s@%s", scheme, user, host); /* Safe */

   return 0;
}

is_msg_var_blocked()

static int is_msg_var_blocked ( const char *  name )

static

Definition at line 857 of file res_pjsip_messaging.c.

References ARRAY_LEN.

Referenced by vars_to_headers().

{
   int i;

   /* Don't block the Max-Forwards header because the user can override it */
   static const char *hdr[] = {
      "To",
      "From",
      "Via",
      "Route",
      "Contact",
      "Call-ID",
      "CSeq",
      "Allow",
      "Content-Length",
      "Content-Type",
      "Request-URI",
   };

   for (i = 0; i < ARRAY_LEN(hdr); ++i) {
      if (!strcasecmp(name, hdr[i])) {
         /* Block addition of this header. */
         return 1;
      }
   }
   return 0;
}

load_module()

static int load_module ( void  )

static

Definition at line 1566 of file res_pjsip_messaging.c.

References AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_msg_tech_register(), ast_msg_tech_unregister(), ast_sip_create_serializer(), ast_sip_get_pjsip_endpoint(), ast_sip_register_service(), ast_sip_session_register_supplement, ast_sip_unregister_service(), messaging_module, NULL, and pjsip_message_method.

Referenced by unload_module().

{
   if (ast_sip_register_service(&messaging_module) != PJ_SUCCESS) {
      return AST_MODULE_LOAD_DECLINE;
   }

   if (pjsip_endpt_add_capability(ast_sip_get_pjsip_endpoint(),
                   NULL, PJSIP_H_ALLOW, NULL, 1,
                   &pjsip_message_method.name) != PJ_SUCCESS) {

      ast_sip_unregister_service(&messaging_module);
      return AST_MODULE_LOAD_DECLINE;
   }

   if (ast_msg_tech_register(&msg_tech)) {
      ast_sip_unregister_service(&messaging_module);
      return AST_MODULE_LOAD_DECLINE;
   }

   message_serializer = ast_sip_create_serializer("pjsip/messaging");
   if (!message_serializer) {
      ast_sip_unregister_service(&messaging_module);
      ast_msg_tech_unregister(&msg_tech);
      return AST_MODULE_LOAD_DECLINE;
   }

   ast_sip_session_register_supplement(&messaging_supplement);
   return AST_MODULE_LOAD_SUCCESS;
}

module_on_rx_request()

static pj_bool_t module_on_rx_request ( pjsip_rx_data *  rdata )

static

Definition at line 1407 of file res_pjsip_messaging.c.

References ast_debug, ast_msg_alloc(), ast_msg_destroy(), ast_msg_has_destination(), ast_msg_queue(), check_content_type(), msg_data::msg, NULL, pjsip_message_method, rx_data_to_ast_msg(), and send_response().

{
   enum pjsip_status_code code;
   struct ast_msg *msg;

   /* if not a MESSAGE, don't handle */
   if (pjsip_method_cmp(&rdata->msg_info.msg->line.req.method, &pjsip_message_method)) {
      return PJ_FALSE;
   }

   code = check_content_type(rdata);
   if (code != PJSIP_SC_OK) {
      send_response(rdata, code, NULL, NULL);
      return PJ_TRUE;
   }

   msg = ast_msg_alloc();
   if (!msg) {
      send_response(rdata, PJSIP_SC_INTERNAL_SERVER_ERROR, NULL, NULL);
      return PJ_TRUE;
   }

   code = rx_data_to_ast_msg(rdata, msg);
   if (code != PJSIP_SC_OK) {
      send_response(rdata, code, NULL, NULL);
      ast_msg_destroy(msg);
      return PJ_TRUE;
   }

   if (!ast_msg_has_destination(msg)) {
      ast_debug(1, "MESSAGE request received, but no handler wanted it\n");
      send_response(rdata, PJSIP_SC_NOT_FOUND, NULL, NULL);
      ast_msg_destroy(msg);
      return PJ_TRUE;
   }

   /* Send it to the messaging core.
    *
    * If we are unable to send a response, the most likely reason is that we
    * are handling a retransmission of an incoming MESSAGE and were unable to
    * create a transaction due to a duplicate key. If we are unable to send
    * a response, we should not queue the message to the dialplan
    */
   if (!send_response(rdata, PJSIP_SC_ACCEPTED, NULL, NULL)) {
      ast_msg_queue(msg);
   }

   return PJ_TRUE;
}

msg_data_create()

static struct msg_data* msg_data_create ( const struct ast_msg *  msg, const char *  destination, const char *  from  )

static

Definition at line 1139 of file res_pjsip_messaging.c.

References ao2_alloc, ao2_ref, ast_msg_ref(), ast_strdup, msg_data::destination, msg_data::from, msg_data::msg, msg_data_destroy(), and NULL.

Referenced by sip_msg_send().

{
   char *uri_params;
   struct msg_data *mdata = ao2_alloc(sizeof(*mdata), msg_data_destroy);

   if (!mdata) {
      return NULL;
   }

   /* typecast to suppress const warning */
   mdata->msg = ast_msg_ref((struct ast_msg *) msg);

   /* To starts with 'pjsip:' which needs to be removed. */
   if (!(destination = strchr(destination, ':'))) {
      ao2_ref(mdata, -1);
      return NULL;
   }
   ++destination;/* Now skip the ':' */

   mdata->destination = ast_strdup(destination);
   mdata->from = ast_strdup(from);

   /*
    * Sometimes from URI can contain URI parameters, so remove them.
    *
    * sip:user;user-options@domain;uri-parameters
    */
   uri_params = strchr(mdata->from, '@');
   if (uri_params && (uri_params = strchr(mdata->from, ';'))) {
      *uri_params = '\0';
   }
   return mdata;
}

msg_data_destroy()

static void msg_data_destroy ( void *  obj )

static

Definition at line 1129 of file res_pjsip_messaging.c.

References ast_free, ast_msg_destroy(), msg_data::destination, msg_data::from, and msg_data::msg.

Referenced by msg_data_create().

{
   struct msg_data *mdata = obj;

   ast_free(mdata->from);
   ast_free(mdata->destination);

   ast_msg_destroy(mdata->msg);
}

msg_send()

static int msg_send ( void *  data )

static

Definition at line 1221 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_begins_with(), ast_debug, ast_free, ast_log, ast_msg_get_body(), ast_msg_get_from(), ast_msg_get_to(), ast_sip_add_body(), ast_sip_create_request(), ast_sip_send_request(), ast_sorcery_object_get_id(), ast_strdupa, ast_strlen_zero, ast_test_suite_event_notify, msg_data::destination, msg_data::from, get_outbound_endpoint(), LOG_ERROR, LOG_WARNING, msg_data::msg, NULL, RAII_VAR, ast_sip_body::type, update_content_type(), update_from(), update_to_display_name(), update_to_uri(), and vars_to_headers().

Referenced by sip_msg_send().

{
   struct msg_data *mdata = data; /* The caller holds a reference */

   struct ast_sip_body body = {
      .type = "text",
      .subtype = "plain",
      .body_text = ast_msg_get_body(mdata->msg)
   };

   pjsip_tx_data *tdata;
   RAII_VAR(char *, uri, NULL, ast_free);
   RAII_VAR(struct ast_sip_endpoint *, endpoint, NULL, ao2_cleanup);

   ast_debug(3, "mdata From: %s msg From: %s mdata Destination: %s msg To: %s\n",
      mdata->from, ast_msg_get_from(mdata->msg), mdata->destination, ast_msg_get_to(mdata->msg));

   endpoint = get_outbound_endpoint(mdata->destination, &uri);
   if (!endpoint) {
      ast_log(LOG_ERROR,
         "PJSIP MESSAGE - Could not find endpoint '%s' and no default outbound endpoint configured\n",
         mdata->destination);

      ast_test_suite_event_notify("MSG_ENDPOINT_URI_FAIL",
         "MdataFrom: %s\r\n"
         "MsgFrom: %s\r\n"
         "MdataDestination: %s\r\n"
         "MsgTo: %s\r\n",
         mdata->from,
         ast_msg_get_from(mdata->msg),
         mdata->destination,
         ast_msg_get_to(mdata->msg));

      return -1;
   }

   ast_debug(3, "Request URI: %s\n", uri);

   if (ast_sip_create_request("MESSAGE", NULL, endpoint, uri, NULL, &tdata)) {
      ast_log(LOG_WARNING, "PJSIP MESSAGE - Could not create request\n");
      return -1;
   }

   /* If there was a To in the actual message, */
   if (!ast_strlen_zero(ast_msg_get_to(mdata->msg))) {
      char *msg_to = ast_strdupa(ast_msg_get_to(mdata->msg));

      /*
       * It's possible that the message To was copied from
       * an incoming MESSAGE in which case it'll have the
       * pjsip: tech prepended to it.  We need to remove it.
       */
      if (ast_begins_with(msg_to, "pjsip:")) {
         msg_to += 6;
      }
      update_to_uri(tdata, msg_to);
   } else {
      /*
       * If there was no To in the message, it's still possible
       * that there is a display name in the mdata To.  If so,
       * we'll copy the URI display name to the tdata To.
       */
      update_to_display_name(tdata, uri);
   }

   if (!ast_strlen_zero(mdata->from)) {
      update_from(tdata, mdata->from);
   } else if (!ast_strlen_zero(ast_msg_get_from(mdata->msg))) {
      update_from(tdata, (char *)ast_msg_get_from(mdata->msg));
   }

#ifdef TEST_FRAMEWORK
   {
      pjsip_name_addr *tdata_name_addr;
      pjsip_sip_uri *tdata_sip_uri;
      char touri[128];
      char fromuri[128];

      tdata_name_addr = (pjsip_name_addr *) PJSIP_MSG_TO_HDR(tdata->msg)->uri;
      tdata_sip_uri = pjsip_uri_get_uri(tdata_name_addr->uri);
      pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, touri, sizeof(touri));
      tdata_name_addr = (pjsip_name_addr *) PJSIP_MSG_FROM_HDR(tdata->msg)->uri;
      tdata_sip_uri = pjsip_uri_get_uri(tdata_name_addr->uri);
      pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, fromuri, sizeof(fromuri));

      ast_test_suite_event_notify("MSG_FROMTO_URI",
         "MdataFrom: %s\r\n"
         "MsgFrom: %s\r\n"
         "MdataDestination: %s\r\n"
         "MsgTo: %s\r\n"
         "Endpoint: %s\r\n"
         "RequestURI: %s\r\n"
         "ToURI: %s\r\n"
         "FromURI: %s\r\n",
         mdata->from,
         ast_msg_get_from(mdata->msg),
         mdata->destination,
         ast_msg_get_to(mdata->msg),
         ast_sorcery_object_get_id(endpoint),
         uri,
         touri,
         fromuri
         );
   }
#endif

   update_content_type(tdata, mdata->msg, &body);

   if (ast_sip_add_body(tdata, &body)) {
      pjsip_tx_data_dec_ref(tdata);
      ast_log(LOG_ERROR, "PJSIP MESSAGE - Could not add body to request\n");
      return -1;
   }

   /*
    * This copies any headers set with MESSAGE_DATA() to the
    * tdata.
    */
   vars_to_headers(mdata->msg, tdata);

   ast_debug(1, "Sending message to '%s' (via endpoint %s) from '%s'\n",
      uri, ast_sorcery_object_get_id(endpoint), mdata->from);

   if (ast_sip_send_request(tdata, NULL, endpoint, NULL, NULL)) {
      ast_log(LOG_ERROR, "PJSIP MESSAGE - Could not send request\n");
      return -1;
   }

   return 0;
}

print_body()

static int print_body ( pjsip_rx_data *  rdata, char *  buf, int  len  )

static

Definition at line 964 of file res_pjsip_messaging.c.

Referenced by rx_data_to_ast_msg().

{
   int res;

   if (!rdata->msg_info.msg->body || !rdata->msg_info.msg->body->len) {
      return 0;
   }

   if ((res = rdata->msg_info.msg->body->print_body(
           rdata->msg_info.msg->body, buf, len)) < 0) {
      return res;
   }

   /* remove any trailing carriage return/line feeds */
   while (res > 0 && ((buf[--res] == '\r') || (buf[res] == '\n')));

   buf[++res] = '\0';

   return res;
}

rx_data_to_ast_msg()

static enum pjsip_status_code rx_data_to_ast_msg ( pjsip_rx_data *  rdata, struct ast_msg *  msg  )

static

Definition at line 1035 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_assert, ast_copy_pj_str(), AST_MAX_EXTENSION, ast_msg_set_body(), ast_msg_set_context(), ast_msg_set_endpoint(), ast_msg_set_exten(), ast_msg_set_from(), ast_msg_set_tech(), ast_msg_set_to(), ast_msg_set_var(), ast_pjsip_rdata_get_endpoint(), AST_SIP_USER_OPTIONS_TRUNCATE_CHECK, ast_sorcery_object_get_id(), buf, context, exten, headers_to_vars(), MAX_BODY_SIZE, NULL, print_body(), RAII_VAR, S_OR, and sip_to_pjsip().

Referenced by module_on_rx_request().

{
   RAII_VAR(struct ast_sip_endpoint *, endpt, NULL, ao2_cleanup);
   pjsip_uri *ruri = rdata->msg_info.msg->line.req.uri;
   pjsip_sip_uri *sip_ruri;
   pjsip_name_addr *name_addr;
   char buf[MAX_BODY_SIZE];
   const char *field;
   const char *context;
   char exten[AST_MAX_EXTENSION];
   int res = 0;
   int size;

   if (!PJSIP_URI_SCHEME_IS_SIP(ruri) && !PJSIP_URI_SCHEME_IS_SIPS(ruri)) {
      return PJSIP_SC_UNSUPPORTED_URI_SCHEME;
   }

   sip_ruri = pjsip_uri_get_uri(ruri);
   ast_copy_pj_str(exten, &sip_ruri->user, AST_MAX_EXTENSION);

   /*
    * We may want to match in the dialplan without any user
    * options getting in the way.
    */
   AST_SIP_USER_OPTIONS_TRUNCATE_CHECK(exten);

   endpt = ast_pjsip_rdata_get_endpoint(rdata);
   ast_assert(endpt != NULL);

   context = S_OR(endpt->message_context, endpt->context);
   res |= ast_msg_set_context(msg, "%s", context);
   res |= ast_msg_set_exten(msg, "%s", exten);

   /* to header */
   name_addr = (pjsip_name_addr *)rdata->msg_info.to->uri;
   size = pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, name_addr, buf, sizeof(buf) - 1);
   if (size <= 0) {
      return PJSIP_SC_INTERNAL_SERVER_ERROR;
   }
   buf[size] = '\0';
   res |= ast_msg_set_to(msg, "%s", sip_to_pjsip(buf, ++size, sizeof(buf) - 1));

   /* from header */
   name_addr = (pjsip_name_addr *)rdata->msg_info.from->uri;
   size = pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, name_addr, buf, sizeof(buf) - 1);
   if (size <= 0) {
      return PJSIP_SC_INTERNAL_SERVER_ERROR;
   }
   buf[size] = '\0';
   res |= ast_msg_set_from(msg, "%s", buf);

   field = pj_sockaddr_print(&rdata->pkt_info.src_addr, buf, sizeof(buf) - 1, 3);
   res |= ast_msg_set_var(msg, "PJSIP_RECVADDR", field);

   switch (rdata->tp_info.transport->key.type) {
   case PJSIP_TRANSPORT_UDP:
   case PJSIP_TRANSPORT_UDP6:
      field = "udp";
      break;
   case PJSIP_TRANSPORT_TCP:
   case PJSIP_TRANSPORT_TCP6:
      field = "tcp";
      break;
   case PJSIP_TRANSPORT_TLS:
   case PJSIP_TRANSPORT_TLS6:
      field = "tls";
      break;
   default:
      field = rdata->tp_info.transport->type_name;
   }
   ast_msg_set_var(msg, "PJSIP_TRANSPORT", field);

   if (print_body(rdata, buf, sizeof(buf) - 1) > 0) {
      res |= ast_msg_set_body(msg, "%s", buf);
   }

   /* endpoint name */
   res |= ast_msg_set_tech(msg, "%s", "PJSIP");
   res |= ast_msg_set_endpoint(msg, "%s", ast_sorcery_object_get_id(endpt));
   if (endpt->id.self.name.valid) {
      res |= ast_msg_set_var(msg, "PJSIP_ENDPOINT", endpt->id.self.name.str);
   }

   res |= headers_to_vars(rdata, msg);

   return !res ? PJSIP_SC_OK : PJSIP_SC_INTERNAL_SERVER_ERROR;
}

send_response()

static pj_status_t send_response ( pjsip_rx_data *  rdata, enum pjsip_status_code  code, pjsip_dialog *  dlg, pjsip_transaction *  tsx  )

static

Definition at line 1378 of file res_pjsip_messaging.c.

References ao2_cleanup, ast_log, ast_pjsip_rdata_get_endpoint(), ast_sip_create_response(), ast_sip_send_stateful_response(), LOG_ERROR, NULL, and status.

Referenced by incoming_in_dialog_request(), and module_on_rx_request().

{
   pjsip_tx_data *tdata;
   pj_status_t status;

   status = ast_sip_create_response(rdata, code, NULL, &tdata);
   if (status != PJ_SUCCESS) {
      ast_log(LOG_ERROR, "Unable to create response (%d)\n", status);
      return status;
   }

   if (dlg && tsx) {
      status = pjsip_dlg_send_response(dlg, tsx, tdata);
   } else {
      struct ast_sip_endpoint *endpoint;

      endpoint = ast_pjsip_rdata_get_endpoint(rdata);
      status = ast_sip_send_stateful_response(rdata, tdata, endpoint);
      ao2_cleanup(endpoint);
   }

   if (status != PJ_SUCCESS) {
      ast_log(LOG_ERROR, "Unable to send response (%d)\n", status);
   }

   return status;
}

sip_msg_send()

static int sip_msg_send ( const struct ast_msg *  msg, const char *  destination, const char *  from  )

static

Definition at line 1352 of file res_pjsip_messaging.c.

References ao2_ref, ast_log, ast_sip_push_task_wait_serializer(), ast_strlen_zero, LOG_ERROR, msg_data_create(), and msg_send().

{
   struct msg_data *mdata;
   int res;

   if (ast_strlen_zero(destination)) {
      ast_log(LOG_ERROR, "SIP MESSAGE - a 'To' URI  must be specified\n");
      return -1;
   }

   mdata = msg_data_create(msg, destination, from);
   if (!mdata) {
      return -1;
   }

   res = ast_sip_push_task_wait_serializer(message_serializer, msg_send, mdata);
   ao2_ref(mdata, -1);

   return res;
}

sip_to_pjsip()

static char* sip_to_pjsip ( char *  buf, int  size, int  capacity  )

static

Definition at line 994 of file res_pjsip_messaging.c.

References ast_log, buf, LOG_WARNING, and NULL.

Referenced by rx_data_to_ast_msg().

{
   int count;
   const char *scheme;
   char *res = buf;

   /* remove any wrapping brackets */
   if (*buf == '<') {
      ++buf;
      --size;
   }

   scheme = strncmp(buf, "sip", 3) ? "pjsip:" : "pj";
   count = strlen(scheme);
   if (count + size >= capacity) {
      ast_log(LOG_WARNING, "Unable to handle MESSAGE- incoming uri "
         "too large for given buffer\n");
      return NULL;
   }

   memmove(res + count, buf, size);
   memcpy(res, scheme, count);

   buf += size - 1;
   if (*buf == '>') {
      *buf = '\0';
   }

   return res;
}

unload_module()

static int unload_module ( void  )

static

Definition at line 1596 of file res_pjsip_messaging.c.

References AST_MODFLAG_LOAD_ORDER, AST_MODPRI_APP_DEPEND, AST_MODULE_INFO(), AST_MODULE_SUPPORT_CORE, ast_msg_tech_unregister(), ast_sip_session_unregister_supplement(), ast_sip_unregister_service(), ast_taskprocessor_unreference(), ASTERISK_GPL_KEY, load_module(), and messaging_module.

{
   ast_sip_session_unregister_supplement(&messaging_supplement);
   ast_msg_tech_unregister(&msg_tech);
   ast_sip_unregister_service(&messaging_module);
   ast_taskprocessor_unreference(message_serializer);
   return 0;
}

update_content_type()

static void update_content_type ( pjsip_tx_data *  tdata, struct ast_msg *  msg, struct ast_sip_body *  body  )

static

Definition at line 1173 of file res_pjsip_messaging.c.

References ast_log, ast_msg_get_var(), ast_strdupa, LOG_WARNING, NULL, ast_sip_body::subtype, type, and ast_sip_body::type.

Referenced by msg_send().

{
   static const pj_str_t CONTENT_TYPE = { "Content-Type", sizeof("Content-Type") - 1 };

   const char *content_type = ast_msg_get_var(msg, pj_strbuf(&CONTENT_TYPE));
   if (content_type) {
      pj_str_t type, subtype;
      pjsip_ctype_hdr *parsed;

      /* Let pjsip do the parsing for us */
      parsed = pjsip_parse_hdr(tdata->pool, &CONTENT_TYPE,
         ast_strdupa(content_type), strlen(content_type),
         NULL);

      if (!parsed) {
         ast_log(LOG_WARNING, "Failed to parse '%s' as a content type. Using text/plain\n",
            content_type);
         return;
      }

      /* We need to turn type and subtype into zero-terminated strings */
      pj_strdup_with_null(tdata->pool, &type, &parsed->media.type);
      pj_strdup_with_null(tdata->pool, &subtype, &parsed->media.subtype);

      body->type = pj_strbuf(&type);
      body->subtype = pj_strbuf(&subtype);
   }
}

update_from()

static int update_from ( pjsip_tx_data *  tdata, char *  from  )

static

Definition at line 788 of file res_pjsip_messaging.c.

References ast_log, ast_strlen_zero, and LOG_WARNING.

Referenced by msg_send().

{
   pjsip_name_addr *name_addr;
   pjsip_sip_uri *uri;
   pjsip_name_addr *parsed_name_addr;

   if (ast_strlen_zero(from)) {
      return 0;
   }

   name_addr = (pjsip_name_addr *) PJSIP_MSG_FROM_HDR(tdata->msg)->uri;
   uri = pjsip_uri_get_uri(name_addr);

   parsed_name_addr = (pjsip_name_addr *) pjsip_parse_uri(tdata->pool, from,
      strlen(from), PJSIP_PARSE_URI_AS_NAMEADDR);
   if (parsed_name_addr) {
      pjsip_sip_uri *parsed_uri;

      if (!PJSIP_URI_SCHEME_IS_SIP(parsed_name_addr->uri)
            && !PJSIP_URI_SCHEME_IS_SIPS(parsed_name_addr->uri)) {
         ast_log(LOG_WARNING, "From address '%s' is not a valid SIP/SIPS URI\n", from);
         return -1;
      }

      parsed_uri = pjsip_uri_get_uri(parsed_name_addr->uri);

      if (pj_strlen(&parsed_name_addr->display)) {
         pj_strdup(tdata->pool, &name_addr->display, &parsed_name_addr->display);
      }

      /* Unlike the To header, we only want to replace the user, host and port */
      pj_strdup(tdata->pool, &uri->user, &parsed_uri->user);
      pj_strdup(tdata->pool, &uri->host, &parsed_uri->host);
      uri->port = parsed_uri->port;

      return 0;
   } else {
      /* assume it is 'user[@domain]' format */
      char *domain = strchr(from, '@');

      if (domain) {
         pj_str_t pj_from;

         pj_strset3(&pj_from, from, domain);
         pj_strdup(tdata->pool, &uri->user, &pj_from);

         pj_strdup2(tdata->pool, &uri->host, domain + 1);
      } else {
         pj_strdup2(tdata->pool, &uri->user, from);
      }

      return 0;
   }

   return -1;
}

update_to_display_name()

static int update_to_display_name ( pjsip_tx_data *  tdata, char *  to  )

static

Definition at line 753 of file res_pjsip_messaging.c.

Referenced by msg_send().

{
   pjsip_name_addr *parsed_name_addr;

   parsed_name_addr = (pjsip_name_addr *) pjsip_parse_uri(tdata->pool, to, strlen(to),
      PJSIP_PARSE_URI_AS_NAMEADDR);

   if (parsed_name_addr) {
      if (pj_strlen(&parsed_name_addr->display)) {
         pjsip_name_addr *name_addr =
            (pjsip_name_addr *) PJSIP_MSG_TO_HDR(tdata->msg)->uri;

         pj_strdup(tdata->pool, &name_addr->display, &parsed_name_addr->display);

      }
      return 0;
   }

   return -1;
}

update_to_uri()

static int update_to_uri ( pjsip_tx_data *  tdata, char *  to  )

static

Definition at line 686 of file res_pjsip_messaging.c.

References ast_alloca, ast_debug, ast_log, buf, DEBUG_ATLEAST, DEBUG_BUF_SIZE, LOG_WARNING, and NULL.

Referenced by msg_send().

{
   pjsip_name_addr *parsed_name_addr;
   pjsip_sip_uri *sip_uri;
   pjsip_name_addr *tdata_name_addr;
   pjsip_sip_uri *tdata_sip_uri;
   char *buf = NULL;
#define DEBUG_BUF_SIZE 256

   parsed_name_addr = (pjsip_name_addr *) pjsip_parse_uri(tdata->pool, to, strlen(to),
      PJSIP_PARSE_URI_AS_NAMEADDR);

   if (!parsed_name_addr || (!PJSIP_URI_SCHEME_IS_SIP(parsed_name_addr->uri)
         && !PJSIP_URI_SCHEME_IS_SIPS(parsed_name_addr->uri))) {
      ast_log(LOG_WARNING, "To address '%s' is not a valid SIP/SIPS URI\n", to);
      return -1;
   }

   sip_uri = pjsip_uri_get_uri(parsed_name_addr->uri);
   if (DEBUG_ATLEAST(3)) {
      buf = ast_alloca(DEBUG_BUF_SIZE);
      pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, sip_uri, buf, DEBUG_BUF_SIZE);
      ast_debug(3, "Parsed To: %.*s  %s\n", (int)parsed_name_addr->display.slen,
         parsed_name_addr->display.ptr, buf);
   }

   tdata_name_addr = (pjsip_name_addr *) PJSIP_MSG_TO_HDR(tdata->msg)->uri;
   if (!tdata_name_addr || (!PJSIP_URI_SCHEME_IS_SIP(tdata_name_addr->uri)
         && !PJSIP_URI_SCHEME_IS_SIPS(tdata_name_addr->uri))) {
      /* Highly unlikely but we have to check */
      ast_log(LOG_WARNING, "tdata To address '%s' is not a valid SIP/SIPS URI\n", to);
      return -1;
   }

   tdata_sip_uri = pjsip_uri_get_uri(tdata_name_addr->uri);
   if (DEBUG_ATLEAST(3)) {
      buf[0] = '\0';
      pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, buf, DEBUG_BUF_SIZE);
      ast_debug(3, "Original tdata To: %.*s  %s\n", (int)tdata_name_addr->display.slen,
         tdata_name_addr->display.ptr, buf);
   }

   /* Replace the uri */
   pjsip_sip_uri_assign(tdata->pool, tdata_sip_uri, sip_uri);
   /* The display name isn't part of the URI so we need to replace it separately */
   pj_strdup(tdata->pool, &tdata_name_addr->display, &parsed_name_addr->display);

   if (DEBUG_ATLEAST(3)) {
      buf[0] = '\0';
      pjsip_uri_print(PJSIP_URI_IN_FROMTO_HDR, tdata_sip_uri, buf, 256);
      ast_debug(3, "New tdata To: %.*s  %s\n", (int)tdata_name_addr->display.slen,
         tdata_name_addr->display.ptr, buf);
   }

   return 0;
#undef DEBUG_BUF_SIZE
}

vars_to_headers()

static enum pjsip_status_code vars_to_headers ( const struct ast_msg *  msg, pjsip_tx_data *  tdata  )

static

Definition at line 892 of file res_pjsip_messaging.c.

References ast_log, ast_msg_var_iterator_destroy(), ast_msg_var_iterator_init(), ast_msg_var_iterator_next(), ast_msg_var_unref_current(), ast_sip_add_header(), is_msg_var_blocked(), ast_msg_var_iterator::iter, LOG_NOTICE, name, and value.

Referenced by msg_send().

{
   const char *name;
   const char *value;
   int max_forwards;
   struct ast_msg_var_iterator *iter;

   for (iter = ast_msg_var_iterator_init(msg);
      ast_msg_var_iterator_next(msg, iter, &name, &value);
      ast_msg_var_unref_current(iter)) {
      if (!strcasecmp(name, "Max-Forwards")) {
         /* Decrement Max-Forwards for SIP loop prevention. */
         if (sscanf(value, "%30d", &max_forwards) != 1 || --max_forwards == 0) {
            ast_msg_var_iterator_destroy(iter);
            ast_log(LOG_NOTICE, "MESSAGE(Max-Forwards) reached zero.  MESSAGE not sent.\n");
            return -1;
         }
         sprintf((char *) value, "%d", max_forwards);
         ast_sip_add_header(tdata, name, value);
      } else if (!is_msg_var_blocked(name)) {
         ast_sip_add_header(tdata, name, value);
      }
   }
   ast_msg_var_iterator_destroy(iter);

   return PJSIP_SC_OK;
}

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PJSIP Messaging Support" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_APP_DEPEND, .requires = "res_pjsip,res_pjsip_session", }

static

Definition at line 1611 of file res_pjsip_messaging.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 1611 of file res_pjsip_messaging.c.

message_serializer

struct ast_taskprocessor* message_serializer

static

Definition at line 140 of file res_pjsip_messaging.c.

messaging_module

pjsip_module messaging_module

static

Definition at line 1559 of file res_pjsip_messaging.c.

Referenced by load_module(), and unload_module().

messaging_supplement

struct ast_sip_session_supplement messaging_supplement

static

Initial value:

= {
   .method = "MESSAGE",
   .incoming_request = incoming_in_dialog_request
}

Definition at line 1554 of file res_pjsip_messaging.c.

msg_tech

const struct ast_msg_tech msg_tech

static

Initial value:

= {
   .name = "pjsip",
   .msg_send = sip_msg_send,
}

Definition at line 1373 of file res_pjsip_messaging.c.

Referenced by action_messagesend(), ast_msg_send(), and msg_send_exec().

pjsip_message_method

const pjsip_method pjsip_message_method = {PJSIP_OTHER_METHOD, {"MESSAGE", 7} }

Definition at line 134 of file res_pjsip_messaging.c.

Referenced by load_module(), and module_on_rx_request().