Uri.cxx

Go to the documentation of this file.

#if defined(HAVE_CONFIG_H)
#include "config.h"
#endif
 
#include <ctype.h>
#include <set>
 
#include "resip/stack/Embedded.hxx"
#include "resip/stack/Helper.hxx"
#include "resip/stack/NameAddr.hxx"
#include "resip/stack/SipMessage.hxx"
#include "resip/stack/Symbols.hxx"
#include "resip/stack/UnknownParameter.hxx"
#include "resip/stack/Uri.hxx"
#include "rutil/compat.hxx"
#include "rutil/DataStream.hxx"
#include "rutil/DnsUtil.hxx"
#include "rutil/Logger.hxx"
#include "rutil/ParseBuffer.hxx"
//#include "rutil/WinLeakCheck.hxx"  // not compatible with placement new used below
 
using namespace resip;
 
#define RESIPROCATE_SUBSYSTEM Subsystem::SIP
#define HANDLE_CHARACTER_ESCAPING //undef for old behaviour
 
static bool initAllTables()
{
   Uri::getUserEncodingTable();
   Uri::getPasswordEncodingTable();
   Uri::getLocalNumberTable();
   Uri::getGlobalNumberTable();
   Uri::getUrnEncodingTable();
   return true;
}
 
const bool Uri::tablesMightBeInitialized(initAllTables());
 
Uri::Uri(PoolBase* pool) 
   : ParserCategory(pool),
     mScheme(Data::Share, Symbols::DefaultSipScheme),
     mPort(0),
     mHostCanonicalized(false),
     mIsBetweenAngleQuotes(false),
     mIsBareAddrSpec(false)
{
}
 
Uri::Uri(const HeaderFieldValue& hfv, Headers::Type type, PoolBase* pool) :
   ParserCategory(hfv, type, pool),
   mPort(0),
   mHostCanonicalized(false),
   mIsBetweenAngleQuotes(false),
   mIsBareAddrSpec(false)
{}
 
 
static const Data parseContext("Uri constructor");
Uri::Uri(const Data& data)
   : ParserCategory(),
     mScheme(Symbols::DefaultSipScheme),
     mPort(0),
     mHostCanonicalized(false),
     mIsBetweenAngleQuotes(false),
     mIsBareAddrSpec(false)
{
   HeaderFieldValue hfv(data.data(), data.size());
   // must copy because parse creates overlays
   Uri tmp(hfv, Headers::UNKNOWN);
   tmp.checkParsed();
   *this = tmp;
}
 
Uri::Uri(const Uri& rhs,
         PoolBase* pool)
   : ParserCategory(rhs, pool),
     mScheme(rhs.mScheme),
     mHost(rhs.mHost),
     mUser(rhs.mUser),
     mUserParameters(rhs.mUserParameters),
     mPort(rhs.mPort),
     mPassword(rhs.mPassword),
     mNetNs(rhs.mNetNs),
     mPath(rhs.mPath),
     mHostCanonicalized(rhs.mHostCanonicalized),
     mCanonicalHost(rhs.mCanonicalHost),
     mIsBetweenAngleQuotes(rhs.mIsBetweenAngleQuotes),
     mIsBareAddrSpec(rhs.mIsBareAddrSpec),
     mEmbeddedHeadersText(rhs.mEmbeddedHeadersText.get() ? new Data(*rhs.mEmbeddedHeadersText) : 0),
     mEmbeddedHeaders(rhs.mEmbeddedHeaders.get() ? new SipMessage(*rhs.mEmbeddedHeaders) : 0),
     mUserRaw(rhs.mUserRaw ? new Data(*rhs.mUserRaw) : nullptr)
{}
 
 
Uri::~Uri()
{}
 
// RFC 3261 19.1.6
#if 0  // deprecated
Uri
Uri::fromTel(const Uri& tel, const Data& host)
{
   resip_assert(tel.scheme() == Symbols::Tel);
 
   Uri u;
   u.scheme() = Symbols::Sip;
   u.user() = tel.user();
   u.host() = host;
   u.param(p_user) = Symbols::Phone;
 
   // need to sort the user parameters
   if (!tel.userParameters().empty())
   {
      DebugLog(<< "Uri::fromTel: " << tel.userParameters());
      Data isub;
      Data postd;
 
      int totalSize  = 0;
      std::set<Data> userParameters;
 
      ParseBuffer pb(tel.userParameters().data(), tel.userParameters().size());
      while (true)
      {
         const char* anchor = pb.position();
         pb.skipToChar(Symbols::SEMI_COLON[0]);
         Data param = pb.data(anchor);
         // !dlb! not supposed to lowercase extension parameters
         param.lowercase();
         totalSize += param.size() + 1;
 
         if (param.prefix(Symbols::Isub))
         {
            isub = param;
         }
         else if (param.prefix(Symbols::Postd))
         {
            postd = param;
         }
         else
         {
            userParameters.insert(param);
         }
         if (pb.eof())
         {
            break;
         }
         else
         {
            pb.skipChar();
         }
      }
 
      u.userParameters().reserve(totalSize);
      if (!isub.empty())
      {
         u.userParameters() = isub;
      }
      if (!postd.empty())
      {
         if (!u.userParameters().empty())
         {
            u.userParameters() += Symbols::SEMI_COLON[0];
         }
         u.userParameters() += postd;
      }
      
      for(std::set<Data>::const_iterator i = userParameters.begin();
          i != userParameters.end(); ++i)
      {
         DebugLog(<< "Adding param: " << *i);
         if (!u.userParameters().empty())
         {
            u.userParameters() += Symbols::SEMI_COLON[0];
         }
         u.userParameters() += *i;
      }
   }
 
   return u;
}
#endif // deprecated
 
Uri
Uri::fromTel(const Uri& tel, const Uri& hostUri)
{
   resip_assert(tel.scheme() == Symbols::Tel);
 
   Uri u(hostUri);
   u.scheme() = Symbols::Sip;
   u.user() = tel.user();
   u.param(p_user) = Symbols::Phone;
 
   // need to sort the user parameters
   if (!tel.userParameters().empty())
   {
      DebugLog(<< "Uri::fromTel: " << tel.userParameters());
      Data isub;
      Data postd;
 
      int totalSize  = 0;
      std::set<Data> userParameters;
 
      ParseBuffer pb(tel.userParameters().data(), tel.userParameters().size());
      while (true)
      {
         const char* anchor = pb.position();
         pb.skipToChar(Symbols::SEMI_COLON[0]);
         Data param = pb.data(anchor);
         // !dlb! not supposed to lowercase extension parameters
         param.lowercase();
         totalSize += (int)param.size() + 1;
 
         if (param.prefix(Symbols::Isub))
         {
            isub = param;
         }
         else if (param.prefix(Symbols::Postd))
         {
            postd = param;
         }
         else
         {
            userParameters.insert(param);
         }
         if (pb.eof())
         {
            break;
         }
         else
         {
            pb.skipChar();
         }
      }
 
      u.userParameters().reserve(totalSize);
      if (!isub.empty())
      {
         u.userParameters() = isub;
      }
      if (!postd.empty())
      {
         if (!u.userParameters().empty())
         {
            u.userParameters() += Symbols::SEMI_COLON[0];
         }
         u.userParameters() += postd;
      }
      
      for(std::set<Data>::const_iterator i = userParameters.begin();
          i != userParameters.end(); ++i)
      {
         DebugLog(<< "Adding param: " << *i);
         if (!u.userParameters().empty())
         {
            u.userParameters() += Symbols::SEMI_COLON[0];
         }
         u.userParameters() += *i;
      }
   }
 
   return u;
}
 
bool
Uri::isEnumSearchable() const
{
   checkParsed();
   int digits = 0;
 
   if(mScheme != Symbols::Tel)
   {
      StackLog(<< "not a tel Uri");
      return false;
   }
 
   if(mUser.size() < 4)
   {
      StackLog(<< "user part of Uri empty or too short for E.164");
      return false;
   }
 
   // E.164 numbers must begin with a + and have at least
   // 3 digits
   if(mUser[0] != '+')
   {
      StackLog(<< "user part of Uri does not begin with `+' or too short");
      return false;
   }
 
   // count the digits (skip the leading `+')
   for(const char* i=user().begin() + 1; i!= user().end(); i++)
   {
      if (isdigit(static_cast< unsigned char >(*i)))
      {
         digits++;
      }
      else
      {
         if (*i != '-')
         {
            StackLog(<< "user part of Uri contains non-digit: " << *i);
            return false; // Only digits and '-' permitted
         }
      }
   }
   if(digits > 15)
   {
      // E.164 only permits 15 digits in a phone number
      StackLog(<< "user part of Uri contains more than 15 digits");
      return false;
   }
 
   DebugLog(<< "is in E.164 format for ENUM: " << mUser);
   return true;
}
 
std::vector<Data> 
Uri::getEnumLookups(const std::vector<Data>& suffixes) const
{
   std::vector<Data> results;
   Data prefix;
   if (isEnumSearchable())
   {
      // skip the leading +
      for (const char* i=user().end()-1 ; i!= user().begin(); --i)
      {
         if (isdigit(static_cast< unsigned char >(*i)))
         {
            prefix += *i;
            prefix += Symbols::DOT;
         }
      }
      StackLog(<< "E.164 number reversed for ENUM query: " << prefix);
      for (std::vector<Data>::const_iterator j=suffixes.begin(); j != suffixes.end(); ++j)
      {
         results.push_back(prefix + *j);
      }
   }
   return results;
}
 
bool
Uri::hasEmbedded() const
{
   checkParsed(); 
   return (mEmbeddedHeadersText.get() && !mEmbeddedHeadersText->empty()) || mEmbeddedHeaders.get() != 0;
}
 
void 
Uri::removeEmbedded()
{
   checkParsed();
   mEmbeddedHeaders.reset();
   mEmbeddedHeadersText.reset();
}
 
Uri&
Uri::operator=(const Uri& rhs)
{
   if (this != &rhs)
   {
      ParserCategory::operator=(rhs);
      mScheme = rhs.mScheme;
      mHost = rhs.mHost;
      mPath = rhs.mPath;
      mHostCanonicalized = rhs.mHostCanonicalized;
      mCanonicalHost = rhs.mCanonicalHost;
      mUser = rhs.mUser;
      if (rhs.mUserRaw)
      {
         mUserRaw.reset(new Data(*rhs.mUserRaw));
      }
      else
      {
         mUserRaw.reset();
      }
      mUserParameters = rhs.mUserParameters;
      mPort = rhs.mPort;
      mPassword = rhs.mPassword;
      mNetNs = rhs.mNetNs;
      if (rhs.mEmbeddedHeaders.get() != 0)
      {
         mEmbeddedHeaders.reset(new SipMessage(*rhs.mEmbeddedHeaders));
      }
      else if(rhs.mEmbeddedHeadersText.get() != 0)
      {
         if(!mEmbeddedHeadersText.get())
         {
            mEmbeddedHeadersText.reset(new Data(*rhs.mEmbeddedHeadersText));
         }
         else
         {
            // !bwc! Data::operator= is smart enough to handle this safely.
            *mEmbeddedHeadersText = *rhs.mEmbeddedHeadersText;
         }
      }
   }
   return *this;
}
 
class OrderUnknownParameters
{
   public:
      OrderUnknownParameters() { notUsed=false; };
 
      ~OrderUnknownParameters() {};
 
      bool operator()(const Parameter* p1, const Parameter* p2) const
      {
         return dynamic_cast<const UnknownParameter*>(p1)->getName() < dynamic_cast<const UnknownParameter*>(p2)->getName();
      }
 
   private:
      bool notUsed;
};
 
bool Uri::compareUriParametersEqual(Parameter* param1, Parameter* param2)
{
   if (!param1 || !param2)
   {
      return false;
   }
 
   switch (param1->getType()) {
      case ParameterTypes::user:
      case ParameterTypes::method:
      case ParameterTypes::maddr:
      case ParameterTypes::transport:
      case ParameterTypes::rinstance:
      case ParameterTypes::comp:
      case ParameterTypes::extension:
      case ParameterTypes::wsSrcIp:
      case ParameterTypes::sigcompId:
         return isEqualNoCase(dynamic_cast<DataParameter*>(param1)->value(),
                              dynamic_cast<DataParameter*>(param2)->value());
 
      case ParameterTypes::ttl:
      case ParameterTypes::duration:
      case ParameterTypes::wsSrcPort:
         return dynamic_cast<UInt32Parameter*>(param1)->value() ==
                dynamic_cast<UInt32Parameter*>(param2)->value();
 
      case ParameterTypes::gr:
         return isEqualNoCase(dynamic_cast<ExistsOrDataParameter*>(param1)->value(),
                              dynamic_cast<ExistsOrDataParameter*>(param2)->value());
 
      case ParameterTypes::lr:
      case ParameterTypes::ob:
         // Exists parameters are equal.
         return true;
 
      default:
         // Other parameters are not considered.
         // Parameters may be added accordingly to RFCs.
         return true;
   }
}
 
bool Uri::compareUriParametersLessThan(Parameter* param1, Parameter* param2)
{
   if (!param1 || !param2)
   {
      return false;
   }
 
   switch (param1->getType()) {
      case ParameterTypes::user:
      case ParameterTypes::method:
      case ParameterTypes::maddr:
      case ParameterTypes::transport:
      case ParameterTypes::rinstance:
      case ParameterTypes::comp:
      case ParameterTypes::extension:
      case ParameterTypes::wsSrcIp:
      case ParameterTypes::sigcompId:
         return isLessThanNoCase(dynamic_cast<DataParameter*>(param1)->value(),
                                 dynamic_cast<DataParameter*>(param2)->value());
 
      case ParameterTypes::ttl:
      case ParameterTypes::duration:
      case ParameterTypes::wsSrcPort:
         return dynamic_cast<UInt32Parameter*>(param1)->value() <
                dynamic_cast<UInt32Parameter*>(param2)->value();
 
      case ParameterTypes::gr:
         return isLessThanNoCase(dynamic_cast<ExistsOrDataParameter*>(param1)->value(),
                                 dynamic_cast<ExistsOrDataParameter*>(param2)->value());
 
      case ParameterTypes::lr:
      case ParameterTypes::ob:
         // Exists parameters are equal.
         return false;
 
      default:
         // Other parameters are not considered.
         // Parameters may be added accordingly to RFCs.
         return false;
   }
}
 
bool Uri::isSignificantUriParameter(const ParameterTypes::Type type) noexcept
{
   return type == ParameterTypes::user ||
          type == ParameterTypes::ttl ||
          type == ParameterTypes::method ||
          type == ParameterTypes::maddr ||
          type == ParameterTypes::transport;
}
 
bool Uri::isUserRelevant() const
{
   checkParsed();
   return isEqualNoCase(mScheme, Symbols::Sip) ||
          isEqualNoCase(mScheme, Symbols::Sips) ||
          isEqualNoCase(mScheme, Symbols::Tel);
}
 
bool
Uri::operator==(const Uri& other) const
{
   checkParsed();
   other.checkParsed();
 
   // compare hosts
   if (DnsUtil::isIpV6Address(mHost) &&
       DnsUtil::isIpV6Address(other.mHost))
   {
      // compare canonicalized IPV6 addresses
 
      // update canonicalized if host changed
      if (!mHostCanonicalized)
      {
         mCanonicalHost = DnsUtil::canonicalizeIpV6Address(mHost);
         mHostCanonicalized=true;
      }
 
      // update canonicalized if host changed
      if (!other.mHostCanonicalized)
      {
         other.mCanonicalHost = DnsUtil::canonicalizeIpV6Address(other.mHost);
         other.mHostCanonicalized=true;
      }
 
      if (mCanonicalHost != other.mCanonicalHost)
      {
         return false;
      }
   }
   else
   {
      if (!isEqualNoCase(mHost, other.mHost))
      {
         return false;
      }
   }
   
   // Case-sensitive user comparison for:
   // - sip:/sips: per RFC 3261 sec 19.1.4.
   // - urn: because the NID (case-insensitive per RFC 8141) is already
   //   normalized to lowercase by Uri::parse() (see comment there), so a
   //   plain compare here is correct: NID case differences have already
   //   been folded away, and NSS case is preserved and compared as-is.
   //   Known deviation: mUser also holds any rq-components/fragment
   //   (see the comment in Uri::parse()'s urn branch), which RFC 8141
   //   sec 3.1 explicitly excludes from URN equivalence -- so here
   //   "urn:example:nss?+rcomponent" != "urn:example:nss", where the RFC
   //   would consider them equivalent. Acceptable for SIP routing
   //   purposes (this is the same granularity used to compare the
   //   sip:/sips: user part above), but not a strict RFC 8141 comparison.
   // Every other scheme defaults to case-insensitive.
   bool userEqual;
   if (isEqualNoCase(mScheme, Symbols::Sip) || isEqualNoCase(mScheme, Symbols::Sips) ||
       isEqualNoCase(mScheme, Symbols::Urn))
   {
      userEqual = (mUser == other.mUser);
   }
   else
   {
      userEqual = isEqualNoCase(mUser, other.mUser);
   }
 
   if (isEqualNoCase(mScheme, other.mScheme) &&
       userEqual &&
       isEqualNoCase(mUserParameters,other.mUserParameters) &&
       mPassword == other.mPassword &&
       mPort == other.mPort &&
       mNetNs == other.mNetNs &&
       mPath == mPath)
   {
      for (ParameterList::const_iterator it = mParameters.begin(); it != mParameters.end(); ++it)
      {
         Parameter* otherParam = other.getParameterByEnum((*it)->getType());
 
         if (Uri::isSignificantUriParameter((*it)->getType()) || otherParam)
         {
            if (!Uri::compareUriParametersEqual(*it, otherParam))
            {
               return false;
            }
         }
      }         
 
      // now check the other way, sigh
      for (ParameterList::const_iterator it = other.mParameters.begin(); it != other.mParameters.end(); ++it)
      {
         Parameter* param = getParameterByEnum((*it)->getType());
 
         if (Uri::isSignificantUriParameter((*it)->getType()) || param)
         {
            if (!Uri::compareUriParametersEqual(*it, param))
            {
               return false;
            }
         }
      }
   }
   else
   {
      return false;
   }
 
   OrderUnknownParameters orderUnknown;
 
#if defined(__SUNPRO_CC) || defined(WIN32) || defined(__sun__)
   // The Solaris Forte STL implementation does not support the
   // notion of a list.sort() function taking a BinaryPredicate.
   // The hacky workaround is to load the Parameter pointers into
   // an STL set which does support an ordering function.
 
   typedef std::set<Parameter*, OrderUnknownParameters> ParameterSet;
   ParameterSet unA, unB;
 
   for (ParameterList::const_iterator i = mUnknownParameters.begin();
        i != mUnknownParameters.end(); ++i)
   {
      unA.insert(*i);
   }
   for (ParameterList::const_iterator i = other.mUnknownParameters.begin();
        i != other.mUnknownParameters.end(); ++i)
   {
      unB.insert(*i);
   }
 
   ParameterSet::iterator a = unA.begin();
   ParameterSet::iterator b = unB.begin();
#else
   // .dlb. more efficient to copy to vector for sorting?
   // Uri comparison is expensive; consider caching? ugh
   ParameterList unA = mUnknownParameters;
   ParameterList unB = other.mUnknownParameters;
 
   sort(unA.begin(), unA.end(), orderUnknown);
   sort(unB.begin(), unB.end(), orderUnknown);
 
   ParameterList::iterator a = unA.begin();
   ParameterList::iterator b = unB.begin();
#endif
 
   while(a != unA.end() && b != unB.end())
   {
      if (orderUnknown(*a, *b))
      {
         ++a;
      }
      else if (orderUnknown(*b, *a))
      {
         ++b;
      }
      else
      {
         if (!isEqualNoCase(dynamic_cast<UnknownParameter*>(*a)->value(),
                            dynamic_cast<UnknownParameter*>(*b)->value()))
         {
            return false;
         }
         ++a;
         ++b;
      }
   }
   return true;
}
 
bool 
Uri::operator!=(const Uri& other) const
{
   return !(*this == other);
}
 
bool
Uri::operator<(const Uri& other) const
{
   other.checkParsed();
   checkParsed();
   if (mUser < other.mUser)
   {
      return true;
   }
 
   if (mUser > other.mUser)
   {
      return false;
   }
 
   if (mUserParameters < other.mUserParameters)
   {
      return true;
   }
 
   if (mUserParameters > other.mUserParameters)
   {
      return false;
   }
 
   // !bwc! Canonicalize before we compare! Jeez...
   if (!mHostCanonicalized)
   {
      if(DnsUtil::isIpV6Address(mHost))
      {
         mCanonicalHost = DnsUtil::canonicalizeIpV6Address(mHost);
      }
      else
      {
         mCanonicalHost = mHost;
         mCanonicalHost.lowercase();
      }
      mHostCanonicalized=true;
   }
   
   if (!other.mHostCanonicalized)
   {
      if(DnsUtil::isIpV6Address(other.mHost))
      {
         other.mCanonicalHost = DnsUtil::canonicalizeIpV6Address(other.mHost);
      }
      else
      {
         other.mCanonicalHost = other.mHost;
         other.mCanonicalHost.lowercase();
      }
      other.mHostCanonicalized=true;
   }
 
   if (mCanonicalHost < other.mCanonicalHost)
   {
      return true;
   }
 
   if (mCanonicalHost > other.mCanonicalHost)
   {
      return false;
   }
 
   if (mPort < other.mPort)
   {
      return true;
   }
 
   if (mPort > other.mPort)
   {
      return false;
   }
 
   for (ParameterList::const_iterator it = mParameters.begin(); it != mParameters.end(); ++it)
      {
         Parameter* otherParam = other.getParameterByEnum((*it)->getType());
 
         if (otherParam)
         {
            if (Uri::compareUriParametersLessThan(*it, otherParam)) {
               return true;
            }
 
            if (Uri::compareUriParametersLessThan(otherParam, *it)) {
               return false;
            }
         }
         else if (Uri::isSignificantUriParameter((*it)->getType()))
         {
            return true;  // Significant URI params should not be ignored.
         }
      }
 
   // Sort unknown parameters from both URIs by their name using comparator class.
   OrderUnknownParameters orderUnknown;
 
#if defined(__SUNPRO_CC) || defined(WIN32) || defined(__sun__)
   // The Solaris Forte STL implementation does not support the
   // notion of a list.sort() function taking a BinaryPredicate.
   // The hacky workaround is to load the Parameter pointers into
   // an STL set which does support an ordering function.
 
   typedef std::set<Parameter*, OrderUnknownParameters> ParameterSet;
   ParameterSet thisUriParamList, otherUriParamList;
 
   for (ParameterList::const_iterator i = mUnknownParameters.begin();
        i != mUnknownParameters.end(); ++i)
   {
      thisUriParamList.insert(*i);
   }
   for (ParameterList::const_iterator i = other.mUnknownParameters.begin();
        i != other.mUnknownParameters.end(); ++i)
   {
      otherUriParamList.insert(*i);
   }
#else
   ParameterList thisUriParamList = mUnknownParameters;
   ParameterList otherUriParamList = other.mUnknownParameters;
 
   sort(thisUriParamList.begin(), thisUriParamList.end(), orderUnknown);
   sort(otherUriParamList.begin(), otherUriParamList.end(), orderUnknown);
#endif
 
   auto thisUriParam = thisUriParamList.begin();
   auto otherUriParam = otherUriParamList.begin();
 
   // Iterate through unknown parameters of both URIs.
   // Advance iterators to compare values of parameters with matching names.
   while(thisUriParam != thisUriParamList.end() && otherUriParam != otherUriParamList.end())
   {
      if (orderUnknown(*thisUriParam, *otherUriParam))
      {
         // this < other param name.
         ++thisUriParam;
      }
      else if (orderUnknown(*otherUriParam, *thisUriParam))
      {
         // other < this param name.
         ++otherUriParam;
      }
      else
      {
         // this == other param name.
         // Unknown parameter names are the same. Compare their values.
         const Data& thisParamValue = dynamic_cast<UnknownParameter*>(*thisUriParam)->value();
         const Data& otherParamValue = dynamic_cast<UnknownParameter*>(*otherUriParam)->value();
 
         if (isLessThanNoCase(thisParamValue,
                              otherParamValue))
         {
            return true;
         }
 
         if (isLessThanNoCase(otherParamValue,
                              thisParamValue))
         {
            return false;
         }
 
         // Move iterators to the next position.
         ++thisUriParam;
         ++otherUriParam;
      }
   }
 
   return false;
}
 
bool
Uri::aorEqual(const resip::Uri& rhs) const
{
   checkParsed();
   rhs.checkParsed();
 
   if (!mHostCanonicalized)
   {
      if(DnsUtil::isIpV6Address(mHost))
      {
         mCanonicalHost = DnsUtil::canonicalizeIpV6Address(mHost);
      }
      else
      {
         mCanonicalHost = mHost;
         mCanonicalHost.lowercase();
      }
      mHostCanonicalized=true;
   }
   
   if (!rhs.mHostCanonicalized)
   {
      if(DnsUtil::isIpV6Address(rhs.mHost))
      {
         rhs.mCanonicalHost = DnsUtil::canonicalizeIpV6Address(rhs.mHost);
      }
      else
      {
         rhs.mCanonicalHost = rhs.mHost;
         rhs.mCanonicalHost.lowercase();
      }
      rhs.mHostCanonicalized=true;
   }
   
   return (mUser == rhs.mUser) && (mCanonicalHost == rhs.mCanonicalHost) && (mPort == rhs.mPort) &&
           isEqualNoCase(mScheme, rhs.mScheme) && (mNetNs == rhs.mNetNs);
}
 
void 
Uri::getAorInternal(bool dropScheme, bool addPort, Data& aor) const
{
   // The AOR is an identity/lookup key, so the user part is intentionally
   // emitted in canonical (table-escaped) form and is NOT preserved verbatim
   // the way encodeParsed()/getAorAsUri() preserve the sender's mUserRaw.
   // Canonicalizing here keeps the key stable regardless of how a sender
   // escaped it (e.g. "%23" vs a literal '#'), which matters because
   // getAorNoPort() feeds auth key comparisons (DigestAuthenticator, etc.)
   // and the registration DB is keyed on this form. Do not change this to
   // preserve mUserRaw without auditing those key/identity paths.
   checkParsed();
   // canonicalize host
 
   addPort = addPort && mPort!=0;
 
   bool hostIsIpV6Address = DnsUtil::isIpV6Address(mHost);
   if(!mHostCanonicalized)
   {
      if (hostIsIpV6Address)
      {
         mCanonicalHost = DnsUtil::canonicalizeIpV6Address(mHost);
      }
      else
      {
         mCanonicalHost = mHost;
         mCanonicalHost.lowercase();
      }
      mHostCanonicalized = true;
   }
 
   // !bwc! Maybe reintroduce caching of aor. (Would use a bool instead of the
   // mOldX cruft)
   //                                                  @:10000
   aor.clear();
   aor.reserve((dropScheme ? 0 : mScheme.size()+1)
       + mUser.size() + mCanonicalHost.size() + 7);
   if(!dropScheme)
   {
      aor += mScheme;
      aor += ':';
   }
 
   if (!mUser.empty())
   {
#ifdef HANDLE_CHARACTER_ESCAPING
      {
         oDataStream str(aor);
         if (isEqualNoCase(mScheme, Symbols::Urn))
         {
            mUser.escapeToStream(str, getUrnEncodingTable());
         }
         else
         {
            mUser.escapeToStream(str, getUserEncodingTable());
         }
      }
#else
      aor += mUser;
#endif
      if(!mCanonicalHost.empty())
      {
         aor += Symbols::AT_SIGN;
      }
   }
 
   if(hostIsIpV6Address && addPort)
   {
      aor += Symbols::LS_BRACKET;
      aor += mCanonicalHost;
      aor += Symbols::RS_BRACKET;
   }
   else
   {
      aor += mCanonicalHost;
   }
 
   if(addPort)
   {
      aor += Symbols::COLON;
      aor += Data(mPort);
   }
}
 
Data 
Uri::getAOR(bool addPort) const
{
   Data result;
   getAorInternal(false, addPort, result);
   return result;
}
 
bool 
Uri::userIsTelephoneSubscriber() const
{
   try
   {
      ParseBuffer pb(mUser);
      pb.assertNotEof();
      const char* anchor=pb.position();
      bool local=false;
      if(*pb.position()=='+')
      {
         // Might be a global phone number
         pb.skipChar();
         pb.skipChars(getGlobalNumberTable());
      }
      else
      {
         pb.skipChars(getLocalNumberTable());
         local=true;
      }
 
      Data dialString(pb.data(anchor));
      if(dialString.empty())
      {
         pb.fail(__FILE__, __LINE__, "Dial string is empty.");
      }
 
      // ?bwc? More dial-string checking? For instance, +/ (or simply /) is not 
      // a valid dial-string according to the BNF; the string must contain at 
      // least one actual digit (or in the local number case, one hex digit or 
      // '*' or '#'. Interestingly, this means that stuff like ///*/// is 
      // valid)
 
      // Dial string looks ok so far; now look for params (there must be a 
      // phone-context param if this is a local number, otherwise there might 
      // or might not be one)
      if(local || !pb.eof())
      {
         // The only thing that can be here is a ';'. If it does, we're going 
         // to say it is good enough for us. If something in the parameter 
         // string is malformed, it'll get caught when/if 
         // getUserAsTelephoneSubscriber() is called.
         pb.skipChar(';');
      }
 
      return true;
   }
   catch(ParseException& /*e*/)
   {
      return false;
   }
}
 
Token 
Uri::getUserAsTelephoneSubscriber() const
{
   // !bwc! Ugly. Someday, refactor all this lazy-parser stuff and make it 
   // possible to control ownership explicitly.
   // Set this up as lazy-parsed, to prevent exceptions from being thrown.
   HeaderFieldValue temp(mUser.data(), mUser.size());
   Token tempToken(temp, Headers::NONE);
   // tempToken does not own the HeaderFieldValue temp, and temp does not own 
   // its buffer.
 
   // Here's the voodoo; invoking operator= makes a deep copy of the stuff in
   // tempToken, with result owning the memory, and result is in the unparsed 
   // state.
   Token result = tempToken;
   return result;
}
 
void 
Uri::setUserAsTelephoneSubscriber(const Token& telephoneSubscriber)
{
   mUser.clear();
   oDataStream str(mUser);
   str << telephoneSubscriber;
   mUserRaw.reset();
}
 
Data
Uri::getAorNoPort() const
{
   Data result;
   getAorInternal(true, false, result);
   return result;
}
 
Data
Uri::getAor() const
{
   Data result;
   getAorInternal(true, true, result);
   return result;
}
 
Uri 
Uri::getAorAsUri(TransportType transportTypeToRemoveDefaultPort) const
{   
   //.dcm. -- tel conversion?
   checkParsed();
   Uri ret;
   ret.scheme() = mScheme;
   ret.user() = mUser;
   // Carry the as-received user bytes so a derived URI that reaches the wire
   // (e.g. a Route built from the AOR) preserves the sender's escaping too.
   if (mUserRaw)
   {
      ret.mUserRaw.reset(new Data(*mUserRaw));
   }
   ret.host() = mHost;
 
   // Remove any default ports (if required)
   if(transportTypeToRemoveDefaultPort == UDP || 
       transportTypeToRemoveDefaultPort == TCP)
   {
      if(mPort != Symbols::DefaultSipPort)
      {
         ret.port() = mPort;
      }
   }
   else if (transportTypeToRemoveDefaultPort == TLS || 
            transportTypeToRemoveDefaultPort == DTLS)
   {
      if(mPort != Symbols::DefaultSipsPort)
      {
         ret.port() = mPort;
      }
   }
   else
   {
      ret.port() = mPort;
   }
 
   return ret;
}
 
#ifdef HANDLE_CHARACTER_ESCAPING
// Decodes [start, pb.position()) into `user`, capturing the as-received
// bytes into `userRaw` (only if a '%' escape is present) so encodeParsed()
// can re-emit them verbatim instead of losing the sender's original
// escaping. Shared by the sip:/sips: and urn: user-parsing below -- both
// need the exact same "scan for '%', then dataUnescaped" dance.
static void
decodeUserPreservingEscapes(ParseBuffer& pb, const char* start,
                             Data& user, std::unique_ptr<Data>& userRaw)
{
   const char* userEnd = pb.position();
   bool userHasEscape = false;
   for (const char* p = start; p < userEnd; ++p)
   {
      if (*p == Symbols::PERCENT[0])
      {
         userHasEscape = true;
         break;
      }
   }
   pb.dataUnescaped(user, start);
   // Capture the as-received bytes only after the decode succeeds -- it can
   // throw on a malformed escape, and userRaw must never hold bytes that
   // fail to decode, so the encode-path re-decode cannot throw. userRaw
   // then always decodes back to the user just produced.
   if (userHasEscape)
   {
      userRaw.reset(new Data(start, (Data::size_type)(userEnd - start)));
   }
}
#endif
 
void
Uri::parse(ParseBuffer& pb)
{
   pb.skipWhitespace();
   const char* start = pb.position();
 
   // Cleared up front so a path that sets no user part leaves no stale raw.
   mUserRaw.reset();
 
   // Relative URLs (typically HTTP) start with a slash.  These
   // are seen when parsing the WebSocket handshake.
   if (*pb.position() == Symbols::SLASH[0])
   {
      mScheme.clear();
      pb.skipToOneOf("?;", ParseBuffer::Whitespace);
      pb.data(mPath, start);
      if (!pb.eof() && !ParseBuffer::oneOf(*pb.position(), ParseBuffer::Whitespace))
      {
         parseParameters(pb);
      }
      return;
   }
 
   pb.skipToOneOf(":@");
 
   pb.assertNotEof();
 
   pb.data(mScheme, start);
   pb.skipChar(Symbols::COLON[0]);
   mScheme.schemeLowercase();
 
   // NID:NSS plus any rq-components ("?+"/"?=") and fragment ("#") is
   // captured as one opaque blob in mUser; no mUserParameters equivalent
   // (RFC 8141 has none).
   if (mScheme==Symbols::Urn)
   {
      const char* anchor = pb.position();
      if (mIsBetweenAngleQuotes)
      {
         // Inside "<...>" the only terminator is '>' (SIP requires angle
         // brackets exactly to avoid ';'/'?'/',' clashing with NameAddr
         // params -- RFC 3261 sec 20 -- so within brackets those chars are
         // legal NSS content and must not be treated as delimiters).
         static std::bitset<256> delimiter=Data::toBitset("\r\n\t >");
         pb.skipToOneOf(delimiter);
      }
      else if (mIsBareAddrSpec)
      {
         // Bare (unbracketed) URI inside a header value (e.g. To/From
         // without "<...>"), flagged by NameAddr::parse(): stop at
         // ';'/'?'/',' too, since NameAddr parameters (";tag=...") may
         // follow directly and RFC 8141 gives no way to tell them apart
         // from NSS content here. Per RFC 3261 sec 20, a producer whose
         // NSS needs these characters must use "<...>" instead, where the
         // permissive rule above still applies.
         static std::bitset<256> delimiter=Data::toBitset("\r\n\t ;?,");
         pb.skipToOneOf(delimiter);
      }
      else
      {
         // Every other context: a Request-URI (RequestLine, never
         // bracketed but with nothing that can follow except whitespace
         // then SIP-Version), a standalone Uri built directly from a
         // string, or any other direct caller. ';'/'?'/',' here are legal
         // NSS content, same as the bracketed case above.
         pb.skipToOneOf(ParseBuffer::Whitespace);
      }
#ifdef HANDLE_CHARACTER_ESCAPING
      // Decode %XX so user() returns the logical value, as for sip:/sips:.
      // But '#'/'?' are structural when unescaped (fragment/rq-components),
      // so a received "%23"/"%3F" (escaped data) and a literal "#"/"?"
      // (real separator) must not collapse to the same mUser and then
      // re-encode with the wrong form -- decodeUserPreservingEscapes()
      // keeps the as-received bytes in mUserRaw for that case.
      decodeUserPreservingEscapes(pb, anchor, mUser, mUserRaw);
#else
      pb.data(mUser, anchor);
#endif
      // RFC 8141 sec 2: NID = alphanum *(alphanum/"-") alphanum, 2-32
      // chars, and the NSS must be non-empty; sec 5.1: the NID must not be
      // "urn" itself (nonsensical/reserved). Reject anything else here so
      // a malformed urn: fails to parse instead of silently reaching the
      // application (e.g. DUM) looking like a well-formed one.
      const Data::size_type sep = mUser.find(Symbols::COLON);
      if (sep == Data::npos)
      {
         pb.fail(__FILE__, __LINE__, "urn: missing NID:NSS separator.");
      }
      if (sep < 2 || sep > 32)
      {
         pb.fail(__FILE__, __LINE__, "urn: NID must be 2-32 characters.");
      }
      for (Data::size_type i = 0; i < sep; ++i)
      {
         const unsigned char c = (unsigned char)mUser[i];
         // Explicit ASCII range, not isalnum(): RFC 8141's NID ABNF is
         // ASCII-only, but isalnum() follows the process-wide C locale,
         // so a non-C locale (common in embedded/softswitch apps that
         // call setlocale() for logging/i18n) would accept 8-bit
         // characters here that RFC 8141 does not allow.
         const bool isAsciiAlnum = (c >= '0' && c <= '9') ||
                                   (c >= 'A' && c <= 'Z') ||
                                   (c >= 'a' && c <= 'z');
         if (!isAsciiAlnum && !(c == '-' && i > 0 && i < sep - 1))
         {
            pb.fail(__FILE__, __LINE__, "urn: NID has an invalid character.");
         }
      }
      if (sep + 1 >= mUser.size())
      {
         pb.fail(__FILE__, __LINE__, "urn: NSS must not be empty.");
      }
      if (isEqualNoCase(mUser.substr(0, sep), Symbols::Urn))
      {
         pb.fail(__FILE__, __LINE__, "urn: NID must not be \"urn\".");
      }
 
      // RFC 8141 sec 2.2: the NID is case-insensitive. Normalize it to
      // lowercase here, the same way schemeLowercase() already normalizes
      // the scheme, so operator==, operator<, the hash function and
      // getAorInternal() all agree on urn: equality without needing a
      // urn-specific comparator.
      // NB: this only runs at parse() time, so a hand-built Uri (user()
      // set directly) is not validated/normalized -- same accepted
      // limitation as the scheme case-sensitivity noted on
      // getAorInternal()/encodeParsed().
      {
         Data nid(mUser.substr(0, sep));
         nid.lowercase();
         mUser = nid + mUser.substr(sep);
      }
      // mUserRaw is deliberately left untouched (still the exact bytes
      // received): the validation above runs on the decoded mUser, so a
      // NID could in principle hide a gratuitous, unnecessary %-escape
      // (e.g. "urn:EX%41MPLE:nss") that isn't reflected at the same byte
      // offset in mUserRaw -- rewriting mUserRaw's NID prefix in place,
      // like above, would silently corrupt it in that case. Leaving it
      // untouched is simpler and always correct: encodeParsed()'s
      // decodedUserRaw==mUser check already re-decodes mUserRaw and falls
      // back to escaping mUser fresh whenever they no longer match (e.g.
      // because of this normalization step here), which is exactly the
      // desired outcome whenever the NID's original casing has changed.
      return;
   }
 
   if (mScheme==Symbols::Tel)
   {
      const char* anchor = pb.position();
      static std::bitset<256> delimiter=Data::toBitset("\r\n\t ;>");
      pb.skipToOneOf(delimiter);
      pb.data(mUser, anchor);
      if (!pb.eof() && *pb.position() == Symbols::SEMI_COLON[0])
      {
         anchor = pb.skipChar();
         pb.skipToOneOf(ParseBuffer::Whitespace, Symbols::RA_QUOTE);
         pb.data(mUserParameters, anchor);
      }
      return;
   }
   
   start = pb.position();
   static std::bitset<256> userPortOrPasswordDelim(Data::toBitset("@:\""));
   // stop at double-quote to prevent matching an '@' in a quoted string param. 
   pb.skipToOneOf(userPortOrPasswordDelim);
   if (!pb.eof())
   {
      const char* atSign=0;
      if (*pb.position() == Symbols::COLON[0])
      {
         // Either a password, or a port
         const char* afterColon = pb.skipChar();
         pb.skipToOneOf("@\"");
         if(!pb.eof() && *pb.position() == Symbols::AT_SIGN[0])
         {
            atSign=pb.position();
            // password
#ifdef HANDLE_CHARACTER_ESCAPING
            pb.dataUnescaped(mPassword, afterColon);
#else
            pb.data(mPassword, afterColon);
#endif
            pb.reset(afterColon-1);
         }
         else
         {
            // port. No user part.
            pb.reset(start);
         }
      }
      else if(*pb.position() == Symbols::AT_SIGN[0])
      {
         atSign=pb.position();
      }
      else
      {
         // Only a hostpart
         pb.reset(start);
      }
 
      if(atSign)
      {
#ifdef HANDLE_CHARACTER_ESCAPING
         // The range dataUnescaped decodes here is exactly [start, position),
         // i.e. up to ':' before a password, else '@' -- decodeUserPreservingEscapes()
         // scans it for an escape and keeps the as-received bytes in mUserRaw.
         decodeUserPreservingEscapes(pb, start, mUser, mUserRaw);
#else
         pb.data(mUser, start);
#endif
         pb.reset(atSign);
         start = pb.skipChar();
      }
   }
   else
   {
      pb.reset(start);
   }
 
   if (pb.eof())
   {
      return;
   }
 
   mHostCanonicalized=false;
   static std::bitset<256> hostDelimiter(Data::toBitset("\r\n\t :;?>"));
   if (*start == '[')
   {
      start = pb.skipChar();
      pb.skipToChar(']');
      pb.data(mHost, start);
      mCanonicalHost = DnsUtil::canonicalizeIpV6Address(mHost);
      if (mCanonicalHost.empty())
      {
         // .bwc. So the V6 addy is garbage.
         throw ParseException("Unparsable V6 address (note, this might"
                                    " be unparsable because IPV6 support is not"
                                    " enabled)","Uri",__FILE__,
                                       __LINE__);
      }
      mHostCanonicalized = true;
      pb.skipChar();
      pb.skipToOneOf(hostDelimiter);
   }
   else
   {
      pb.skipToOneOf(hostDelimiter);
      pb.data(mHost, start);
   }
 
   if (!pb.eof() && *pb.position() == ':')
   {
      start = pb.skipChar();
      mPort = pb.uInt32();
   }
   else
   {
      mPort = 0;
   }
 
   parseParameters(pb);
 
   if (!pb.eof() && *pb.position() == Symbols::QUESTION[0])
   {
      const char* anchor = pb.position();
 
      if (mIsBetweenAngleQuotes)
      {
         // Embedded headers will either end at the angle bracket (when Uri is in a NameAddr that uses angle 
         // brackets) or at a semi-colon (when Uri is in a NameAddr that doesn't use angle brackets and has 
         // NameAddr parameters following the embedded headers), or in Whitespace.
         // We used to just look for either of the 3 terminators, however to be more tolerant of endpoints 
         // that do not properly escape ;'s in the embedded headers, we relax the rules, only when the uri
         // falls between angle quotes/brackets - in this case we will allow non-escaped semi-colons by only
         // looking for > and whitespace as a terminator.
         pb.skipToOneOf(">", ParseBuffer::Whitespace);
      }
      else
      {
         pb.skipToOneOf(">;", ParseBuffer::Whitespace);
      }
 
      if(!mEmbeddedHeadersText.get()) mEmbeddedHeadersText.reset(new Data);
      pb.data(*mEmbeddedHeadersText, anchor);
   }
}
 
ParserCategory*
Uri::clone() const
{
   return new Uri(*this);
}
 
ParserCategory*
Uri::clone(void* location) const
{
   return new (location) Uri(*this);
}
 
ParserCategory*
Uri::clone(PoolBase* pool) const
{
   return new (pool) Uri(*this);
}
 
void Uri::setUriUserEncoding(unsigned char c, bool encode) 
{
   getUserEncodingTable()[c] = encode; 
}
 
void Uri::setUriPasswordEncoding(unsigned char c, bool encode)
{
   getPasswordEncodingTable()[c] = encode;
}
 
void Uri::setUriUrnEncoding(unsigned char c, bool encode)
{
   getUrnEncodingTable()[c] = encode;
}
 
// should not encode user parameters unless its a tel?
EncodeStream& 
Uri::encodeParsed(EncodeStream& str) const
{
   // Relative URIs may not have the scheme
   if (!mScheme.empty())
   {
      str << mScheme << Symbols::COLON;
   }
 
   if (!mUser.empty())
   {
#ifdef HANDLE_CHARACTER_ESCAPING
      // urn: uses its own table (doesn't escape ':', '@', ';', '?', '#',
      // sub-delims -- RFC 8141); every other scheme uses the sip:/sips:
      // user table.
      const EncodingTable& table = isEqualNoCase(mScheme, Symbols::Urn)
         ? getUrnEncodingTable() : getUserEncodingTable();
      if (mUserRaw)
      {
         // Emit the as-received bytes verbatim while they still decode (via the
         // same dataUnescaped as parse) to the current mUser, so the sender's
         // escaping (e.g. %23) survives regardless of the encoding table; a
         // post-parse edit breaks the match and falls back to table escaping.
         // Cost: re-decodes and compares on the encode path for every
         // %-containing user part (inline Data buffer avoids a heap alloc for
         // short values; unescaped users skip this branch).
         Data decodedUserRaw;
         ParseBuffer pb(mUserRaw->data(), mUserRaw->size());
         const char* anchor = pb.position();
         pb.skipToEnd();
         pb.dataUnescaped(decodedUserRaw, anchor);
         if (decodedUserRaw == mUser)
         {
            str << *mUserRaw;
         }
         else
         {
            mUser.escapeToStream(str, table);
         }
      }
      else
      {
         mUser.escapeToStream(str, table);
      }
#else
      str << mUser;
#endif
      if (!mUserParameters.empty())
      {
         str << Symbols::SEMI_COLON[0] << mUserParameters;
      }
      if (!mPassword.empty())
      {
         str << Symbols::COLON;
#ifdef HANDLE_CHARACTER_ESCAPING
         mPassword.escapeToStream(str, getPasswordEncodingTable());
#else
         str << mPassword;
#endif
      }
   }
   if (!mHost.empty())
   {
     if (!mUser.empty())
     {
       str << Symbols::AT_SIGN;
     }
     if (DnsUtil::isIpV6Address(mHost))
     {
        str << '[' << mHost << ']';
     }
     else
     {
        str << mHost;
     }
   }
   if (mPort != 0)
   {
      str << Symbols::COLON << mPort;
   }
   if (!mPath.empty())
   {
      str << mPath;
   }
   encodeParameters(str);
   encodeEmbeddedHeaders(str);
 
   return str;
}
 
SipMessage&
Uri::embedded()
{
   checkParsed();
   if (mEmbeddedHeaders.get() == 0)
   {
      this->mEmbeddedHeaders.reset(new SipMessage());
      if (mEmbeddedHeadersText.get() && !mEmbeddedHeadersText->empty())
      {
         ParseBuffer pb(mEmbeddedHeadersText->data(), mEmbeddedHeadersText->size());
         this->parseEmbeddedHeaders(pb);
      }
   }
 
   return *mEmbeddedHeaders;
}
 
const SipMessage&
Uri::embedded() const
{
   Uri* ncthis = const_cast<Uri*>(this);
   return ncthis->embedded();
}
 
static const Data bodyData("Body");
void
Uri::parseEmbeddedHeaders(ParseBuffer& pb)
{
   DebugLog(<< "Uri::parseEmbeddedHeaders");
   if (!pb.eof() && *pb.position() == Symbols::QUESTION[0])
   {
      pb.skipChar();
   }
 
   const char* anchor;
   Data headerName;
   Data headerContents;
 
   bool first = true;
   while (!pb.eof())
   {
      if (first)
      {
         first = false;
      }
      else
      {
         pb.skipChar(Symbols::AMPERSAND[0]);
      }
 
      anchor = pb.position();
      pb.skipToChar(Symbols::EQUALS[0]);
      pb.data(headerName, anchor);
      // .dlb. in theory, need to decode header name
 
      anchor = pb.skipChar(Symbols::EQUALS[0]);
      pb.skipToChar(Symbols::AMPERSAND[0]);
      pb.data(headerContents, anchor);
 
      unsigned int len;
      char* decodedContents = Embedded::decode(headerContents, len);
      mEmbeddedHeaders->addBuffer(decodedContents);
 
      if (isEqualNoCase(bodyData, headerName))
      {
         mEmbeddedHeaders->setBody(decodedContents, len);
      }
      else
      {
         DebugLog(<< "Uri::parseEmbeddedHeaders(" << headerName << ", " << Data(decodedContents, len) << ")");
         mEmbeddedHeaders->addHeader(Headers::getType(headerName.data(), headerName.size()),
                                     headerName.data(), static_cast<uint32_t>(headerName.size()),
                                     decodedContents, len);
      }
   }
}
 
EncodeStream& 
Uri::encodeEmbeddedHeaders(EncodeStream& str) const
{
   if (mEmbeddedHeaders.get())
   {
      mEmbeddedHeaders->encodeEmbedded(str);
   }
   else if(mEmbeddedHeadersText.get())
   {
      // never decoded
      str << *mEmbeddedHeadersText;
   }
   return str;
}
 
Data 
Uri::toString() const
{
   Data out;
   {
      oDataStream dataStream(out);
      this->encodeParsed(dataStream);
   }
   return out;
}
 
ParameterTypes::Factory Uri::ParameterFactories[ParameterTypes::MAX_PARAMETER]={0};
 
Parameter* 
Uri::createParam(ParameterTypes::Type type, ParseBuffer& pb, const std::bitset<256>& terminators, PoolBase* pool)
{
   if(type > ParameterTypes::UNKNOWN && type < ParameterTypes::MAX_PARAMETER && ParameterFactories[type])
   {
      return ParameterFactories[type](type, pb, terminators, pool);
   }
   return 0;
}
 
bool 
Uri::exists(const Param<Uri>& paramType) const
{
    checkParsed();
    bool ret = getParameterByEnum(paramType.getTypeNum()) != NULL;
    return ret;
}
 
void 
Uri::remove(const Param<Uri>& paramType)
{
    checkParsed();
    removeParameterByEnum(paramType.getTypeNum());
}
 
#define defineParam(_enum, _name, _type, _RFC_ref_ignored)                                                      \
_enum##_Param::DType&                                                                                           \
Uri::param(const _enum##_Param& paramType)                                                           \
{                                                                                                               \
   checkParsed();                                                                                               \
   _enum##_Param::Type* p =                                                                                     \
      static_cast<_enum##_Param::Type*>(getParameterByEnum(paramType.getTypeNum()));                            \
   if (!p)                                                                                                      \
   {                                                                                                            \
      p = new _enum##_Param::Type(paramType.getTypeNum());                                                      \
      mParameters.push_back(p);                                                                                 \
   }                                                                                                            \
   return p->value();                                                                                           \
}                                                                                                               \
                                                                                                                \
const _enum##_Param::DType&                                                                                     \
Uri::param(const _enum##_Param& paramType) const                                                     \
{                                                                                                               \
   checkParsed();                                                                                               \
   _enum##_Param::Type* p =                                                                                     \
      static_cast<_enum##_Param::Type*>(getParameterByEnum(paramType.getTypeNum()));                            \
   if (!p)                                                                                                      \
   {                                                                                                            \
      InfoLog(<< "Missing parameter " _name " " << ParameterTypes::ParameterNames[paramType.getTypeNum()]);     \
      DebugLog(<< *this);                                                                                       \
      throw Exception("Missing parameter " _name, __FILE__, __LINE__);                                          \
   }                                                                                                            \
   return p->value();                                                                                           \
}
 
defineParam(ob,"ob",ExistsParameter,"RFC 5626");
defineParam(gr, "gr", ExistsOrDataParameter, "RFC 5627");
defineParam(comp, "comp", DataParameter, "RFC 3486");
defineParam(duration, "duration", UInt32Parameter, "RFC 4240");
defineParam(lr, "lr", ExistsParameter, "RFC 3261");
defineParam(maddr, "maddr", DataParameter, "RFC 3261");
defineParam(method, "method", DataParameter, "RFC 3261");
defineParam(transport, "transport", DataParameter, "RFC 3261");
defineParam(ttl, "ttl", UInt32Parameter, "RFC 3261");
defineParam(user, "user", DataParameter, "RFC 3261, 4967");
defineParam(extension, "ext", DataParameter, "RFC 3966"); // Token is used when ext is a user-parameter
defineParam(sigcompId, "sigcomp-id", QuotedDataParameter, "RFC 5049");
defineParam(rinstance, "rinstance", DataParameter, "proprietary (resip)");
defineParam(addTransport, "addTransport", ExistsParameter, "RESIP INTERNAL");
defineParam(wsSrcIp, "ws-src-ip", DataParameter, "RESIP INTERNAL (WebSocket)");
defineParam(wsSrcPort, "ws-src-port", UInt32Parameter, "RESIP INTERNAL (WebSocket)");
 
#undef defineParam
 
HashValueImp(resip::Uri, resip::Data::from(data).hash());
 
/* ====================================================================
 * The Vovida Software License, Version 1.0 
 * 
 * Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 * 
 * 3. The names "VOCAL", "Vovida Open Communication Application Library",
 *    and "Vovida Open Communication Application Library (VOCAL)" must
 *    not be used to endorse or promote products derived from this
 *    software without prior written permission. For written
 *    permission, please contact vocal@vovida.org.
 *
 * 4. Products derived from this software may not be called "VOCAL", nor
 *    may "VOCAL" appear in their name, without prior written
 *    permission of Vovida Networks, Inc.
 * 
 * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
 * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
 * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
 * IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
 * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
 * DAMAGE.
 * 
 * ====================================================================
 * 
 * This software consists of voluntary contributions made by Vovida
 * Networks, Inc. and many individuals on behalf of Vovida Networks,
 * Inc.  For more information on Vovida Networks, Inc., please see
 * <http://www.vovida.org/>.
 *
 */