id.c
1a47dd77
 /*
  * $Id$
  *
  * Copyright (C) 2005 iptelorg GmbH
  *
  * This file is part of ser, a free SIP server.
  *
  * ser 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 2 of the License, or
  * (at your option) any later version
  *
  * For a license to use the ser software under conditions
  * other than those described here, or to purchase support for this
  * software, please contact iptel.org by e-mail at the following addresses:
  *    info@iptel.org
  *
  * ser 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 this program; if not, write to the Free Software 
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  */
 
1d0661db
 /*!
  * \file
  * \brief SIP-router core :: 
  * \ingroup core
  * Module: \ref core
  */
 
1a47dd77
 #include "id.h"
09794258
 #include "parser/parse_from.h"
 #include "parser/parse_uri.h"
9d409a40
 #include "parser/digest/digest.h"
09794258
 #include "ut.h"
1a47dd77
 
a20be8fb
 static str uid_name = STR_STATIC_INIT(AVP_UID);
 static str did_name = STR_STATIC_INIT(AVP_DID);
 
1a47dd77
 
 /*
  * Set From UID
  */
09189798
 int set_from_uid(str* uid)
1a47dd77
 {
 	struct search_state s;
a20be8fb
 	int_str val, name;
1a47dd77
 	avp_t* a;
 
a20be8fb
 	name.s = uid_name;
8a63d2d1
 	a = search_first_avp(AVP_CLASS_USER | AVP_TRACK_FROM | AVP_NAME_STR, name, 0, &s);
1a47dd77
 	while(a) {
 		destroy_avp(a);
 		a = search_next_avp(&s, 0);
 	}
 
8a63d2d1
 	val.s = *uid;
09189798
 	return add_avp(AVP_CLASS_USER | AVP_TRACK_FROM | AVP_NAME_STR | AVP_VAL_STR, name, val);
1a47dd77
 }
 
 
9d409a40
 /* Extract username attribute from authorized credentials */
 static inline str* cred_user(struct sip_msg* msg)
 {
 	struct hdr_field* h;
 	auth_body_t* cred;
 
 	get_authorized_cred(msg->proxy_auth, &h);
 	if (!h) get_authorized_cred(msg->authorization, &h);
 	if (!h) return 0;
 	cred = (auth_body_t*)(h->parsed);
 	if (!cred || !cred->digest.username.user.len) return 0;
 	return &cred->digest.username.user;
 }
 
1a47dd77
 /*
  * Set From UID
  */
09794258
 int get_from_uid(str* uid, struct sip_msg* msg)
1a47dd77
 {
09794258
 	static char buf[MAX_URI_SIZE];
 	struct to_body* from;
 	struct sip_uri puri;
9d409a40
 	str* du;
a20be8fb
 	int_str val, name;
1a47dd77
 
a20be8fb
 	name.s = uid_name;
8a63d2d1
 	if (search_first_avp(AVP_CLASS_USER | AVP_TRACK_FROM | AVP_NAME_STR, name, &val, 0)) {
 		*uid = val.s;
1a47dd77
 		return 1;
 	} else {
9d409a40
 		du = cred_user(msg);
 		if (du) {
 			     /* Try digest username first */
 			*uid = *du;
 		} else {
 			     /* Get From URI username */
 			if (parse_from_header(msg) < 0) {
 				LOG(L_ERR, "get_from_uid: Error while parsing From header\n");
 				return -1;
 			}
 			from = get_from(msg);
 			if (parse_uri(from->uri.s, from->uri.len, &puri) == -1) {
 				LOG(L_ERR, "get_from_uid: Error while parsing From URI\n");
 				return -1;
 			}
09794258
 		
9d409a40
 			if (puri.user.len > MAX_URI_SIZE) {
 				LOG(L_ERR, "get_from_uid: Username too long\n");
 				return -1;
 			}
 			memcpy(buf, puri.user.s, puri.user.len);
 			uid->s = buf;
 			uid->len = puri.user.len;
 			strlower(uid);
09794258
 		}
9d409a40
 		
8a63d2d1
 		val.s = *uid;
 		add_avp(AVP_CLASS_USER | AVP_TRACK_FROM | AVP_NAME_STR | AVP_VAL_STR, name, val);
1a47dd77
 		return 0;
 	}
 }
 
 
9b578f89
 int get_to_uid(str* uid, struct sip_msg* msg)
 {
 	static char buf[MAX_URI_SIZE];
 	struct to_body* to;
 	struct sip_uri puri;
 	char* p;
 	int_str val, name;
 
 	name.s = uid_name;
 	if (search_first_avp(AVP_CLASS_USER | AVP_TRACK_TO | AVP_NAME_STR, name, &val, 0)) {
 		*uid = val.s;
 		return 1;
 	} else {
7cf1c596
 		if (msg->REQ_METHOD == METHOD_REGISTER) {
9b578f89
 			if ((msg->to==0) && 
 				(parse_headers(msg, HDR_TO_F, 0) < 0 || msg->to == 0)) {
 				DBG("get_to_uid: Error while parsing To URI: "
 					" to header bad or missing\n");
 				return -1;
 			}
 			to = get_to(msg);
 			if (parse_uri(to->uri.s, to->uri.len, &puri) == -1) {
 				DBG("get_to_uid: Error while parsing To URI\n");
 				return -1;
 			}
 			p = puri.user.s;
 			uid->len = puri.user.len;
 		} else {
 			if (!msg->parsed_uri_ok && (parse_sip_msg_uri(msg) < 0)) {
 				DBG("Error while parsing the Request-URI\n");
 				return -1;
 			}
 			p = msg->parsed_uri.user.s;
 			uid->len = msg->parsed_uri.user.len;
 		}
 			
 		if (uid->len > MAX_URI_SIZE) {
 			DBG("get_to_uid: Username too long\n");
 			return -1;
 		}
a78ea556
 		if (p == NULL || uid->len == 0) {
 			DBG("get_to_uid: Username is empty\n");
 			return -1;
 		}
7f1e216a
 		memcpy(buf, p, uid->len);
9b578f89
 		uid->s = buf;
 		strlower(uid);
 
 		val.s = *uid;
 		add_avp(AVP_CLASS_USER | AVP_TRACK_TO | AVP_NAME_STR | AVP_VAL_STR, name, val);
 		return 0;
 	}
 }
 
 
1a47dd77
 /*
  * Set To UID
  */
09189798
 int set_to_uid(str* uid)
1a47dd77
 {
 	struct search_state s;
a20be8fb
 	int_str val, name;
1a47dd77
 	avp_t* a;
 
a20be8fb
 	name.s = uid_name;
8a63d2d1
 	a = search_first_avp(AVP_CLASS_USER | AVP_TRACK_TO | AVP_NAME_STR, name, 0, &s);
1a47dd77
 	while(a) {
 		destroy_avp(a);
 		a = search_next_avp(&s, 0);
 	}
 
8a63d2d1
 	val.s = *uid;
09189798
 	return add_avp(AVP_CLASS_USER | AVP_TRACK_TO | AVP_NAME_STR | AVP_VAL_STR, name, val);
1a47dd77
 }
 
 
 /*
8a63d2d1
  * Return current To domain id
1a47dd77
  */
8a63d2d1
 int get_to_did(str* did, struct sip_msg* msg)
1a47dd77
 {
a20be8fb
 	int_str val, name;
09794258
 
a20be8fb
 	name.s = did_name;
 	if (search_first_avp(AVP_TRACK_TO | AVP_NAME_STR, name, &val, 0)) {
8a63d2d1
 		*did = val.s;
1a47dd77
 		return 1;
8a63d2d1
 	} 
 	return 0;
 }
09794258
 
8a63d2d1
 
 /*
  * Return current To domain id
  */
 int get_from_did(str* did, struct sip_msg* msg)
 {
a20be8fb
 	int_str val, name;
8a63d2d1
 
a20be8fb
 	name.s = did_name;
 	if (search_first_avp(AVP_TRACK_FROM | AVP_NAME_STR, name, &val, 0)) {
8a63d2d1
 		*did = val.s;
 		return 1;
 	} 
 	return 0;
1a47dd77
 }
8a63d2d1