reSIProcate/stack  9694
Defines | Functions
testEmbedded.cxx File Reference
#include "rutil/DataStream.hxx"
#include "resip/stack/SipMessage.hxx"
#include "resip/stack/Uri.hxx"
#include "resip/stack/Embedded.hxx"
#include "resip/stack/ParserCategories.hxx"
#include "rutil/Logger.hxx"
Include dependency graph for testEmbedded.cxx:

Go to the source code of this file.

Defines

#define RESIPROCATE_SUBSYSTEM   Subsystem::TEST
#define RESIP_COOKIE   "-524287-"

Functions

int main (int argc, char **argv)

Define Documentation

#define RESIP_COOKIE   "-524287-"

Definition at line 12 of file testEmbedded.cxx.

Referenced by main().

#define RESIPROCATE_SUBSYSTEM   Subsystem::TEST

Definition at line 11 of file testEmbedded.cxx.


Function Documentation

int main ( int  argc,
char **  argv 
)

Definition at line 18 of file testEmbedded.cxx.

References resip::Log::Cout, resip::Data::data(), resip::Embedded::decode(), resip::Uri::embedded(), resip::Embedded::encode(), resip::LazyParser::encode(), resip::SipMessage::exists(), resip::Uri::hasEmbedded(), resip::SipMessage::header(), resip::Uri::host(), resip::Log::Info, resip::Log::initialize(), resip::RequestLine::method(), resip::ParserCategory::param(), resip::BranchParameter::reset(), RESIP_COOKIE, resip::Via::sentHost(), resip::Via::sentPort(), resip::Data::size(), resip::Log::toLevel(), resip::Via::transport(), resip::NameAddr::uri(), and resip::Uri::user().

{
   Log::initialize(Log::Cout, argc > 1 ? Log::toLevel(argv[1]) :  Log::Info, argv[0]);

   {
      Data foo("abcdefghi1232454435");
      assert(Embedded::encode(foo) == foo);
   }

   {
      // ^ is not valid in this part of a URI; see RFC 3261.
      Data foo("abcdefghi1232454435^ * ");
      cerr << Embedded::encode(foo) << endl;
      assert(Embedded::encode(foo) == "abcdefghi1232454435%5E%20*%20");
   }

   {
      Data foo("abcdefghi1232454435^&*&");
      unsigned int c;
      char* res = Embedded::decode(foo, c);

      cerr << Data(res, c) << endl;
      assert(foo == Data(res, c));
      delete [] res;
   }

   {
      Data foo("!@#$%^&*() ?:=17qwerty");
      Data bar = Embedded::encode(foo);

      cerr << bar << endl;

      unsigned int c;
      char* res = Embedded::decode(bar, c);
      cerr << Data(res, c) << endl;
      assert(foo == Data(res, c));

      delete [] res;
   }

   {
      Data foo("!@#$%^&*() ?:=17qwerty");
      Data bar(Embedded::encode(Embedded::encode(foo)));

      cerr << bar << endl;

      unsigned int c;
      char* res1 = Embedded::decode(bar, c);
      Data rab(res1, c);
      char* res2 = Embedded::decode(rab, c);

      assert(foo == Data(res2, c));

      delete [] res1;
      delete [] res2;
   }

   {
      cerr << "Produce embedded, single header" << endl;
      Uri foo;
      foo.user() = "speedy";
      foo.host() = "cathaynetworks.com";
      foo.embedded().header(h_CSeq).method() = ACK;
      foo.embedded().header(h_CSeq).sequence() = 4178;

      Data buf;
      {
         DataStream str(buf);
         foo.encode(str);
      }
      cerr << endl << buf << endl;
      assert(buf == "sip:speedy@cathaynetworks.com?CSeq=4178%20ACK");
   }

   {
      cerr << "Produce embedded, multiple headers" << endl;
      Uri foo;
      foo.user() = "speedy";
      foo.host() = "cathaynetworks.com";
      foo.embedded().header(h_CSeq).method() = ACK;
      foo.embedded().header(h_CSeq).sequence() = 4178;

      Via via;
      BranchParameter branch = via.param(p_branch);

      branch.reset("fobbieBletch");
      via.transport() = "TLS";
      via.sentHost() = "cathay.com";
      via.sentPort() = 5066;
      via.param(p_branch) = branch;
      foo.embedded().header(h_Vias).push_back(via);

      branch.reset("bletchieFoo");
      via.transport() = "TCP";
      via.sentHost() = "ixolib.com";
      via.sentPort() = 5067;
      via.param(p_branch) = branch;
      foo.embedded().header(h_Vias).push_back(via);

      NameAddr route;
      route.uri() = Uri("sip:flibble@gronk.example.com");
      foo.embedded().header(h_Routes).push_back(route);

      Data buf;
      {
         DataStream str(buf);
         foo.encode(str);
      }

      cerr << buf << endl;

      assert(buf == "sip:speedy@cathaynetworks.com?Via=SIP%2F2.0%2FTLS%20cathay.com:5066%3Bbranch%3Dz9hG4bK" RESIP_COOKIE "1---fobbieBletch%3Brport&Via=SIP%2F2.0%2FTCP%20ixolib.com:5067%3Bbranch%3Dz9hG4bK" RESIP_COOKIE "1---bletchieFoo%3Brport&Route=%3Csip:flibble%40gronk.example.com%3E&CSeq=4178%20ACK");
   }

   {
      cerr << "Parse <Uri> with embedded" << endl;
      
      Data nad("bob<sips:bob@foo.com?CSeq=314159%20ACK>;tag=wd834f");
      NameAddr na(nad); 

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_CSeq));
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 314159);
   }

   {
      cerr << "Parse Uri with embedded" << endl;
      
      Data nad("sips:bob@foo.com;ttl=134?CSeq=314159%20ACK");
      NameAddr na(nad); 

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_CSeq));
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 314159);
      assert(na.uri().param(p_ttl) == 134);
   }

   {
      cerr << "Parse Uri with embedded followed by NameAddr parameter" << endl;
      
      Data nad("sips:bob@foo.com;ttl=134?CSeq=314159%20ACK;tag=17");
      NameAddr na(nad);

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_CSeq));
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 314159);
      assert(na.uri().param(p_ttl) == 134);
      assert(na.param(p_tag) == "17");
   }

   {
      cerr << "Parse Uri with multiple headers" << endl;
      
      Data nad("sip:speedy@cathaynetworks.com?Via=SIP/2.0/TLS%20cathay.com:5066%3Bbranch%3Dz9hG4bKfobbieBletch-1&Via=SIP/2.0/TCP%20ixolib.com:5067%3Bbranch%3Dz9hG4bKbletchieFoo-1&CSeq=4178%20ACK");
      NameAddr na(nad);

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_Vias));
      assert(na.uri().embedded().exists(h_CSeq));
      
      assert(na.uri().embedded().header(h_Vias).size() == 2);
      assert(na.uri().embedded().header(h_Vias).front().transport() == "TLS");
      assert((++(na.uri().embedded().header(h_Vias).begin()))->transport() == "TCP");
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 4178);
   }

   {
      cerr << "Parse Request-Line with embedded" << endl;
      
      Data nad("INVITE sips:bob@foo.com?CSeq=314159%20ACK SIP/2.0");
      HeaderFieldValue hfv(nad.data(), nad.size());
      RequestLine na(hfv); 

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_CSeq));
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 314159);
   }

   {
      cerr << "Parse Request-Line with embedded (and another param)" << endl;
      
      Data nad("INVITE sips:bob@foo.com;ttl=134?CSeq=314159%20ACK SIP/2.0");
      HeaderFieldValue hfv(nad.data(), nad.size());
      RequestLine na(hfv); 

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_CSeq));
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 314159);
      assert(na.uri().param(p_ttl) == 134);
   }

   {
      cerr << "Parse Request-Line with multiple headers" << endl;
      
      Data nad("INVITE sip:speedy@cathaynetworks.com?Via=SIP/2.0/TLS%20cathay.com:5066%3Bbranch%3Dz9hG4bKfobbieBletch-1&Via=SIP/2.0/TCP%20ixolib.com:5067%3Bbranch%3Dz9hG4bKbletchieFoo-1&CSeq=4178%20ACK SIP/2.0");
      HeaderFieldValue hfv(nad.data(), nad.size());
      RequestLine na(hfv); 

      assert(na.uri().hasEmbedded());
      assert(na.uri().embedded().exists(h_Vias));
      assert(na.uri().embedded().exists(h_CSeq));
      
      assert(na.uri().embedded().header(h_Vias).size() == 2);
      assert(na.uri().embedded().header(h_Vias).front().transport() == "TLS");
      assert((++(na.uri().embedded().header(h_Vias).begin()))->transport() == "TCP");
      assert(na.uri().embedded().header(h_CSeq).method() == ACK);
      assert(na.uri().embedded().header(h_CSeq).sequence() == 4178);
   }

   cerr << endl << "Tests OK" << endl;
   return 0;
}

Here is the call graph for this function: