1 files changed, 211 insertions, 0 deletions
diff --git a/src/parser/hdr_via.cpp b/src/parser/hdr_via.cpp
new file mode 100644
index 0000000..d076bfe
--- /dev/null
+++ b/src/parser/hdr_via.cpp
@@ -0,0 +1,211 @@
+/*
+    Copyright (C) 2005-2009  Michel de Boer <michel@twinklephone.com>
+
+    This program 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.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program; if not, write to the Free Software
+    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+*/
+
+#include <iostream>
+#include "definitions.h"
+#include "hdr_via.h"
+#include "util.h"
+#include "parse_ctrl.h"
+#include "protocol.h"
+#include "sockets/url.h"
+
+t_via::t_via() {
+	port = 0;
+	ttl = 0;
+	rport_present = false;
+	rport = 0;
+}
+
+t_via::t_via(const string &_host, const int _port, bool add_rport) {
+	protocol_name = "SIP";
+	protocol_version = SIP_VERSION;
+	transport = "UDP";
+	host = _host;
+	branch = RFC3261_COOKIE + random_token(8);
+
+	if (_port != get_default_port("sip")) {
+		port = _port;
+	} else {
+		port = 0;
+	}
+
+	ttl = 0;
+	rport_present = add_rport;
+	rport = 0;
+}
+
+void t_via::add_extension(const t_parameter &p) {
+	extensions.push_back(p);
+}
+
+string t_via::encode(void) const {
+	string s;
+
+	s = protocol_name + '/' + protocol_version + '/' + transport;
+	s += ' ';
+	s += host;
+
+	if (port > 0) {
+		s += ':';
+		s += int2str(port);
+	}
+
+	if (ttl > 0) s += int2str(ttl, ";ttl=%d");
+
+	if (maddr.size() > 0) {
+		s += ";maddr=";
+		s += maddr;
+	}
+
+	if (received.size() > 0) {
+		s += ";received=";
+		s += received;
+	}
+
+	if (rport_present) {
+		s += ";rport";
+		if (rport > 0) {
+			s += "=";
+			s += int2str(rport);
+		}
+	}
+
+	if (branch.size() > 0) {
+		s += ";branch=";
+		s += branch;
+	}
+
+	s += param_list2str(extensions);
+	return s;
+}
+
+void t_via::get_response_dst(t_ip_port &ip_port) const {
+	string url_str("sip:");
+
+	// RFC 3261 18.2.2
+	// Determine the address to send a repsonse to
+	// NOTE: the received-parameter will be added by the listener if needed.
+	
+	if (tolower(transport) == "tcp") {
+		// NOTE: The response must be sent over the connection on which
+		// the request was received. The address returned here is an
+		// alternative if that connection is closed already.
+		if (received.size() > 0) {
+			url_str += received;
+		} else {
+			url_str += host;
+		}
+			
+		url_str += ":";
+		
+		// NOTE: The rport parameter is not processed here as it only
+		// applies to unreliable transports (RFC 3581 4)
+		url_str += int2str(port);
+		
+		t_url u(url_str);
+		list<t_ip_port> ip_list = u.get_h_ip_srv("tcp");
+		ip_port = ip_list.front();
+	} else {
+		if (maddr.size() > 0) {
+			url_str += maddr;
+		} else if (received.size() > 0) {
+			url_str += received;
+		} else {
+			url_str += host;
+		}
+	
+		// RFC 3581 4
+		if (rport_present && rport > 0) {
+			// NOTE: the rport value will be added by the UDP listener
+			// if the rport parameter without value was present.
+			url_str += ':';
+			url_str += int2str(rport);
+		} else if (port != 0) {
+			url_str += ':';
+			url_str += int2str(port);
+		}
+		
+		// If there was no maddr parameter, then the URL will always point to
+		// an IP address; either the host was an IP address or a received parameter
+		// containing an IP address was added (see RFC 3261 18.2.1)
+		// If there was an maddr, then the URL can be a domain that could have
+		// multiple SRV records. RFC 3263 section 5 does not specify what to do in
+		// this case. So just send the response to the first destination.
+		t_url u(url_str);
+		list<t_ip_port> ip_list = u.get_h_ip_srv("udp");
+		ip_port = ip_list.front();
+	}
+}
+
+bool t_via::rfc3261_compliant(void) const {
+	return (branch.find(RFC3261_COOKIE) == 0);
+}
+
+
+t_hdr_via::t_hdr_via() : t_header("Via", "v") {}
+
+void t_hdr_via::add_via(const t_via &v) {
+	populated = true;
+	via_list.push_back(v);
+}
+
+string t_hdr_via::encode(void) const {
+	return (t_parser::multi_values_as_list ? 
+			t_header::encode() : encode_multi_header());
+}
+
+string t_hdr_via::encode_multi_header(void) const {
+	string s;
+
+	if (!populated) return s;
+
+	for (list<t_via>::const_iterator i = via_list.begin();
+	     i != via_list.end(); i++)
+	{
+		s += (t_parser::compact_headers ? compact_name : header_name);
+		s += ": ";
+		s += i->encode();
+		s += CRLF;
+	}
+
+	return s;
+}
+
+string t_hdr_via::encode_value(void) const {
+	string s;
+
+	if (!populated) return s;
+
+	for (list<t_via>::const_iterator i = via_list.begin();
+	     i != via_list.end(); i++)
+	{
+		if (i != via_list.begin()) s += ",";
+		s += i->encode();
+	}
+
+	return s;
+}
+
+void t_hdr_via::get_response_dst(t_ip_port &ip_port) const {
+	if (!populated) {
+		ip_port.clear();
+		return;
+	}
+
+	via_list.front().get_response_dst(ip_port);
+}