/src/opensips/transformations.c

Source
/*
 * Copyright (C) 2007 voice-system.ro
 *
 * 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
 *
 */

/*! \file
 * \brief Support for transformations
 */

/* make strptime available */
#define _GNU_SOURCE
#include <time.h>

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

#include "dprint.h"
#include "mem/mem.h"
#include "ut.h"
#include "trim.h"
#include "dset.h"
#include "usr_avp.h"
#include "errinfo.h"
#include "resolve.h"
#include "ip_addr.h"

#include "parser/parse_param.h"
#include "parser/parse_uri.h"
#include "parser/parse_via.h"
#include "parser/parse_to.h"
#include "parser/sdp/sdp_helpr_funcs.h"
#include "parser/sdp/sdp.h"

#include "lib/csv.h"
#include "strcommon.h"
#include "transformations.h"
#include "re.h"
#include "sha1.h"
#include "sha256.h"
#include "sha512.h"
#include "time_rec.h"

#define TR_BUFFER_SIZE 65536

/* two buffers are enough to allow infinite chaining (R/W <-> W/R) */
#define TR_CHAIN_BUFS  2

/* a separate set of chaining buffers for each script function argument */
static char __tr_buffers[MAX_ACTION_ELEMS - 1][TR_CHAIN_BUFS][TR_BUFFER_SIZE];
static int __crt_tr_bufs, __crt_tr_link;

#define get_tr_buffer() \
  __tr_buffers[__crt_tr_bufs] \
    [__crt_tr_link = (__crt_tr_link + 1) % TR_CHAIN_BUFS]

trans_extra_t *tr_extra_list;

static const trans_export_t core_trans[] = {
  {str_const_init("s"), tr_parse_string, tr_eval_string},
  {str_const_init("i"), tr_parse_integer, tr_eval_integer},
  {str_const_init("uri"), tr_parse_uri, tr_eval_uri},
  {str_const_init("via"), tr_parse_via, tr_eval_via},
  {str_const_init("param"), tr_parse_paramlist, tr_eval_paramlist},
  {str_const_init("nameaddr"), tr_parse_nameaddr, tr_eval_nameaddr},
  {str_const_init("ip"), tr_parse_ip, tr_eval_ip},
  {str_const_init("csv"), tr_parse_csv, tr_eval_csv},
  {str_const_init("sdp"), tr_parse_sdp, tr_eval_sdp},
  {str_const_init("re"), tr_parse_re, tr_eval_re},
  {{0,0}, 0, 0}
};

int tr_add_extra(const trans_export_t *e)
{
  trans_extra_t *tr_extra;
  int i;

  if(!e || !e->name.s || !e->parse_func || !e->eval_func) {
    LM_ERR("invalid transformation export parameters\n");
    return -1;
  }

  for (i = 0; core_trans[i].name.s; i++)
    if (e->name.len == core_trans[i].name.len &&
      !memcmp(e->name.s, core_trans[i].name.s, e->name.len)) {
      LM_ERR("transformation class <%.*s> already registered by core\n",
        e->name.len, e->name.s);
      return -1;
    }
  for (tr_extra = tr_extra_list; tr_extra; tr_extra = tr_extra->next)
    if (e->name.len == tr_extra->tre.name.len &&
      !memcmp(e->name.s, tr_extra->tre.name.s, e->name.len)) {
      LM_ERR("transformation class <%.*s> already registered\n",
        e->name.len, e->name.s);
      return -1;
    }

  tr_extra = NULL;
  tr_extra = pkg_malloc(sizeof *tr_extra);
  if (!tr_extra) {
    LM_ERR("No more pkg mem\n");
    return -1;
  }
  memcpy(&tr_extra->tre, e, sizeof(trans_export_t));
  tr_extra->next = tr_extra_list;
  tr_extra_list = tr_extra;

  return 0;
}

int register_trans_mod(const char *mod_name, const trans_export_t *tr_exports)
{
  int i;

  if (!tr_exports)
    return 0;

  for (i = 0; tr_exports[i].name.s; i++)
    if (tr_add_extra(&tr_exports[i]) < 0) {
      LM_ERR("failed to register transformation class <%.*s> for module %s\n",
          tr_exports[i].name.len, tr_exports[i].name.s, mod_name);
      return -1;
    }

  return 0;
}

void tr_free_extra_list(void)
{
  trans_extra_t *tre, *tre_aux;

  tre = tr_extra_list;
  while (tre) {
    tre_aux = tre;
    tre = tre->next;
    pkg_free(tre_aux);
  }
}

int run_transformations(struct sip_msg *msg, trans_t *tr, pv_value_t *val)
{
  trans_t *it;
  int ret = 0;

  if (tr==NULL || val==NULL) {
    LM_DBG("null pointer\n");
    ret = -1;
    goto out;
  }

  it = tr;
  while (it) {
    ret = (*it->trf)(msg, it->params, it->subtype, val);
    if(ret!=0)
      goto out;
    it = it->next;
  }

out:
  /* advancing the current set of buffers avoids buffer overruns when passing
   * multiple transformation-enabled vars as cfg function parameters */
  __crt_tr_bufs = (__crt_tr_bufs + 1) % (MAX_ACTION_ELEMS - 1);

  return ret;
}

static void trans_fill_left(pv_value_t *val, str pad, int len, char *_tr_buffer)
{
  char *p;
  int r;

  /* fill with a single char */
  if (pad.len == 1) {
    memset(_tr_buffer, pad.s[0], len);
    memcpy(_tr_buffer + len, val->rs.s, val->rs.len);

    val->flags = PV_VAL_STR;
    val->rs.s = _tr_buffer;
    val->rs.len += len;

  /* fill with a string */
  } else {
    p = _tr_buffer;
    r = len % pad.len;
    /* handle the first non-even pad */
    if (r != 0) {
      memcpy(p, pad.s + (pad.len - r), r);
      p += r;
      len -= r;
      val->rs.len += r;
    }

    /* save initial string len */
    r = val->rs.len;

    while (len > 0) {
      memcpy(p, pad.s, pad.len);
      p += pad.len;
      val->rs.len += pad.len;
      len -= pad.len;
    }

    memcpy(p + len, val->rs.s, r);

    val->flags = PV_VAL_STR;
    val->rs.s = _tr_buffer;
  }
}

static void trans_fill_right(pv_value_t *val, str pad, int len, char *_tr_buffer)
{
  char *p;
  int r;

  memcpy(_tr_buffer, val->rs.s, val->rs.len);

  /* fill with a single char */
  if (pad.len == 1) {
    memset(_tr_buffer + val->rs.len, pad.s[0], len);

    val->flags = PV_VAL_STR;
    val->rs.s = _tr_buffer;
    val->rs.len += len;

  /* fill with a string */
  } else {
    p = _tr_buffer + val->rs.len;

    while (len > 0) {
      r = len < pad.len ? len : pad.len;
      memcpy(p, pad.s, r);
      p += r;
      val->rs.len += r;
      len -= pad.len;
    }

    val->flags = PV_VAL_STR;
    val->rs.s = _tr_buffer;
  }
}

int tr_eval_string(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  int i, j;
  char *p, *s, *_tr_buffer = get_tr_buffer();
  str st;
  pv_value_t v;
  pv_elem_p el=NULL;

  if (!val)
    return -1;

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

  switch(subtype)
  {
    case TR_S_LEN:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->ri = val->rs.len;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_S_INT:
      if(!(val->flags&PV_VAL_INT))
      {
        //Default conversion to 0
        val->ri = 0;
        /*Ignore the return value of str2sint.
          str2sint will convert the string up until it finds a non-number char
          which is the desired behavior for the script level transformation*/
        str2sint(&val->rs, &val->ri);
      } else {
        if(!(val->flags&PV_VAL_STR))
          val->rs.s = int2str(val->ri, &val->rs.len);
      }

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      break;
    case TR_S_MD5:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      compute_md5(_tr_buffer, val->rs.s, val->rs.len);
      _tr_buffer[MD5_LEN] = '\0';
      val->flags = PV_VAL_STR;
      val->ri = 0;
      val->rs.s = _tr_buffer;
      val->rs.len = MD5_LEN;
      break;
    case TR_S_SHA1:
    case TR_S_SHA1_HMAC:
    case TR_S_SHA224:
    case TR_S_SHA224_HMAC:
    case TR_S_SHA256:
    case TR_S_SHA256_HMAC:
    case TR_S_SHA384:
    case TR_S_SHA384_HMAC:
    case TR_S_SHA512:
    case TR_S_SHA512_HMAC:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      unsigned char sha_buf[64];
      int sha_hash_len = 0;

      if (tp != 0) { // We have parameter (hmac function)
        if(tp->type==TR_PARAM_STRING)
        {
          st = tp->v.s;
        } else {
          if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
          {
            LM_ERR("sha hmac transformation cannot get p1\n");
            goto error;
          }
          st = v.rs;
        }
      }

      if (subtype == TR_S_SHA1) {
        sha1((unsigned char *)val->rs.s, val->rs.len, sha_buf);
        sha_hash_len = 20;
      } else if (subtype == TR_S_SHA224) {
        sha256((unsigned char *)val->rs.s, val->rs.len, sha_buf, 1);
        sha_hash_len = 28;
      } else if (subtype == TR_S_SHA256) {
        sha256((unsigned char *)val->rs.s, val->rs.len, sha_buf, 0);
        sha_hash_len = 32;
      } else if (subtype == TR_S_SHA384) {
        sha512((unsigned char *)val->rs.s, val->rs.len, sha_buf, 1);
        sha_hash_len = 48;
      } else if (subtype == TR_S_SHA512) {
        sha512((unsigned char *)val->rs.s, val->rs.len, sha_buf, 0);
        sha_hash_len = 64;
      } else if (subtype == TR_S_SHA1_HMAC) {
        sha1_hmac((unsigned char *)st.s, st.len,
          (unsigned char *)val->rs.s, val->rs.len, sha_buf);
        sha_hash_len = 20;
      } else if (subtype == TR_S_SHA224_HMAC) {
        sha256_hmac((unsigned char *)st.s, st.len,
          (unsigned char *)val->rs.s, val->rs.len, sha_buf, 1);
        sha_hash_len = 28;
      } else if (subtype == TR_S_SHA256_HMAC) {
        sha256_hmac((unsigned char *)st.s, st.len,
          (unsigned char *)val->rs.s, val->rs.len, sha_buf, 0);
        sha_hash_len = 32;
      } else if (subtype == TR_S_SHA384_HMAC) {
        sha512_hmac((unsigned char *)st.s, st.len,
          (unsigned char *)val->rs.s, val->rs.len, sha_buf, 1);
        sha_hash_len = 48;
      } else if (subtype == TR_S_SHA512_HMAC) {
        sha512_hmac((unsigned char *)st.s, st.len,
          (unsigned char *)val->rs.s, val->rs.len, sha_buf, 0);
        sha_hash_len = 64;
      }

      val->flags = PV_VAL_STR;
      val->ri = 0;
      val->rs.s = _tr_buffer;
      val->rs.len = string2hex((char *)sha_buf, sha_hash_len, _tr_buffer);
      _tr_buffer[sha_hash_len*2] = '\0';
      break;
    case TR_S_CRC32:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      unsigned int crc_val;
      int length = 10;
      crc32_uint(&val->rs,&crc_val);
      val->rs.len = length;
      val->rs.s = int2str(crc_val,&length);
      val->flags = PV_VAL_STR;
      break;
    case TR_S_ENCODEHEXA:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE/2-1)
        goto error;
      j = 0;
      for(i=0; i<val->rs.len; i++)
      {
        _tr_buffer[j++] = fourbits2char[(unsigned char)val->rs.s[i] >> 4];
        _tr_buffer[j++] = fourbits2char[(unsigned char)val->rs.s[i] & 0xf];
      }
      _tr_buffer[j] = '\0';
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs.s = _tr_buffer;
      val->rs.len = j;
      break;
    case TR_S_DECODEHEXA:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE*2-1)
        goto error;
      for(i=0; i<val->rs.len/2; i++)
      {
        if(val->rs.s[2*i]>='0'&&val->rs.s[2*i]<='9')
          _tr_buffer[i] = (val->rs.s[2*i]-'0') << 4;
        else if(val->rs.s[2*i]>='a'&&val->rs.s[2*i]<='f')
          _tr_buffer[i] = (val->rs.s[2*i]-'a'+10) << 4;
        else if(val->rs.s[2*i]>='A'&&val->rs.s[2*i]<='F')
          _tr_buffer[i] = (val->rs.s[2*i]-'A'+10) << 4;
        else goto error;

        if(val->rs.s[2*i+1]>='0'&&val->rs.s[2*i+1]<='9')
          _tr_buffer[i] += val->rs.s[2*i+1]-'0';
        else if(val->rs.s[2*i+1]>='a'&&val->rs.s[2*i+1]<='f')
          _tr_buffer[i] += val->rs.s[2*i+1]-'a'+10;
        else if(val->rs.s[2*i+1]>='A'&&val->rs.s[2*i+1]<='F')
          _tr_buffer[i] += val->rs.s[2*i+1]-'A'+10;
        else goto error;
      }
      _tr_buffer[i] = '\0';
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs.s = _tr_buffer;
      val->rs.len = i;
      break;
    case TR_S_HEX2DEC:
      if(val->flags&PV_VAL_INT)
        break; /* already converted */
      s = NULL;
      if (hexstr2int(val->rs.s, val->rs.len, (unsigned int *)&i) < 0)
        goto error;
      val->rs.s = int2str(i, &val->rs.len);
      val->ri = i;
      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      break;
    case TR_S_DEC2HEX:
      if(!(val->flags&PV_VAL_INT))
      {
        if(str2sint(&val->rs, &val->ri)!=0)
          goto error;
      }
      val->rs.len = snprintf(_tr_buffer, TR_BUFFER_SIZE, "%x", val->ri);
      if (val->rs.len < 0 || val->rs.len > TR_BUFFER_SIZE)
        goto error;
      val->ri = 0;
      val->rs.s = _tr_buffer;
      val->flags = PV_VAL_STR;
      break;
    case TR_S_DATE2UNIX:
      if(!(val->flags&PV_VAL_STR))
        goto error;

      struct tm date_tm;

      memcpy(_tr_buffer, val->rs.s, val->rs.len);
      _tr_buffer[val->rs.len] = 0;

      memset(&date_tm, 0, sizeof date_tm);

      if (!strptime(_tr_buffer, "%a, %d %b %Y %H:%M:%S GMT", &date_tm)) {
        LM_ERR("Failed to parse Date header field\n");
        goto error;
      }

      _tz_set("");
      snprintf(_tr_buffer, TR_BUFFER_SIZE, "%lld", (long long)mktime(&date_tm));
      tz_reset();

      if (strncmp(_tr_buffer, "-1", strlen("-1")) == 0) {
        LM_ERR("Failed convert to UNIX time\n");
        goto error;
      }

      val->rs.len = strlen(_tr_buffer);
      if (val->rs.len < 0 || val->rs.len > TR_BUFFER_SIZE)
        goto error;
      val->ri = 0;
      val->rs.s = _tr_buffer;
      val->flags = PV_VAL_STR;
      break;
    case TR_S_ESCAPECOMMON:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE/2-1)
        goto error;
      i = escape_common(_tr_buffer, val->rs.s, val->rs.len);
      _tr_buffer[i] = '\0';
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs.s = _tr_buffer;
      val->rs.len = i;
      break;
    case TR_S_UNESCAPECOMMON:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;
      i = unescape_common(_tr_buffer, val->rs.s, val->rs.len);
      _tr_buffer[i] = '\0';
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs.s = _tr_buffer;
      val->rs.len = i;
      break;
    case TR_S_ESCAPEUSER:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE/2-1)
        goto error;
      st.s = _tr_buffer;
      st.len = TR_BUFFER_SIZE;
      if (escape_user(&val->rs, &st))
        goto error;
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_UNESCAPEUSER:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;
      st.s = _tr_buffer;
      st.len = TR_BUFFER_SIZE;
      if (unescape_user(&val->rs, &st))
        goto error;
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_ESCAPEPARAM:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE/2-1)
        goto error;
      st.s = _tr_buffer;
      st.len = TR_BUFFER_SIZE;
      if (escape_param(&val->rs, &st) < 0)
        goto error;
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_UNESCAPEPARAM:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;
      st.s = _tr_buffer;
      st.len = TR_BUFFER_SIZE;
      if (unescape_param(&val->rs, &st) < 0)
        goto error;
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_SUBSTR:
      if(tp==NULL || tp->next==NULL)
      {
        LM_ERR("substr invalid parameters\n");
        goto error;
      }
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(tp->type==TR_PARAM_NUMBER)
      {
        i = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("substr cannot get p1\n");
          goto error;
        }
        i = v.ri;
      }
      if(tp->next->type==TR_PARAM_NUMBER)
      {
        j = tp->next->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->next->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("substr cannot get p2\n");
          goto error;
        }
        j = v.ri;
      }
      LM_DBG("i=%d j=%d\n", i, j);

      /* adjust negative offset */
      if (i < 0)
      {
        if (-i > val->rs.len)
        {
          /* negative start out of range */
          goto error;
        } else {
          i = val->rs.len + i;
        }
      }
      /* start position out of range ? */
      if (i >= val->rs.len)
      {
        /* return NULL output */
        goto error;
      }

      /* adjust negative index */
      if (j < 1)
        j = val->rs.len + j - i;

      /* cut if length > string */
      if (i+j > val->rs.len)
        j = val->rs.len - i;

      val->flags = PV_VAL_STR;
      val->ri = 0;

      val->rs.s += i;
      val->rs.len = j;
      break;

    case TR_S_SELECT:
      if(tp==NULL || tp->next==NULL)
      {
        LM_ERR("select invalid parameters\n");
        goto error;
      }
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(tp->type==TR_PARAM_NUMBER)
      {
        i = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("select cannot get p1\n");
          goto error;
        }
        i = v.ri;
      }
      val->flags = PV_VAL_STR;
      val->ri = 0;
      if(i<0)
      {
        s = val->rs.s+val->rs.len-1;
        p = s;
        i = -i;
        i--;
        while(p>=val->rs.s)
        {
          if(*p==tp->next->v.s.s[0])
          {
            if(i==0)
              break;
            s = p-1;
            i--;
          }
          p--;
        }
        if(i==0)
        {
          val->rs.s = p+1;
          val->rs.len = s-p;
        } else {
          val->flags = PV_VAL_NULL;
        }
      } else {
        s = val->rs.s;
        p = s;
        while(p<val->rs.s+val->rs.len)
        {
          if(*p==tp->next->v.s.s[0])
          {
            if(i==0)
              break;
            s = p + 1;
            i--;
          }
          p++;
        }
        if(i==0)
        {
          val->rs.s = s;
          val->rs.len = p-s;
        } else {
          val->flags = PV_VAL_NULL;
        }
      }
      break;

    case TR_S_TOLOWER:
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
        break;
      }
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;
      st.s = _tr_buffer;
      st.len = val->rs.len;
      for (i=0; i<st.len; i++)
        st.s[i]=(val->rs.s[i]>='A' && val->rs.s[i]<='Z')
              ?('a' + val->rs.s[i] -'A'):val->rs.s[i];
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;

    case TR_S_TOUPPER:
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
        break;
      }
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;
      st.s = _tr_buffer;
      st.len = val->rs.len;
      for (i=0; i<st.len; i++)
        st.s[i]=(val->rs.s[i]>='a' && val->rs.s[i]<='z')
              ?('A' + val->rs.s[i] -'a'):val->rs.s[i];
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_INDEX:
    case TR_S_RINDEX:
      /* Ensure it is in string format */
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }

      /* Needle to look for in haystack */
      if(tp->type==TR_PARAM_STRING)
      {
        st = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
                                                || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("index/rindex cannot get p1\n");
          goto error;
        }

        st = v.rs;
      }

      /* User supplied starting position */
      if (tp->next != NULL) {
        if(tp->next->type==TR_PARAM_NUMBER)
        {
          i = tp->next->v.n;
        } else {
          if(pv_get_spec_value(msg, (pv_spec_p)tp->next->v.data, &v)!=0
              || (!(v.flags&PV_VAL_INT)))
          {
            LM_ERR("index/rindex cannot get p2\n");
            goto error;
          }
          i = v.ri;
        }
      } else {
        /* Default start positions: 0 for index, end of str for rindex */
        i = (subtype == TR_S_INDEX ? 0 : (val->rs.len - 1));
      }

      /* If start is negative base it off end of string
         e.g -2 on 10 char str start of 8. */
      if (i < 0 ){
        if ( val->rs.len > 0 ) {
          /* Support wrapping on negative index
             e.g -2 and -12 index are same on strlen of 10 */
          i = ( (i * -1) % val->rs.len );
          /* No remainder means we start at 0
             otherwise take remainder off the end */
          if ( i > 0) {
            i = (val->rs.len - i);
          }
        } else {
          /* Case of searching through an empty string is caught later */
          i = 0;
        }
      }

      /* Index */
      if (subtype == TR_S_INDEX) {
        /* If start index is beyond end of string or
           Needle is bigger than haystack return NULL */
        if ( i >= val->rs.len || st.len > (val->rs.len - i)) {
          memset(val, 0, sizeof(pv_value_t));
          val->flags = PV_VAL_NULL;
          break;
        }

        /* Iterate through string starting at index
           After j there are no longer enough characters left to match the needle */
        j = (val->rs.len - st.len);
        while (i <= j) {
          if (val->rs.s[i] == st.s[0]) {
            /* First character matches, do a full comparison
               shortcut for single character lookups */
            if (st.len == 1 || strncmp(val->rs.s + i, st.s, st.len) == 0) {
              /* Bingo, found it */
              memset(val, 0, sizeof(pv_value_t));
              val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
              val->ri = i;
              val->rs.s = int2str(val->ri, &val->rs.len);
              return 0;
            }
          }
          i++;
        }
      /* Rindex */
      } else {
        /* Needle bigger than haystack */
        if ( st.len > val->rs.len ) {
          memset(val, 0, sizeof(pv_value_t));
          val->flags = PV_VAL_NULL;
          break;
        }

        /* Incase of RINDEX clamp index to end of string */
        if (i >= val->rs.len) {
          i = (val->rs.len - 1);
        }

        /* Start position does not leave enough characters to match needle, jump ahead */
        if ( st.len > (val->rs.len - i) ) {
          /* Minimum start position allowing for matches */
          i = (val->rs.len - st.len);
        }

        /* Iterate through string starting at index and going backwards */
        while (i >= 0) {
          if (val->rs.s[i] == st.s[0]) {
            /* First character matches, do a full comparison
               shortcut for single character lookups */
            if (st.len == 1 || strncmp(val->rs.s + i, st.s, st.len) == 0) {
              /* Bingo, found it */
              memset(val, 0, sizeof(pv_value_t));
              val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
              val->ri = i;
              val->rs.s = int2str(val->ri, &val->rs.len);
              return 0;
            }
          }
          i--;
        }

      }

      /* Not found */
      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_NULL;
      break;
    case TR_S_FILL_LEFT:
    case TR_S_FILL_RIGHT:

      /* padding string parameter */
      st = tp->v.s;

      /* padded final length parameter */
      i = tp->next->v.n;

      if (val->flags & PV_VAL_STR)
      {
        i -= val->rs.len;
      } else if (val->flags & PV_VAL_INT)
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        i -= val->rs.len;
      }

      /* no need for padding */
      if (i < 0)
        return 0;

      if (subtype == TR_S_FILL_LEFT)
        trans_fill_left(val, st, i, _tr_buffer);
      else
        trans_fill_right(val, st, i, _tr_buffer);

      break;
    case TR_S_WIDTH:
      if(tp==NULL || tp->next!=NULL)
      {
        LM_ERR("width invalid parameters\n");
        goto error;
      }
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);
      if(tp->type==TR_PARAM_NUMBER)
      {
        i = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("substr cannot get p1\n");
          goto error;
        }
        i = v.ri;
      }
      if (i <= 0) {
        LM_ERR("width invalid (must be >= 1)\n");
        goto error;
      }
      if (i <= val->rs.len) {
        /* since the requested width is less than
           the value length, just update the length */
        val->rs.len = i;
        break;
      }

      if(i>TR_BUFFER_SIZE-1)
        /* width cant be greater than buffer */
        goto error;

      j = i - val->rs.len; /* calc extra length */
      p = _tr_buffer;

      /* copy existing string to buffer and append j spaces */
      memcpy(p, val->rs.s, val->rs.len);
      memset(p+val->rs.len, ' ', j);
      memset(val, 0, sizeof(pv_value_t));

      val->flags = PV_VAL_STR;
      val->rs.s = _tr_buffer;
      val->rs.len = i;
      break;
    case TR_S_B64ENCODE:
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
        break;
      }
      if(val->rs.len>TR_BUFFER_SIZE-1 ||
        calc_base64_encode_len(val->rs.len)>TR_BUFFER_SIZE) {
        LM_ERR("b64encode value larger than buffer\n");
        goto error;
      }
      st.s = _tr_buffer;
      st.len = calc_base64_encode_len(val->rs.len);

      base64encode((unsigned char *)st.s,
             (unsigned char *)val->rs.s,
             val->rs.len);

      memset(val, 0, sizeof(pv_value_t));
      val->flags = PV_VAL_STR;
      val->rs = st;
      break;
    case TR_S_B64DECODE:
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
        break;
      }
      if(val->rs.len>TR_BUFFER_SIZE-1) {
        LM_ERR("b64decode value larger than buffer\n");
        return -1;
      }
                        st.s = _tr_buffer;
                        st.len = base64decode((unsigned char *)st.s, 
                                              (unsigned char *)val->rs.s,
                                              val->rs.len);
                        memset(val, 0, sizeof(pv_value_t));
                        val->flags = PV_VAL_STR;
                        val->rs = st;
                        break;
    case TR_S_XOR:
      /* ensure string format */
      if(!(val->flags&PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }
      if(val->rs.len>TR_BUFFER_SIZE-1) {
        LM_ERR("xor value larger than buffer\n");
        goto error;
      }
      /* secret to use */
      if(tp->type==TR_PARAM_STRING)
      {
        st = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
                                                || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("xor cannot get p1\n");
          return -1;
        }
        st = v.rs;
      }
      
      p = _tr_buffer;
      for (i=0; i<val->rs.len; i++) {
        *p = val->rs.s[i] ^ st.s[i % st.len];
        p++;
      }
      /* leave val flags and length in tact and update with result */
                        val->rs.s = _tr_buffer;
      break;
    case TR_S_TRIM:
      if (!(val->flags & PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }

      trim(&val->rs);
      break;
    case TR_S_TRIMR:
      if (!(val->flags & PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }

      trim_trailing(&val->rs);
      break;
    case TR_S_TRIML:
      if (!(val->flags & PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }

      trim_leading(&val->rs);
      break;
    case TR_S_REVERSE:
      if (!(val->flags & PV_VAL_STR))
      {
        val->rs.s = int2str(val->ri, &val->rs.len);
        val->flags |= PV_VAL_STR;
      }

      /*To big for buffer*/
      if(val->rs.len>TR_BUFFER_SIZE-1)
        goto error;

      p = _tr_buffer;

      /*Reverse Order*/
      for (i=0; i < val->rs.len; i++) {
        p[val->rs.len - 1 - i] = val->rs.s[i];
      }

      /*Save Result*/
      val->rs.s = _tr_buffer;
      val->flags = PV_VAL_STR;
      break;
    case TR_S_EVAL:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      if (pv_parse_format(&val->rs,&el) != 0) {
        LM_ERR("Failed to parse input \n");
        goto error;
      }

      if (pv_printf_s(msg,el,&st) != 0) {
        LM_ERR("Failed to print input \n");
        pv_elem_free_all(el);
        goto error;
      }

      memcpy(_tr_buffer,st.s,st.len);
      _tr_buffer[st.len] = '\0';

      val->flags = PV_VAL_STR;
      val->ri = 0;
      val->rs.s = _tr_buffer;
      val->rs.len = st.len;

      pv_elem_free_all(el);
      break;
    default:
      LM_ERR("unknown subtype %d\n",
          subtype);
      goto error;
  }

  return 0;
error:
  val->flags = PV_VAL_NULL;
  return -1;
}

int tr_eval_integer(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  if (!val)
    return -1;

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

  if (subtype != TR_I_BOOL) {
    LM_ERR("unknown subtype %d\n", subtype);
    goto error;
  }

  if (!pvv_is_int(val)) {
    LM_ERR("boolean transformation requires an integer value\n");
    goto error;
  }

  *val = val->ri ? pv_true : pv_false;
  val->flags |= PV_VAL_BOOL;
  return 0;

error:
  val->flags = PV_VAL_NULL;
  return -1;
}

static str _tr_empty = { "", 0 };
static str _tr_uri = {0, 0};
static struct sip_uri _tr_parsed_uri;
static param_t* _tr_uri_params = NULL;

int tr_eval_uri(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  pv_value_t v;
  str sv;
  param_hooks_t phooks;
  param_t *pit=NULL;

  if (!val)
    return -1;

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

  if((!(val->flags&PV_VAL_STR)) || val->rs.len<=0)
    goto error;

  if(_tr_uri.len==0 || _tr_uri.len!=val->rs.len ||
      strncmp(_tr_uri.s, val->rs.s, val->rs.len)!=0)
  {
    if(val->rs.len>_tr_uri.len)
    {
      if(_tr_uri.s) pkg_free(_tr_uri.s);
      _tr_uri.s = (char*)pkg_malloc((val->rs.len+1)*sizeof(char));
      if(_tr_uri.s==NULL)
      {
        LM_ERR("no more private memory\n");
        if(_tr_uri_params != NULL)
        {
          free_params(_tr_uri_params);
          _tr_uri_params = 0;
        }
        memset(&_tr_uri, 0, sizeof(str));
        memset(&_tr_parsed_uri, 0, sizeof(struct sip_uri));
        goto error;
      }
    }
    _tr_uri.len = val->rs.len;
    memcpy(_tr_uri.s, val->rs.s, val->rs.len);
    _tr_uri.s[_tr_uri.len] = '\0';
    /* reset old values */
    memset(&_tr_parsed_uri, 0, sizeof(struct sip_uri));
    if(_tr_uri_params != NULL)
    {
      free_params(_tr_uri_params);
      _tr_uri_params = 0;
    }
    /* parse uri -- params only when requested */
    if(parse_uri(_tr_uri.s, _tr_uri.len, &_tr_parsed_uri)!=0)
    {
      LM_ERR("invalid uri [%.*s]\n", val->rs.len,
          val->rs.s);
      if(_tr_uri_params != NULL)
      {
        free_params(_tr_uri_params);
        _tr_uri_params = 0;
      }
      pkg_free(_tr_uri.s);
      memset(&_tr_uri, 0, sizeof(str));
      memset(&_tr_parsed_uri, 0, sizeof(struct sip_uri));
      goto error;
    }
  }
  memset(val, 0, sizeof(pv_value_t));
  val->flags = PV_VAL_STR;

  switch(subtype)
  {
    case TR_URI_USER:
      val->rs = (_tr_parsed_uri.user.s)?_tr_parsed_uri.user:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_HOST:
      val->rs = (_tr_parsed_uri.host.s)?_tr_parsed_uri.host:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_PASSWD:
      val->rs = (_tr_parsed_uri.passwd.s)?_tr_parsed_uri.passwd:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_PORT:
      val->flags |= PV_TYPE_INT|PV_VAL_INT;
      val->rs = (_tr_parsed_uri.port.s)?_tr_parsed_uri.port:_tr_empty;
      val->ri = _tr_parsed_uri.port_no;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_PARAMS:
      val->rs = (_tr_parsed_uri.params.s)?_tr_parsed_uri.params:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_PARAM:
      if(tp==NULL)
      {
        LM_ERR("param invalid parameters\n");
        goto error;
      }
      if(_tr_parsed_uri.params.len<=0)
      {
        val->flags = PV_VAL_NULL;
        break;
      }

      if(_tr_uri_params == NULL)
      {
        sv = _tr_parsed_uri.params;
        if (parse_params(&sv, CLASS_ANY, &phooks, &_tr_uri_params)<0)
          goto error;
      }
      if(tp->type==TR_PARAM_STRING)
      {
        sv = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("param cannot get p1\n");
          goto error;
        }
        sv = v.rs;
      }
      for (pit = _tr_uri_params; pit; pit=pit->next)
      {
        if (pit->name.len==sv.len
            && strncasecmp(pit->name.s, sv.s, sv.len)==0)
        {
          if (ZSTR(pit->body))
            val->rs = STR_EMPTY;
          else
            val->rs = pit->body;
          goto done;
        }
      }
      val->flags = PV_VAL_NULL;
      break;
    case TR_URI_HEADERS:
      val->rs = (_tr_parsed_uri.headers.s)?_tr_parsed_uri.headers:
            _tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_TRANSPORT:
      val->rs = (_tr_parsed_uri.transport_val.s)?
        _tr_parsed_uri.transport_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_TTL:
      val->rs = (_tr_parsed_uri.ttl_val.s)?
        _tr_parsed_uri.ttl_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_UPARAM:
      val->rs = (_tr_parsed_uri.user_param_val.s)?
        _tr_parsed_uri.user_param_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_MADDR:
      val->rs = (_tr_parsed_uri.maddr_val.s)?
        _tr_parsed_uri.maddr_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_METHOD:
      val->rs = (_tr_parsed_uri.method_val.s)?
        _tr_parsed_uri.method_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_LR:
      val->rs = (_tr_parsed_uri.lr_val.s)?
        _tr_parsed_uri.lr_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_R2:
      val->rs = (_tr_parsed_uri.r2_val.s)?
        _tr_parsed_uri.r2_val:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_URI_SCHEMA:
      val->rs.s = _tr_uri.s;
      /* maximum size of schema can be 4 so the ':' shall be found after
       * five chars */
      val->rs.len = q_memchr(val->rs.s, ':', 5) - val->rs.s;
      break;
    default:
      LM_ERR("unknown subtype %d\n",
          subtype);
      goto error;
  }
done:
  return 0;
error:
  val->flags = PV_VAL_NULL;
  return -1;
}


/* last via string */
static str _tr_via = {0, 0};
/* the actual len of the allocated buffer (to hold the via) */
static int _tr_via_buf_len = 0;
/* holder for the parsed via */
static struct via_body *_tr_parsed_via = 0;

int tr_eval_via(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  pv_value_t v;
  str sv;
  struct via_param *pit;

  if (!val)
    return -1;

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

  // WATCHOUT: need at least 2 chars so \r\n check wont segfault
  if(!(val->flags&PV_VAL_STR) || val->rs.len<=2) {
    val->flags = PV_VAL_NULL;
    return -1;
  }

  if(_tr_via_buf_len==0 || _tr_via.len!=val->rs.len ||
      strncmp(_tr_via.s, val->rs.s, val->rs.len)!=0
      || _tr_parsed_via==0)
  {
    if (val->rs.len+4 > _tr_via_buf_len)
    {
      if(_tr_via.s) pkg_free(_tr_via.s);
      _tr_via.s = (char*)pkg_malloc((val->rs.len+4)*sizeof(char));
      if(_tr_via.s==NULL)
      {
        _tr_via_buf_len = 0;
        LM_ERR("no more private memory\n");
        goto error;
      }
      _tr_via_buf_len = val->rs.len+4;
    }
    _tr_via.len = val->rs.len;
    memcpy(_tr_via.s, val->rs.s, val->rs.len);
    // $hdr PV strips off the terminating CRLR
    // parse_via wants to parse a full message (including
    // multiple vias), not just a header line.  Fake this
    _tr_via.s[_tr_via.len+0] = '\r';
    _tr_via.s[_tr_via.len+1] = '\n';
    _tr_via.s[_tr_via.len+2] = 'A'; // anything other than V
    _tr_via.s[_tr_via.len+3] = '\0';
    /* reset old values */
    free_via_list(_tr_parsed_via);
    if ( (_tr_parsed_via=pkg_malloc(sizeof(struct via_body))) == NULL ) {
      LM_ERR("no more private memory\n");
      goto error;
    }
    memset(_tr_parsed_via, 0, sizeof(struct via_body));
    parse_via(_tr_via.s, _tr_via.s+_tr_via.len+4, _tr_parsed_via);
    if(_tr_parsed_via->error != PARSE_OK) {
      LM_ERR("invalid via [%.*s]\n", val->rs.len,
          val->rs.s);
      goto error;
    }
  }
  memset(val, 0, sizeof(pv_value_t));
  val->flags = PV_VAL_STR;

  switch(subtype)
  {
    case TR_VIA_NAME:
      val->rs = (_tr_parsed_via->name.s)?_tr_parsed_via->name:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_VERSION:
      val->rs = (_tr_parsed_via->version.s)?_tr_parsed_via->version:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_TRANSPORT:
      val->rs = (_tr_parsed_via->transport.s)?_tr_parsed_via->transport:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_HOST:
      val->rs = (_tr_parsed_via->host.s)?_tr_parsed_via->host:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_PORT:
      val->flags |= PV_TYPE_INT|PV_VAL_INT;
      val->rs = (_tr_parsed_via->port_str.s)?_tr_parsed_via->port_str:_tr_empty;
      val->ri = _tr_parsed_via->port;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_PARAMS:
      val->rs = (_tr_parsed_via->params.s)?_tr_parsed_via->params:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_COMMENT:
      val->rs = (_tr_parsed_via->comment.s)?_tr_parsed_via->comment:_tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_PARAM:  // param by name
      if(tp==NULL)
      {
        LM_ERR("param invalid parameters\n");
        val->flags = PV_VAL_NULL;
        return -1;
      }
      if(_tr_parsed_via->params.len<=0)
      {
        val->flags = PV_VAL_NULL;
        break;
      }

      if(tp->type==TR_PARAM_STRING)
      {
        sv = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("param cannot get p1\n");
          val->flags = PV_VAL_NULL;
          return -1;
        }
        sv = v.rs;
      }
      for (pit = _tr_parsed_via->param_lst; pit; pit=pit->next)
      {
        if (pit->name.len==sv.len
            && strncasecmp(pit->name.s, sv.s, sv.len)==0)
        {
          val->rs = pit->value;
          goto done;
        }
      }
      val->flags = PV_VAL_NULL;
      break;
    case TR_VIA_BRANCH:
      val->rs = (_tr_parsed_via->branch&&_tr_parsed_via->branch->value.s)?_tr_parsed_via->branch->value: _tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_RECEIVED:
      val->rs = (_tr_parsed_via->received&&_tr_parsed_via->received->value.s)?_tr_parsed_via->received->value: _tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_VIA_RPORT:
      val->rs = (_tr_parsed_via->rport&&_tr_parsed_via->rport->value.s)?_tr_parsed_via->rport->value: _tr_empty;
      val->flags |=  (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    default:
      LM_ERR("unknown subtype %d\n",
          subtype);
      val->flags = PV_VAL_NULL;
      return -1;
  }

done:
  return 0;

error:
  if ( _tr_via.s ) {
    pkg_free(_tr_via.s);
  }
  memset(&_tr_via, 0, sizeof(str));
  if ( _tr_parsed_via ) {
        free_via_list(_tr_parsed_via);
    _tr_parsed_via = 0;
  }
  val->flags = PV_VAL_NULL;
  return -1;
}

static str _tr_csv_str = {0,0};
static csv_record* _tr_csv_list = NULL;

int tr_eval_csv(struct sip_msg *msg, tr_param_t *tp,int subtype,
    pv_value_t *val)
{
  csv_record *cit=NULL;
  int n,i,list_size=0;
  pv_value_t v;

  if (!val)
    return -1;

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

  if (!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  if(_tr_csv_str.len==0 || _tr_csv_str.len!=val->rs.len ||
      strncmp(_tr_csv_str.s, val->rs.s, val->rs.len)!=0)
  {
    if(val->rs.len>_tr_csv_str.len)
    {
      if(_tr_csv_str.s) pkg_free(_tr_csv_str.s);
        _tr_csv_str.s = (char*)pkg_malloc((val->rs.len+1));
      if(_tr_csv_str.s==NULL)
      {
        LM_ERR("no more private memory\n");
        memset(&_tr_csv_str, 0, sizeof(str));
        if(_tr_csv_list != NULL)
        {
          free_csv_record(_tr_csv_list);
          _tr_csv_list = NULL;
        }
        goto error;
      }
    }
    _tr_csv_str.len = val->rs.len;
    memcpy(_tr_csv_str.s, val->rs.s, val->rs.len);
    _tr_csv_str.s[_tr_csv_str.len] = '\0';

    /* reset old values */
    if(_tr_csv_list != NULL)
    {
      free_csv_record(_tr_csv_list);
      _tr_csv_list = NULL;
    }

    /* parse csv */
    _tr_csv_list = _parse_csv_record(&_tr_csv_str, CSV_RFC_4180);
    if (!_tr_csv_list)
      goto error;
  }

  if (_tr_csv_list == NULL)
    goto error;

  switch(subtype)
  {
    case TR_CSV_COUNT:
      val->ri = 0;
      for (cit=_tr_csv_list;cit;cit=cit->next)
        val->ri++;

      val->rs.s = int2str(val->ri, &val->rs.len);
      val->flags = PV_VAL_INT | PV_VAL_STR | PV_TYPE_INT;
      break;
    case TR_CSV_VALUEAT:
      if(tp==NULL)
      {
        LM_ERR("csv invalid parameters\n");
        goto error;
      }
      if(tp->type==TR_PARAM_NUMBER)
      {
        n = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("cannot get parameter\n");
          goto error;
        }
        n = v.ri;
      }

      if (n<0)
      {
        for (cit=_tr_csv_list;cit;cit=cit->next)
          list_size++;
        n = list_size + n;
        if (n<0)
        {
          LM_ERR("Too large negative index\n");
          goto error;
        }
      }

      cit = _tr_csv_list;
      for (i=0;i<n;i++)
      {
        cit=cit->next;
        if (!cit)
        {
          LM_ERR("Index out of bounds\n");
          goto error;
        }
      }

      val->rs = cit->s;
      val->flags =  PV_VAL_STR;
      break;

    default:
      LM_ERR("unknown subtype %d\n",subtype);
      goto error;
  }

  return 0;

error:
  val->flags = PV_VAL_NULL;
  return -1;
}

static str _tr_sdp_str;

int tr_eval_sdp(struct sip_msg *msg, tr_param_t *tp,int subtype,
    pv_value_t *val)
{
  str media;
  char *bodylimit;
  char *answer;
  char *answerEnd;
  char searchLine;
  int entryNo,i,lenoff;

  pv_value_t v;
  sdp_info_t sdp;
  sdp_session_cell_t *session;
  sdp_stream_cell_t *stream;

  if (!val)
    return -1;

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

  if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  if (!tp)
    goto error;

  if(_tr_sdp_str.len==0 || _tr_sdp_str.len!=val->rs.len ||
      strncmp(_tr_sdp_str.s, val->rs.s, val->rs.len)!=0)
  {
    if (pkg_str_extend(&_tr_sdp_str, val->rs.len + 3 /* \r\n\0 */) != 0)
    {
      LM_ERR("no more private memory\n");
      goto error;
    }

    _tr_sdp_str.len = val->rs.len + 2;
    _tr_sdp_str.s[0] = '\r';
    _tr_sdp_str.s[1] = '\n';
    memcpy(_tr_sdp_str.s + 2, val->rs.s, val->rs.len);
    _tr_sdp_str.s[_tr_sdp_str.len] = '\0';

  }

  switch (subtype)
  {
    case TR_SDP_LINEAT:

      /* line index is mandatory */
      if (!tp->next)
        goto error;
      bodylimit = _tr_sdp_str.s + _tr_sdp_str.len;
      searchLine = *(tp->v.s.s);
      if(tp->next->type==TR_PARAM_NUMBER)
        entryNo = tp->next->v.n;
      else
      {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->next->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("cannot get parameter\n");
          goto error;
        }
        entryNo = v.ri;
      }
      if (entryNo < 0)
      {
        LM_ERR("negative index provided for sdp.lineat\n");
        goto error;
      }

      answer = find_sdp_line(_tr_sdp_str.s, bodylimit, searchLine);
      if (!answer) {
        LM_DBG("No such line [%c=]\n", searchLine);
        return pv_get_null(NULL, NULL, val);
      }

      for (i=1;i<=entryNo;i++)
      {
        answer = find_next_sdp_line(answer,bodylimit,searchLine,bodylimit);
        if (!answer || answer == bodylimit)
        {
          val->flags = PV_VAL_NULL;
          LM_DBG("No such line [%c] nr %d in SDP body. Max fields = %d\n",
              searchLine,entryNo,i);
          return 0;
        }
      }

      /* find CR */
      answerEnd = strchr(answer,13);
      if (answerEnd == NULL)
      {
        LM_ERR("malformed SDP body\n");
        goto error;
      }

      val->flags = PV_VAL_STR;
      val->rs.s = answer;
      val->rs.len = answerEnd - answer;

      break;

    case TR_SDP_STREAM:
    case TR_SDP_STREAM_DEL:
      /* determine the media type we are talking about
       * either by index or by name */
      media = STR_NULL;
      entryNo = 0;
      switch (tp->type) {
        case TR_PARAM_NUMBER:
          entryNo = tp->v.n;
          break;
        case TR_PARAM_STRING:
          media = tp->v.s;
          break;
        case TR_PARAM_SPEC:
          media.s = NULL;
          if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0)
          {
            LM_ERR("cannot get parameter\n");
            goto error;
          }
          if (v.flags & PV_VAL_INT)
            entryNo = v.ri;
          else if (str2sint(&v.rs, &entryNo) < 0)
            media = v.rs;
          /* else entryNo has the media index */
          break;
      }

      memset(&sdp, 0, sizeof(sdp));
      if (parse_sdp_session(&_tr_sdp_str, 0, NULL, &sdp) < 0)
        goto error;

      if (media.s == NULL) {
        if (entryNo < 0) {
          if (entryNo + sdp.streams_num < 0)
            /* out of bounds index */
            goto parse_sdp_free;
          entryNo += sdp.streams_num;
        } else if (entryNo >= sdp.streams_num)
          goto parse_sdp_free;
        LM_DBG("stream index %d\n", entryNo);
      } else
        LM_DBG("stream type %.*s\n", media.len, media.s);
      lenoff = 0;
      if (subtype == TR_SDP_STREAM_DEL) {
        for (session = sdp.sessions; session; session = session->next) {
          for (stream = session->streams; stream; stream = stream->next) {
            if ((media.s != NULL && stream->media.len == media.len &&
                /* hack to update the offset */
                strncasecmp(stream->media.s, media.s, media.len) == 0) ||
              (media.s == NULL && entryNo == stream->stream_num)) {

              memmove(stream->body.s - lenoff, stream->body.s - lenoff + stream->body.len,
                  _tr_sdp_str.s + _tr_sdp_str.len - stream->body.s);
              _tr_sdp_str.len -= stream->body.len;

              if (media.s == NULL)
                goto success;

              lenoff += stream->body.len;
            }
          }
          if (media.s == NULL)
            entryNo -= session->streams_num;
        }
      } else {
        for (session = sdp.sessions; session; session = session->next) {
          for (stream = session->streams; stream; stream = stream->next) {
            if ((media.s != NULL && stream->media.len == media.len &&
                strncasecmp(stream->media.s, media.s, media.len) == 0) ||
              (media.s == NULL && entryNo == stream->stream_num)) {

              val->rs.len = stream->body.len;
              val->rs.s = stream->body.s;
              goto ret;
            }
          }
        }
      }
      if (!lenoff) /* no stream found */
        goto parse_sdp_free;
success:
      val->rs.len = _tr_sdp_str.len - 2;
      val->rs.s = _tr_sdp_str.s + 2;
ret:
      val->flags = PV_VAL_STR;
      free_sdp_content(&sdp);
      break;
    default:
      LM_ERR("unknown subtype %d\n",subtype);
      goto error;
  }

  return 0;

parse_sdp_free:
  free_sdp_content(&sdp);

error:
  val->flags = PV_VAL_NULL;
  return -1;
}

int tr_eval_ip(struct sip_msg *msg, tr_param_t *tp,int subtype,
    pv_value_t *val)
{
  char *buffer, *_tr_buffer = get_tr_buffer();
  struct ip_addr *p_ip;
  str inet = str_init("INET");
  str inet6 = str_init("INET6");
  struct hostent *server;
  struct ip_addr ip;
  unsigned int len, rc;
  struct net *mask;
  pv_value_t v;
  str sv;
  char *p;

  if (!val)
    return -1;

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

  if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  switch (subtype)
  {
    case TR_IP_FAMILY:
      if (val->rs.len == 4)
      {
        memcpy(val->rs.s,inet.s,inet.len);
        val->rs.len = inet.len;
      }
      else if (val->rs.len == 16)
      {
        memcpy(val->rs.s,inet6.s,inet6.len);
        val->rs.len = inet6.len;
      }
      else
      {
        LM_ERR("Invalid ip address provided for ip.family. "
          "Binary format expected !\n");
        goto error;
      }

      val->flags = PV_VAL_STR;
      break;
    case TR_IP_NTOP:
      if (val->rs.len == 4)
        ip.af = AF_INET;
      else if (val->rs.len == 16)
        ip.af = AF_INET6;
      else
      {
        LM_ERR("Invalid ip address provided for ip.ntop. "
          "Binary format expected !\n");
        goto error;
      }

      memcpy(ip.u.addr,val->rs.s,val->rs.len);
      ip.len = val->rs.len;
      buffer = ip_addr2a(&ip);

      val->rs.len = strlen(buffer);
      memcpy(_tr_buffer, buffer, val->rs.len);
      val->rs.s = _tr_buffer;

      val->flags = PV_VAL_STR;
      break;
    case TR_IP_ISIP:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      if ( str2ip(&(val->rs)) || str2ip6(&(val->rs)) )
        val->ri = 1;
      else
        val->ri = 0;

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_IP_ISIP4:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      if (str2ip(&(val->rs)))
        val->ri = 1;
      else
        val->ri = 0;

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_IP_ISIP6:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      if (str2ip6(&(val->rs)))
        val->ri = 1;
      else
        val->ri = 0;

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_IP_PTON:
      p_ip = str2ip(&(val->rs));
      if (!p_ip)
      {
        p_ip = str2ip6(&(val->rs));
        if (!p_ip)
        {
          LM_ERR("pton transformation applied to invalid IP\n");
          goto error;
        }
      }

      memcpy(_tr_buffer, (char *)p_ip->u.addr, p_ip->len);
      val->rs.s = _tr_buffer;
      val->rs.len = p_ip->len;

      val->flags = PV_VAL_STR;
      break;
    case TR_IP_RESOLVE:
    case TR_IP_RESOLVE_V4:
    case TR_IP_RESOLVE_V6:
      val->flags = PV_VAL_STR;
      if (val->rs.len + 1 > TR_BUFFER_SIZE) {
        LM_ERR("failed to resolve host, length too large (%d)\n",
               val->rs.len);
        goto error;
      }
      memcpy(_tr_buffer, val->rs.s, val->rs.len);
      _tr_buffer[val->rs.len] = '\0';

      if (subtype == TR_IP_RESOLVE_V4)
        server = resolvehost_af(_tr_buffer, 0, AF_INET);
      else if (subtype == TR_IP_RESOLVE_V6)
        server = resolvehost_af(_tr_buffer, 0, AF_INET6);
      else
        server = resolvehost(_tr_buffer, 0);
      if (!server || !server->h_addr)
      {
        val->flags = PV_VAL_NULL;
        return 0;
      }

      if (server->h_addrtype == AF_INET)
      {
        memcpy(ip.u.addr,server->h_addr,4);
        ip.len = 4;
        ip.af = AF_INET;
      }
      else if (server->h_addrtype == AF_INET6)
      {
        memcpy(ip.u.addr,server->h_addr,16);
        ip.len = 16;
        ip.af = AF_INET6;
      }
      else
      {
        LM_ERR("Unexpected IP address type \n");
        goto error;
      }

      buffer = ip_addr2a(&ip);

      val->rs.len = strlen(buffer);
      memcpy(_tr_buffer, buffer, val->rs.len);
      val->rs.s = _tr_buffer;

      break;
    case TR_IP_MATCHES:
      /* get the input which must be an IP addr as string */
      if ( (p_ip=str2ip(&val->rs))==NULL &&
      (p_ip=str2ip6(&val->rs))==NULL ) {
        LM_ERR("Invalid input IP address <%.*s>\n",
          val->rs.len,val->rs.s);
        goto error;
      }
      ip = *p_ip;
      /* get the parameter which must be IP/netlen */
      if (tp->type == TR_PARAM_STRING) {
        sv = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0) {
          LM_ERR("cannot get value from spec\n");
          goto error;
        }
        sv = v.rs;
      }
      /* the value must be in "ip/marsklen" format */
      if ( (p=q_memchr(sv.s, '/', sv.len))==NULL) {
        LM_ERR("value not in ip/len format, separator not found\n");
        goto error;
      }
      val->rs.s = sv.s;
      val->rs.len = p-sv.s;
      if ( (p_ip=str2ip(&val->rs))==NULL &&
      (p_ip=str2ip6(&val->rs))==NULL ) {
        LM_ERR("Invalid parameter IP address <%.*s>\n",
          val->rs.len,val->rs.s);
        goto error;
      }
      val->rs.s = p+1;
      val->rs.len = sv.s+sv.len-p-1;
      if (str2int(&val->rs, &len)!=0 || len>p_ip->len*8) {
        LM_ERR("Invalid mask len in parameter <%.*s>\n",
          val->rs.len,val->rs.s);
        goto error;
      }

      mask = mk_net_bitlen(p_ip, len);
      rc = matchnet(&ip, mask);
      pkg_free(mask);

      switch (rc) {
        case 1: /* matches */
          val->ri = 1; break;
        case 0: /* does not matches */
          val->ri = 0; break;
        default:
          LM_ERR("cannot compare, different AF?\n");
          goto error;
      }

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_IP_ISPRIVATE:
      if(!(val->flags&PV_VAL_STR))
        val->rs.s = int2str(val->ri, &val->rs.len);

      val->ri = ip_addr_is_1918(&(val->rs), 0);

      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;

    default:
      LM_ERR("unknown subtype %d\n",subtype);
      goto error;
  }

  return 0;
error:
  val->flags = PV_VAL_NULL;
  return -1;
}

static char *reg_input_buf = NULL;
static struct subst_expr *subst_re = NULL;
static str buf_re = { 0, 0 };
int tr_eval_re(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  int match_no=0;
  pv_value_t v;
  str *result;
  str sv;
  char *s, *e, *p;
  char *buf;

  if (!val)
    return -1;

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

  if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  switch (subtype) {
    case TR_RE_SUBST:
        if (tp->type == TR_PARAM_STRING) {
          sv = tp->v.s;
        } else {
          if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
              || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0) {
            LM_ERR("cannot get value from spec\n");
            goto error;
          }
          sv = v.rs;
        }
        /* temporary use the regex input buffer to check the subst */
        buf = pkg_realloc(reg_input_buf, sv.len);
        if (!buf) {
          LM_ERR("not enough memory for regex buffer %d [%.*s]\n",
              sv.len, sv.len, sv.s);
          goto error;
        }
        reg_input_buf = buf;
        /* copy un-escaped str to buf */
        for (s = sv.s, e = sv.s + sv.len, p = buf; s < e; s++, p++) {
          if (*s=='\\') {
            if (s + 1 >= e)
              break;
            if (*(s + 1) == TR_RBRACKET || *(s + 1) == TR_LBRACKET) {
              s++;
              sv.len--;
            }
          }
          *p = *s;
        }
        sv.s = buf;

        LM_DBG("Trying to apply regexp [%.*s] on : [%.*s]\n",
            sv.len,sv.s,val->rs.len, val->rs.s);
        if (subst_re==NULL || !buf_re.s || buf_re.len != sv.len ||
        memcmp(buf_re.s, sv.s, sv.len) != 0) {
          LM_DBG("we must compile the regexp\n");
          if (subst_re != NULL) {
            LM_DBG("freeing prev regexp\n");
            subst_expr_free(subst_re);
          }
          subst_re=subst_parser(&sv);
          if (subst_re==0) {
            LM_ERR("Can't compile regexp\n");
            goto error;
          }
          /* swap buffers */
          reg_input_buf = buf_re.s;
          buf_re.s = buf;
          buf_re.len = sv.len;
        } else
          LM_DBG("yay, we can use the pre-compile regexp\n");

        buf = pkg_realloc(reg_input_buf, val->rs.len + 1);
        if (!buf) {
          LM_ERR("not enough memory for input buffer %d [%.*s]\n",
              val->rs.len + 1, val->rs.len, val->rs.s);
          goto error;
        }
        reg_input_buf = buf;
        memcpy(reg_input_buf,val->rs.s,val->rs.len);
        reg_input_buf[val->rs.len]=0;

        result=subst_str(reg_input_buf, msg, subst_re, &match_no);
        if (result == NULL) {
          if (match_no == 0) {
            LM_DBG("no match for subst expression\n");
            break;
          } else if (match_no < 0) {
            LM_ERR("subst failed\n");
            goto error;
          }
        }
        /* release the input buffer */
        pkg_free(reg_input_buf);
        reg_input_buf = result->s;
        val->flags = PV_VAL_STR;
        val->rs.s = result->s;
        val->rs.len = result->len;
        pkg_free(result);
        return 0;
    default:
      LM_ERR("Unexpected subtype for RE : %d\n",subtype);
      goto error;
  }
  return 0;

error:
  val->flags = PV_VAL_NULL;
  return -1;
}

static str _tr_params_str = {0, 0};
static param_t* _tr_params_list = NULL;

int tr_eval_paramlist(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  pv_value_t v;
  str sv;
  int n, i;
  param_hooks_t phooks;
  param_t *pit=NULL;

  if (!val)
    return -1;

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

  if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  if(_tr_params_str.len==0 || _tr_params_str.len!=val->rs.len ||
      strncmp(_tr_params_str.s, val->rs.s, val->rs.len)!=0)
  {

    if(val->rs.len>_tr_params_str.len)
    {
      if(_tr_params_str.s) pkg_free(_tr_params_str.s);
      _tr_params_str.s = (char*)pkg_malloc((val->rs.len+1)*sizeof(char));
      if(_tr_params_str.s==NULL)
      {
        LM_ERR("no more private memory\n");
        memset(&_tr_params_str, 0, sizeof(str));
        if(_tr_params_list != NULL)
        {
          free_params(_tr_params_list);
          _tr_params_list = 0;
        }
        goto error;
      }
    }
    _tr_params_str.len = val->rs.len;
    memcpy(_tr_params_str.s, val->rs.s, val->rs.len);
    _tr_params_str.s[_tr_params_str.len] = '\0';

    /* reset old values */
    if(_tr_params_list != NULL)
    {
      free_params(_tr_params_list);
      _tr_params_list = 0;
    }

    /* parse params */
    sv = _tr_params_str;
    if (parse_params(&sv, CLASS_ANY, &phooks, &_tr_params_list)<0)
      goto error;

  }

  if(_tr_params_list==NULL)
    goto error;

  memset(val, 0, sizeof(pv_value_t));
  val->flags = PV_VAL_STR;

  switch(subtype)
  {
    case TR_PL_VALUE:
      if(tp==NULL)
      {
        LM_ERR("value invalid parameters\n");
        goto error;
      }

      if(tp->type==TR_PARAM_STRING)
      {
        sv = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("value cannot get p1\n");
          goto error;
        }
        sv = v.rs;
      }

      for (pit = _tr_params_list; pit; pit=pit->next)
      {
        if (pit->name.len==sv.len
            && strncasecmp(pit->name.s, sv.s, sv.len)==0)
        {
          if (ZSTR(pit->body))
            val->rs = STR_EMPTY;
          else
            val->rs = pit->body;
          goto done;
        }
      }
      val->flags = PV_VAL_NULL;
      break;

    case TR_PL_VALUEAT:
      if(tp==NULL)
      {
        LM_ERR("name invalid parameters\n");
        goto error;
      }

      if(tp->type==TR_PARAM_NUMBER)
      {
        n = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("name cannot get p1\n");
          goto error;
        }
        n = v.ri;
      }
      if(n>=0)
      {
        for (pit = _tr_params_list; pit; pit=pit->next)
        {
          if(n==0)
          {
            val->rs = pit->body;
            goto done;
          }
          n--;
        }
      } else {
        /* ugly hack -- params are in reverse order
         * - first count then find */
        n = -n;
        n--;

        i = 0;
        for (pit = _tr_params_list; pit; pit=pit->next)
          i++;
        if(n<i)
        {
          n = i - n - 1;
          for (pit = _tr_params_list; pit; pit=pit->next)
          {
            if(n==0)
            {
              val->rs = pit->body;
              goto done;
            }
            n--;
          }
        }
      }
      val->flags = PV_VAL_NULL;
      break;

    case TR_PL_NAME:
      if(tp==NULL)
      {
        LM_ERR("name invalid parameters\n");
        goto error;
      }

      if(tp->type==TR_PARAM_NUMBER)
      {
        n = tp->v.n;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("name cannot get p1\n");
          goto error;
        }
        n = v.ri;
      }
      if(n>=0)
      {
        for (pit = _tr_params_list; pit; pit=pit->next)
        {
          if(n==0)
          {
            val->rs = pit->name;
            goto done;
          }
          n--;
        }
      } else {
        /* ugly hack -- params are in sorted order
         * - first count then find */
        n = -n;
        n--;

        i = 0;
        for (pit = _tr_params_list; pit; pit=pit->next)
          i++;
        if(n<i)
        {
          n = i - n - 1;
          for (pit = _tr_params_list; pit; pit=pit->next)
          {
            if(n==0)
            {
              val->rs = pit->name;
              goto done;
            }
            n--;
          }
        }
      }
      val->flags = PV_VAL_NULL;
      break;

    case TR_PL_COUNT:
      val->ri = 0;
      for (pit = _tr_params_list; pit; pit=pit->next) {
        val->ri++;
      }
      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;


    case TR_PL_EXIST:
      if(tp==NULL)
      {
        LM_ERR("value invalid parameters\n");
        goto error;
      }

      if(tp->type==TR_PARAM_STRING)
      {
        sv = tp->v.s;
      } else {
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_STR)) || v.rs.len<=0)
        {
          LM_ERR("value cannot get p1\n");
          goto error;
        }
        sv = v.rs;
      }

      val->ri = 0;
      for (pit = _tr_params_list; pit; pit=pit->next)
      {
        if (pit->name.len==sv.len
            && strncasecmp(pit->name.s, sv.s, sv.len)==0)
        {
          val->ri = 1;
          break;
        }
      }
      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->rs.s = int2str(val->ri, &val->rs.len);
      goto done;

    default:
      LM_ERR("unknown subtype %d\n",
          subtype);
      goto error;
  }

done:
  return 0;
error:
  val->flags = PV_VAL_NULL;
  return -1;
}

static str nameaddr_str = {0, 0};
static struct to_body *nameaddr_to_body = NULL;

int tr_eval_nameaddr(struct sip_msg *msg, tr_param_t *tp, int subtype,
    pv_value_t *val)
{
  struct to_param* topar;
  pv_value_t v;
  int index, total;
  struct to_body *nameaddr = NULL;

  if (!val)
    return -1;

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

  if(!(val->flags&PV_VAL_STR) || val->rs.len<=0)
    goto error;

  LM_DBG("String to transform %.*s\n", val->rs.len, val->rs.s);

  if(nameaddr_str.len==0 || nameaddr_str.len!=val->rs.len ||
      strncmp(nameaddr_str.s, val->rs.s, val->rs.len)!=0)
  {
    /* copy the value in the global variable */
    if(val->rs.len+CRLF_LEN > nameaddr_str.len)
    {
      if(nameaddr_str.s) pkg_free(nameaddr_str.s);
      nameaddr_str.s =
          (char*)pkg_malloc((val->rs.len+CRLF_LEN+1)*sizeof(char));
      if(nameaddr_str.s==NULL)
      {
        LM_ERR("no more private memory\n");
        memset(&nameaddr_str, 0, sizeof(str));
        goto error;
      }
    }
    nameaddr_str.len = val->rs.len + CRLF_LEN;
    memcpy(nameaddr_str.s, val->rs.s, val->rs.len);
    memcpy(nameaddr_str.s + val->rs.len, CRLF, CRLF_LEN);
    nameaddr_str.s[nameaddr_str.len] = '\0';

    /* reset old values */
    if (nameaddr_to_body) {
      free_to(nameaddr_to_body);
      nameaddr_to_body = NULL;
    }

    /* parse TO hdr + params */
    nameaddr_to_body = (struct to_body*)pkg_malloc(sizeof(struct to_body));
    if(nameaddr_to_body==NULL)
    {
      LM_ERR("no more private memory\n");
      /* keep the buffer, but flush the content to force the realloc
         next time */
      nameaddr_str.s[0] = 0;
      goto error;
    }
    parse_multi_to(nameaddr_str.s, nameaddr_str.s + nameaddr_str.len,
      nameaddr_to_body);
  }

  if (nameaddr_to_body->error == PARSE_ERROR)
  {
    LM_ERR("Wrong syntax. It must have the To header format\n");
    goto error;
  }

  /* check if there is an index set */
  if (tp && (subtype != TR_NA_PARAM || tp->next)) {
    /* we do have an index */
    switch (tp->type) {
      case TR_PARAM_NUMBER:
        index = tp->v.n;
        break;
      case TR_PARAM_SPEC:
        if(pv_get_spec_value(msg, (pv_spec_p)tp->v.data, &v)!=0
            || (!(v.flags&PV_VAL_INT)))
        {
          LM_ERR("invalid index type: %d; integer expected\n",
              v.flags);
          goto error;
        }
        index = v.ri;
        break;
      default:
        LM_ERR("unsupported index type: %d\n", tp->type);
        goto error;
    }
    tp = tp->next;
    if (index < 0) {
      total = 0;
      for (nameaddr = nameaddr_to_body; nameaddr; nameaddr = nameaddr->next)
        total++;
      if (index + total < 0) {
        LM_DBG("index %d out of bounds %d\n", index, total);
        goto out_of_bounds;
      }
      index = total + index;
    }
    for (nameaddr = nameaddr_to_body;
        nameaddr && index != 0;
        nameaddr = nameaddr->next, index--);
    if (index > 0 || !nameaddr) {
      LM_DBG("index out of bounds\n");
      goto out_of_bounds;
    }

  } else {
    /* otherwise we default to first body */
    nameaddr = nameaddr_to_body;
  }

  memset(val, 0, sizeof(pv_value_t));
  val->flags = PV_VAL_STR;

  switch(subtype)
  {
    case TR_NA_URI:
      val->rs =(nameaddr->uri.s)?nameaddr->uri:_tr_empty;
      val->flags |= (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_NA_LEN:
      val->flags = PV_TYPE_INT|PV_VAL_INT|PV_VAL_STR;
      val->ri = nameaddr->body.len;
      val->rs.s = int2str(val->ri, &val->rs.len);
      break;
    case TR_NA_NAME:
      val->rs = (nameaddr->display.s)?
        nameaddr->display:_tr_empty;
      val->flags |= (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_NA_PARAM:
      if (!tp)
        goto error;
      if(tp->type != TR_PARAM_STRING)
      {
        LM_ERR("Wrong type for parameter, it must string\n");
        goto error;
      }
      topar = nameaddr->param_lst;
      /* search the parameter */
      while(topar)
      {
        if(topar->name.len == tp->v.s.len &&
            strncmp(topar->name.s, tp->v.s.s, topar->name.len)== 0)
          break;
        topar = topar->next;
      }
      val->rs = (topar)?topar->value:_tr_empty;
      val->flags |= (val->rs.len) ? 0 : PV_VAL_NULL;
      break;
    case TR_NA_PARAMS:
      topar = nameaddr->param_lst;
      if (!topar) {
        LM_DBG("no params\n");
        val->flags = PV_VAL_NULL;
      }
      else {
        LM_DBG("We have params\n");
        val->rs.s = topar->name.s;
        if (nameaddr->last_param->value.s==NULL) {
          val->rs.len = nameaddr->last_param->name.s +
            nameaddr->last_param->name.len - val->rs.s;
        } else {
          val->rs.len = nameaddr->last_param->value.s +
            nameaddr->last_param->value.len - val->rs.s;
          /* compensate the len if the value of the last param is
           * a quoted value (include the closing quote in the len) */
          if ( (val->rs.s+val->rs.len<nameaddr_str.len+nameaddr_str.s) &&
          (val->rs.s[val->rs.len]=='"' || val->rs.s[val->rs.len]=='\'' ) )
            val->rs.len++;
        }
      }
      break;

    default:
      LM_ERR("unknown subtype %d\n", subtype);
      goto error;
  }

  return 0;

error:
  val->flags = PV_VAL_NULL;
  return -1;
out_of_bounds:
  val->flags = PV_VAL_NULL;
  return 0;
}


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

char* parse_transformation(str *in, trans_t **tr)
{
  char *p;
  str tclass;
  trans_t *t = NULL;
  trans_t *t0 = NULL;
  str s;
  const trans_export_t *tr_export;
  trans_extra_t *tr_extra;
  int i, nesting_level = 0;

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

  p = in->s;
  do {
    while(is_in_str(p, in) && is_ws(*p)) p++;
    if(*p != TR_LBRACKET)
      break;
    p++;

    t = (trans_t*)pkg_malloc(sizeof(trans_t));
    if(t == NULL)
    {
      LM_ERR("no more private memory\n");
      return NULL;
    }
    memset(t, 0, sizeof(trans_t));
    if(t0==NULL)
      *tr = t;
    else
      t0->next = t;
    t0 = t;

    /* find transformation class */
    tclass.s = p;
    while(is_in_str(p, in) && *p!=TR_CLASS_MARKER) p++;
    if(*p!=TR_CLASS_MARKER || tclass.s == p)
    {
      LM_ERR("invalid transformation: %.*s (%c)!\n", in->len, in->s, *p);
      goto error;
    }
    tclass.len = p - tclass.s;
    p++;

    tr_export = NULL;

    /* search through core transformations */
    for (i = 0; core_trans[i].name.s; i++)
      if (core_trans[i].name.len == tclass.len &&
        !strncasecmp(core_trans[i].name.s, tclass.s, tclass.len)) {
        tr_export = &core_trans[i];
        break;
      }

    if (!tr_export)
      /* search through module exported transformations */
      for (tr_extra = tr_extra_list; tr_extra; tr_extra = tr_extra->next)
        if (tr_extra->tre.name.len == tclass.len &&
          !strncasecmp(tr_extra->tre.name.s, tclass.s, tclass.len)) {
          tr_export = &tr_extra->tre;
          break;
        }

    if (!tr_export) {
      LM_ERR("unknown transformation: [%.*s] in [%.*s]\n",
        tclass.len, tclass.s, in->len, in->s);
      goto error;
    }

    t->trf = tr_export->eval_func;

    s.s = p;
    /* allow nested transformations! */
    while(is_in_str(p, in) && (nesting_level > 0 || *p != TR_RBRACKET)) {
      if (*p == TR_LBRACKET)
        nesting_level++;

      if (*p == TR_RBRACKET)
        nesting_level--;
      p++;
    }

    if(*p == '\0') {
      LM_ERR("invalid transformation: %.*s\n", in->len, in->s);
      goto error;
    }
    s.len = p - s.s;

    if (tr_export->parse_func(&s, t) < 0)
      goto error;

    p++;
    if(!is_in_str(p, in))
      break;
  } while(1);

  return p;
error:
  LM_ERR("error parsing [%.*s]\n", in->len, in->s);
  t = *tr;
  while(t)
  {
    t0 = t;
    t = t->next;
    free_tr_param(t0->params);
    pkg_free(t0);
  }
  return NULL;
}

char *tr_parse_nparam(char *p, str *in, tr_param_t **tp)
{
  char *p0;
  pv_spec_t *spec = NULL;
  int n, sign;
  str s;

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

  if(*p == PV_MARKER) { /* pseudo-variable */
    spec = pkg_malloc(sizeof(pv_spec_t));
    if (spec == NULL) {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    s.s = p;
    s.len = in->s + in->len - p;
    p0 = pv_parse_spec(&s, spec);
    if(p0 == NULL) {
      LM_ERR("invalid spec in substr transformation: %.*s!\n",
        in->len, in->s);
      goto error;
    }
    p = p0;
    *tp = pkg_malloc(sizeof(tr_param_t));
    if(*tp == NULL) {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    memset(*tp, 0, sizeof(tr_param_t));
    (*tp)->type = TR_PARAM_SPEC;
    (*tp)->v.data = (void*)spec;

    return p;
  } else {
    if (*p == '+' || *p == '-' || (*p >= '0' && *p <= '9')) { /* number */
      sign = 1;
      if (*p == '-') {
        p++;
        sign = -1;
      } else if (*p == '+') p++;
      n = 0;
      while (is_in_str(p, in) && is_ws(*p))
        p++;
      while (is_in_str(p, in) && *p >= '0' && *p <= '9') {
        n = n*10 + *p - '0';
        p++;
      }
      *tp = pkg_malloc(sizeof(tr_param_t));
      if (*tp == NULL) {
        LM_ERR("no more private memory!\n");
        goto error;
      }
      memset(*tp, 0, sizeof(tr_param_t));
      (*tp)->type = TR_PARAM_NUMBER;
      (*tp)->v.n = sign*n;
    } else {
      LM_ERR("invalid param in transformation: %.*s!!\n",
        in->len, in->s);
      goto error;
    }

    return p;
  }

error:
  if (spec)
    pv_spec_free(spec);
  return NULL;
}

/*
 * Not all transformation string parameters have the same meaning
 * Some of them are SIP headers, thus they cannot contain whitespace,
 * while others may just be strings with no additional restrictions.
 * Set the mode to TR_PARSE_SPARAM_WS if your param may contain
 * whitespace
 *    -> e.g. ' ', "foo bar", "foob\tar" ...
 */

char *tr_parse_sparam(char *p, str *in, tr_param_t **tp,
    enum tr_parse_sparam_mode mode)
{
  char *p0, *ps;
  pv_spec_t *spec = NULL;
  str s;

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

  if (*p == PV_MARKER) { /* pseudo-variable */
    spec = pkg_malloc(sizeof(pv_spec_t));
    if (spec == NULL) {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    s.s = p;
    s.len = in->s + in->len - p;
    p0 = pv_parse_spec(&s, spec);
    if (p0 == NULL) {
      LM_ERR("invalid spec in substr transformation: %.*s!\n",
        in->len, in->s);
      goto error;
    }
    p = p0;
    *tp = pkg_malloc(sizeof(tr_param_t));
    if (*tp == NULL) {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    memset(*tp, 0, sizeof(tr_param_t));
    (*tp)->type = TR_PARAM_SPEC;
    (*tp)->v.data = (void*)spec;

    return p;
  } else { /* string */
    ps = p;
    while (is_in_str(p, in) &&
        (mode != TR_PARSE_SPARAM_NO_WS || !is_ws(*p))) {
      if ((*p == TR_PARAM_MARKER ||
          (*p == TR_RBRACKET &&
              mode != TR_PARSE_SPARAM_WS_RBRACKET)) &&
          (p - 1 < ps || *(p - 1) != '\\'))
        break;
      p++;
    }

    if (*p == '\0') {
      LM_ERR("invalid param in transformation: %.*s!!\n",
        in->len, in->s);
      goto error;
    }
    *tp = pkg_malloc(sizeof(tr_param_t));
    if (*tp == NULL) {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    memset(*tp, 0, sizeof(tr_param_t));
    (*tp)->type = TR_PARAM_STRING;
    (*tp)->v.s.s = ps;
    (*tp)->v.s.len = p - ps;

    return p;
  }

error:
  if (spec)
    pv_spec_free(spec);
  return NULL;
}

int tr_parse_string(str* in, trans_t *t)
{
  char *p, *cp;
  str name;
  tr_param_t *tp = NULL;

  if(in==NULL || t==NULL)
    return -1;

  p = in->s;
  name.s = in->s;

  /* find next token */
  while(is_in_str(p, in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if(*p=='\0')
  {
    LM_ERR("invalid transformation: %.*s\n",
        in->len, in->s);
    goto error;
  }
  name.len = p - name.s;
  trim(&name);

  if(name.len==3 && strncasecmp(name.s, "len", 3)==0)
  {
    t->subtype = TR_S_LEN;
    return 0;
  } else if(name.len==3 && strncasecmp(name.s, "int", 3)==0) {
    t->subtype = TR_S_INT;
    return 0;
  } else if(name.len==3 && strncasecmp(name.s, "md5", 3)==0) {
    t->subtype = TR_S_MD5;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "crc32", 5)==0) {
    t->subtype = TR_S_CRC32;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "tolower", 7)==0) {
    t->subtype = TR_S_TOLOWER;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "toupper", 7)==0) {
    t->subtype = TR_S_TOUPPER;
    return 0;
  } else if(name.len==11 && strncasecmp(name.s, "encode.hexa", 11)==0) {
    t->subtype = TR_S_ENCODEHEXA;
    return 0;
  } else if(name.len==11 && strncasecmp(name.s, "decode.hexa", 11)==0) {
    t->subtype = TR_S_DECODEHEXA;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "hex2dec", 7)==0) {
    t->subtype = TR_S_HEX2DEC;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "dec2hex", 7)==0) {
    t->subtype = TR_S_DEC2HEX;
    return 0;
  } else if(name.len==9 && strncasecmp(name.s, "date2unix", 9)==0) {
    t->subtype = TR_S_DATE2UNIX;
    return 0;
  } else if(name.len==13 && strncasecmp(name.s, "escape.common", 13)==0) {
    t->subtype = TR_S_ESCAPECOMMON;
    return 0;
  } else if(name.len==15 && strncasecmp(name.s, "unescape.common", 15)==0) {
    t->subtype = TR_S_UNESCAPECOMMON;
    return 0;
  } else if(name.len==11 && strncasecmp(name.s, "escape.user", 11)==0) {
    t->subtype = TR_S_ESCAPEUSER;
    return 0;
  } else if(name.len==13 && strncasecmp(name.s, "unescape.user", 13)==0) {
    t->subtype = TR_S_UNESCAPEUSER;
    return 0;
  } else if(name.len==12 && strncasecmp(name.s, "escape.param", 12)==0) {
    t->subtype = TR_S_ESCAPEPARAM;
    return 0;
  } else if(name.len==14 && strncasecmp(name.s, "unescape.param", 14)==0) {
    t->subtype = TR_S_UNESCAPEPARAM;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "index", 5)==0) {
    t->subtype = TR_S_INDEX;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid index transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS)) == NULL)
      goto error;
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if(*p!=TR_PARAM_MARKER && *p!=TR_RBRACKET)
    {
      LM_ERR("invalid index transformation: %.*s!\n",
        in->len, in->s);
      goto error;
    }
    if (*p!=TR_RBRACKET) {
      p++;
      if (tr_parse_nparam(p, in, &tp) == NULL)
        goto error;
      t->params->next = tp;
    } else {
      t->params->next = NULL;
    }

    tp = 0;

    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "rindex", 6)==0) {
    t->subtype = TR_S_RINDEX;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid rindex transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS)) == NULL)
      goto error;
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if(*p!=TR_PARAM_MARKER && *p!=TR_RBRACKET)
    {
      LM_ERR("invalid rindex transformation: %.*s!\n",
        in->len, in->s);
      goto error;
    }
    if (*p!=TR_RBRACKET) {
      p++;
      if (tr_parse_nparam(p, in, &tp) == NULL)
        goto error;
      t->params->next = tp;
    } else {
      t->params->next = NULL;
    }

    tp = 0;

    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "substr", 6)==0) {
    t->subtype = TR_S_SUBSTR;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid substr transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_nparam(p, in, &tp)) == NULL)
      goto error;
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid substr transformation: %.*s!\n",
        in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    t->params->next = tp;
    tp = 0;

    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "select", 6)==0) {
    t->subtype = TR_S_SELECT;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid select transformation: %.*s!\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_nparam(p, in, &tp)) == NULL)
      goto error;
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if(*p!=TR_PARAM_MARKER || *(p+1)=='\0')
    {
      LM_ERR("invalid select transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    tp = (tr_param_t*)pkg_malloc(sizeof(tr_param_t));
    if(tp==NULL)
    {
      LM_ERR("no more private memory!\n");
      goto error;
    }
    memset(tp, 0, sizeof(tr_param_t));
    tp->type = TR_PARAM_STRING;
    tp->v.s.s = p;
    tp->v.s.len = 1;
    t->params->next = tp;
    tp = 0;

    return 0;
  } else if ((name.len==9 && strncasecmp(name.s, "fill.left", 9)==0) ||
        (name.len==10 && strncasecmp(name.s, "fill.right", 10)==0)) {

    t->subtype = (name.len == 9 ? TR_S_FILL_LEFT : TR_S_FILL_RIGHT);
    if (*p != TR_PARAM_MARKER)
    {
      LM_ERR("invalid fill transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_WS)) == NULL)
      goto error;
    if (tp->type == TR_PARAM_SPEC)
    {
      LM_ERR("fill transformation does not allow PVs: %.*s!\n", in->len, in->s);
      goto error;
    }
    if (tp->v.s.len == 0)
    {
      LM_ERR("fill transformation is a NOP, maybe use quotes? %.*s\n",
          in->len, in->s);
      goto error;
    }

    if (tp->v.s.len > 1) {
      /* we allowed all whitespace, so manually skip trailing ws */
      cp = &tp->v.s.s[tp->v.s.len - 1];
      trim_trail_ws(cp);
      tp->v.s.len -= &tp->v.s.s[tp->v.s.len - 1] - cp;

      /* support for quoted chars/strings */
      if (tp->v.s.len > 1 &&
        ((tp->v.s.s[0] == '\'' && tp->v.s.s[tp->v.s.len - 1] == '\'') ||
        (tp->v.s.s[0] == '\"' && tp->v.s.s[tp->v.s.len - 1] == '\"'))) {

        if (tp->v.s.len == 2)
        {
          LM_ERR("fill transformation is a NOP, maybe use quotes? %.*s\n",
              in->len, in->s);
          goto error;
        }

        tp->v.s.len -= 2;
        tp->v.s.s++;
      }
    }
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if (*p != TR_PARAM_MARKER || *(p+1) == '\0')
    {
      LM_ERR("invalid fill transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    if (tp->type == TR_PARAM_SPEC)
    {
      LM_ERR("fill transformation does not allow PVs: %.*s!\n", in->len, in->s);
      goto error;
    }
    t->params->next = tp;

    tp = 0;

    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "width", 5)==0) {
    t->subtype = TR_S_WIDTH;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid substr transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_nparam(p, in, &tp)) == NULL)
      goto error;
    if(tp->type==TR_PARAM_NUMBER && tp->v.n<0)
    {
      LM_ERR("width negative\n");
      goto error;
    }
    t->params = tp;
    tp = 0;
    while(is_in_str(p, in) && (*p==' ' || *p=='\t' || *p=='\n')) p++;
    if(*p!=TR_RBRACKET)
    {
      LM_ERR("invalid width transformation: %.*s!!\n",
        in->len, in->s);
      goto error;
    }
    return 0;
  } else if(name.len==9 && strncasecmp(name.s, "b64encode", 9)==0) {
    t->subtype = TR_S_B64ENCODE;
    return 0;
  } else if(name.len==9 && strncasecmp(name.s, "b64decode", 9)==0) {
    t->subtype = TR_S_B64DECODE;
    return 0;
  } else if(name.len==3 && strncasecmp(name.s, "xor", 3)==0) {
    t->subtype = TR_S_XOR;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid xor transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;
    tp = 0;

    return 0;
  } else if (strncasecmp(name.s, "trim", 4) == 0) {
    if (name.len == 4)
      t->subtype = TR_S_TRIM;
    else if (name.len > 4 && strncasecmp(name.s, "trimr", 5) == 0)
      t->subtype = TR_S_TRIMR;
    else if (name.len > 4 && strncasecmp(name.s, "triml", 5) == 0)
      t->subtype = TR_S_TRIML;
    else {
      LM_ERR("bad trim transformation!\n");
      goto error;
    }

    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "reverse", 7)==0) {
    t->subtype = TR_S_REVERSE;
    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "eval", 4)==0) {
    t->subtype = TR_S_EVAL;
    return 0;
    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "sha1", 4)==0) {
    t->subtype = TR_S_SHA1;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "sha224", 6)==0) {
    t->subtype = TR_S_SHA224;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "sha256", 6)==0) {
    t->subtype = TR_S_SHA256;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "sha384", 6)==0) {
    t->subtype = TR_S_SHA384;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "sha512", 6)==0) {
    t->subtype = TR_S_SHA512;
    return 0;
  } else if ( (name.len==9 || name.len==11) && strncasecmp(name.s, "sha", 3)==0 &&
      strncasecmp(name.s+(name.len-5), "_hmac", 5)==0 ) {

    if (strncasecmp(name.s+3, "1", 1) == 0) { // SHA1
      t->subtype = TR_S_SHA1_HMAC;
    } else if (strncasecmp(name.s+3, "224", 3) == 0) { // SHA224
      t->subtype = TR_S_SHA224_HMAC;
    } else if (strncasecmp(name.s+3, "256", 3) == 0) { // SHA256
      t->subtype = TR_S_SHA256_HMAC;
    } else if (strncasecmp(name.s+3, "384", 3) == 0) { // SHA384
      t->subtype = TR_S_SHA384_HMAC;
    } else if (strncasecmp(name.s+3, "512", 3) == 0) { // SHA512
      t->subtype = TR_S_SHA512_HMAC;
    } else {
      goto unknown;
    }

    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid sha hmac transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;
    tp = 0;

    return 0;
  }

unknown:
  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  if(tp)
    free_tr_param(tp);
  return -1;
}

int tr_parse_integer(str *in, trans_t *t)
{
  str name;

  if (!in || !t)
    return -1;

  name = *in;
  trim(&name);

  if (name.len == 4 && strncasecmp(name.s, "bool", 4) == 0) {
    t->subtype = TR_I_BOOL;
    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
  return -1;
}

int tr_parse_uri(str* in, trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;

  if(in==NULL || in->s==NULL || t==NULL)
    return -1;
  p = in->s;
  name.s = in->s;

  /* find next token */
  while(*p && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if(*p=='\0')
  {
    LM_ERR("invalid transformation: %.*s\n", in->len, in->s);
    goto error;
  }
  name.len = p - name.s;
  trim(&name);

  if(name.len==4 && strncasecmp(name.s, "user", 4)==0)
  {
    t->subtype = TR_URI_USER;
    return 0;
  } else if((name.len==4 && strncasecmp(name.s, "host", 4)==0)
      || (name.len==6 && strncasecmp(name.s, "domain", 6)==0)) {
    t->subtype = TR_URI_HOST;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "passwd", 6)==0) {
    t->subtype = TR_URI_PASSWD;
    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "port", 4)==0) {
    t->subtype = TR_URI_PORT;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "params", 6)==0) {
    t->subtype = TR_URI_PARAMS;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "param", 5)==0) {
    t->subtype = TR_URI_PARAM;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid param transformation: %.*s\n", in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;
    return 0;
  } else if(name.len==9 && strncasecmp(name.s, "transport", 9)==0) {
    t->subtype = TR_URI_TRANSPORT;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "headers", 7)==0) {
    t->subtype = TR_URI_HEADERS;
    return 0;
  } else if(name.len==3 && strncasecmp(name.s, "ttl", 3)==0) {
    t->subtype = TR_URI_TTL;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "uparam", 6)==0) {
    t->subtype = TR_URI_UPARAM;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "maddr", 5)==0) {
    t->subtype = TR_URI_MADDR;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "method", 6)==0) {
    t->subtype = TR_URI_METHOD;
    return 0;
  } else if(name.len==2 && strncasecmp(name.s, "lr", 2)==0) {
    t->subtype = TR_URI_LR;
    return 0;
  } else if(name.len==2 && strncasecmp(name.s, "r2", 2)==0) {
    t->subtype = TR_URI_R2;
    return 0;
  } else if (name.len==6 && strncasecmp(name.s, "schema", 6)==0) {
    t->subtype = TR_URI_SCHEMA;
    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s!\n", in->len,
      in->s, name.len, name.s);
error:
  return -1;
}


int tr_parse_via(str* in, trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;

  if(in==NULL || in->s==NULL || t==NULL)
    return -1;
  p = in->s;
  name.s = in->s;

  /* find next token */
  while(*p && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if(*p=='\0')
  {
    LM_ERR("invalid transformation: %.*s\n", in->len, in->s);
    goto error;
  }
  name.len = p - name.s;
  trim(&name);

  if(name.len==4 && strncasecmp(name.s, "name", 4)==0)
  {
    t->subtype = TR_VIA_NAME;
    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "version", 7)==0)
  {
    t->subtype = TR_VIA_VERSION;
    return 0;
  } else if(name.len==9 && strncasecmp(name.s, "transport", 9)==0) {
    t->subtype = TR_VIA_TRANSPORT;
    return 0;
  } else if((name.len==4 && strncasecmp(name.s, "host", 4)==0)
      || (name.len==6 && strncasecmp(name.s, "domain", 6)==0)) {
    t->subtype = TR_VIA_HOST;
    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "port", 4)==0) {
    t->subtype = TR_VIA_PORT;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "params", 6)==0) {
    t->subtype = TR_VIA_PARAMS;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "param", 5)==0) {
    t->subtype = TR_VIA_PARAM;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid param transformation: %.*s\n", in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;

    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "comment", 7)==0) {
    t->subtype = TR_VIA_COMMENT;
    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "branch", 6)==0) {
    t->subtype = TR_VIA_BRANCH;
    return 0;
  } else if(name.len==8 && strncasecmp(name.s, "received", 8)==0) {
    t->subtype = TR_VIA_RECEIVED;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "rport", 5)==0) {
    t->subtype = TR_VIA_RPORT;
    return 0;
  }


  LM_ERR("unknown transformation: %.*s/%.*s!\n", in->len,
      in->s, name.len, name.s);
error:
  return -1;
}

int tr_parse_paramlist(str* in, trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;

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

  p = in->s;
  name.s = in->s;

  /* find next token */
  while(is_in_str(p, in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if(*p=='\0')
  {
    LM_ERR("invalid transformation: %.*s\n",
        in->len, in->s);
    goto error;
  }
  name.len = p - name.s;
  trim(&name);

  if(name.len==5 && strncasecmp(name.s, "value", 5)==0)
  {
    t->subtype = TR_PL_VALUE;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid value transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;

    return 0;

  } else if(str_match(&name, &(str_const_init("exist")))
            || str_match(&name, &(str_const_init("exists")))) {
    t->subtype = TR_PL_EXIST;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid value transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    t->params = tp;

    return 0;
  } else if(name.len==7 && strncasecmp(name.s, "valueat", 7)==0) {
    t->subtype = TR_PL_VALUEAT;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid name transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    t->params = tp;

    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "name", 4)==0) {
    t->subtype = TR_PL_NAME;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid name transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    t->params = tp;

    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "count", 5)==0) {
    t->subtype = TR_PL_COUNT;
    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s!\n",
      in->len, in->s, name.len, name.s);
error:
  return -1;
}

int tr_parse_nameaddr(str* in, trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;


  if(in==NULL || t==NULL)
    return -1;

  p = in->s;
parse_name:
  name.s = p;

  /* find next token */
  while(is_in_str(p, in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET && *p!=TR_CLASS_MARKER) p++;
  if(*p=='\0')
  {
    LM_ERR("invalid transformation: %.*s\n",
        in->len, in->s);
    goto error;
  }
  name.len = p - name.s;
  trim(&name);
  if (*p == TR_CLASS_MARKER) {
    if (t->params) {
      LM_ERR("transformation [%.*s] already has an index!\n",
          in->len, in->s);
      goto error;
    }
    /* we either have a pvar, or an index */
    if (tr_parse_nparam(name.s, &name, &tp) == NULL) {
      LM_ERR("invalid index: %.*s\n", name.len, name.s);
      goto error;
    }
    t->params = tp;
    tp = 0;
    p++;
    goto parse_name;
  }

  if(name.len==3 && strncasecmp(name.s, "uri", 3)==0)
  {
    t->subtype = TR_NA_URI;
    return 0;
  } else if(name.len==3 && strncasecmp(name.s, "len", 3)==0)
  {
    t->subtype = TR_NA_LEN;
    return 0;
  } else if(name.len==4 && strncasecmp(name.s, "name", 4)==0) {
    t->subtype = TR_NA_NAME;
    return 0;
  } else if(name.len==5 && strncasecmp(name.s, "param", 5)==0) {
    t->subtype = TR_NA_PARAM;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid value transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    if (t->params)
      t->params->next = tp;
    else
      t->params = tp;
    tp = 0;

    return 0;
  } else if(name.len==6 && strncasecmp(name.s, "params", 6)==0) {
    t->subtype = TR_NA_PARAMS;
    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  return -1;
}

int tr_parse_csv(str *in, trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;

  if (in == NULL || t == NULL)
    return -1;

  p = in->s;
  name.s = in->s;

  /* find next token */
  while (is_in_str(p,in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if (*p == '\0')
  {
    LM_ERR("invalid transformation: %.*s\n",in->len,in->s);
    return -1;
  }

  name.len = p - name.s;
  trim(&name);

  if (name.len==5 && strncasecmp(name.s,"count",5)==0)
  {
    t->subtype = TR_CSV_COUNT;
    return 0;
  }
  else if (name.len==5 && strncasecmp(name.s,"value",5)==0)
  {
    t->subtype = TR_CSV_VALUEAT;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid name transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    t->params = tp;
    tp = 0;

    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  return -1;

}

int tr_parse_sdp(str *in, trans_t *t)
{
  int tmp;
  char *p;
  str name;
  tr_param_t *tp = NULL;

  if (in == NULL || t == NULL)
    return -1;

  p = in->s;
  name.s = in->s;

  /* find next token */
  while (is_in_str(p,in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if (*p == '\0')
  {
    LM_ERR("invalid transformation: %.*s\n",in->len,in->s);
    return -1;
  }

  name.len = p - name.s;
  trim(&name);

  if (name.len==4 && strncasecmp(name.s,"line",4)==0)
  {
    t->subtype = TR_SDP_LINEAT;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid lineat transformation: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS)) == NULL)
      goto error;
    t->params = tp;
    tp = 0;
    trim_ws(p);
    if(*p!=TR_PARAM_MARKER)
    {
      /* lineat has only one parameter */
      tp = (tr_param_t*)pkg_malloc(sizeof(tr_param_t));
      if (!tp)
      {
        LM_ERR("no more pkg memory\n");
        goto error;
      }
      memset(tp, 0, sizeof(tr_param_t));
      tp->type = TR_PARAM_NUMBER;
      tp->v.n = 0;
      t->params->next = tp;
      LM_DBG("sdp.lineat with only one parameter. default = 1\n");
      return 0;
    }
    p++;

    if (tr_parse_nparam(p, in, &tp) == NULL)
      goto error;
    if(tp->type==TR_PARAM_NUMBER && tp->v.n<0)
    {
      LM_ERR("lineat negative argument\n");
      goto error;
    }
    t->params->next = tp;
    tp = 0;

    return 0;
  } else if ((name.len==13 && strncasecmp(name.s,"stream-delete",13)==0) ||
        (name.len==6 && strncasecmp(name.s,"stream",6)==0)) {
    if (name.len == 6)
      t->subtype = TR_SDP_STREAM;
    else
      t->subtype = TR_SDP_STREAM_DEL;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("media delete without type or index: %.*s!\n", in->len, in->s);
      goto error;
    }
    p++;
    if ((p = tr_parse_sparam(p, in, &tp, TR_PARSE_SPARAM_NO_WS)) == NULL)
      goto error;
    /* if it is a static numeric, convert it now */
    if (tp->type == TR_PARAM_STRING) {
      /* try to convert it now to an int, if possible */
      if (str2sint(&tp->v.s, &tmp) >= 0) {
        tp->v.n = tmp;
        tp->type = TR_PARAM_NUMBER;
      }
    }
    t->params = tp;
    tp = 0;

    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  return -1;
}

int tr_parse_ip(str *in, trans_t *t)
{
  char *p;
  str name;

  if (in == NULL || t == NULL)
    return -1;

  p = in->s;
  name.s = in->s;

  /* find next token */
  while (is_in_str(p,in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if (*p == '\0')
  {
    LM_ERR("invalid transformation: %.*s\n",in->len,in->s);
    goto error;
  }

  name.len = p - name.s;
  trim(&name);

  if (name.len==6 && strncasecmp(name.s,"family",6)==0) {
    t->subtype = TR_IP_FAMILY;
    return 0;
  } else if (name.len==4 && strncasecmp(name.s,"ntop",4)==0) {
    t->subtype = TR_IP_NTOP;
    return 0;
  } else if (name.len == 4 && strncasecmp(name.s,"isip",4) == 0) {
    t->subtype = TR_IP_ISIP;
    return 0;
        } else if (name.len == 5 && strncasecmp(name.s,"isip4",5) == 0) {
                t->subtype = TR_IP_ISIP4;
                return 0;
        } else if (name.len == 5 && strncasecmp(name.s,"isip6",5) == 0) {
                t->subtype = TR_IP_ISIP6;
                return 0;
  } else if (name.len == 4 && strncasecmp(name.s,"pton",4) == 0) {
    t->subtype = TR_IP_PTON;
    return 0;
  } else if (name.len == 7 && strncasecmp(name.s,"resolve",7) == 0) {
    t->subtype = TR_IP_RESOLVE;
    return 0;
  } else if (name.len == 8 && strncasecmp(name.s,"resolve4",8) == 0) {
    t->subtype = TR_IP_RESOLVE_V4;
    return 0;
  } else if (name.len == 8 && strncasecmp(name.s,"resolve6",8) == 0) {
    t->subtype = TR_IP_RESOLVE_V6;
    return 0;
  } else if (name.len == 7 && strncasecmp(name.s,"matches",5) == 0) {
    t->subtype = TR_IP_MATCHES;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid value transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    LM_DBG("preparing to parse param\n");
    if (tr_parse_sparam(p, in, &t->params, TR_PARSE_SPARAM_NO_WS) == NULL)
      goto error;
    return 0;
  } else if (name.len == 9 && strncasecmp(name.s,"isprivate",9) == 0) {
    t->subtype = TR_IP_ISPRIVATE;
    return 0;
  }


  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  return -1;

}

int tr_parse_re(str *in,trans_t *t)
{
  char *p;
  str name;
  tr_param_t *tp = NULL;

  if (in == NULL || t == NULL)
    return -1;

  p = in->s;
  name.s = in->s;

  /* find next token */
  while (is_in_str(p,in) && *p!=TR_PARAM_MARKER && *p!=TR_RBRACKET) p++;
  if (*p == '\0')
  {
    LM_ERR("invalid transformation: %.*s\n",in->len,in->s);
    goto error;
  }

  name.len = p - name.s;
  trim(&name);

  if (name.len==5 && strncasecmp(name.s,"subst",5)==0)
  {
    t->subtype = TR_RE_SUBST;
    if(*p!=TR_PARAM_MARKER)
    {
      LM_ERR("invalid value transformation: %.*s\n",
          in->len, in->s);
      goto error;
    }
    p++;
    LM_DBG("preparing to parse param\n");
    /* The substitution expression may contain unescaped regex braces. */
    if (tr_parse_sparam(p, in, &tp,
        TR_PARSE_SPARAM_WS_RBRACKET) == NULL)
      goto error;
    t->params = tp;
    tp = 0;

    return 0;
  }

  LM_ERR("unknown transformation: %.*s/%.*s/%d!\n", in->len, in->s,
      name.len, name.s, name.len);
error:
  return -1;
}

void free_transformation(trans_t *t)
{
  trans_t *t0;

  while(t)
  {
    t0 = t;
    t = t->next;
    free_tr_param(t0->params);
    pkg_free(t0);
  }
}

void free_tr_param(tr_param_t *tp)
{
  tr_param_t *tp0;

  if(tp==NULL) return;
  while(tp)
  {
    tp0 = tp;
    tp = tp->next;
    if(tp0->type==TR_PARAM_SPEC)
      pv_spec_free((pv_spec_t*)tp0->v.data);
    pkg_free(tp0);
  }
}

Coverage Report

Created: 2026-10-10 06:26