pvar.c

/**
 * Copyright (C) 2010-2020 OpenSIPS Solutions
 * Copyright (C) 2005-2009 Voice Sistem SRL
 * Copyright (C) 2001-2003 FhG Fokus
 *
 * This file is part of opensips, a free SIP server.
 *
 * opensips 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
 *
 * opensips 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA
 *
 * History:
 * --------
 * 2004-10-20 - added header name specifier (ramona)
 * 2005-06-14 - added avp name specifier (ramona)
 * 2005-06-18 - added color printing support via escape sequesnces
 *              contributed by Ingo Flaschberger (daniel)
 * 2005-06-22 - created this file from modules/xlog/pv_lib.c (daniel)
 * 2009-04-28 - $ct and $ct.fields() PVs added (bogdan)
 * 2009-05-02 - $branch() added, $br, $bR, $bf, $bF removed (bogdan)
 */

#include <stdio.h>
#include <string.h>
#include <time.h>
#include <sys/types.h>
#include <unistd.h>

#include "dprint.h"
#include "mem/mem.h"
#include "mem/shm_mem.h"
#include "ut.h"
#include "trim.h"
#include "dset.h"
#include "action.h"
#include "socket_info.h"
#include "route_struct.h"
#include "usr_avp.h"
#include "errinfo.h"
#include "transformations.h"
#include "script_var.h"
#include "pvar.h"
#include "flags.h"
#include "xlog.h"

#include "parser/parse_from.h"
#include "parser/parse_uri.h"
#include "parser/parse_hname2.h"
#include "parser/parse_content.h"
#include "parser/parse_refer_to.h"
#include "parser/parse_rpid.h"
#include "parser/parse_diversion.h"
#include "parser/parse_ppi.h"
#include "parser/parse_pai.h"
#include "parser/digest/digest.h"
#include "parser/contact/parse_contact.h"

#define is_in_str(p, in) (p<in->s+in->len && *p)

extern int curr_action_line;
extern char *curr_action_file;

typedef struct _pv_extra
{
	pv_export_t pve;
	struct _pv_extra *next;
} pv_extra_t, *pv_extra_p;

pv_extra_p  *_pv_extra_list=0;

static str str_marker = { PV_MARKER_STR, 1 };

/* IMPORTANT : the "const" strings returned by the var functions must
   be read-write (as they may be changed by the script interpreter), so
   we need to allocated as array and not as pointing to RO data segment
   */
static char _str_null_hlp[] = "<null>";
static str str_null         = str_init(_str_null_hlp);

static char _str_empty_hlp[] = "";
static str str_empty         = str_init(_str_empty_hlp);

int _pv_pid = 0;

#define PV_FIELD_DELIM ", "
#define PV_FIELD_DELIM_LEN (sizeof(PV_FIELD_DELIM) - 1)

#define PV_LOCAL_BUF_SIZE	511
static char pv_local_buf[PV_LOCAL_BUF_SIZE+1];

/* pv context list */
pv_context_t* pv_context_lst = NULL;

static pv_context_t* pv_get_context(const str* name);
static pv_context_t* add_pv_context(const str* name, pv_contextf_t get_context);

static int pv_parse_argv_name(pv_spec_p sp, const str *in);
static int pv_get_argv(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res);
static int pv_contextlist_check(void);
/* always obtain a printable version of the given (pv_value_t *) */
static str pv_value_print(const pv_value_t *val);

static int pvc_before_check = 1;

int pv_print_buf_size = 20000;
#define PV_PRINT_BUF_NO   7
str *pv_print_buf;

#define is_pv_print_buf(p) (p >= (char *)pv_print_buf && \
			p <= (char *)pv_print_buf + \
				PV_PRINT_BUF_NO * (sizeof(*pv_print_buf) + pv_print_buf_size))

int init_pvar_support(void)
{
	int i;

	/* check pv context list */
	if (pv_contextlist_check() != 0) {
		LM_ERR("used pv context that was not defined\n");
		return -1;
	}

	pv_print_buf = pkg_malloc(PV_PRINT_BUF_NO * (sizeof(str)
	                               + pv_print_buf_size));
	if (!pv_print_buf) {
		LM_ERR("oom\n");
		return -1;
	}

	for (i = 0; i < PV_PRINT_BUF_NO; i++) {
		pv_print_buf[i].s = (char *)(pv_print_buf + PV_PRINT_BUF_NO)
		                              + i * pv_print_buf_size;
		pv_print_buf[i].len = pv_print_buf_size;
	}

	return 0;
}

/* route param variable */
static int pv_get_param(struct sip_msg *msg,  pv_param_t *ip, pv_value_t *res);
static int pv_parse_param_name(pv_spec_p sp, const str *in);

/********** helper functions ********/
/**
 * convert unsigned int to pv_value_t
 */
int pv_get_uintval(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, unsigned int uival)
{
	int l = 0;
	char *ch = NULL;

	if(res==NULL)
		return -1;

	ch = int2str(uival, &l);
	res->rs.s = ch;
	res->rs.len = l;

	res->ri = (int)uival;
	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
	return 0;
}

/**
 * convert signed int to pv_value_t
 */
int pv_get_sintval(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, int sival)
{
	int l = 0;
	char *ch = NULL;

	if(res==NULL)
		return -1;

	ch = sint2str(sival, &l);
	res->rs.s = ch;
	res->rs.len = l;

	res->ri = sival;
	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
	return 0;
}

/**
 * convert str to pv_value_t
 */
int pv_get_strval(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, str *sval)
{
	if(res==NULL)
		return -1;

	res->rs = *sval;
	res->flags = PV_VAL_STR;
	return 0;
}

/**
 * convert str-int to pv_value_t (type is str)
 */
static int pv_get_strintval(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, str *sval, int ival)
{
	if(res==NULL)
		return -1;

	res->rs = *sval;
	res->ri = ival;
	res->flags = PV_VAL_STR|PV_VAL_INT;
	return 0;
}

/**
 * convert int-str to pv_value_t (type is int)
 */
static int pv_get_intstrval(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, int ival, str *sval)
{
	if(res==NULL)
		return -1;

	res->rs = *sval;
	res->ri = ival;
	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
	return 0;
}

/************************************************************/
static int pv_get_marker(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	return pv_get_strintval(msg, param, res, &str_marker, (int)str_marker.s[0]);
}

int pv_get_null(struct sip_msg *msg, pv_param_t *param, pv_value_t *res)
{
	if(res==NULL)
		return -1;

	res->rs = str_empty;
	res->ri = 0;
	res->flags = PV_VAL_NULL;
	return 0;
}

/************************************************************/
static int pv_get_pid(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(_pv_pid == 0)
		_pv_pid = (int)getpid();
	return pv_get_sintval(msg, param, res, _pv_pid);
}


extern int return_code;
static int pv_get_return_code(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	return pv_get_sintval(msg, param, res, return_code);
}

static int pv_get_route_name(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	static str rn_buf;

	str s;
	int i, idx, idx_flags, len, rlen, has_name;

	if (pv_get_spec_index(msg, param, &idx, &idx_flags) != 0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if (idx_flags == PV_IDX_ALL) {
		get_top_route_type(&s, &has_name);
		if (!has_name)
			goto unnamed_route;

		len = strlen(route_stack[0]);
		if (pkg_str_extend(&rn_buf, s.len + 2 + len + 1) != 0) {
			LM_ERR("oom\n");
			return pv_get_null(msg, param, res);
		}

		len = sprintf(rn_buf.s, "%.*s[%s]", s.len, s.s, route_stack[idx]);
		goto print_remaining;

	unnamed_route:
		if (pkg_str_extend(&rn_buf, s.len + 1) != 0) {
			LM_ERR("oom\n");
			return pv_get_null(msg, param, res);
		}

		len = sprintf(rn_buf.s, "%.*s", s.len, s.s);

	print_remaining:
		s = str_route;

		for (i = 1; i < route_stack_size; i++) {
			if (!route_stack[i]) {
				if (pkg_str_extend(&rn_buf, len + 3 + s.len + 1) != 0) {
					LM_ERR("oom\n");
					return pv_get_null(msg, param, res);
				}

				len += sprintf(rn_buf.s + len, " > %.*s", s.len, s.s);
			} else if (route_stack[i][0] != '!') {
				rlen = strlen(route_stack[i]);

				if (pkg_str_extend(&rn_buf, len + s.len + 5 + rlen + 1) != 0) {
					LM_ERR("oom\n");
					return pv_get_null(msg, param, res);
				}

				len += sprintf(rn_buf.s + len, " > %.*s[%s]",
									s.len, s.s, route_stack[i]);
			} else {
				rlen = strlen(route_stack[i]);

				/* the "!" marker tells us to print that route name as-is */
				if (pkg_str_extend(&rn_buf, len + rlen + 3) != 0) {
					LM_ERR("oom\n");
					return pv_get_null(msg, param, res);
				}

				len += sprintf(rn_buf.s + len, " > %s", route_stack[i] + 1);
			}
		}

		s.s = rn_buf.s;
		s.len = len;
		return pv_get_strval(msg, param, res, &s);
	}

	if (idx < 0)
		idx += route_stack_size;

	/* index out of bounds -- play nice and return NULL */
	if (idx > route_stack_size - 1 || idx < 0)
		return pv_get_null(msg, param, res);

	/* reverse the index, since we index the route stack backwards */
	idx = route_stack_size - idx - 1;

	if (idx == 0) {
		get_top_route_type(&s, &has_name);
		if (!has_name)
			goto out_ok;

	} else {
		s = str_route;
		if (!route_stack[idx])
			goto out_ok;
	}

	len = strlen(route_stack[idx]);

	if (route_stack[idx][0] != '!') {
		if (pkg_str_extend(&rn_buf, s.len + 2 + len + 1) != 0) {
			LM_ERR("oom\n");
			return pv_get_null(msg, param, res);
		}

		s.len = sprintf(rn_buf.s, "%.*s[%s]", s.len, s.s, route_stack[idx]);
		s.s = rn_buf.s;
	} else {
		/* the "!" marker tells us to print that route name as-is */
		if (pkg_str_extend(&rn_buf, len) != 0) {
			LM_ERR("oom\n");
			return pv_get_null(msg, param, res);
		}

		s.len = sprintf(rn_buf.s, "%s", route_stack[idx] + 1);
		s.s = rn_buf.s;
	}


out_ok:
	return pv_get_strval(msg, param, res, &s);
}

static int pv_get_times(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	return pv_get_uintval(msg, param, res, (unsigned int)time(NULL));
}

static int pv_get_timem(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	struct timeval TP;

	if(msg==NULL)
		return -1;

	gettimeofday(&TP, NULL);
	return pv_get_uintval(msg, param, res, (unsigned int)TP.tv_usec);
}

static int pv_get_start_times(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	return pv_get_uintval(msg, param, res, (unsigned int)startup_time);
}

static int pv_parse_time_name(pv_spec_p sp, const str *in)
{
	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = AVP_NAME_STR;
	sp->pvp.pvn.u.isname.name.s.s = pkg_malloc(in->len + 1);
	if (sp->pvp.pvn.u.isname.name.s.s==NULL) {
		LM_ERR("failed to allocated private mem\n");
		return -1;
	}
	memcpy(sp->pvp.pvn.u.isname.name.s.s, in->s, in->len);
	sp->pvp.pvn.u.isname.name.s.s[in->len] = 0;
	sp->pvp.pvn.u.isname.name.s.len = in->len;
	return 0;
}

static int pv_get_formated_time(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	static char buf[128];
	struct tm ltime;
	time_t t;

	if(msg==NULL)
		return -1;

	time( &t );
	localtime_r(&t, &ltime);
	res->rs.len = strftime( buf, 127, param->pvn.u.isname.name.s.s, &ltime);

	if (res->rs.len<=0)
		return pv_get_null(msg, param, res);

	res->rs.s = buf;
	res->flags = PV_VAL_STR;
	return 0;
}

#define CTIME_BUFFER_NO 5
#define CTIME_BUFFER_SIZE 26

static int pv_get_timef(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	static char ctime_bufs[CTIME_BUFFER_NO][CTIME_BUFFER_SIZE];
	static char *buf;
	static int ctime_buf_no = 0;
	time_t t;
	str s;

	if(msg==NULL)
		return -1;

	t = time(NULL);
	buf = ctime_bufs[ctime_buf_no];
	ctime_buf_no = (ctime_buf_no + 1) % CTIME_BUFFER_NO;
	s.s = ctime_r(&t, buf);
	s.len = strlen(s.s)-1;
	return pv_get_strintval(msg, param, res, &s, (int)t);
}

static int pv_get_msgid(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;
	return pv_get_uintval(msg, param, res, msg->id);
}

static int pv_get_method(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->first_line.type == SIP_REQUEST)
	{
		return pv_get_strintval(msg, param, res,
				&msg->first_line.u.request.method,
				(int)msg->first_line.u.request.method_value);
	}

	if(msg->cseq==NULL && ((parse_headers(msg, HDR_CSEQ_F, 0)==-1) ||
				(msg->cseq==NULL)))
	{
		LM_ERR("no CSEQ header\n");
		return pv_get_null(msg, param, res);
	}

	return pv_get_strintval(msg, param, res,
			&get_cseq(msg)->method,
			get_cseq(msg)->method_id);
}

static int pv_get_status(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->first_line.type != SIP_REPLY)
		return pv_get_null(msg, param, res);

	return pv_get_intstrval(msg, param, res,
			(int)msg->first_line.u.reply.statuscode,
			&msg->first_line.u.reply.status);
}

static int pv_get_reason(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->first_line.type != SIP_REPLY)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &msg->first_line.u.reply.reason);
}

static int pv_get_ruri(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL || res==NULL)
		return -1;

	if(msg->first_line.type == SIP_REPLY)	/* REPLY doesn't have a ruri */
		return pv_get_null(msg, param, res);

	if(msg->parsed_uri_ok==0 /* R-URI not parsed*/ && parse_sip_msg_uri(msg)<0)
	{
		LM_ERR("failed to parse the R-URI\n");
		return pv_get_null(msg, param, res);
	}

	if (msg->new_uri.s!=NULL)
		return pv_get_strval(msg, param, res, &msg->new_uri);
	return pv_get_strval(msg, param, res, &msg->first_line.u.request.uri);
}

static int pv_get_ru_q(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL || res==NULL)
		return -1;

	if(msg->first_line.type == SIP_REPLY)
		return pv_get_null(msg, param, res);

	return pv_get_sintval(msg, param, res, get_ruri_q(msg));
}

static int pv_get_ouri(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL || res==NULL)
		return -1;

	if(msg->first_line.type == SIP_REPLY)	/* REPLY doesn't have a ruri */
		return pv_get_null(msg, param, res);

	if(msg->parsed_orig_ruri_ok==0
			/* orig R-URI not parsed*/ && parse_orig_ruri(msg)<0)
	{
		LM_ERR("failed to parse the R-URI\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_strval(msg, param, res, &msg->first_line.u.request.uri);
}

static int pv_get_xuri_attr(struct sip_msg *msg, struct sip_uri *parsed_uri,
		pv_param_t *param, pv_value_t *res)
{
	unsigned short proto;
	str proto_s;

	if(param->pvn.u.isname.name.n==1) /* username */
	{
		if(parsed_uri->user.s==NULL || parsed_uri->user.len<=0)
			return pv_get_null(msg, param, res);
		return pv_get_strval(msg, param, res, &parsed_uri->user);
	} else if(param->pvn.u.isname.name.n==2) /* domain */ {
		if(parsed_uri->host.s==NULL || parsed_uri->host.len<=0)
			return pv_get_null(msg, param, res);
		return pv_get_strval(msg, param, res, &parsed_uri->host);
	} else if(param->pvn.u.isname.name.n==3) /* port */ {
		if(parsed_uri->port.s==NULL)
			return pv_get_uintval(msg, param, res,
				get_uri_port( parsed_uri, &proto));
		return pv_get_strintval(msg, param, res, &parsed_uri->port,
				(int)parsed_uri->port_no);
	} else if(param->pvn.u.isname.name.n==4) /* protocol */ {
		if(parsed_uri->transport_val.s==NULL) {
			get_uri_port(parsed_uri, &proto);
			proto_s.s = protos[proto].name;
			proto_s.len = strlen(proto_s.s);
			return pv_get_strintval(msg, param, res, &proto_s, (int)proto);
		}
		return pv_get_strintval(msg, param, res, &parsed_uri->transport_val,
				(int)parsed_uri->proto);
	}
	LM_ERR("unknown specifier\n");
	return pv_get_null(msg, param, res);
}

static int pv_get_ruri_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->first_line.type == SIP_REPLY)	/* REPLY doesn't have a ruri */
		return pv_get_null(msg, param, res);

	if(msg->parsed_uri_ok==0 /* R-URI not parsed*/ && parse_sip_msg_uri(msg)<0)
	{
		LM_ERR("failed to parse the R-URI\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_xuri_attr(msg, &(msg->parsed_uri), param, res);
}

static int pv_get_ouri_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->first_line.type == SIP_REPLY)	/* REPLY doesn't have a ruri */
		return pv_get_null(msg, param, res);

	if(msg->parsed_orig_ruri_ok==0
			/* orig R-URI not parsed*/ && parse_orig_ruri(msg)<0)
	{
		LM_ERR("failed to parse the R-URI\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_xuri_attr(msg, &(msg->parsed_orig_ruri), param, res);
}

static int pv_get_path(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(!msg->path_vec.s)
	{
		return pv_get_null(msg, param, res);
	}
	return pv_get_strval(msg, param, res, &msg->path_vec);
}

#define CT_NAME_S        "name"
#define CT_NAME_LEN      (sizeof(CT_NAME_S)-1)
#define CT_NAME_ID       1
#define CT_URI_S         "uri"
#define CT_URI_LEN       (sizeof(CT_URI_S)-1)
#define CT_URI_ID        2
#define CT_Q_S           "q"
#define CT_Q_LEN         (sizeof(CT_Q_S)-1)
#define CT_Q_ID          3
#define CT_EXPIRES_S     "expires"
#define CT_EXPIRES_LEN   (sizeof(CT_EXPIRES_S)-1)
#define CT_EXPIRES_ID     4
#define CT_METHODS_S     "methods"
#define CT_METHODS_LEN   (sizeof(CT_METHODS_S)-1)
#define CT_METHODS_ID    5
#define CT_RECEIVED_S    "received"
#define CT_RECEIVED_LEN  (sizeof(CT_RECEIVED_S)-1)
#define CT_RECEIVED_ID   6
#define CT_PARAMS_S      "params"
#define CT_PARAMS_LEN    (sizeof(CT_PARAMS_S)-1)
#define CT_PARAMS_ID     7

static int pv_parse_ct_name(pv_spec_p sp, const str *in)
{
	if (sp==NULL)
		return -1;

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = 0;

	if (in==NULL || in->s==NULL || in->len==0) {
		sp->pvp.pvn.u.isname.name.n = 0;
	} else
	if (in->len==CT_NAME_LEN &&
	strncasecmp(in->s, CT_NAME_S, CT_NAME_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_NAME_ID;
	} else
	if (in->len==CT_URI_LEN &&
	strncasecmp(in->s, CT_URI_S, CT_URI_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_URI_ID;
	} else
	if (in->len==CT_Q_LEN &&
	strncasecmp(in->s, CT_Q_S, CT_Q_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_Q_ID;
	} else
	if (in->len==CT_EXPIRES_LEN &&
	strncasecmp(in->s, CT_EXPIRES_S, CT_EXPIRES_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_EXPIRES_ID;
	} else
	if (in->len==CT_METHODS_LEN &&
	strncasecmp(in->s, CT_METHODS_S, CT_METHODS_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_METHODS_ID;
	} else
	if (in->len==CT_RECEIVED_LEN &&
	strncasecmp(in->s, CT_RECEIVED_S, CT_RECEIVED_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_RECEIVED_ID;
	} else
	if (in->len==CT_PARAMS_LEN &&
	strncasecmp(in->s, CT_PARAMS_S, CT_PARAMS_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = CT_PARAMS_ID;
	} else {
		LM_ERR("unsupported CT field <%.*s>\n",in->len,in->s);
		return -1;
	}

	return 0;
}


static inline int get_contact_body_field(pv_value_t *res,struct hdr_field *cth,
										contact_t *ct, pv_name_t *pvn)
{
	param_t *p;

	if (ct==NULL) {
		/* star contact hdr */
		if (pvn->u.isname.name.n==0) {
			res->rs = cth->body;
			res->flags = PV_VAL_STR;
			return 0;
		}
		return pv_get_null(NULL, NULL, res);
	}

	switch (pvn->u.isname.name.n) {
		case 0: /* all body */
			res->rs.s = ct->name.s?ct->name.s:ct->uri.s;
			res->rs.len = ct->len;
			break;
		case CT_NAME_ID: /* name only */
			if (ct->name.s==NULL || ct->name.len==0)
				return pv_get_null(NULL, NULL, res);
			res->rs = ct->name;
			break;
		case CT_URI_ID: /* uri only */
			res->rs = ct->uri;
			break;
		case CT_Q_ID: /* Q param only */
			if ( !ct->q || !ct->q->body.s || !ct->q->body.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = ct->q->body;
			break;
		case CT_EXPIRES_ID: /* EXPIRES param only */
			if (!ct->expires||!ct->expires->body.s||!ct->expires->body.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = ct->expires->body;
			break;
		case CT_METHODS_ID: /* METHODS param only */
			if (!ct->methods||!ct->methods->body.s||!ct->methods->body.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = ct->methods->body;
			break;
		case CT_RECEIVED_ID: /* RECEIVED param only */
			if(!ct->received||!ct->received->body.s||!ct->received->body.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = ct->received->body;
			break;
		case CT_PARAMS_ID: /* all param */
			if (!ct->params)
				return pv_get_null(NULL, NULL, res);
			res->rs.s = ct->params->name.s;
			for( p=ct->params ; p->next ; p=p->next);
			res->rs.len = p->name.s + p->len - res->rs.s;
			break;
		default:
			LM_CRIT("BUG - unsupported ID %d\n",pvn->u.isname.type);
			return pv_get_null(NULL, NULL, res);
	}

	res->flags = PV_VAL_STR;
	return 0;
}


static int pv_get_contact_body(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	struct hdr_field *ct_h;
	contact_body_t *ct_b;
	contact_t *ct;
	int idx;
	int idxf;
	char *p;

	if(msg==NULL)
		return -1;

	/* get all CONTACT headers */
	if(parse_headers(msg, HDR_EOH_F, 0)==-1 || msg->contact==NULL ||
	!msg->contact->body.s || msg->contact->body.len<=0)
	{
		LM_DBG("no contact header!\n");
		return pv_get_null(msg, param, res);
	}

	ct_h = msg->contact;
	if (parse_contact( ct_h )!=0) {
		LM_ERR("failed to parse contact hdr\n");
		return -1;
	}
	ct_b = (contact_body_t*)ct_h->parsed;
	if (ct_b==NULL)
		return pv_get_null(msg, param, res);
	ct = ct_b->contacts;

	/* get the index */
	if(pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if( idxf!=PV_IDX_ALL && idx==0) {
		/* no index specified -> return the first contact body */
		return get_contact_body_field( res , ct_h, ct, &param->pvn);
	}

	if(idxf==PV_IDX_ALL) {
		/* return all contact bodies */
		p = pv_local_buf;
		do {
			if(p!=pv_local_buf) {
				if (p-pv_local_buf+PV_FIELD_DELIM_LEN+1>PV_LOCAL_BUF_SIZE){
					LM_ERR("local buffer length exceeded\n");
					return pv_get_null(msg, param, res);
				}
				memcpy(p, PV_FIELD_DELIM, PV_FIELD_DELIM_LEN);
				p += PV_FIELD_DELIM_LEN;
			}

			get_contact_body_field( res , ct_h, ct, &param->pvn);
			if (p-pv_local_buf+res->rs.len+1>PV_LOCAL_BUF_SIZE) {
				LM_ERR("local buffer length exceeded!\n");
				return pv_get_null(msg, param, res);
			}
			memcpy(p, res->rs.s, res->rs.len);
			p += res->rs.len;

			ct = ct?ct->next:NULL;
			while (ct==NULL && ct_h!=NULL) {
				ct_h = ct_h->sibling;
				if (ct_h) {
					if (parse_contact( ct_h )!=0) {
						LM_ERR("failed to parse contact hdr\n");
						return -1;
					}
					ct_b = (contact_body_t*)ct_h->parsed;
					ct = ct_b->contacts;
				}
			}
		} while (ct_h);

		res->rs.s = pv_local_buf;
		res->rs.len = p - pv_local_buf;
		res->flags = PV_VAL_STR;
		return 0;
	}

	/* numerical index */
	if (idx<0) {
		/* index from the end */
		idxf=0;
		while(ct_h) {
			idxf++;
			ct = ct?ct->next:NULL;
			while (ct==NULL && ct_h!=NULL) {
				ct_h = ct_h->sibling;
				if (ct_h) {
					if (parse_contact( ct_h)!=0) {
						LM_ERR("failed to parse contact hdr\n");
						return -1;
					}
					ct_b = (contact_body_t*)ct_h->parsed;
					ct = ct_b->contacts;
				}
			}
		}
		if (-idx>idxf)
			return pv_get_null(msg, param, res);

		idx = idxf +idx;
		ct_h = msg->contact;
		ct_b = (contact_body_t*)ct_h->parsed;
		ct = ct_b->contacts;
	}

	while (idx!=0 && ct_h) {
		/* get to the next contact body */
		idx--;
		ct = ct?ct->next:NULL;
		while (ct==NULL && ct_h!=NULL) {
			ct_h = ct_h->sibling;
			if (ct_h) {
				if (parse_contact( ct_h )!=0) {
					LM_ERR("failed to parse contact hdr\n");
					return -1;
				}
				ct_b = (contact_body_t*)ct_h->parsed;
				ct = ct_b->contacts;
			}
		}
	}

	/* nothing found ?*/
	if (ct==NULL)
		return pv_get_null(msg, param, res);

	/* take the current body */
	return get_contact_body_field( res , ct_h, ct, &param->pvn);
}

extern err_info_t _oser_err_info;
static int pv_get_errinfo_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(param->pvn.u.isname.name.n==0) /* class */ {
		return pv_get_sintval(msg, param, res, _oser_err_info.eclass);
	} else if(param->pvn.u.isname.name.n==1) /* level */ {
		return pv_get_sintval(msg, param, res, _oser_err_info.level);
	} else if(param->pvn.u.isname.name.n==2) /* info */ {
		if(_oser_err_info.info.s==NULL)
			pv_get_null(msg, param, res);
		return pv_get_strval(msg, param, res, &_oser_err_info.info);
	} else if(param->pvn.u.isname.name.n==3) /* rcode */ {
		return pv_get_sintval(msg, param, res, _oser_err_info.rcode);
	} else if(param->pvn.u.isname.name.n==4) /* rreason */ {
		if(_oser_err_info.rreason.s==NULL)
			pv_get_null(msg, param, res);
		return pv_get_strval(msg, param, res, &_oser_err_info.rreason);
	} else {
		LM_DBG("invalid attribute!\n");
		return pv_get_null(msg, param, res);
	}
}

static int pv_get_xto_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res, struct to_body *xto, int type)
{
	struct sip_uri *uri;
	if(xto==NULL)
		return -1;

	if(param->pvn.u.isname.name.n==1) /* uri */
		return pv_get_strval(msg, param, res, &xto->uri);

	if(param->pvn.u.isname.name.n==4) /* tag */
	{
		if (xto->tag_value.s==NULL || xto->tag_value.len<=0)
		{
		        LM_DBG("no Tag parameter\n");
		        return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &xto->tag_value);
	}

	if(param->pvn.u.isname.name.n==5) /* display name */
	{
		if(xto->display.s==NULL || xto->display.len<=0)
		{
			LM_DBG("no Display name\n");
			return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &xto->display);
	}

	if(type==0)
	{
		if((uri=parse_to_uri(msg))==NULL)
		{
			LM_ERR("cannot parse To URI\n");
			return pv_get_null(msg, param, res);
		}
	} else {
		if((uri=parse_from_uri(msg))==NULL)
		{
			LM_ERR("cannot parse From URI\n");
			return pv_get_null(msg, param, res);
		}
	}

	if(param->pvn.u.isname.name.n==2) /* username */
	{
	    if(uri->user.s==NULL || uri->user.len<=0)
		{
		    LM_DBG("no username\n");
			return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &uri->user);
	} else if(param->pvn.u.isname.name.n==3) /* domain */ {
	    if(uri->host.s==NULL || uri->host.len<=0)
		{
		    LM_DBG("no domain\n");
			return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &uri->host);
	}

	LM_ERR("unknown specifier\n");
	return pv_get_null(msg, param, res);
}

static int pv_get_to_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->to==NULL && parse_headers(msg, HDR_TO_F, 0)==-1)
	{
		LM_ERR("cannot parse To header\n");
		return pv_get_null(msg, param, res);
	}
	if(msg->to==NULL || get_to(msg)==NULL) {
		LM_DBG("no To header\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_xto_attr(msg, param, res, get_to(msg), 0);
}

static int pv_get_from_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(parse_from_header(msg)<0)
	{
		LM_ERR("cannot parse From header\n");
		return pv_get_null(msg, param, res);
	}

	if(msg->from==NULL || get_from(msg)==NULL) {
		LM_DBG("no From header\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_xto_attr(msg, param, res, get_from(msg), 1);
}

static int pv_get_cseq(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->cseq==NULL && ((parse_headers(msg, HDR_CSEQ_F, 0)==-1)
				|| (msg->cseq==NULL)) )
	{
		LM_ERR("cannot parse CSEQ header\n");
		return pv_get_null(msg, param, res);
	}
	return pv_get_strval(msg, param, res, &(get_cseq(msg)->number));
}

static int pv_get_msg_buf(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str s;
	if(msg==NULL)
		return -1;

	s.s = msg->buf;
	s.len = msg->len;
	return pv_get_strval(msg, param, res, &s);
}

static int pv_get_msg_len(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	return pv_get_uintval(msg, param, res, msg->len);
}

static int pv_get_flags(struct sip_msg *msg, pv_param_t *param,
                         pv_value_t *res)
{
	str buf;

	if (!msg)
		return -1;

	buf = bitmask_to_flag_list(FLAG_TYPE_MSG, msg->flags);

	return pv_get_strval(msg, param, res, &buf);
}

static int pv_get_bflags(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str buf;

	if (!msg)
		return -1;

	buf = bitmask_to_flag_list(FLAG_TYPE_BRANCH, getb0flags(msg));

	return pv_get_strval(msg, param, res, &buf);
}

static int pv_get_callid(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->callid==NULL && ((parse_headers(msg, HDR_CALLID_F, 0)==-1) ||
				(msg->callid==NULL)) )
	{
		LM_ERR("cannot parse Call-Id header\n");
		return pv_get_null(msg, param, res);
	}

	return pv_get_strval(msg, param, res, &msg->callid->body);
}

static int pv_get_srcip(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str s;
	if(msg==NULL)
		return -1;

	if ( (s.s=ip_addr2a(&msg->rcv.src_ip))==NULL)
		return pv_get_null(msg, param, res);
	s.len = strlen(s.s);
	return pv_get_strval(msg, param, res, &s);
}

static int pv_get_srcport(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;
	return pv_get_uintval(msg, param, res, msg->rcv.src_port);
}

static int pv_get_rcvip(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->rcv.bind_address==NULL
			|| msg->rcv.bind_address->address_str.s==NULL)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &msg->rcv.bind_address->address_str);
}

static int pv_get_rcvport(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(msg->rcv.bind_address==NULL
			|| msg->rcv.bind_address->port_no_str.s==NULL)
		return pv_get_null(msg, param, res);

	return pv_get_intstrval(msg, param, res,
			(int)msg->rcv.bind_address->port_no,
			&msg->rcv.bind_address->port_no_str);
}

static int pv_get_force_sock(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if (msg->force_send_socket==0)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &msg->force_send_socket->sock_str);
}

static int pv_get_useragent(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;
	if(msg->user_agent==NULL && ((parse_headers(msg, HDR_USERAGENT_F, 0)==-1)
			 || (msg->user_agent==NULL)))
	{
		LM_DBG("no User-Agent header\n");
		return pv_get_null(msg, param, res);
	}

	return pv_get_strval(msg, param, res, &msg->user_agent->body);
}

static int pv_get_refer_to(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(parse_refer_to_header(msg)==-1)
	{
		LM_DBG("no Refer-To header\n");
		return pv_get_null(msg, param, res);
	}

	if(msg->refer_to==NULL || get_refer_to(msg)==NULL)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &(get_refer_to(msg)->uri));
}

static int pv_get_diversion(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str *val;
	str name;

	if(msg == NULL)
		return -1;

	if(parse_diversion_header(msg) == -1)
	{
		LM_DBG("no Diversion header\n");
		return pv_get_null(msg, param, res);
	}

	if(msg->diversion == NULL || get_diversion(msg) == NULL)
	{
		LM_DBG("no Diversion header\n");
		return pv_get_null(msg, param, res);
	}

	if(param->pvn.u.isname.name.n == 1)  { /* uri */
		return pv_get_strval(msg, param, res, &(get_diversion(msg)->uri));
	}

	if(param->pvn.u.isname.name.n == 2)  { /* reason param */
	    name.s = "reason";
	    name.len = 6;
	    val = diversion_param(msg, name);
	    if (val) {
			return pv_get_strval(msg, param, res, val);
	    } else {
			return pv_get_null(msg, param, res);
	    }
	}

	if(param->pvn.u.isname.name.n == 3)  { /* privacy param */
	    name.s = "privacy";
	    name.len = 7;
	    val = diversion_param(msg, name);
	    if (val) {
			return pv_get_strval(msg, param, res, val);
	    } else {
			return pv_get_null(msg, param, res);
	    }
	}

	LM_ERR("unknown diversion specifier\n");
	return pv_get_null(msg, param, res);
}

static int pv_get_rpid(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if(parse_rpid_header(msg)==-1)
	{
		LM_DBG("no RPID header\n");
		return pv_get_null(msg, param, res);
	}

	if(msg->rpid==NULL || get_rpid(msg)==NULL)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &(get_rpid(msg)->uri));
}

static int pv_get_ppi_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
    struct sip_uri *uri;

    if(msg==NULL)
	return -1;

    if(parse_ppi_header(msg) < 0) {
	LM_DBG("no P-Preferred-Identity header\n");
	return pv_get_null(msg, param, res);
    }

    if(msg->ppi == NULL || get_ppi(msg) == NULL) {
	       LM_DBG("no P-Preferred-Identity header\n");
		return pv_get_null(msg, param, res);
    }

    if(param->pvn.u.isname.name.n == 1) { /* uri */
		return pv_get_strval(msg, param, res, &(get_ppi(msg)->uri));
    }

    if(param->pvn.u.isname.name.n==4) { /* display name */
		if(get_ppi(msg)->display.s == NULL ||
				get_ppi(msg)->display.len <= 0) {
		    LM_DBG("no P-Preferred-Identity display name\n");
			return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &(get_ppi(msg)->display));
    }

    if((uri=parse_ppi_uri(msg))==NULL) {
		LM_ERR("cannot parse P-Preferred-Identity URI\n");
		return pv_get_null(msg, param, res);
    }

    if(param->pvn.u.isname.name.n==2) { /* username */
		if(uri->user.s==NULL || uri->user.len<=0) {
		    LM_DBG("no P-Preferred-Identity username\n");
		    return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &uri->user);
    } else if(param->pvn.u.isname.name.n==3) { /* domain */
		if(uri->host.s==NULL || uri->host.len<=0) {
			LM_DBG("no P-Preferred-Identity domain\n");
			return pv_get_null(msg, param, res);
		}
		return pv_get_strval(msg, param, res, &uri->host);
    }

	LM_ERR("unknown specifier\n");
	return pv_get_null(msg, param, res);
}

static int pv_get_pai(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
    if(msg==NULL)
		return -1;

    if(parse_pai_header(msg)==-1)
    {
		LM_DBG("no P-Asserted-Identity header\n");
		return pv_get_null(msg, param, res);
    }

    if(msg->pai==NULL || get_pai(msg)==NULL) {
		LM_DBG("no P-Asserted-Identity header\n");
		return pv_get_null(msg, param, res);
    }

	return pv_get_strval(msg, param, res, &(get_pai(msg)->uri));
}

/* proto of received message: $pr or $proto*/
static int pv_get_proto(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str s;
	if(msg==NULL)
		return -1;

	if ( msg->rcv.proto>=PROTO_FIRST && msg->rcv.proto<PROTO_LAST &&
	protos[msg->rcv.proto].id ) {
		s.s = protos[msg->rcv.proto].name;
		s.len = strlen(s.s);
	} else {
		s = str_null;
	}

	return pv_get_strintval(msg, param, res, &s, (int)msg->rcv.proto);
}


static int pv_get_dset(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str s;

	if(msg==NULL)
		return -1;

	s.s = print_dset(msg, &s.len);
	if (s.s == NULL)
		return pv_get_null(msg, param, res);
	s.len -= CRLF_LEN;

	return pv_get_strval(msg, param, res, &s);
}


static int pv_get_dsturi(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	if (msg->dst_uri.s == NULL) {
		LM_DBG("no destination URI\n");
		return pv_get_null(msg, param, res);
	}

	return pv_get_strval(msg, param, res, &msg->dst_uri);
}

static int pv_get_dsturi_attr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	struct sip_uri uri;
	unsigned short proto;
	str proto_s;

	if(msg==NULL)
		return -1;

	if (msg->dst_uri.s == NULL) {
		LM_DBG("no destination URI\n");
		return pv_get_null(msg, param, res);
	}

	if(parse_uri(msg->dst_uri.s, msg->dst_uri.len, &uri)!=0)
	{
		LM_ERR("failed to parse dst uri\n");
		return pv_get_null(msg, param, res);
	}

	if(param->pvn.u.isname.name.n==1) /* domain */
	{
		if(uri.host.s==NULL || uri.host.len<=0)
			return pv_get_null(msg, param, res);
		return pv_get_strval(msg, param, res, &uri.host);
	} else if(param->pvn.u.isname.name.n==2) /* port */ {
		if(uri.port.s==NULL)
			return pv_get_uintval(msg, param, res, get_uri_port(&uri, &proto));
		return pv_get_strintval(msg, param, res, &uri.port, (int)uri.port_no);
	} else if(param->pvn.u.isname.name.n==3) /* proto */ {
		if(uri.transport_val.s==NULL) {
			get_uri_port(&uri, &proto);
			proto_s.s = protos[proto].name;
			proto_s.len = strlen(proto_s.s);
			return pv_get_strintval(msg, param, res, &proto_s, (int)proto);
		}
		return pv_get_strintval(msg, param, res, &uri.transport_val,
				(int)uri.proto);
	}

	LM_ERR("invalid specifier\n");
	return pv_get_null(msg, param, res);
}

static int pv_get_content_type(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
#define BUFLEN 1024

	str s;
	int idx=-1;
	int idxf=-1;
	int distance=0;
	char buf[BUFLEN];
	struct sip_msg_body* sbody;
	struct body_part* body_part;
	struct body_part* neg_index[2];

	if(msg==NULL)
		return -1;

	if (pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	/* no index or all contenttypes */
	if (param->pvi.type==0 || idxf == PV_IDX_ALL) {
		if(msg->content_type==NULL
				&& ((parse_headers(msg, HDR_CONTENTTYPE_F, 0)==-1)
				 || (msg->content_type==NULL)))
		{
			LM_DBG("no Content-Type header\n");
			return pv_get_null(msg, param, res);
		}

		/* only the main contenttype requested*/
		if (param->pvi.type==0)
			return pv_get_strval(msg, param, res, &msg->content_type->body);
	}

	if ( parse_sip_body(msg)<0 || (sbody=msg->body)==NULL ) {
		LM_DBG("no body found\n");
		return pv_get_null(msg, param, res);
	}

	/* one contenttype request */
	if (idxf != PV_IDX_ALL) {
		if (idx< 0) {
			neg_index[0] = neg_index[1] = &sbody->first;
			/*distance=last_body_postition-searched_body_position*/
			distance -= idx+1;
			while (neg_index[1]->next) {
				if (distance == 0) {
					neg_index[0] = neg_index[0]->next;
				} else {
					distance--;
				}
				neg_index[1] = neg_index[1]->next;
			}

			if (distance>0) {
				LM_ERR("Index too low [%d]\n", idx);
				return pv_get_null(msg, param, res);
			}

			s.s = convert_mime2string_CT(neg_index[0]->mime);
			s.len = strlen(s.s);
		} else {
			body_part = &sbody->first;
			distance = idx;
			while (distance && body_part->next) {
				distance--;
				body_part=body_part->next;
			}

			if (distance > 0) {
				LM_ERR("Index too big [%d]\n", idx);
				return pv_get_null(msg, param, res);
			}

			s.s = convert_mime2string_CT(body_part->mime);
			s.len = strlen(s.s);
		}
	} else {
		/* copy main content type */
		memcpy(buf, msg->content_type->body.s, msg->content_type->body.len);
		buf[msg->content_type->body.len] = ',';
		s.len = msg->content_type->body.len+1;

		/* copy all the other contenttypes */
		body_part = &sbody->first;
		while (body_part) {
			s.s = convert_mime2string_CT(body_part->mime);
			if (s.len + strlen(s.s) >= BUFLEN) {
				LM_CRIT("buffer overflow! Too many contenttypes!\n");
				return pv_get_null(msg, param, res);
			}

			memcpy( buf+s.len, s.s, strlen(s.s));
			s.len += strlen(s.s);

			/* delimiter only if something follows */
			if(body_part->next)
				buf[s.len++] = ',';

			body_part = body_part->next;
		}
		s.s = buf;
	}

	return pv_get_strval(msg, param, res, &s);

#undef BUFLEN
}

static int pv_get_content_length(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;
	if(msg->content_length==NULL
			&& ((parse_headers(msg, HDR_CONTENTLENGTH_F, 0)==-1)
			 || (msg->content_length==NULL)))
	{
		LM_DBG("no Content-Length header\n");
		return pv_get_null(msg, param, res);
	}

	return pv_get_intstrval(msg, param, res,
			(int)(long)msg->content_length->parsed,
			&msg->content_length->body);
}

static int pv_parse_rb_name(pv_spec_p sp, const str *in)
{
	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;

	if (decode_mime_type( in->s, in->s+in->len ,
	(unsigned int *)&sp->pvp.pvn.u.isname.name.n , NULL) == 0) {
		LM_ERR("unsupported mime <%.*s>\n",in->len,in->s);
		return -1;
	}

	sp->pvp.pvn.type = PV_NAME_INTSTR;  /* INT/STR for var name type */
	sp->pvp.pvn.u.isname.type = 0;      /* name is INT */

	return 0;
}


static int pv_get_msg_body(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str s;
	int idx=-1;
	int idxf=-1;
	int distance=0;
	struct sip_msg_body* sbody;
	struct body_part* body_part;
	struct body_part* neg_index[2];
	unsigned int mime;

	if(msg==NULL)
		return -1;

	if (pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	/* any index specified */
	if (param->pvi.type==0 || idxf==PV_IDX_ALL) {
		if (param->pvn.u.isname.name.n==0) {
			/* no name/mime -> requests all bodies */
			if (get_body( msg, &s)!=0 || s.len==0 ) {
				LM_DBG("no message body\n");
				return pv_get_null(msg, param, res);
			}
			goto end;
		} else {
			/* return first part with the requested mime */
			idx = 0;
		}
	}

	if ( parse_sip_body(msg)<0 || (sbody=msg->body)==NULL ) {
		LM_DBG("no body found\n");
		return pv_get_null(msg, param, res);
	}

	mime = param->pvn.u.isname.name.n;
	LM_DBG("--------mime is <%d>, idx=%d\n",mime, idx);

#define first_part_by_mime( _part_start, _part_end, _mime) \
	do {\
		_part_end = _part_start;\
		while( (_part_end) && \
		!(is_body_part_received(_part_end) && ((_mime)==0 || \
		(_mime)==(_part_end)->mime )) ) { \
			_part_end = (_part_end)->next; \
		} \
	}while(0)

	if (idx<0) {
		first_part_by_mime( &sbody->first, neg_index[1], mime );
		neg_index[0] = neg_index[1];
		/*distance=last_body_postition-searched_body_position*/
		distance -= idx+1;
		while (neg_index[1]->next) {
			if (distance == 0) {
				first_part_by_mime( neg_index[0]->next, neg_index[0], mime );
			} else {
				distance--;
			}
			first_part_by_mime( neg_index[1]->next, neg_index[1], mime );
		}

		if (distance>0) {
			LM_DBG("Index too low [%d]\n", idx);
			return pv_get_null(msg, param, res);
		}

		s.s = neg_index[0]->body.s;
		s.len = neg_index[0]->body.len;
	} else {
		first_part_by_mime( &sbody->first, body_part, mime );
		distance = idx;
		while (distance && body_part ) {
			distance--;
			first_part_by_mime( body_part->next, body_part, mime );
		}

		if (distance>0 || body_part==NULL) {
			LM_DBG("Index too big [%d], body_part=%p\n", idx,body_part);
			return pv_get_null(msg, param, res);
		}

		s.s = body_part->body.s;
		s.len = body_part->body.len;
	}

end:
	return pv_get_strval(msg, param, res, &s);
}

static int pv_get_authattr(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	struct hdr_field *hdr;
	str *s;

	if(msg==NULL)
		return -1;

	if ((msg->REQ_METHOD==METHOD_ACK) || (msg->REQ_METHOD==METHOD_CANCEL)) {
		LM_DBG("no [Proxy-]Authorization header\n");
		return pv_get_null(msg, param, res);
	}

	if ((parse_headers(msg, HDR_PROXYAUTH_F|HDR_AUTHORIZATION_F, 0)==-1)
			|| (msg->proxy_auth==0 && msg->authorization==0))
	{
		LM_DBG("no [Proxy-]Authorization header\n");
		return pv_get_null(msg, param, res);
	}

	hdr = (msg->proxy_auth==0)?msg->authorization:msg->proxy_auth;
	if(parse_credentials(hdr)!=0) {
		LM_ERR("failed to parse credentials\n");
		return pv_get_null(msg, param, res);
	}

	switch(param->pvn.u.isname.name.n)
	{
		case 11:
			s = &((auth_body_t*)(hdr->parsed))->digest.nc;
			break;
		case 10:
			s = &((auth_body_t*)(hdr->parsed))->digest.qop.qop_str;
			break;
		case 9:
			s = &((auth_body_t*)(hdr->parsed))->digest.alg.alg_str;
			break;
		case 8:
			s = &((auth_body_t*)(hdr->parsed))->digest.opaque;
			break;
		case 7:
			s = &((auth_body_t*)(hdr->parsed))->digest.cnonce;
			break;
		case 6:
			s = &((auth_body_t*)(hdr->parsed))->digest.response;
			break;
		case 5:
			s = &((auth_body_t*)(hdr->parsed))->digest.nonce;
			break;
		case 4:
			s = &((auth_body_t*)(hdr->parsed))->digest.username.domain;
			break;
		case 3:
			s = &((auth_body_t*)(hdr->parsed))->digest.uri;
			break;
		case 2:
			s = &((auth_body_t*)(hdr->parsed))->digest.realm;
			break;
		case 1:
			s = &((auth_body_t*)(hdr->parsed))->digest.username.user;
			break;
		default:
			s = &((auth_body_t*)(hdr->parsed))->digest.username.whole;
	}

	if (s->len==0)
		return pv_get_null(msg, param, res);
	return pv_get_strval(msg, param, res, s);
}


static inline str *cred_user(struct sip_msg *rq)
{
	struct hdr_field* h;
	auth_body_t* cred;

	get_authorized_cred(rq->proxy_auth, &h);
	if (!h) get_authorized_cred(rq->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;
}


static inline str *cred_realm(struct sip_msg *rq)
{
	str* realm;
	struct hdr_field* h;
	auth_body_t* cred;

	get_authorized_cred(rq->proxy_auth, &h);
	if (!h) get_authorized_cred(rq->authorization, &h);
	if (!h) return 0;
	cred=(auth_body_t*)(h->parsed);
	if (!cred) return 0;
	realm = GET_REALM(&cred->digest);
	if (!realm->len || !realm->s) {
		return 0;
	}
	return realm;
}

static int pv_get_acc_username(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	static char buf[MAX_URI_SIZE];
	str* user;
	str* realm;
	struct sip_uri puri;
	struct to_body* from;
	str s;

	/* try to take it from credentials */
	user = cred_user(msg);
	if (user) {
		realm = cred_realm(msg);
		if (realm) {
			s.len = user->len+1+realm->len;
			if (s.len > MAX_URI_SIZE) {
				LM_ERR("uri too long\n");
				return pv_get_null(msg, param, res);
			}
			s.s = buf;
			memcpy(s.s, user->s, user->len);
			(s.s)[user->len] = '@';
			memcpy(s.s+user->len+1, realm->s, realm->len);
			return pv_get_strval(msg, param, res, &s);
		}
		return pv_get_strval(msg, param, res, user);
	}

	/* from from uri */
	if(parse_from_header(msg)<0)
	{
		LM_ERR("cannot parse FROM header\n");
		return pv_get_null(msg, param, res);
	}
	if (msg->from && (from=get_from(msg)) && from->uri.len) {
		if (parse_uri(from->uri.s, from->uri.len, &puri) < 0 ) {
			LM_ERR("bad From URI\n");
			return pv_get_null(msg, param, res);
		}
		s.len = puri.user.len + 1 + puri.host.len;
		if (s.len > MAX_URI_SIZE) {
			LM_ERR("from URI too long\n");
			return pv_get_null(msg, param, res);
		}
		s.s = buf;
		memcpy(s.s, puri.user.s, puri.user.len);
		(s.s)[puri.user.len] = '@';
		memcpy(s.s + puri.user.len + 1, puri.host.s, puri.host.len);
	} else {
		s.len = 0;
		s.s = 0;
	}
	return pv_get_strval(msg, param, res, &s);
}


#define BR_URI_S         "uri"
#define BR_URI_LEN       (sizeof(BR_URI_S)-1)
#define BR_URI_ID        1
#define BR_DURI_S        "duri"
#define BR_DURI_LEN      (sizeof(BR_DURI_S)-1)
#define BR_DURI_ID       2
#define BR_Q_S           "q"
#define BR_Q_LEN         (sizeof(BR_Q_S)-1)
#define BR_Q_ID          3
#define BR_PATH_S        "path"
#define BR_PATH_LEN      (sizeof(BR_PATH_S)-1)
#define BR_PATH_ID       4
#define BR_FLAGS_S       "flags"
#define BR_FLAGS_LEN     (sizeof(BR_FLAGS_S)-1)
#define BR_FLAGS_ID       5
#define BR_SOCKET_S       "socket"
#define BR_SOCKET_LEN     (sizeof(BR_SOCKET_S)-1)
#define BR_SOCKET_ID      6

static int pv_parse_branch_name(pv_spec_p sp, const str *in)
{
	if (sp==NULL || in==NULL || in->s==NULL || in->len==0)
		return -1;

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = 0;

	if (in->len==BR_URI_LEN &&
	strncasecmp(in->s, BR_URI_S, BR_URI_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_URI_ID;
	} else
	if (in->len==BR_DURI_LEN &&
	strncasecmp(in->s, BR_DURI_S, BR_DURI_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_DURI_ID;
	} else
	if (in->len==BR_Q_LEN &&
	strncasecmp(in->s, BR_Q_S, BR_Q_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_Q_ID;
	} else
	if (in->len==BR_PATH_LEN &&
	strncasecmp(in->s, BR_PATH_S, BR_PATH_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_PATH_ID;
	} else
	if (in->len==BR_FLAGS_LEN &&
	strncasecmp(in->s, BR_FLAGS_S, BR_FLAGS_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_FLAGS_ID;
	} else
	if (in->len==BR_SOCKET_LEN &&
	strncasecmp(in->s, BR_SOCKET_S, BR_SOCKET_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = BR_SOCKET_ID;
	} else {
		LM_ERR("unsupported BRANCH field <%.*s>\n",in->len,in->s);
		return -1;
	}

	return 0;
}

static inline int get_branch_field( int idx, pv_name_t *pvn, pv_value_t *res)
{
	str uri;
	qvalue_t q;
	str duri;
	str path;
	unsigned int flags;
	struct socket_info *si;

	uri.s = get_branch(idx, &uri.len, &q, &duri, &path, &flags, &si);
	if (!uri.s)
		return pv_get_null( NULL, NULL, res);

	/* got a valid branch, return the field */
	switch (pvn->u.isname.name.n) {
		case 0:
		case BR_URI_ID: /* return URI */
			res->rs = uri;
			res->flags = PV_VAL_STR;
			break;
		case BR_Q_ID: /* return Q */
			res->rs.s = q2str(q, (unsigned int*)&res->rs.len);
			res->flags = PV_VAL_STR;
			break;
		case BR_DURI_ID: /* return DURI */
			if ( !duri.s || !duri.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = duri;
			res->flags = PV_VAL_STR;
			break;
		case BR_PATH_ID: /* return PATH */
			if ( !path.s || !path.len)
				return pv_get_null(NULL, NULL, res);
			res->rs = path;
			res->flags = PV_VAL_STR;
			break;
		case BR_FLAGS_ID: /* return FLAGS */
			res->rs = bitmask_to_flag_list(FLAG_TYPE_BRANCH, flags);
			res->flags = PV_VAL_STR;
			break;
		case BR_SOCKET_ID: /* return SOCKET */
			if ( !si )
				return pv_get_null(NULL, NULL, res);
			res->rs = si->sock_str;
			res->flags = PV_VAL_STR;
			break;
		default:
			LM_CRIT("BUG - unsupported ID %d\n",pvn->u.isname.name.n);
			return pv_get_null(NULL, NULL, res);
	}
	return 0;
}


static int pv_get_branch_fields(struct sip_msg *msg, pv_param_t *param,
		pv_value_t *res)
{
	str uri;
	qvalue_t q;
	int idx;
	int idxf;
	char *p;

	if(msg==NULL || res==NULL)
		return -1;

	if (get_nr_branches() == 0)
		return pv_get_null(msg, param, res);

	/* get the index */
	if(pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if (idxf!=PV_IDX_ALL && idx==0) {
		/* no index specified -> return the first branch */
		return get_branch_field( 0, &param->pvn, res);
	}

	if(idxf==PV_IDX_ALL) {
		/* return all branches */
		p = pv_local_buf;
		idx = 0;

		while ( (uri.s=get_branch(idx, &uri.len, &q, 0, 0, 0, 0))!=NULL ) {

			if ( pv_local_buf + PV_LOCAL_BUF_SIZE <=
			p + uri.len + PV_FIELD_DELIM_LEN ) {
				LM_ERR("local buffer length exceeded\n");
				return pv_get_null(msg, param, res);
			}

			if (idx) {
				memcpy(p, PV_FIELD_DELIM, PV_FIELD_DELIM_LEN);
				p += PV_FIELD_DELIM_LEN;
			}

			memcpy(p, uri.s, uri.len);
			p += uri.len;
			idx++;
		}

		res->rs.s = pv_local_buf;
		res->rs.len = p - pv_local_buf;
		res->flags = PV_VAL_STR;
		return 0;
	}

	/* numerical index */
	if (idx<0) {
		/* index from the end */
		if (-idx > get_nr_branches())
			return pv_get_null(msg, param, res);
		idx = get_nr_branches() + idx;
	}

	/* return the request branch info */
	return get_branch_field( idx, &param->pvn, res);
}


/******** LISTENING SOCKETS related vars & functions **********/

#define SOCK_IP_S             "ip"
#define SOCK_IP_LEN           (sizeof(SOCK_IP_S)-1)
#define SOCK_IP_ID            1
#define SOCK_PORT_S           "port"
#define SOCK_PORT_LEN         (sizeof(SOCK_PORT_S)-1)
#define SOCK_PORT_ID          2
#define SOCK_PROTO_S          "proto"
#define SOCK_PROTO_LEN        (sizeof(SOCK_PROTO_S)-1)
#define SOCK_PROTO_ID         3
#define SOCK_ADV_IP_S         "advertised_ip"
#define SOCK_ADV_IP_LEN       (sizeof(SOCK_ADV_IP_S)-1)
#define SOCK_ADV_IP_ID        4
#define SOCK_ADV_PORT_S       "advertised_port"
#define SOCK_ADV_PORT_LEN     (sizeof(SOCK_ADV_PORT_S)-1)
#define SOCK_ADV_PORT_ID      5
#define SOCK_TAG_S            "tag"
#define SOCK_TAG_LEN          (sizeof(SOCK_TAG_S)-1)
#define SOCK_TAG_ID           6
#define SOCK_ANYCAST_S        "anycast"
#define SOCK_ANYCAST_LEN      (sizeof(SOCK_ANYCAST_S)-1)
#define SOCK_ANYCAST_ID       7
#define SOCK_AF_S             "af"
#define SOCK_AF_LEN           (sizeof(SOCK_AF_S)-1)
#define SOCK_AF_ID            8

static int pv_parse_socket_name(pv_spec_p sp, const str *in)
{
	if (sp==NULL || in==NULL || in->s==NULL || in->len==0)
		return -1;

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = 0;

	if (in->len==SOCK_IP_LEN &&
	strncasecmp(in->s, SOCK_IP_S, SOCK_IP_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_IP_ID;
	} else
	if (in->len==SOCK_PORT_LEN &&
	strncasecmp(in->s, SOCK_PORT_S, SOCK_PORT_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_PORT_ID;
	} else
	if (in->len==SOCK_PROTO_LEN &&
	strncasecmp(in->s, SOCK_PROTO_S, SOCK_PROTO_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_PROTO_ID;
	} else
	if (in->len==SOCK_ADV_IP_LEN &&
	strncasecmp(in->s, SOCK_ADV_IP_S, SOCK_ADV_IP_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_ADV_IP_ID;
	} else
	if (in->len==SOCK_ADV_PORT_LEN &&
	strncasecmp(in->s, SOCK_ADV_PORT_S, SOCK_ADV_PORT_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_ADV_PORT_ID;
	} else
	if (in->len==SOCK_TAG_LEN &&
	strncasecmp(in->s, SOCK_TAG_S, SOCK_TAG_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_TAG_ID;
	} else
	if (in->len==SOCK_ANYCAST_LEN &&
	strncasecmp(in->s, SOCK_ANYCAST_S, SOCK_ANYCAST_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_ANYCAST_ID;
	} else
	if (in->len==SOCK_AF_LEN &&
	strncasecmp(in->s, SOCK_AF_S, SOCK_AF_LEN)==0 ) {
		sp->pvp.pvn.u.isname.name.n = SOCK_AF_ID;
	} else {
		LM_ERR("unsupported SOCKET_IN/OUT field <%.*s>\n",in->len,in->s);
		return -1;
	}

	return 0;
}


static inline int get_socket_field( struct socket_info *si,
											pv_name_t *pvn, pv_value_t *res)
{
	if (si==NULL)
		return pv_get_null( NULL, NULL, res);

	/* return the field */
	switch (pvn->u.isname.name.n) {
		case 0: /* return full socket description */
			res->rs = si->sock_str;
			res->flags = PV_VAL_STR;
			break;
		case SOCK_IP_ID: /* return IP address */
			res->rs = si->address_str;
			res->flags = PV_VAL_STR;
			break;
		case SOCK_PORT_ID: /* return PORT */
			res->rs = si->port_no_str;
			res->ri = si->port_no;
			res->flags = PV_VAL_STR|PV_VAL_INT;
			break;
		case SOCK_PROTO_ID: /* return PROTOCOL */
			if ( si->proto>=PROTO_FIRST && si->proto<PROTO_LAST &&
			protos[si->proto].id ) {
				res->rs.s = protos[si->proto].name;
				res->rs.len = strlen(res->rs.s);
				res->flags = PV_VAL_STR;
			} else {
				return pv_get_null( NULL, NULL, res);
			}
			break;
		case SOCK_ADV_IP_ID: /* return advertised IP address */
			if (si->adv_name_str.s) {
				res->rs = si->adv_name_str;
				res->flags = PV_VAL_STR;
			} else {
				return pv_get_null( NULL, NULL, res);
			}
			break;
		case SOCK_ADV_PORT_ID: /* return advertised PORT */
			if (si->adv_port_str.s) {
				res->rs = si->adv_port_str;
				res->ri = si->adv_port;
				res->flags = PV_VAL_STR|PV_VAL_INT;
			} else {
				return pv_get_null( NULL, NULL, res);
			}
			break;
		case SOCK_TAG_ID: /* return internal TAG */
			if (si->tag.s) {
				res->rs = si->tag;
				res->flags = PV_VAL_STR;
			} else {
				return pv_get_null( NULL, NULL, res);
			}
			break;
		case SOCK_ANYCAST_ID: /* return ANYCAST */
			if (si->flags&SI_IS_ANYCAST)
				res->ri = 1;
			else
				res->ri = 0;
			res->flags = PV_VAL_INT;
			break;
		case SOCK_AF_ID:  /* returns Address Family */
			if (si->address.af == AF_INET) {
				res->rs.s = "INET";
				res->rs.len = 4;
			} else if (si->address.af == AF_INET6) {
				res->rs.s = "INET6";
				res->rs.len = 5;
			} else
				return pv_get_null( NULL, NULL, res);
			res->flags = PV_VAL_STR|PV_VAL_INT;
			break;
		default:
			LM_CRIT("BUG - unsupported ID %d\n",pvn->u.isname.name.n);
			return pv_get_null(NULL, NULL, res);
	}
	return 0;
}


static int pv_get_socket_in_fields(struct sip_msg *msg, pv_param_t *param,
															pv_value_t *res)
{

	if(msg==NULL || res==NULL)
		return -1;

	return get_socket_field( msg->rcv.bind_address, &param->pvn, res);
}


static int pv_get_socket_out_fields(struct sip_msg *msg, pv_param_t *param,
															pv_value_t *res)
{
	struct socket_info *si;

	if(msg==NULL || res==NULL)
		return -1;

	si = (msg->force_send_socket) ?
		msg->force_send_socket : msg->rcv.bind_address;

	return get_socket_field( si, &param->pvn, res);
}




/************************************************************/

/**
 *
 */
static int pv_get_avp(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	unsigned short name_type;
	int avp_name;
	int_str avp_value;
	struct usr_avp *avp;
	int_str avp_value0;
	struct usr_avp *avp0;
	int idx;
	int idxf;
	char *p;
	int n=0;

	if(msg==NULL || res==NULL || param==NULL)
		return -1;

	/* get the name */
	if(pv_get_avp_name(msg, param, &avp_name, &name_type)!=0)
	{
		LM_ERR("invalid name\n");
		return -1;
	}
	/* get the index */
	if(pv_get_spec_index(msg, param, &idx, &idxf)!=0)
	{
		LM_ERR("invalid index\n");
		return -1;
	}
	if (idxf==PV_IDX_APPEND)
		return pv_get_null(msg, param, res);

	if ((avp=search_first_avp(name_type, avp_name, &avp_value, 0))==0)
		return pv_get_null(msg, param, res);
	res->flags = PV_VAL_STR;

	if (idxf!=PV_IDX_ALL && idx==0)
	{
		if(avp->flags & AVP_VAL_STR) {
			res->rs = avp_value.s;
		} else if(avp->flags & AVP_VAL_NULL) {
			res->flags |= PV_VAL_NULL;
		} else {
			res->rs.s = sint2str(avp_value.n, &res->rs.len);
			res->ri = avp_value.n;
			res->flags |= PV_VAL_INT|PV_TYPE_INT;
		}
		return 0;
	}

	/* print the entire AVP array */
	if(idxf==PV_IDX_ALL)
	{
		p = pv_local_buf;

		/* separately handle the first AVP */
		if(avp->flags & AVP_VAL_STR) {
			res->rs = avp_value.s;
		} else if(avp->flags & AVP_VAL_NULL) {
			memset(&res->rs, 0, sizeof res->rs);
		} else {
			res->rs.s = sint2str(avp_value.n, &res->rs.len);
		}

		if(p-pv_local_buf+res->rs.len+1>PV_LOCAL_BUF_SIZE)
		{
			LM_ERR("local buffer length exceeded!\n");
			return pv_get_null(msg, param, res);
		}
		memcpy(p, res->rs.s, res->rs.len);
		p += res->rs.len;

		/* print subsequent AVPs as [DELIM AVP]* */
		while ((avp = search_first_avp(name_type, avp_name, &avp_value, avp)))
		{
			if(avp->flags & AVP_VAL_STR) {
				res->rs = avp_value.s;
			} else if(avp->flags & AVP_VAL_NULL) {
				memset(&res->rs, 0, sizeof res->rs);
			} else {
				res->rs.s = sint2str(avp_value.n, &res->rs.len);
			}

			if(p-pv_local_buf+PV_FIELD_DELIM_LEN+1>PV_LOCAL_BUF_SIZE)
			{
				LM_ERR("local buffer length exceeded\n");
				return pv_get_null(msg, param, res);
			}
			memcpy(p, PV_FIELD_DELIM, PV_FIELD_DELIM_LEN);
			p += PV_FIELD_DELIM_LEN;

			if(p-pv_local_buf+res->rs.len+1>PV_LOCAL_BUF_SIZE)
			{
				LM_ERR("local buffer length exceeded!\n");
				return pv_get_null(msg, param, res);
			}
			memcpy(p, res->rs.s, res->rs.len);
			p += res->rs.len;
		}

		*p = 0;
		res->rs.s = pv_local_buf;
		res->rs.len = p - pv_local_buf;
		return 0;
	}

	/* we have a numeric index */
	if(idx<0)
	{
		n = 1;
		avp0 = avp;
		while ((avp0=search_first_avp(name_type, avp_name,
						&avp_value0, avp0))!=0) n++;
		idx = -idx;
		if(idx>n)
		{
			LM_DBG("index out of range\n");
			return pv_get_null(msg, param, res);
		}
		idx = n - idx;
		if(idx==0)
		{
			if(avp->flags & AVP_VAL_STR) {
				res->rs = avp_value.s;
			} else if(avp->flags & AVP_VAL_NULL) {
				res->flags |= PV_VAL_NULL;
			} else {
				res->rs.s = sint2str(avp_value.n, &res->rs.len);
				res->ri = avp_value.n;
				res->flags |= PV_VAL_INT|PV_TYPE_INT;
			}
			return 0;
		}
	}
	n=0;
	while(n<idx
			&& (avp=search_first_avp(name_type, avp_name, &avp_value, avp))!=0)
		n++;

	if(avp!=0)
	{
		if(avp->flags & AVP_VAL_STR) {
			res->rs = avp_value.s;
		} else if(avp->flags & AVP_VAL_NULL) {
			res->flags |= PV_VAL_NULL;
		} else {
			res->rs.s = sint2str(avp_value.n, &res->rs.len);
			res->ri = avp_value.n;
			res->flags |= PV_VAL_INT|PV_TYPE_INT;
		}
		return 0;
	}

	LM_DBG("index out of range\n");
	return pv_get_null(msg, param, res);
}


static int pv_resolve_hdr_name(const str *in, pv_value_t *tv)
{
	struct hdr_field hdr;
	str s;
	if(in->len>=PV_LOCAL_BUF_SIZE-1)
	{
		LM_ERR("name too long\n");
		return -1;
	}
	memcpy(pv_local_buf, in->s, in->len);
	pv_local_buf[in->len] = ':';
	s.s = pv_local_buf;
	s.len = in->len+1;

	if (parse_hname2(s.s, s.s + ((s.len<4)?4:s.len), &hdr)==0)
	{
		LM_ERR("error parsing header name [%.*s]\n", s.len, s.s);
		return -1;
	}
	if (hdr.type!=HDR_OTHER_T && hdr.type!=HDR_ERROR_T)
	{
		LM_DBG("using hdr type (%d) instead of <%.*s>\n",
			hdr.type, in->len, in->s);
		tv->flags = 0;
		tv->ri = hdr.type;
	} else {
		tv->flags = PV_VAL_STR;
		tv->rs = *in;
	}
	return 0;
}

static int pv_get_hdr_prolog(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res, pv_value_t* tv)
{
	if(msg==NULL || res==NULL || param==NULL)
		return -1;

	/* get the name */
	if(param->pvn.type == PV_NAME_PVAR)
	{
		if(pv_get_spec_name(msg, param, tv)!=0 || (!(tv->flags&PV_VAL_STR)))
		{
			LM_ERR("invalid name\n");
			return -1;
		}
		if (pv_resolve_hdr_name(&tv->rs, tv) < 0)
			return -1;
	} else {
		if(param->pvn.u.isname.type == AVP_NAME_STR)
		{
			tv->flags = PV_VAL_STR;
			tv->rs = param->pvn.u.isname.name.s;
		} else {
			tv->flags = 0;
			tv->ri = param->pvn.u.isname.name.n;
		}
	}
	/* we need to be sure we have parsed all headers */
	if(parse_headers(msg, HDR_EOH_F, 0)<0)
	{
		LM_ERR("error parsing headers\n");
		return pv_get_null(msg, param, res);
	}
	return 1;
}

static int pv_get_hdrcnt(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	pv_value_t tv;
	struct hdr_field *hf;
	unsigned int n;
	int ret;

	if ( (ret=pv_get_hdr_prolog(msg,  param, res, &tv)) <= 0 )
	    	return ret;

	n = 0;
	if (tv.flags==0) {
		/* it is a known header -> use type to find it */
		for (hf=msg->headers; hf; hf=hf->next) {
			if (tv.ri==hf->type)
			        ++n;
		}
	} else {
		/* it is an un-known header -> use name to find it */
		for (hf=msg->headers; hf; hf=hf->next) {
			if (hf->type==HDR_OTHER_T && hf->name.len==tv.rs.len
			&& strncasecmp(hf->name.s, tv.rs.s, hf->name.len)==0)
				++n;
		}
	}
	return pv_get_uintval(msg, param, res, n);
}

static int pv_get_hdr(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	int idx;
	int idxf;
	pv_value_t tv;
	struct hdr_field *hf;
	struct hdr_field *hf0;
	char *p;
	int n;
	int ret;

	if ( (ret=pv_get_hdr_prolog(msg,  param, res, &tv)) <= 0 )
	    	return ret;

	if (tv.flags==0) {
		/* it is a known header -> use type to find it */
		for (hf=msg->headers; hf; hf=hf->next) {
			if (tv.ri==hf->type)
				break;
		}
	} else {
		/* it is an un-known header -> use name to find it */
		for (hf=msg->headers; hf; hf=hf->next) {
			if (hf->type==HDR_OTHER_T && hf->name.len==tv.rs.len
			&& strncasecmp(hf->name.s, tv.rs.s, hf->name.len)==0)
				break;
		}
	}

	if(hf==NULL)
		return pv_get_null(msg, param, res);
	/* get the index */
	if(pv_get_spec_index(msg, param, &idx, &idxf)!=0)
	{
		LM_ERR("invalid index\n");
		return -1;
	}

	/* get the value */
	res->flags = PV_VAL_STR;
	if(idxf!=PV_IDX_ALL && idx==0)
	{
		res->rs  = hf->body;
		return 0;
	}
	if(idxf==PV_IDX_ALL)
	{
		p = pv_local_buf;
		do {
			if(p!=pv_local_buf)
			{
				if(p-pv_local_buf+PV_FIELD_DELIM_LEN+1>PV_LOCAL_BUF_SIZE)
				{
					LM_ERR("local buffer length exceeded\n");
					return pv_get_null(msg, param, res);
				}
				memcpy(p, PV_FIELD_DELIM, PV_FIELD_DELIM_LEN);
				p += PV_FIELD_DELIM_LEN;
			}

			if(p-pv_local_buf+hf->body.len+1>PV_LOCAL_BUF_SIZE)
			{
				LM_ERR("local buffer length exceeded!\n");
				return pv_get_null(msg, param, res);
			}
			memcpy(p, hf->body.s, hf->body.len);
			p += hf->body.len;
			/* next hf */
			if (tv.flags==0) {
				/* it is a known header -> use type to find it */
				for (hf=hf->next ; hf; hf=hf->next) {
					if (tv.ri==hf->type)
						break;
				}
			} else {
				/* it is an un-known header -> use name to find it */
				for (hf=hf->next ; hf; hf=hf->next) {
					if (hf->type==HDR_OTHER_T && hf->name.len==tv.rs.len
					&& strncasecmp(hf->name.s, tv.rs.s, hf->name.len)==0)
						break;
				}
			}
		} while (hf);
		*p = 0;
		res->rs.s = pv_local_buf;
		res->rs.len = p - pv_local_buf;
		return 0;
	}

	/* we have a numeric index */
	hf0 = 0;
	if(idx<0)
	{
		n = 1;
		/* count headers */
		if (tv.flags==0 ) {
			/* it is a known header -> use type to find it */
			for (hf0=hf->next; hf0; hf0=hf0->next) {
				if (tv.ri==hf0->type)
					n++;
			}
		} else {
			/* it is an un-known header -> use name to find it */
			for (hf0=hf->next; hf0; hf0=hf0->next) {
				if (hf0->type==HDR_OTHER_T && hf0->name.len==tv.rs.len
				&& strncasecmp(hf0->name.s, tv.rs.s, hf0->name.len)==0)
					n++;
			}
		}

		idx = -idx;
		if(idx>n)
		{
			LM_DBG("index out of range\n");
			return pv_get_null(msg, param, res);
		}
		idx = n - idx;
		if(idx==0)
		{
			res->rs  = hf->body;
			return 0;
		}
	}
	n=0;
	while(n<idx)
	{
		if (tv.flags==0) {
			/* it is a known header -> use type to find it */
			for (hf0=hf->next; hf0; hf0=hf0->next) {
				if (tv.ri==hf0->type) {
					n++;
					if(n==idx) break;
				}
			}
		} else {
			/* it is an un-known header -> use name to find it */
			for (hf0=hf->next; hf0; hf0=hf0->next) {
				if (hf0->type==HDR_OTHER_T && hf0->name.len==tv.rs.len
				&& strncasecmp(hf0->name.s, tv.rs.s, hf0->name.len)==0) {
					n++;
					if(n==idx) break;
				}
			}
		}
		if(hf0==NULL)
			break;
	}

	if(hf0!=0)
	{
		res->rs  = hf0->body;
		return 0;
	}

	LM_DBG("index out of range\n");
	return pv_get_null(msg, param, res);

}

static int pv_get_hdr_name(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	int idx, idx_f;
	struct hdr_field *hf;
	char *p;
	int n;

	if(msg==NULL || res==NULL || param==NULL)
		return -1;

	/* get the index */
	if (pv_get_spec_index(msg, param, &idx, &idx_f) != 0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	/* make sure we have parsed all the headers */
	if (parse_headers(msg, HDR_EOH_F, 0) <0 ) {
		LM_ERR("error parsing headers\n");
		return pv_get_null(msg, param, res);
	}

	res->flags = PV_VAL_STR;

	if (idx_f == PV_IDX_ALL) {
		/* return all header names, separated by ',' */

		p = pv_local_buf;
		hf = msg->headers;
		do {
			if (p != pv_local_buf) {
				if (p - pv_local_buf + PV_FIELD_DELIM_LEN + 1 > PV_LOCAL_BUF_SIZE) {
					LM_ERR("local buffer length exceeded\n");
					return pv_get_null(msg, param, res);
				}
				memcpy(p, PV_FIELD_DELIM, PV_FIELD_DELIM_LEN);
				p += PV_FIELD_DELIM_LEN;
			}

			if (p - pv_local_buf + hf->name.len + 1 > PV_LOCAL_BUF_SIZE) {
				LM_ERR("local buffer length exceeded!\n");
				return pv_get_null(msg, param, res);
			}
			memcpy(p, hf->name.s, hf->name.len);
			p += hf->name.len;

			hf = hf->next;
		} while (hf);

		*p = 0;
		res->rs.s = pv_local_buf;
		res->rs.len = p - pv_local_buf;
		return 0;
	}

	if (idx < 0) {
		/* negative index, translate it to a positive one */

		n = 0;
		for (hf = msg->headers; hf; hf = hf->next, n++) ;
		idx = -idx;
		if(idx > n) {
			LM_DBG("index [%d] out of range\n", -idx);
			return pv_get_null(msg, param, res);
		}
		idx = n - idx;
	}

	for (hf = msg->headers, n = 0; hf && n != idx; hf = hf->next, n++) ;

	if (!hf) {
		LM_DBG("index [%d] out of range\n", idx);
		return pv_get_null(msg, param, res);
	}

	res->rs = hf->name;
	return 0;
}

static int pv_get_scriptvar(struct sip_msg *msg,  pv_param_t *param,
		pv_value_t *res)
{
	int ival = 0;
	char *sval = NULL;
	script_var_t *sv=NULL;

	if(msg==NULL || res==NULL)
		return -1;

	if(param==NULL || param->pvn.u.dname==0)
		return pv_get_null(msg, param, res);

	sv= (script_var_t*)param->pvn.u.dname;

	if (sv->v.flags&VAR_VAL_NULL)
		return pv_get_null(msg, param, res);

	if(sv->v.flags&VAR_VAL_STR)
	{
		res->rs = sv->v.value.s;
		res->flags = PV_VAL_STR;
	} else {
		sval = sint2str(sv->v.value.n, &ival);

		res->rs.s = sval;
		res->rs.len = ival;

		res->ri = sv->v.value.n;
		res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;
	}
	return 0;
}

static int pv_get_af(struct sip_msg *msg,  pv_param_t *param,
		pv_value_t *res)
{
	if(msg==NULL)
		return -1;

	res->flags = PV_VAL_STR;
	if (msg->rcv.src_ip.af == AF_INET) {
		res->rs.s = "INET";
		res->rs.len = 4;
	} else if (msg->rcv.src_ip.af == AF_INET6) {
		res->rs.s = "INET6";
		res->rs.len = 5;
	} else
		return pv_get_null(msg, param, res);

	return 0;
}

/********* end PV get functions *********/

/********* start PV set functions *********/
static int pv_set_avp(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	int avp_name;
	int_str avp_val;
	int flags;
	unsigned short name_type;
	int idx, idxf;

	if(param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(pv_get_avp_name(msg, param, &avp_name, &name_type)!=0)
	{
		LM_ALERT("BUG in getting dst AVP name\n");
		goto error;
	}

	/* get the index */
	if(pv_get_spec_index(msg, param, &idx, &idxf)!=0)
	{
		LM_ERR("invalid index\n");
		return -1;
	}

	if(val == NULL)
	{
		if(op == COLONEQ_T || idxf == PV_IDX_ALL)
			destroy_avps(name_type, avp_name, 1);
		else
		{
			if(idx < 0)
			{
				LM_ERR("Index with negative value\n");
				return -1;
			}
			destroy_index_avp(name_type, avp_name, idx);
		}
		return 0;
	}

	if(op == COLONEQ_T || idxf == PV_IDX_ALL)
		destroy_avps(name_type, avp_name, 1);

	flags = name_type;
	if(val->flags&PV_TYPE_INT)
	{
		avp_val.n = val->ri;
	} else {
		avp_val.s = val->rs;
		flags |= AVP_VAL_STR;
	}

	if(idxf == PV_IDX_INT || idxf == PV_IDX_PVAR) /* if the avp is indexed */
	{
		if(replace_avp(flags, avp_name, avp_val, idx)< 0)
		{
			LM_ERR("Failed to replace avp\n");
			goto error;
		}
	}
	else if (idxf == PV_IDX_APPEND) /* add AVP at the end */
	{
		if (add_avp_last(flags, avp_name, avp_val)<0)
		{
			LM_ERR("error - cannot add AVP\n");
			goto error;
		}
	}
	else {
		if (add_avp(flags, avp_name, avp_val)<0)
		{
			LM_ERR("error - cannot add AVP\n");
			goto error;
		}
	}

	return 0;
error:
	return -1;
}

static int pv_set_scriptvar(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	int_str avp_val;
	int flags;

	if(param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(param->pvn.u.dname==0)
	{
		LM_ERR("error - cannot find svar\n");
		goto error;
	}
	if(val == NULL)
	{
		set_var_value((script_var_t*)param->pvn.u.dname, NULL, VAR_VAL_NULL);
		return 0;
	}
	if(val->flags&PV_TYPE_INT)
	{
		avp_val.n = val->ri;
		flags = 0;
	} else {
		avp_val.s = val->rs;
		flags = VAR_VAL_STR;
	}
	if(set_var_value((script_var_t*)param->pvn.u.dname, &avp_val, flags)==NULL)
	{
		LM_ERR("error - cannot set svar [%.*s] \n",
				((script_var_t*)param->pvn.u.dname)->name.len,
				((script_var_t*)param->pvn.u.dname)->name.s);
		goto error;
	}
	return 0;
error:
	return -1;
}

static int pv_set_dsturi(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if(msg==NULL || param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val == NULL)
	{
		reset_dst_uri(msg);

		return 1;
	}
	if(!(val->flags&PV_VAL_STR))
	{
		LM_ERR("error - str value required to set dst uri\n");
		goto error;
	}

	if(set_dst_uri(msg, &val->rs)!=0)
		goto error;

	return 0;
error:
	return -1;
}

static int pv_set_ruri(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if(msg==NULL || param==NULL || val==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(!(val->flags&PV_VAL_STR))
	{
		LM_ERR("str value required to set R-URI\n");
		goto error;
	}

	if (set_ruri( msg, &val->rs)!=0) {
		LM_ERR("failed to set RURI\n");
		goto error;
	}

	return 0;
error:
	return -1;
}

static int pv_set_ru_q(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if(msg==NULL || param==NULL || val==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(!(val->flags&PV_VAL_INT))
	{
		LM_ERR("int value required to set r-uri queue value\n");
		return -1;
	}

	if (val->ri > 1000) {
		LM_WARN("queue value too big %d - setting queue to "
				"maximum value (1000)\n", val->ri);
		set_ruri_q(msg, 1000);
	} else
		set_ruri_q(msg, val->ri);

	return 0;
}

static int pv_set_ruri_user(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	str sval;

	if(msg==NULL || param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val == NULL)
		sval = str_empty;
	else if(!(val->flags&PV_VAL_STR)) {
		LM_ERR("str value required to set R-URI user\n");
		return -1;
	} else
		sval = val->rs;

	if (rewrite_ruri(msg, &sval, 0, RW_RURI_USER) < 0) {
		LM_ERR("Failed to set R-URI user\n");
		return -1;
	}

	return 0;
}

static int pv_set_ruri_host(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if(msg==NULL || param==NULL || val==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(!(val->flags&PV_VAL_STR))
	{
		LM_ERR("str value required to set R-URI hostname\n");
		return -1;
	}

	if (rewrite_ruri(msg, &val->rs, 0, RW_RURI_HOST) < 0) {
		LM_ERR("Failed to set R-URI hostname\n");
		return -1;
	}

	return 0;
}

static int pv_set_dsturi_host(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if(msg==NULL || param==NULL || val==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(!(val->flags&PV_VAL_STR))
	{
		LM_ERR("str value required to set DST-URI hostname\n");
		return -1;
	}

	if (set_dst_host_port(msg, &val->rs, NULL) < 0) {
		LM_ERR("Failed to set DST-URI host\n");
		return -1;
	}

	return 0;
}

static int pv_set_dsturi_port(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	str sval;

	if(msg==NULL || param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val == NULL)
		sval = str_empty;
	else if(!(val->flags&PV_VAL_STR))
		sval.s = int2str(val->ri, &sval.len);
	else
		sval = val->rs;

	if (set_dst_host_port(msg, NULL, &sval) < 0) {
		LM_ERR("Failed to set DST-URI port\n");
		return -1;
	}

	return 0;
}




static int pv_set_ruri_port(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	str sval;

	if(msg==NULL || param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val == NULL)
		sval = str_empty;
	else if(!(val->flags&PV_VAL_STR))
		sval.s = int2str(val->ri, &sval.len);
	else
		sval = val->rs;

	if (rewrite_ruri(msg, &sval, 0, RW_RURI_PORT) < 0) {
		LM_ERR("Failed to set R-URI hostname\n");
		return -1;
	}

	return 0;
}


static int pv_set_branch(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	if (msg==NULL || param==NULL) {
		LM_ERR("bad parameters\n");
		return -1;
	}

	if (!val || !(val->flags&PV_VAL_STR) || val->flags&(PV_VAL_NULL) ||
	val->rs.len==0 ) {
		LM_ERR("str value required to create a new branch\n");
		return -1;
	}

	if (append_branch( msg, &val->rs, NULL, NULL, Q_UNSPECIFIED,  0, NULL)!=1){
		LM_ERR("failed to append new branch\n");
		return -1;
	}

	return 0;
}


static int pv_set_branch_fields(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	int idx;
	int idxf;
	str *s;
	qvalue_t q;
	unsigned int flags;
	struct socket_info *si;

	if (msg==NULL || param==NULL) {
		LM_ERR("bad parameters\n");
		return -1;
	}

	if (msg->first_line.type == SIP_REPLY)
		return -1;

	/* get the index */
	if (pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if(idxf==PV_IDX_ALL) {
		LM_ERR("SCRIPT BUG - * not allowed in branch assignment\n");
		return -1;
	}

	if (idx<0) {
		idx = get_nr_branches() + idx;
	}

	if (idx<0 || idx>=get_nr_branches()) {
		LM_ERR("SCRIPT BUG - inexisting branch assignment [%d/%d]\n",
			get_nr_branches(), idx);
		return -1;
	}

	switch (param->pvn.u.isname.name.n) {
		case BR_URI_ID: /* set URI */
			if (!val || !(val->flags&PV_VAL_STR) || val->flags&(PV_VAL_NULL) ||
			val->rs.len==0 ) {
				LM_ERR("str value required to set the branch URI\n");
				return -1;
			}
			s = &val->rs;
			return update_branch( idx, &s, NULL,
				NULL, NULL, NULL, NULL);
		case BR_Q_ID: /* set Q */
			if ( val && !(val->flags&PV_VAL_INT) ) {
				LM_ERR("INT value required to set the branch Q\n");
				return -1;
			}
			q = (!val||val->flags&PV_VAL_NULL)? Q_UNSPECIFIED : val->ri;
			return update_branch( idx, NULL, NULL,
				NULL, &q, NULL, NULL);
		case BR_DURI_ID: /* set DURI */
			if ( val && !(val->flags&PV_VAL_STR) ) {
				LM_ERR("STR value required to set the branch DURI\n");
				return -1;
			}
			s = (!val||val->flags&PV_VAL_NULL)? NULL : &val->rs;
			return update_branch( idx, NULL, &s,
				NULL, NULL, NULL, NULL);
		case BR_PATH_ID: /* set PATH */
			if ( val && !(val->flags&PV_VAL_STR) ) {
				LM_ERR("STR value required to set the branch PATH\n");
				return -1;
			}
			s = (!val||val->flags&PV_VAL_NULL)? NULL : &val->rs;
			return update_branch( idx, NULL, NULL,
				&s, NULL, NULL, NULL);
		case BR_FLAGS_ID: /* set FLAGS */
			if ( val && !(val->flags&PV_VAL_STR) ) {
				LM_ERR("string value required to set the branch FLAGS\n");
				return -1;
			}
			flags = (!val||val->flags&PV_VAL_NULL)?
				0 : flag_list_to_bitmask(str2const(&val->rs), FLAG_TYPE_BRANCH, FLAG_DELIM);
			return update_branch( idx, NULL, NULL,
				NULL, NULL, &flags, NULL);
		case BR_SOCKET_ID: /* set SOCKET */
			if ( val && !(val->flags&PV_VAL_STR) ) {
				LM_ERR("STR value required to set the branch SOCKET\n");
				return -1;
			}
			if (!val || val->flags&PV_VAL_NULL) {
				si = NULL;
			} else {
				str host;
				int port, proto;
				if (parse_phostport(val->rs.s, val->rs.len, &host.s, &host.len,
				&port, &proto) < 0) {
					LM_ERR("invalid socket specification\n");
					return -1;
				}
				set_sip_defaults( port, proto);
				si = grep_internal_sock_info(&host, (unsigned short)port,
					(unsigned short)proto);
				if (si==NULL)
					return -1;
			}
			return update_branch( idx, NULL, NULL,
				NULL, NULL, NULL, &si);
		default:
			LM_CRIT("BUG - unsupported ID %d\n",param->pvn.u.isname.type);
			return -1;
	}
}

static int pv_set_force_sock(struct sip_msg* msg, pv_param_t *param,
		int op, pv_value_t *val)
{
	struct socket_info *si;
	int port, proto;
	str host;

	if(msg==NULL || param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val==NULL)
	{
		msg->force_send_socket = NULL;
		return 0;
	}

	if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
	{
		LM_ERR("str value required to set the force send sock\n");
		goto error;
	}

	if (parse_phostport(val->rs.s, val->rs.len, &host.s, &host.len, &port, &proto) < 0)
	{
		LM_ERR("invalid socket specification\n");
		goto error;
	}
	set_sip_defaults( port, proto);
	si = grep_internal_sock_info(&host, (unsigned short)port,
		(unsigned short)proto);
	if (si!=NULL)
	{
		msg->force_send_socket = si;
	} else {
		LM_WARN("no socket found to match [%.*s]\n",
				val->rs.len, val->rs.s);
	}

	return 0;
error:
	return -1;
}


/********* end PV set functions *********/

static int pv_parse_scriptvar_name(pv_spec_p sp, const str *in)
{
	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;

	sp->pvp.pvn.type = PV_NAME_PVAR;
	sp->pvp.pvn.u.dname = (void*)add_var(in);
	if(sp->pvp.pvn.u.dname==NULL)
	{
		LM_ERR("cannot register var [%.*s]\n", in->len, in->s);
		return -1;
	}
	return 0;
}

static int pv_parse_hdr_name(pv_spec_p sp, const str *in)
{
	char *p;
	pv_spec_p nsp = 0;
	pv_value_t tv;

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;

	p = in->s;
	if(*p==PV_MARKER)
	{
		nsp = (pv_spec_p)pkg_malloc(sizeof(pv_spec_t));
		if(nsp==NULL)
		{
			LM_ERR("no more memory\n");
			return -1;
		}
		p = pv_parse_spec(in, nsp);
		if(p==NULL)
		{
			LM_ERR("invalid name [%.*s]\n", in->len, in->s);
			pv_spec_free(nsp);
			return -1;
		}
		//LM_ERR("dynamic name [%.*s]\n", in->len, in->s);
		//pv_print_spec(nsp);
		sp->pvp.pvn.type = PV_NAME_PVAR;
		sp->pvp.pvn.u.dname = (void*)nsp;
		return 0;
	}

	if (pv_resolve_hdr_name(in, &tv) < 0)
		return -1;

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	if (!tv.flags)
	{
		LM_DBG("using hdr type (%d) instead of <%.*s>\n",
			tv.ri, in->len, in->s);
		sp->pvp.pvn.u.isname.type = 0;
		sp->pvp.pvn.u.isname.name.n = tv.ri;
	} else {
		sp->pvp.pvn.u.isname.type = AVP_NAME_STR;
		sp->pvp.pvn.u.isname.name.s = *in;
	}
	return 0;
}

int pv_parse_avp_name(pv_spec_p sp, const str *in)
{
	char *p;
	char *s;
	pv_spec_p nsp = 0;

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;
	p = in->s;
	if(*p==PV_MARKER)
	{
		nsp = (pv_spec_p)pkg_malloc(sizeof(pv_spec_t));
		if(nsp==NULL)
		{
			LM_ERR("no more memory\n");
			return -1;
		}
		s = pv_parse_spec(in, nsp);
		if(s==NULL)
		{
			LM_ERR("invalid name [%.*s]\n", in->len, in->s);
			pv_spec_free(nsp);
			return -1;
		}
		//LM_ERR("dynamic name [%.*s]\n", in->len, in->s);
		//pv_print_spec(nsp);
		sp->pvp.pvn.type = PV_NAME_PVAR;
		sp->pvp.pvn.u.dname = (void*)nsp;
		return 0;
	}
	/*LM_DBG("static name [%.*s]\n", in->len, in->s);*/
	/* always an int type from now */
	sp->pvp.pvn.u.isname.type = 0;
	if(parse_avp_spec(in, &sp->pvp.pvn.u.isname.name.n)!=0)
	{
		LM_ERR("bad avp name [%.*s]\n", in->len, in->s);
		return -1;
	}
	sp->pvp.pvn.type = PV_NAME_INTSTR;
	return 0;
}

static int pv_parse_avp_index(pv_spec_p sp, const str *in)
{
	#define AVP_APPEND_IDX "append"

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;

	if ( (in->len==(sizeof(AVP_APPEND_IDX)-1)) &&
	strncasecmp(in->s,AVP_APPEND_IDX,in->len)==0) {
		sp->pvp.pvi.type = PV_IDX_APPEND;
		return 0;
	}
	return pv_parse_index(sp,in);
}

int pv_parse_index(pv_spec_p sp, const str *in)
{
	char *p;
	char *s;
	int sign;
	pv_spec_p nsp = 0;

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;
	p = in->s;
	if(*p==PV_MARKER)
	{
		nsp = (pv_spec_p)pkg_malloc(sizeof(pv_spec_t));
		if(nsp==NULL)
		{
			LM_ERR("no more memory\n");
			return -1;
		}
		memset(nsp, 0, sizeof(pv_spec_t));
		s = pv_parse_spec(in, nsp);
		if(s==NULL)
		{
			LM_ERR("invalid index [%.*s]\n", in->len, in->s);
			pv_spec_free(nsp);
			return -1;
		}
		sp->pvp.pvi.type = PV_IDX_PVAR;
		sp->pvp.pvi.u.dval = (void*)nsp;
		return 0;
	}
	if(*p=='*' && in->len==1)
	{
		sp->pvp.pvi.type = PV_IDX_ALL;
		return 0;
	}
	sign = 1;
	if(*p=='-')
	{
		sign = -1;
		p++;
	}
	sp->pvp.pvi.u.ival = 0;
	while(p<in->s+in->len && *p>='0' && *p<='9')
	{
		sp->pvp.pvi.u.ival = sp->pvp.pvi.u.ival * 10 + *p - '0';
		p++;
	}
	if(p!=in->s+in->len)
	{
		LM_ERR("invalid index [%.*s]\n", in->len, in->s);
		return -1;
	}
	sp->pvp.pvi.u.ival *= sign;
	sp->pvp.pvi.type = PV_IDX_INT;

	return 0;
}

int pv_init_iname(pv_spec_p sp, int param)
{
	if(sp==NULL)
		return -1;
	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.name.n = param;
	return 0;
}

static int pv_get_line_number(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res){
	int l;
	char *ch;

	if (param==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if(res == NULL) {
		return -1;
	}

	res->ri = curr_action_line;
	ch = int2str( (unsigned long)res->ri, &l);

	res->rs.s = ch;
	res->rs.len = l;

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}

static int pv_get_cfg_file_name(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res){

	if (param==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if(res == NULL) {
		return -1;
	}

	res->rs.s = curr_action_file;
	res->rs.len = (res->rs.s)?(strlen(res->rs.s)):(0);

	res->flags = PV_VAL_STR;

	return 0;
}


static int pv_set_log_level(struct sip_msg* msg, pv_param_t *param, int op,
															pv_value_t *val)
{
	if(param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val==NULL || (val->flags&(PV_VAL_NULL|PV_VAL_NONE))!=0) {
		/* reset the value to default */
		reset_proc_log_level();
	} else {
		if ((val->flags&PV_TYPE_INT)==0) {
			LM_ERR("input for $log_level found not to be an integer\n");
			return -1;
		}
		set_proc_log_level(val->ri);
	}

	return 0;
}

static int pv_get_log_level(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	int l;

	if (param==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if(res == NULL) {
		return -1;
	}

	res->ri = *log_level;
	res->rs.s = sint2str( (long)res->ri, &l);
	res->rs.len = l;

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}

static int pv_set_xlog_level(struct sip_msg* msg, pv_param_t *param, int op,
															pv_value_t *val)
{
	if(param==NULL)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(val==NULL || (val->flags&(PV_VAL_NULL|PV_VAL_NONE))!=0) {
		/* reset the value to default */
		reset_xlog_level();
	} else {
		if ((val->flags&PV_TYPE_INT)==0) {
			LM_ERR("input for $xlog_level found not to be an integer\n");
			return -1;
		}
		set_local_xlog_level( val->ri );
	}

	return 0;
}

static int pv_get_xlog_level(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	int l;

	if (param==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if(res == NULL) {
		return -1;
	}

	res->ri = *xlog_level;
	res->rs.s = sint2str( (long)res->ri, &l);
	res->rs.len = l;

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}


/************** MSG FLAGS function *****************/

static int msg_flag_parse_name(pv_spec_p sp, const str *in)
{
	unsigned int idx;
	if (sp==NULL || in==NULL || in->s==NULL || in->len==0)
		return -1;

	if ( (idx=fixup_flag(FLAG_TYPE_MSG, in))==NAMED_FLAG_ERROR) {
		LM_ERR("failed to fix the flag <%.*s>\n",in->len,in->s);
		return -1;
	}

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = 0;

	sp->pvp.pvn.u.isname.name.n = idx;

	return 0;
}


static int msg_flag_set(struct sip_msg* msg, pv_param_t *param, int op,
															pv_value_t *val)
{
	if(param==NULL) {
		LM_ERR("bad parameters\n");
		return -1;
	}

	if (val==NULL || (val->flags&(PV_VAL_NULL|PV_VAL_NONE))!=0 ||
	(val->flags&PV_TYPE_INT)==0 ) {
		LM_ERR("input for $msg.flag() found not to be an integer\n");
		return -1;
	}

	if (val->ri==0)
		resetflag (msg, (unsigned int)param->pvn.u.isname.name.n);
	else
		setflag( msg, (unsigned int)param->pvn.u.isname.name.n);

	return 0;
}


static int msg_flag_get(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	if (param==NULL||res==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if ( isflagset( msg, (unsigned int)param->pvn.u.isname.name.n)==1 ) {
		res->ri = 1;
		res->rs.s = "true";
		res->rs.len = 4;
	} else {
		res->ri = 0;
		res->rs.s = "false";
		res->rs.len = 5;
	}

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}


/************** MSG TYPE function *****************/

static int msg_is_request_get(struct sip_msg *msg, pv_param_t *param, pv_value_t *res)
{
	if (param==NULL||res==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if ( msg->first_line.type==SIP_REQUEST ) {
		res->ri = 1;
		res->rs.s = "true";
		res->rs.len = 4;
	} else {
		res->ri = 0;
		res->rs.s = "false";
		res->rs.len = 5;
	}

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}


static int msg_type_get(struct sip_msg *msg, pv_param_t *param, pv_value_t *res)
{
	if (param==NULL||res==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	if ( msg->first_line.type==SIP_REQUEST ) {
		res->rs.s = "request";
		res->rs.len = 7;
	} else {
		res->rs.s = "reply";
		res->rs.len = 5;
	}

	res->flags = PV_VAL_STR;

	return 0;
}



/************** BRANCH FLAGS function *****************/

static int branch_flag_parse_name(pv_spec_p sp, const str *in)
{
	unsigned int idx;
	if (sp==NULL || in==NULL || in->s==NULL || in->len==0)
		return -1;

	if ( (idx=fixup_flag(FLAG_TYPE_BRANCH, in))==NAMED_FLAG_ERROR) {
		LM_ERR("failed to fix the flag <%.*s>\n",in->len,in->s);
		return -1;
	}

	sp->pvp.pvn.type = PV_NAME_INTSTR;
	sp->pvp.pvn.u.isname.type = 0;

	sp->pvp.pvn.u.isname.name.n = idx;

	return 0;
}


static int branch_flag_set(struct sip_msg* msg, pv_param_t *param, int op,
															pv_value_t *val)
{
	int idx;
	int idxf;

	if(param==NULL) {
		LM_ERR("bad parameters\n");
		return -1;
	}

	if (val==NULL || (val->flags&(PV_VAL_NULL|PV_VAL_NONE))!=0 ||
	(val->flags&PV_TYPE_INT)==0 ) {
		LM_ERR("input for $branch.flag() found not to be an integer\n");
		return -1;
	}

	/* get the index */
	if (pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if(idxf==PV_IDX_ALL) {
		LM_ERR("SCRIPT BUG - * not allowed in branch flag assignment\n");
		return -1;
	}

	if (idx<0) {
		idx = get_nr_branches() + idx;
	}

	if (idx<0 || idx>=get_nr_branches()) {
		LM_DBG("inexisting branch flag assignment [%d/%d]\n",
			get_nr_branches(), idx);
		return -1;
	}

	if (val->ri==0)
		resetbflag (msg, idx, param->pvn.u.isname.name.n);
	else
		setbflag( msg, idx, param->pvn.u.isname.name.n);

	return 0;
}


static int branch_flag_get(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	int idx;
	int idxf;

	if (param==NULL||res==NULL) {
		LM_CRIT("BUG - bad parameters\n");
		return -1;
	}

	/* get the index */
	if (pv_get_spec_index(msg, param, &idx, &idxf)!=0) {
		LM_ERR("invalid index\n");
		return -1;
	}

	if(idxf==PV_IDX_ALL) {
		LM_ERR("SCRIPT BUG - * not allowed in branch flag reading\n");
		return -1;
	}

	if (idx<0) {
		idx = get_nr_branches() + idx;
	}

	if (idx<0 || idx>=get_nr_branches()) {
		LM_DBG("inexisting branch flag reading [%d/%d]\n",
			get_nr_branches(), idx);
		return -1;
	}

	if ( isbflagset( msg, idx, param->pvn.u.isname.name.n)==1 ) {
		res->ri = 1;
		res->rs.s = "true";
		res->rs.len = 4;
	} else {
		res->ri = 0;
		res->rs.s = "false";
		res->rs.len = 5;
	}

	res->flags = PV_VAL_STR|PV_VAL_INT|PV_TYPE_INT;

	return 0;
}


/********** generic helper functions ***************/

static int pv_is_obsolete(const pv_spec_p sp, int param)
{
	char *old, *new;

	switch(sp->type) {
		case PVT_RCVIP: /* added in 3.1 */
			old="$Ri";
			new="$socket_in(ip)";
			break;
		case PVT_RCVPORT: /* added in 3.1 */
			old="$Rp";
			new="$socket_in(port)";
			break;
		case PVT_PROTO: /* added in 3.1 */
			old="$pr/$proto";
			new="$socket_in(proto)";
			break;
		case PVT_FORCE_SOCK: /* added in 3.1 */
			old="$fs";
			new="$socket_out";
			break;
		case PVT_AF: /* added in 3.1 */
			old="$af";
			new="$socket_in(af)";
			break;
		default:
			LM_BUG("unrecognized deprecated pvar %d\n",sp->type);
			return -1;
	}

	LM_WARN("variable '%s' is marked as deprecated and it will be soon "
		"removed, please use '%s' instead\n",old,new);
	return 0;
}


/**
 * the table with core pseudo-variables
 */
static const pv_export_t _pv_names_table[] = {
	{str_init("avp"), PVT_AVP, pv_get_avp, pv_set_avp,
		pv_parse_avp_name, pv_parse_avp_index, 0, 0},
	{str_init("hdr"), PVT_HDR, pv_get_hdr, 0, pv_parse_hdr_name,
		pv_parse_index, 0, 0},
	{str_init("hdr_name"), PVT_HDR_NAME, pv_get_hdr_name, 0, 0,
		pv_parse_index, 0, 0},
	{str_init("hdrcnt"), PVT_HDRCNT, pv_get_hdrcnt, 0, pv_parse_hdr_name, 0, 0, 0},
	{str_init("var"), PVT_SCRIPTVAR, pv_get_scriptvar,
		pv_set_scriptvar, pv_parse_scriptvar_name, 0, 0, 0},
	{str_init("ai"), /* */
		PVT_PAI_URI, pv_get_pai, 0,
		0, 0, 0, 0},
	{str_init("au"), /* */
		PVT_AUTH_USERNAME, pv_get_authattr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("ar"), /* auth realm */
		PVT_AUTH_REALM, pv_get_authattr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("adu"), /* auth digest uri */
		PVT_AUTH_DURI, pv_get_authattr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("ad"), /* */
		PVT_AUTH_DOMAIN, pv_get_authattr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("an"), /* */
		PVT_AUTH_NONCE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 5},
	{str_init("auth.nonce"), /* */
		PVT_AUTH_NONCE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 5},
	{str_init("auth.resp"), /* */
		PVT_AUTH_RESPONSE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 6},
	{str_init("auth.cnonce"), /* */
		PVT_AUTH_CNONCE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 7},
	{str_init("auth.opaque"), /* */
		PVT_AUTH_OPAQUE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 8},
	{str_init("auth.alg"), /* */
		PVT_AUTH_ALGORITHM, pv_get_authattr, 0,
		0, 0, pv_init_iname, 9},
	{str_init("auth.qop"), /* */
		PVT_AUTH_QOP, pv_get_authattr, 0,
		0, 0, pv_init_iname, 10},
	{str_init("auth.nc"), /* */
		PVT_AUTH_NONCE_COUNT, pv_get_authattr, 0,
		0, 0, pv_init_iname, 11},
	{str_init("aU"), /* */
		PVT_AUTH_USERNAME_WHOLE, pv_get_authattr, 0,
		0, 0, pv_init_iname, 99},
	{str_init("Au"), /* */
		PVT_ACC_USERNAME, pv_get_acc_username, 0,
		0, 0, pv_init_iname, 1},
	{str_init("af"),
		PVT_AF, pv_get_af, 0,
		0, 0, pv_is_obsolete, 0},	/* */
	{str_init("bf"), /* */
		PVT_BFLAGS, pv_get_bflags, 0,
		0, 0, 0, 0},
	{str_init("branch"), /* */
		PVT_BRANCH, pv_get_branch_fields, pv_set_branch,
		0, 0, 0, 0},
	{str_init("branch"), /* */
		PVT_BRANCH, pv_get_branch_fields, pv_set_branch_fields,
		pv_parse_branch_name, pv_parse_index, 0, 0},
	{str_init("branch.flag"), /* */
		PVT_BRANCH_FLAG, branch_flag_get, branch_flag_set,
		branch_flag_parse_name, pv_parse_index, 0, 0},
	{str_init("ci"), /* */
		PVT_CALLID, pv_get_callid, 0,
		0, 0, 0, 0},
	{str_init("cl"), /* */
		PVT_CONTENT_LENGTH, pv_get_content_length, 0,
		0, 0, 0, 0},
	{str_init("cs"), /* */
		PVT_CSEQ, pv_get_cseq, 0,
		0, 0, 0, 0},
	{str_init("ct"), /* */
		PVT_CONTACT, pv_get_contact_body, 0,
		0, pv_parse_index, 0, 0},
	{str_init("ct.fields"), /* */
		PVT_CONTACT, pv_get_contact_body, 0,
		pv_parse_ct_name, pv_parse_index, 0, 0},
	{str_init("cT"), /* */
		PVT_CONTENT_TYPE, pv_get_content_type, 0,
		0, pv_parse_index, 0, 0},
	{str_init("dd"), /* */
		PVT_DSTURI_DOMAIN, pv_get_dsturi_attr, pv_set_dsturi_host,
		0, 0, pv_init_iname, 1},
	{str_init("di"), /* */
		PVT_DIVERSION_URI, pv_get_diversion, 0,
		0, 0, pv_init_iname, 1},
	{str_init("dir"), /* */
		PVT_DIV_REASON, pv_get_diversion, 0,
		0, 0, pv_init_iname, 2},
	{str_init("dip"), /* */
		PVT_DIV_PRIVACY, pv_get_diversion, 0,
		0, 0, pv_init_iname, 3},
	{str_init("dp"), /* */
		PVT_DSTURI_PORT, pv_get_dsturi_attr, pv_set_dsturi_port,
		0, 0, pv_init_iname, 2},
	{str_init("dP"), /* */
		PVT_DSTURI_PROTOCOL, pv_get_dsturi_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("ds"), /* */
		PVT_DSET, pv_get_dset, 0,
		0, 0, 0, 0},
	{str_init("du"), /* */
		PVT_DSTURI, pv_get_dsturi, pv_set_dsturi,
		0, 0, 0, 0},
	{str_init("duri"), /* */
		PVT_DSTURI, pv_get_dsturi, pv_set_dsturi,
		0, 0, 0, 0},
	{str_init("err.class"), /* */
		PVT_ERR_CLASS, pv_get_errinfo_attr, 0,
		0, 0, 0, 0},
	{str_init("err.level"), /* */
		PVT_ERR_LEVEL, pv_get_errinfo_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("err.info"), /* */
		PVT_ERR_INFO, pv_get_errinfo_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("err.rcode"), /* */
		PVT_ERR_RCODE, pv_get_errinfo_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("err.rreason"), /* */
		PVT_ERR_RREASON, pv_get_errinfo_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("fd"), /* */
		PVT_FROM_DOMAIN, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("from.domain"), /* */
		PVT_FROM_DOMAIN, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("fn"), /* */
		PVT_FROM_DISPLAYNAME, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 5},
	{str_init("fs"), /* */
		PVT_FORCE_SOCK, pv_get_force_sock, pv_set_force_sock,
		0, 0, pv_is_obsolete, 0},
	{str_init("ft"), /* */
		PVT_FROM_TAG, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("fu"), /* */
		PVT_FROM, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("from"), /* */
		PVT_FROM, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("fU"), /* */
		PVT_FROM_USERNAME, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("from.user"), /* */
		PVT_FROM_USERNAME, pv_get_from_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("log_level"), /* per process log level*/
		PVT_LOG_LEVEL, pv_get_log_level, pv_set_log_level,
		0, 0, 0, 0},
	{str_init("mb"), /* */
		PVT_MSG_BUF, pv_get_msg_buf, 0,
		0, 0, 0, 0},
	{str_init("mf"), /* */
		PVT_FLAGS, pv_get_flags, 0,
		0, 0, 0, 0},
	{str_init("msg.flag"), /* */
		PVT_MSG_FLAG, msg_flag_get, msg_flag_set,
		msg_flag_parse_name, 0, 0, 0},
	{str_init("msg.is_request"), /* */
		PVT_MSG_FLAG, msg_is_request_get, 0,
		0, 0, 0, 0},
	{str_init("msg.type"), /* */
		PVT_MSG_FLAG, msg_type_get, 0,
		0, 0, 0, 0},
	{str_init("mi"), /* */
		PVT_MSGID, pv_get_msgid, 0,
		0, 0, 0, 0},
	{str_init("ml"), /* */
		PVT_MSG_LEN, pv_get_msg_len, 0,
		0, 0, 0, 0},
	{str_init("od"), /* */
		PVT_OURI_DOMAIN, pv_get_ouri_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("op"), /* */
		PVT_OURI_PORT, pv_get_ouri_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("oP"), /* */
		PVT_OURI_PROTOCOL, pv_get_ouri_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("ou"), /* */
		PVT_OURI, pv_get_ouri, 0,
		0, 0, 0, 0},
	{str_init("ouri"), /* */
		PVT_OURI, pv_get_ouri, 0,
		0, 0, 0, 0},
	{str_init("oU"), /* */
		PVT_OURI_USERNAME, pv_get_ouri_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("path"), /* */
		PVT_PATH, pv_get_path, 0,
		0, 0, 0, 0},
	{str_init("pd"), /* */
		PVT_PPI_DOMAIN, pv_get_ppi_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("pn"), /* */
		PVT_PPI_DISPLAYNAME, pv_get_ppi_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("pp"), /* */
		PVT_PID, pv_get_pid, 0,
		0, 0, 0, 0},
	{str_init("pr"), /* */
		PVT_PROTO, pv_get_proto, 0,
		0, 0, pv_is_obsolete, 0},
	{str_init("proto"), /* */
		PVT_PROTO, pv_get_proto, 0,
		0, 0, pv_is_obsolete, 0},
	{str_init("pu"), /* */
		PVT_PPI, pv_get_ppi_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("pU"), /* */
		PVT_PPI_USERNAME, pv_get_ppi_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("rb"), /* */
		PVT_MSG_BODY, pv_get_msg_body, 0,
		0, pv_parse_index, 0, 0},
	{str_init("rb"), /* */
		PVT_MSG_BODY, pv_get_msg_body, 0,
		pv_parse_rb_name, pv_parse_index, 0, 0},
	{str_init("rc"), /* */
		PVT_RETURN_CODE, pv_get_return_code, 0,
		0, 0, 0, 0},
	{str_init("retcode"), /* */
		PVT_RETURN_CODE, pv_get_return_code, 0,
		0, 0, 0, 0},
	{str_init("rd"), /* */
		PVT_RURI_DOMAIN, pv_get_ruri_attr, pv_set_ruri_host,
		0, 0, pv_init_iname, 2},
	{str_init("ruri.domain"), /* */
		PVT_RURI_DOMAIN, pv_get_ruri_attr, pv_set_ruri_host,
		0, 0, pv_init_iname, 2},
	{str_init("re"), /* */
		PVT_RPID_URI, pv_get_rpid, 0,
		0, 0, 0, 0},
	{str_init("rm"), /* */
		PVT_METHOD, pv_get_method, 0,
		0, 0, 0, 0},
	{str_init("route"), /* */
		PVT_ROUTE_NAME, pv_get_route_name, 0,
		0, pv_parse_index, 0, 0},
	{str_init("rp"), /* */
		PVT_RURI_PORT, pv_get_ruri_attr, pv_set_ruri_port,
		0, 0, pv_init_iname, 3},
	{str_init("rP"), /* */
		PVT_RURI_PROTOCOL, pv_get_ruri_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("rr"), /* */
		PVT_REASON, pv_get_reason, 0,
		0, 0, 0, 0},
	{str_init("rs"), /* */
		PVT_STATUS, pv_get_status, 0,
		0, 0, 0, 0},
	{str_init("rt"), /* */
		PVT_REFER_TO, pv_get_refer_to, 0,
		0, 0, 0, 0},
	{str_init("ru"), /* */
		PVT_RURI, pv_get_ruri, pv_set_ruri,
		0, 0, 0, 0},
	{str_init("ruri"), /* */
		PVT_RURI, pv_get_ruri, pv_set_ruri,
		0, 0, 0, 0},
	{str_init("ru_q"), /* */
		PVT_RU_Q, pv_get_ru_q, pv_set_ru_q,
		0, 0, 0, 0},
	{str_init("rU"), /* */
		PVT_RURI_USERNAME, pv_get_ruri_attr, pv_set_ruri_user,
		0, 0, pv_init_iname, 1},
	{str_init("ruri.user"), /* */
		PVT_RURI_USERNAME, pv_get_ruri_attr, pv_set_ruri_user,
		0, 0, pv_init_iname, 1},
	{str_init("Ri"), /* */
		PVT_RCVIP, pv_get_rcvip, 0,
		0, 0, pv_is_obsolete, 0},
	{str_init("Rp"), /* */
		PVT_RCVPORT, pv_get_rcvport, 0,
		0, 0, pv_is_obsolete, 0},
	{str_init("src_ip"), /* */
		PVT_SRCIP, pv_get_srcip, 0,
		0, 0, 0, 0},
	{str_init("socket_in"), /* */
		PVT_SOCKET_IN, pv_get_socket_in_fields, NULL,
		0, 0, 0, 0},
	{str_init("socket_in"), /* */
		PVT_SOCKET_IN, pv_get_socket_in_fields, NULL,
		pv_parse_socket_name, 0, 0, 0},
	{str_init("socket_out"), /* */
		PVT_SOCKET_OUT, pv_get_socket_out_fields, pv_set_force_sock,
		0, 0, 0, 0},
	{str_init("socket_out"), /* */
		PVT_SOCKET_OUT, pv_get_socket_out_fields, NULL,
		pv_parse_socket_name, 0, 0, 0},
	{str_init("si"), /* */
		PVT_SRCIP, pv_get_srcip, 0,
		0, 0, 0, 0},
	{str_init("sp"), /* */
		PVT_SRCPORT, pv_get_srcport, 0,
		0, 0, 0, 0},
	{str_init("td"), /* */
		PVT_TO_DOMAIN, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("to.domain"), /* */
		PVT_TO_DOMAIN, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 3},
	{str_init("time"), /* */
		PVT_TIME, pv_get_formated_time, 0,
		pv_parse_time_name, 0, 0, 0},
	{str_init("tn"), /* */
		PVT_TO_DISPLAYNAME, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 5},
	{str_init("tt"), /* */
		PVT_TO_TAG, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 4},
	{str_init("tu"), /* */
		PVT_TO, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("to"), /* */
		PVT_TO, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 1},
	{str_init("tU"), /* */
		PVT_TO_USERNAME, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("to.user"), /* */
		PVT_TO_USERNAME, pv_get_to_attr, 0,
		0, 0, pv_init_iname, 2},
	{str_init("Tf"), /* */
		PVT_TIMEF, pv_get_timef, 0,
		0, 0, 0, 0},
	{str_init("Ts"), /* */
		PVT_TIMES, pv_get_times, 0,
		0, 0, 0, 0},
	{str_init("Tsm"), /* */
		PVT_TIMES, pv_get_timem, 0,
		0, 0, 0, 0},
	{str_init("TS"), /* */
		PVT_TIMES, pv_get_start_times, 0,
		0, 0, 0, 0},
	{str_init("ua"), /* */
		PVT_USERAGENT, pv_get_useragent, 0,
		0, 0, 0, 0},
	{str_init("C"), PVT_COLOR, pv_get_color, 0,
		pv_parse_color_name, 0, 0, 0 },
	{str_init("argv"), PVT_ARGV, pv_get_argv, 0,
		pv_parse_argv_name, 0, 0, 0 },
	{str_init("param"), PVT_ROUTE_PARAM, pv_get_param, 0,
		pv_parse_param_name, 0, 0, 0 },
	{str_init("cfg_line"), PVT_LINE_NUMBER, pv_get_line_number, 0,
		0, 0, 0, 0 },
	{str_init("cfg_file"), PVT_CFG_FILE_NAME, pv_get_cfg_file_name, 0,
	0, 0, 0, 0 },
	{str_init("xlog_level"), PVT_XLOG_LEVEL, pv_get_xlog_level,
		pv_set_xlog_level, 0, 0, 0, 0 },
	{{0,0}, 0, 0, 0, 0, 0, 0, 0}
};

static const pv_export_t* pv_lookup_spec_name(str *pvname, pv_spec_p e, int has_name)
{
	int i;
	pv_extra_p pvi;
	int found;

	if(pvname==0 || e==0)
	{
		LM_ERR("bad parameters\n");
		return NULL;
	}
	/* search in main table */
	for(i=0; _pv_names_table[i].name.s!=0; i++)
	{
		if(_pv_names_table[i].name.len==pvname->len
			&& !((has_name?1:0) ^ (_pv_names_table[i].parse_name?1:0))
			&& memcmp(_pv_names_table[i].name.s, pvname->s, pvname->len)==0)
		{
			/*LM_DBG("found [%.*s] [%d]\n", pvname->len, pvname->s,
					_pv_names_table[i].type);*/
			/* copy data from table to spec */
			e->type = _pv_names_table[i].type;
			e->getf = _pv_names_table[i].getf;
			e->setf = _pv_names_table[i].setf;
			return &_pv_names_table[i];
		}
	}
	/* search in extra list */
	if(_pv_extra_list==0)
	{
		LM_DBG("extra items list is empty\n");
		return NULL;
	}
	pvi = *_pv_extra_list;
	while(pvi)
	{
		if(pvi->pve.name.len>pvname->len)
			break;
		if(pvi->pve.name.len==pvname->len)
		{
			found = strncmp(pvi->pve.name.s, pvname->s, pvname->len);
			if(found>0)
				break;
			if(found==0)
			{
				LM_DBG("found in extra list [%.*s]\n", pvname->len, pvname->s);
				/* copy data from export to spec */
				e->type = pvi->pve.type;
				e->getf = pvi->pve.getf;
				e->setf = pvi->pve.setf;
				return &(pvi->pve);
			}
		}
		pvi = pvi->next;
	}

	return NULL;
}

static int is_pv_valid_char(char c)
{
	if((c>='0' && c<='9') || (c>='a' && c<='z') || (c>='A' && c<='Z')
			|| (c=='_') || (c=='.'))
		return 1;
	return 0;
}

char* pv_parse_spec(const str *in, const pv_spec_p e)
{
	char *p;
	str s;
	str pvname;
	str pvcontext;
	int pvstate;
	int has_inner_name;
	trans_t *tr = NULL;
	const pv_export_t *pte = NULL;
	int n=0;

	if(in==NULL || in->s==NULL || e==NULL || *in->s!=PV_MARKER)
	{
		LM_ERR("bad parameters\n");
		return NULL;
	}

//	LM_DBG("***** input [%.*s] (%d)\n", in->len, in->s, in->len);
	tr = 0;
	pvstate = 0;
	memset(e, 0, sizeof(pv_spec_t));
	p = in->s;
	p++;
	if(*p==PV_LNBRACKET)
	{
		p++;
		pvstate = 1;
	}
	pvname.s = p;
	if(*p == PV_MARKER) {
		p++;
		if(pvstate==1)
		{
			if(*p!=PV_RNBRACKET)
				goto error;
			p++;
		}
		e->getf = pv_get_marker;
		e->type = PVT_MARKER;
		pvname.len = 1;
		goto done_all;
	}

	if (*p==PV_LCBRACKET)
	{ /* context definition*/
		p++;
		pvcontext.s = p;

		while(is_in_str(p,in) && is_pv_valid_char(*p))
			p++;

		if(*p != PV_RCBRACKET)
		{
			LM_ERR("Expected to find the end of the context\n");
			return 0;
		}
		pvcontext.len = p - pvcontext.s;
		LM_DBG("Context name is %.*s\n", pvcontext.len, pvcontext.s);
		p++;
		e->pvc = pv_get_context(&pvcontext);
		if(e->pvc == NULL)
		{
			if(!pvc_before_check)
			{
				LM_ERR("Requested a non existing pv context\n");
				return 0;
			}
			LM_DBG("No context definition found for [%.*s]\n", pvcontext.len, pvcontext.s);
			/* create a dummy context strcuture to be filled by the register functions */
			e->pvc = add_pv_context(&pvcontext, 0);
			if(e->pvc == NULL )
			{
				LM_ERR("Failed to new context\n");
				return 0;
			}
		}
	}

	pvname.s = p;
	while(is_in_str(p,in) && is_pv_valid_char(*p))
		p++;
	pvname.len = p - pvname.s;

	if(pvstate==1)
	{
		if(*p==PV_RNBRACKET)
		{ /* full pv name ended here*/
			goto done_inm;
		} else if(*p==PV_LNBRACKET) {
			p++;
			pvstate = 2;
		} else if(*p==PV_LIBRACKET) {
			p++;
			pvstate = 3;
		} else if(*p==TR_LBRACKET) {
			p++;
			pvstate = 4;
		}
		else {
			LM_ERR("invalid char '%c' in [%.*s] (%d)\n", *p, in->len, in->s,
					pvstate);
			goto error;
		}
	} else {
		if(!is_in_str(p, in)) {
			p--;
			goto done_inm;
		} else if(*p==PV_LNBRACKET) {
			p++;
			pvstate = 5;
		} else {
			/* still in input str, but end of PV */
			/* p is increased at the end, so decrement here */
			p--;
			goto done_inm;
		}
	}

done_inm:
	has_inner_name = (pvstate==2||pvstate==5)?1:0;
	if((pte = pv_lookup_spec_name(&pvname, e, has_inner_name))==NULL)
	{
		LM_ERR("unknown script var $%.*s%s, maybe a 'loadmodule' statement "
		       "is missing?\n", pvname.len, pvname.s,has_inner_name ? "()":"");
		goto error;
	}
	if(pvstate==2 || pvstate==5)
	{
		s.s = p;
		n = 0;
		while(is_in_str(p, in))
		{
			if(*p==PV_RNBRACKET)
			{
				if(n==0)
					break;
				n--;
			}
			if(*p == PV_LNBRACKET)
				n++;
			p++;
		}

		if(!is_in_str(p, in))
			goto error;

		if(p==s.s)
		{
			LM_ERR("pvar \"%.*s\" does not get empty name param\n",
					pvname.len, pvname.s);
			goto error;
		}
		s.len = p - s.s;
		if(pte->parse_name == NULL || pte->parse_name(e, &s)!=0)
		{
			LM_ERR("pvar \"%.*s\" has an invalid name param [%.*s]\n",
					pvname.len, pvname.s, s.len, s.s);
			goto error;
		}
		if(pvstate==2)
		{
			p++;
			if(*p==PV_RNBRACKET)
			{ /* full pv name ended here*/
				goto done_vnm;
			} else if(*p==PV_LIBRACKET) {
				p++;
				pvstate = 3;
			} else if(*p==TR_LBRACKET) {
				p++;
				pvstate = 4;
			} else {
				LM_ERR("invalid char '%c' in [%.*s] (%d)\n", *p, in->len, in->s,
					pvstate);
				goto error;
			}
		} else {
			if(*p==PV_RNBRACKET)
			{ /* full pv name ended here*/
				p++;
				goto done_all;
			} else {
				LM_ERR("invalid char '%c' in [%.*s] (%d)\n", *p, in->len, in->s,
					pvstate);
				goto error;
			}
		}
	}
done_vnm:
	if(pvstate==3)
	{
		if(pte->parse_index==NULL)
		{
			LM_ERR("pvar \"%.*s\" does not get index param\n",
					pvname.len, pvname.s);
			goto error;
		}
		s.s = p;
		n = 0;
		while(is_in_str(p, in))
		{
			if(*p==PV_RIBRACKET)
			{
				if(n==0)
					break;
				n--;
			}
			if(*p == PV_LIBRACKET)
				n++;
			p++;
		}
		if(!is_in_str(p, in))
			goto error;

		if(p==s.s)
		{
			LM_ERR("pvar \"%.*s\" does not get empty index param\n",
					pvname.len, pvname.s);
			goto error;
		}
		s.len = p - s.s;
		if(pte->parse_index(e, &s)!=0)
		{
			LM_ERR("pvar \"%.*s\" has an invalid index param [%.*s]\n",
					pvname.len, pvname.s, s.len, s.s);
			goto error;
		}
		p++;
		if(*p==PV_RNBRACKET)
		{ /* full pv name ended here*/
			goto done_idx;
		} else if(*p==TR_LBRACKET) {
			p++;
			pvstate = 4;
		} else {
			LM_ERR("invalid char '%c' in [%.*s] (%d)\n", *p, in->len, in->s,
					pvstate);
			goto error;
		}
	}
done_idx:
	if(pvstate==4)
	{
		s.s = p-1;
		n = 0;
		while(is_in_str(p, in))
		{
			if(*p==TR_RBRACKET)
			{
				if(n==0)
				{
					/* yet another transformation */
					p++;
					while(is_in_str(p, in) && (*p==' ' || *p=='\t')) p++;

					if(!is_in_str(p, in) || *p != TR_LBRACKET)
					{
						p--;
						break;
					}
				}
				n--;
			}
			if(*p == TR_LBRACKET)
				n++;
			p++;
		}
		if(!is_in_str(p, in))
			goto error;

		if(p==s.s)
		{
			LM_ERR("pvar \"%.*s\" does not get empty index param\n",
					pvname.len, pvname.s);
			goto error;
		}
		s.len = p - s.s + 1;

		p = parse_transformation(&s, &tr);
		if(p==NULL)
		{
			LM_ERR("ERROR:bad tr in pvar name \"%.*s\"\n",
					pvname.len, pvname.s);
			goto error;
		}
		if(*p!=PV_RNBRACKET)
		{
			LM_ERR("bad pvar name \"%.*s\" (%c)!\n", in->len, in->s, *p);
			goto error;
		}
		e->trans = (void*)tr;
	}
	p++;

done_all:
	if(pte!=NULL && pte->init_param)
		pte->init_param(e, pte->iparam);
	return p;

error:
	if(p!=NULL)
		LM_ERR("wrong char [%c/%d] in [%.*s] at [%d (%d)]\n", *p, (int)*p,
			in->len, in->s, (int)(p-in->s), pvstate);
	else
		LM_ERR("invalid parsing in [%.*s] at (%d)\n", in->len, in->s, pvstate);
	return NULL;

} /* end: pv_parse_spec */

/**
 *
 */
int pv_parse_format(const str *in, pv_elem_p *el)
{
	char *p, *p0;
	int n = 0;
	pv_elem_p e, e0;
	str s;

	if(in==NULL || in->s==NULL || el==NULL)
		return -1;

	/*LM_DBG("parsing [%.*s]\n", in->len, in->s);*/

	if(in->len == 0)
	{
		*el = pkg_malloc(sizeof(pv_elem_t));
		if(*el == NULL) {
			LM_ERR("not enough pkg memory for PV element (1)\n");
			goto error;
		}
		memset(*el, 0, sizeof(pv_elem_t));
		(*el)->text = *in;
		return 0;
	}

	p = in->s;
	*el = NULL;
	e = e0 = NULL;

	while(is_in_str(p,in))
	{
		e0 = e;
		e = pkg_malloc(sizeof(pv_elem_t));
		if(!e) {
			LM_ERR("not enough pkg memory for PV element (2)\n");
			goto error;
		}
		memset(e, 0, sizeof(pv_elem_t));
		n++;
		if(*el == NULL)
			*el = e;
		if(e0)
			e0->next = e;

		e->text.s = p;
		while(is_in_str(p,in) && *p!=PV_MARKER)
			p++;
		e->text.len = p - e->text.s;

		if(!is_in_str(p,in))
			break;
		s.s = p;
		s.len = in->s+in->len-p;
		p0 = pv_parse_spec(&s, &e->spec);

		if(p0==NULL) {
			LM_ERR("parsing PV spec failed\n");
			goto error;
		}
		if(!is_in_str(p0,in))
			break;
		p = p0;
	}
	/*LM_DBG("format parsed OK: [%d] items\n", n);*/

	if(*el == NULL)
		return -1;

	return 0;

error:
	pv_elem_free_all(*el);
	*el = NULL;
	return -1;
}

int pv_get_spec_name(struct sip_msg* msg, pv_param_p ip, pv_value_t *name)
{
	if(msg==NULL || ip==NULL || name==NULL)
		return -1;
	memset(name, 0, sizeof(pv_value_t));

	if(ip->pvn.type==PV_NAME_INTSTR)
	{
		if(ip->pvn.u.isname.type&AVP_NAME_STR)
		{
			name->rs = ip->pvn.u.isname.name.s;
			name->flags = PV_VAL_STR;
		} else {
			name->ri = ip->pvn.u.isname.name.n;
			name->flags = PV_VAL_INT|PV_TYPE_INT;
		}
		return 0;
	}
	/* pvar */
	if(pv_get_spec_value(msg, (const pv_spec_p)(ip->pvn.u.dname), name)!=0)
	{
		LM_ERR("cannot get name value\n");
		return -1;
	}
	if(name->flags&PV_VAL_NULL || name->flags&PV_VAL_EMPTY)
	{
		LM_ERR("null or empty name\n");
		return -1;
	}
	return 0;
}

int pv_get_avp_name(struct sip_msg* msg, pv_param_p ip, int *avp_name,
		unsigned short *name_type)
{
	pv_value_t tv;
	if(ip==NULL || avp_name==NULL || name_type==NULL)
		return -1;
	*avp_name = 0;
	*name_type = 0;

	if(ip->pvn.type==PV_NAME_INTSTR)
	{
		*name_type = ip->pvn.u.isname.type;
		*avp_name = ip->pvn.u.isname.name.n;
		*name_type &= AVP_SCRIPT_MASK;
		return 0;
	}
	/* pvar */
	if(pv_get_spec_value(msg, (const pv_spec_p)(ip->pvn.u.dname), &tv)!=0)
	{
		LM_ERR("cannot get avp value\n");
		return -1;
	}
	if(tv.flags&PV_VAL_NULL || tv.flags&PV_VAL_EMPTY)
	{
		LM_ERR("null or empty name\n");
		return -1;
	}

	if(!(tv.flags&PV_VAL_STR))
		tv.rs.s = int2str(tv.ri, &tv.rs.len);

	/* search the name here */
	*avp_name = get_avp_id(&tv.rs);
	if (*avp_name == 0) {
		LM_ERR("cannot find avp %.*s\n", tv.rs.len, tv.rs.s);
		return -1;
	}
	return 0;
}


int pv_get_spec_index(struct sip_msg* msg, pv_param_p ip, int *idx, int *flags)
{
	pv_value_t tv;
	if(ip==NULL || idx==NULL || flags==NULL)
		return -1;

	*idx = 0;
	*flags = ip->pvi.type;

	if(ip->pvi.type == 0)
		return 0;

	if(ip->pvi.type == PV_IDX_ALL || ip->pvi.type == PV_IDX_APPEND) {
		return 0;
	}

	if(ip->pvi.type == PV_IDX_INT)
	{
		*idx = ip->pvi.u.ival;
		return 0;
	}

	/* pvar */
	if(pv_get_spec_value(msg, (const pv_spec_p)ip->pvi.u.dval, &tv)!=0)
	{
		LM_ERR("cannot get index value\n");
		return -1;
	}
	if(!(tv.flags & PV_VAL_INT))
	{
		LM_ERR("invalid index value\n");
		return -1;
	}
	*idx = tv.ri;
	return 0;
}

/* function to set pv value */
int pv_set_value(struct sip_msg* msg, pv_spec_p sp,
		int op, pv_value_t *value)
{
	struct sip_msg* pv_msg;

	if(msg==NULL || sp==NULL || sp->setf==NULL || sp->type==PVT_NONE)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	if(sp->pvc && sp->pvc->contextf)
	{
		pv_msg = sp->pvc->contextf(msg);
		if(pv_msg == NULL || pv_msg==FAKED_REPLY)
		{
			LM_DBG("Invalid %p pv context message\n",pv_msg);
			return -1;
		}
	}
	else
		pv_msg = msg;

	return (*sp->setf)(pv_msg, &(sp->pvp), op, value);
}

int pv_get_spec_value(struct sip_msg* msg, const pv_spec_p sp, pv_value_t *value)
{
	struct sip_msg* pv_msg;

	if(msg==NULL || sp==NULL || sp->getf==NULL || value==NULL
			|| sp->type==PVT_NONE)
	{
		LM_ERR("bad parameters\n");
		return -1;
	}

	memset(value, 0, sizeof(pv_value_t));

	if(sp->pvc && sp->pvc->contextf)
	{
		LM_DBG("Found context function %p\n", sp->pvc->contextf);
		pv_msg = sp->pvc->contextf(msg);
		if(pv_msg == NULL || pv_msg==FAKED_REPLY)
		{
			LM_DBG("Invalid %p pv context message\n",pv_msg);
			return pv_get_null( NULL, NULL, value);
		}
	} else {
		pv_msg = msg;
	}
	if((*sp->getf)(pv_msg, &(sp->pvp), value)!=0)
		return pv_get_null( NULL, NULL, value);
	if(sp->trans)
		if (run_transformations(pv_msg, (trans_t*)sp->trans, value)!=0)
			return pv_get_null( NULL, NULL, value);
	return 0;
}

int pv_print_spec(struct sip_msg* msg, const pv_spec_p sp, char *buf, int *len)
{
	pv_value_t tok;
	if(msg==NULL || sp==NULL || buf==NULL || len==NULL)
		return -1;

	if(*len <= 0)
		return -1;

	memset(&tok, 0, sizeof(pv_value_t));

	/* put the value of the specifier */
	if(pv_get_spec_value(msg, sp, &tok)==0)
	{
		if(tok.flags&PV_VAL_NULL)
			tok.rs = str_null;
		if(tok.rs.len < *len)
			memcpy(buf, tok.rs.s, tok.rs.len);
		else
			goto overflow;
	}

	*len = tok.rs.len;
	buf[tok.rs.len] = '\0';
	return 0;

overflow:
	LM_ERR("buffer overflow -- increase the buffer size...\n");
	return -1;
}


int pv_printf(struct sip_msg* msg, pv_elem_p list, char *buf, int *len)
{
	int n;
	pv_value_t tok;
	str print;
	pv_elem_p it;
	char *cur;

	if(msg==NULL || list==NULL || buf==NULL || len==NULL)
		return -1;

	if(*len <= 0)
		return -1;

	*buf = '\0';
	cur = buf;

	n = 0;
	for (it=list; it; it=it->next)
	{
		/* put the text */
		if(it->text.s && it->text.len>0)
		{
			if(n+it->text.len < *len)
			{
				memcpy(cur, it->text.s, it->text.len);
				n += it->text.len;
				cur += it->text.len;
			} else {
				LM_ERR("no more space for text [%d][%d]\n", n, it->text.len);
				goto overflow;
			}
		}
		/* put the value of the specifier */
		if(it->spec.type!=PVT_NONE
				&& pv_get_spec_value(msg, &(it->spec), &tok)==0)
		{
			print = pv_value_print(&tok);
			if (n + print.len >= *len) {
				LM_ERR("no more space for spec value [%d][%d]\n",
				       n, print.len);
				goto overflow;
			}

			memcpy(cur, print.s, print.len);
			n += print.len;
			cur += print.len;
		}
	}

	goto done;

overflow:
	if (is_pv_print_buf(buf))
		LM_ERR("buffer too small -- increase 'pv_print_buf_size' from [%d]\n",
				*len);
	else
		LM_ERR("buffer too small -- increase the buffer size "
				"from [%d]...\n", *len);
	return -1;

done:
#ifdef EXTRA_DEBUG
	LM_DBG("final buffer length %d\n", n);
#endif
	*cur = '\0';
	*len = n;
	return 0;
}



pvname_list_t* parse_pvname_list(str *in, unsigned int type)
{
	pvname_list_t* head = NULL;
	pvname_list_t* al = NULL;
	pvname_list_t* last = NULL;
	char *p;
	pv_spec_t spec;
	str s;

	if(in==NULL || in->s==NULL)
	{
		LM_ERR("bad parameters\n");
		return NULL;
	}

	p = in->s;
	while(is_in_str(p, in))
	{
		while(is_in_str(p, in) && (is_ws(*p)||*p==','||*p==';'))
			p++;
		if(!is_in_str(p, in))
		{
			if(head==NULL)
				LM_ERR("wrong item name list [%.*s]\n", in->len, in->s);
			return head;
		}
		s.s=p;
		s.len = in->s+in->len-p;
		p = pv_parse_spec(&s, &spec);
		if(p==NULL || (type && spec.type!=type))
		{
			LM_ERR("wrong item name list [%.*s]!\n", in->len, in->s);
			goto error;
		}
		al = (pvname_list_t*)pkg_malloc(sizeof(pvname_list_t));
		if(al==NULL)
		{
			LM_ERR("no more memory!\n");
			goto error;
		}
		memset(al, 0, sizeof(pvname_list_t));
		memcpy(&al->sname, &spec, sizeof(pv_spec_t));

		if(last==NULL)
		{
			head = al;
			last = al;
		} else {
			last->next = al;
			last = al;
		}
	}

	return head;

error:
	while(head)
	{
		al = head;
		head=head->next;
		pkg_free(al);
	}
	return NULL;
}

int pv_elem_free_all(pv_elem_p log)
{
	pv_elem_p t;
	while(log)
	{
		t = log;
		log = log->next;
		pkg_free(t);
	}
	return 0;
}

static str pv_value_print(const pv_value_t *val)
{
	str printed = str_init(NULL);

	if (val->flags & PV_VAL_NULL)
		return str_null;

	if (val->flags & PV_VAL_STR)
		return val->rs;

	if (val->flags & (PV_VAL_INT|PV_TYPE_INT)) {
		printed.s = int2str(val->ri, &printed.len);
		return printed;
	}

	LM_ERR("unknown type %x\n", val->flags);
	return str_empty;
}

void pv_value_destroy(pv_value_t *val)
{
	if(val==0) return;
	if(val->flags&PV_VAL_PKG) pkg_free(val->rs.s);
	if(val->flags&PV_VAL_SHM) shm_free(val->rs.s);
	memset(val, 0, sizeof(pv_value_t));
}

/* IMPORTANT NOTE - even if the function prints and returns a static buffer, it
 * has built-in support for PV_PRINTF_BUF_NO levels of nesting
 * (or concurrent usage).  If you think it's not enough for you, either use
 * pv_printf() directly, either increase PV_PRINT_BUF_NO   --bogdan */
int pv_printf_s(struct sip_msg* msg, pv_elem_p list, str *s)
{
	static int buf_itr = 0;

	if (list->next==0 && list->spec.getf==0) {
		*s = list->text;
		return 0;
	} else {
		*s = pv_print_buf[buf_itr];
		buf_itr = (buf_itr + 1) % PV_PRINT_BUF_NO;
		return pv_printf(msg, list, s->s, &s->len);
	}
}

void pv_spec_free(pv_spec_t *spec)
{
	if(spec==0) return;
	/* TODO: free name if it is PV */
	if(spec->trans)
		free_transformation((trans_t*)spec->trans);
	pkg_free(spec);
}

int pv_spec_dbg(const pv_spec_p sp)
{
	if(sp==NULL)
	{
		LM_DBG("spec: <<NULL>>\n");
		return 0;
	}
	LM_DBG("<spec>\n");
	LM_DBG("type: %d\n", sp->type);
	LM_DBG("getf: %p\n", sp->getf);
	LM_DBG("setf: %p\n", sp->setf);
	LM_DBG("tran: %p\n", sp->trans);
	LM_DBG("<param>\n");
	LM_DBG("<name>\n");
	LM_DBG("type: %d\n", sp->pvp.pvn.type);
	if(sp->pvp.pvn.type==PV_NAME_INTSTR)
	{
		LM_DBG("sub-type: %d\n", sp->pvp.pvn.u.isname.type);
		if (sp->pvp.pvn.u.isname.type&AVP_NAME_STR)
		{
			LM_DBG("name str: %.*s\n",
					sp->pvp.pvn.u.isname.name.s.len,
					sp->pvp.pvn.u.isname.name.s.s);
		} else {
			LM_DBG("name in: %d\n",
					sp->pvp.pvn.u.isname.name.n);
		}

	} else if(sp->pvp.pvn.type==PV_NAME_PVAR) {
		pv_spec_dbg((pv_spec_p)sp->pvp.pvn.u.dname);
	} else {
		LM_DBG("name: unknown\n");
	}
	LM_DBG("</name>\n");
	LM_DBG("<index>\n");
	LM_DBG("type: %d\n", sp->pvp.pvi.type);
	if(sp->pvp.pvi.type==PV_IDX_INT)
	{
		LM_DBG("index: %d\n", sp->pvp.pvi.u.ival);
	} else if(sp->pvp.pvi.type==PV_IDX_PVAR) {
		pv_spec_dbg((pv_spec_p)sp->pvp.pvi.u.dval);
	} else if(sp->pvp.pvi.type==PV_IDX_ALL){
		LM_DBG("index: *\n");
	} else {
		LM_DBG("index: unknown\n");
	}
	LM_DBG("</index>\n");
	LM_DBG("</param>\n");
	LM_DBG("</spec\n");
	return 0;
}


/**
 *
 */
static int pv_init_extra_list(void)
{
	_pv_extra_list = (pv_extra_p*)pkg_malloc(sizeof(pv_extra_p));
	if(_pv_extra_list==0)
	{
		LM_ERR("cannot alloc extra items list\n");
		return -1;
	}
	*_pv_extra_list=0;
	return 0;
}

static int pv_add_extra(pv_export_t *e)
{
	char *p;
	const str *in;
	pv_extra_t *pvi = NULL;
	pv_extra_t *pvj = NULL;
	pv_extra_t *pvn = NULL;
	int found;

	if(e==NULL || e->name.s==NULL || e->getf==NULL || e->type==PVT_NONE)
	{
		LM_ERR("invalid parameters\n");
		return -1;
	}

	if(_pv_extra_list==0)
	{
		LM_DBG("extra items list is not initialized\n");
		if(pv_init_extra_list()!=0)
		{
			LM_ERR("cannot intit extra list\n");
			return -1;
		}
	}
	in = &(e->name);
	p = in->s;
	while(is_in_str(p,in) && is_pv_valid_char(*p))
		p++;
	if(is_in_str(p,in))
	{
		LM_ERR("invalid char [%c] in [%.*s]\n", *p, in->len, in->s);
		return -1;
	}
	found = 0;
	pvi = *_pv_extra_list;
	while(pvi)
	{
		if(pvi->pve.name.len > in->len)
			break;
		if(pvi->pve.name.len==in->len)
		{
			found = strncmp(pvi->pve.name.s, in->s, in->len);
			if(found>0)
				break;
			if(found==0)
			{
				LM_ERR("pvar [%.*s] already exists\n", in->len, in->s);
				return -1;
			}
		}
		pvj = pvi;
		pvi = pvi->next;
	}

	pvn = (pv_extra_t*)pkg_malloc(sizeof(pv_extra_t));
	if(pvn==0)
	{
		LM_ERR("no more memory\n");
		return -1;
	}
	memcpy(&pvn->pve, e, sizeof(*e));
	pvn->pve.type += PVT_EXTRA;

	if(pvj==0)
	{
		pvn->next = *_pv_extra_list;
		*_pv_extra_list = pvn;
		goto done;
	}
	pvn->next = pvj->next;
	pvj->next = pvn;

done:
	return 0;
}

int register_pvars_mod(char *mod_name, pv_export_t *items)
{
	int ret;
	int i;

	if (items==0)
		return 0;

	for ( i=0 ; items[i].name.s ; i++ ) {
		ret = pv_add_extra(&items[i]);
		if (ret!=0) {
			LM_ERR("failed to register pseudo-variable <%.*s> for module %s\n",
					items[i].name.len, items[i].name.s, mod_name);
		}
	}
	return 0;
}

/**
 *
 */
int pv_free_extra_list(void)
{
	pv_extra_p xe;
	pv_extra_p xe1;
	if(_pv_extra_list!=0)
	{
		xe = *_pv_extra_list;
		while(xe!=0)
		{
			xe1 = xe;
			xe = xe->next;
			pkg_free(xe1);
		}
		pkg_free(_pv_extra_list);
		_pv_extra_list = 0;
	}

	return 0;
}

static pv_context_t* new_pv_context(const str* name, pv_contextf_t get_context)
{
	pv_context_t* pvc_new = NULL;
	int size;
/*
	if(get_context == NULL)
	{
		LM_ERR("NULL pointer to function\n");
		return 0;
	}
*/
	size = sizeof(pv_context_t) + name->len;
	pvc_new = (pv_context_t*)pkg_malloc(size);
	if(pvc_new == NULL)
	{
		LM_ERR("No more memory\n");
		return 0;
	}
	memset(pvc_new, 0, size);

	pvc_new->name.s = (char*)pvc_new + sizeof(pv_context_t);
	memcpy(pvc_new->name.s, name->s, name->len);
	pvc_new->name.len = name->len;

	pvc_new->contextf = get_context;

	return pvc_new;
}

int register_pv_context(char* cname, pv_contextf_t get_context)
{
	pv_context_t* pvc = pv_context_lst;
	str name;

	if(cname == NULL)
	{
		LM_DBG("NULL parameter\n");
		return -1;
	}

	name.s = cname;
	name.len = strlen(cname);

	LM_DBG("Registered new context: %.*s / %p\n", name.len, name.s, get_context);
	pvc = pv_get_context(&name);
	if(pvc == NULL)
	{
		LM_DBG("Context not found\n");
		if(add_pv_context(&name, get_context) == NULL)
		{
			LM_ERR("Failed to add context\n");
			return -1;
		}
		return 1;
	}

	if(pvc->contextf!=NULL)
	{
		LM_ERR("Context already registered [%s]\n", cname);
		return -1;
	}
	if(get_context == NULL)
	{
		LM_ERR("NULL context getter function\n");
		return -1;
	}
	pvc->contextf= get_context;
	return 1;
}


/* function to register a pv context getter */
static pv_context_t* add_pv_context(const str* name, pv_contextf_t get_context)
{
	pv_context_t* pvc = pv_context_lst;
	pv_context_t* pvc_new, *pvc_prev;

	if(pvc == NULL)
	{
		pvc_new = new_pv_context(name, get_context);
		if(pvc_new == NULL)
		{
			LM_ERR("Failed to allocate context\n");
			return 0;
		}
		pv_context_lst = pvc_new;
		return pvc_new;
	}

	while(pvc)
	{
		if(pvc->name.len == name->len && strncmp(pvc->name.s, name->s, name->len)==0)
		{
			LM_ERR("PV Context already registered [%.*s]\n", name->len, name->s);
			return 0;
		}
		pvc_prev = pvc;
		pvc = pvc->next;
	}

	pvc_new = new_pv_context(name, get_context);
	if(pvc_new == NULL)
	{
		LM_ERR("Failed to allocate context\n");
		return 0;
	}

	LM_DBG("Registered new context: %.*s\n", name->len, name->s);

	pvc_prev->next = pvc_new;

	return pvc_new;
}

static pv_context_t* pv_get_context(const str* name)
{
	pv_context_t* pvc = pv_context_lst;

	while(pvc)
	{
		if(pvc->name.len == name->len &&
				strncmp(pvc->name.s, name->s, name->len) == 0)
		{
			return pvc;
		}
		pvc = pvc->next;
	}
	return 0;
}

static int pv_contextlist_check(void)
{
	pv_context_t* pvc = pv_context_lst;

	while(pvc)
	{
		if(pvc->contextf == NULL)
			return -1;

		pvc = pvc->next;
	}
	pvc_before_check = 0;
	return 0;
}

/* argument options '-o' */
argv_p argv_vars = NULL;

static argv_p search_argv(const str *name)
{
	argv_p it;

	for (it = argv_vars; it; it = it->next) {
		if (it->name.len == name->len &&
				!strncmp(it->name.s, name->s, name->len))
			return it;
	}
	return 0;
}

int add_arg_var(char *opt)
{
	char *eq;
	str name;
	argv_p new = NULL;

	if (!opt) {
		LM_ERR("cannot receive null option\n");
		return -1;
	}

	eq = strchr(opt, '=');
	if (!eq) {
		LM_ERR("invalid option format - '=' char cannot be found\n");
		return -1;
	}
	if (eq <= opt) {
		LM_ERR("no option name specified\n");
		return -1;
	}

	name.s = opt;
	name.len = eq - name.s;

	/* check for duplicate option name */
	if (search_argv(&name)) {
		LM_ERR("duplicate option name <%.*s>\n", name.len, name.s);
		return -1;
	}

	new = (argv_p)pkg_malloc(sizeof(argv_t));
	if (!new) {
		LM_ERR("no more pkg memory\n");
		return -1;
	}
	memset(new, 0, sizeof(argv_t));

	new->name.s = name.s;
	new->name.len = name.len;

	new->value.s = eq+1;
	new->value.len = strlen(opt) + opt - new->value.s;

	if (!new->value.len)
		new->value.s = 0;

	new->next = argv_vars;
	argv_vars = new;

	LM_DBG("added argument name <%.*s> = <%.*s>\n",
			name.len, name.s, new->value.len, new->value.s);
	return 0;

}

static int pv_parse_argv_name(pv_spec_p sp, const str *in)
{
	argv_p v_arg;

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;

	v_arg = search_argv(in);
	if (!v_arg) {
		LM_DBG("$argv(%.*s) not found\n", in->len, in->s);
		sp->pvp.pvv.len = 0;
		sp->pvp.pvv.s = 0;
	} else {
		sp->pvp.pvv = v_arg->value;
		sp->pvp.pvn.u.isname.name.s = v_arg->name;
	}

	sp->pvp.pvn.type = PV_NAME_PVAR;

	return 0;
}

static int pv_get_argv(struct sip_msg *msg,  pv_param_t *param, pv_value_t *res)
{
	if (!param) {
		LM_ERR("null parameter received\n");
		return -1;
	}

	if (param->pvv.len == 0 || !param->pvv.s)
		return pv_get_null(msg, param, res);

	return pv_get_strval(msg, param, res, &param->pvv);
}

static int pv_parse_param_name(pv_spec_p sp, const str *in)
{
	char *p;
	char *s;
	pv_spec_p nsp = 0;

	if(in==NULL || in->s==NULL || sp==NULL)
		return -1;
	p = in->s;
	if(*p==PV_MARKER)
	{
		nsp = (pv_spec_p)pkg_malloc(sizeof(pv_spec_t));
		if(nsp==NULL)
		{
			LM_ERR("no more memory\n");
			return -1;
		}
		s = pv_parse_spec(in, nsp);
		if(s==NULL)
		{
			LM_ERR("invalid name [%.*s]\n", in->len, in->s);
			pv_spec_free(nsp);
			return -1;
		}
		sp->pvp.pvn.type = PV_NAME_PVAR;
		sp->pvp.pvn.u.dname = (void*)nsp;
		return 0;
	}
	/*LM_DBG("static name [%.*s]\n", in->len, in->s);*/
	/* always an int type from now */
	sp->pvp.pvn.u.isname.type = 0;
	sp->pvp.pvn.type = PV_NAME_INTSTR;
	/* do our best to convert it to an index */
	if (str2int(in, (unsigned int *)&sp->pvp.pvn.u.isname.name.n) < 0)
	{
		/* remember it was a string, so we can retrieve it later */
		sp->pvp.pvn.u.isname.name.s = *in;
		sp->pvp.pvn.u.isname.type = AVP_NAME_STR;
	}
	return 0;

}

static int pv_get_param(struct sip_msg *msg,  pv_param_t *ip, pv_value_t *res)
{
	if (!ip)
	{
		LM_ERR("null parameter received\n");
		return -1;
	}
	return route_params_run(msg, ip, res);
}

void destroy_argv_list(void)
{
	argv_p arg;

	while (argv_vars) {
		arg = argv_vars;
		argv_vars = argv_vars->next;
		pkg_free(arg);
	}
}