diff libgaim/protocols/oscar/peer_proxy.c @ 14192:60b1bc8dbf37

[gaim-migrate @ 16863] Renamed 'core' to 'libgaim' committer: Tailor Script <[e-mail]>

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/libgaim/protocols/oscar/peer_proxy.c	Sat Aug 19 01:50:10 2006 +0000
@@ -0,0 +1,353 @@
+/*
+ * Gaim's oscar protocol plugin
+ * This file is the legal property of its developers.
+ * Please see the AUTHORS file distributed alongside this file.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+*/
+
+#ifdef HAVE_CONFIG_H
+#include  <config.h>
+#endif
+
+#include "oscar.h"
+#include "peer.h"
+
+static void
+peer_proxy_send(PeerConnection *conn, ProxyFrame *frame)
+{
+	size_t length;
+	ByteStream bs;
+
+	gaim_debug_info("oscar", "Outgoing peer proxy frame with "
+			"type=0x%04hx, unknown=0x%08x, "
+			"flags=0x%04hx, and payload length=%hd\n",
+			frame->type, frame->unknown,
+			frame->flags, frame->payload.len);
+
+	length = 12 + frame->payload.len;
+	byte_stream_init(&bs, malloc(length), length);
+	byte_stream_put16(&bs, length - 2);
+	byte_stream_put16(&bs, PEER_PROXY_PACKET_VERSION);
+	byte_stream_put16(&bs, frame->type);
+	byte_stream_put32(&bs, frame->unknown);
+	byte_stream_put16(&bs, frame->flags);
+	byte_stream_putraw(&bs, frame->payload.data, frame->payload.len);
+
+	peer_connection_send(conn, &bs);
+
+	free(bs.data);
+}
+
+/**
+ * Create a rendezvous "init send" packet and send it on its merry way.
+ * This is the first packet sent to the proxy server by the first client
+ * to indicate that this will be a proxied connection
+ *
+ * @param conn The peer connection.
+ */
+static void
+peer_proxy_send_create_new_conn(PeerConnection *conn)
+{
+	ProxyFrame frame;
+	GaimAccount *account;
+	const gchar *sn;
+	guint8 sn_length;
+	size_t length;
+
+	memset(&frame, 0, sizeof(ProxyFrame));
+	frame.type = PEER_PROXY_TYPE_CREATE;
+	frame.flags = 0x0000;
+
+	account = gaim_connection_get_account(conn->od->gc);
+	sn = gaim_account_get_username(account);
+	sn_length = strlen(sn);
+	length = 1 + sn_length + 8 + 20;
+	byte_stream_init(&frame.payload, malloc(length), length);
+	byte_stream_put8(&frame.payload, sn_length);
+	byte_stream_putraw(&frame.payload, (const guint8 *)sn, sn_length);
+	byte_stream_putraw(&frame.payload, conn->cookie, 8);
+
+	byte_stream_put16(&frame.payload, 0x0001); /* Type */
+	byte_stream_put16(&frame.payload, 16); /* Length */
+	byte_stream_putcaps(&frame.payload, conn->type); /* Value */
+
+	peer_proxy_send(conn, &frame);
+}
+
+/**
+ * Create a rendezvous "init recv" packet and send it on its merry way.
+ * This is the first packet sent to the proxy server by the second client
+ * involved in this rendezvous proxy session.
+ *
+ * @param conn The peer connection.
+ * @param pin The 2 byte PIN sent to us by the other user.  This acts
+ *        as our passcode when establishing the proxy session.
+ */
+static void
+peer_proxy_send_join_existing_conn(PeerConnection *conn, guint16 pin)
+{
+	ProxyFrame frame;
+	GaimAccount *account;
+	const gchar *sn;
+	guint8 sn_length;
+	size_t length;
+
+	memset(&frame, 0, sizeof(ProxyFrame));
+	frame.type = PEER_PROXY_TYPE_JOIN;
+	frame.flags = 0x0000;
+
+	account = gaim_connection_get_account(conn->od->gc);
+	sn = gaim_account_get_username(account);
+	sn_length = strlen(sn);
+	length = 1 + sn_length + 2 + 8 + 20;
+	byte_stream_init(&frame.payload, malloc(length), length);
+	byte_stream_put8(&frame.payload, sn_length);
+	byte_stream_putraw(&frame.payload, (const guint8 *)sn, sn_length);
+	byte_stream_put16(&frame.payload, pin);
+	byte_stream_putraw(&frame.payload, conn->cookie, 8);
+
+	byte_stream_put16(&frame.payload, 0x0001); /* Type */
+	byte_stream_put16(&frame.payload, 16); /* Length */
+	byte_stream_putcaps(&frame.payload, conn->type); /* Value */
+
+	peer_proxy_send(conn, &frame);
+}
+
+/**
+ * Handle an incoming peer proxy negotiation frame.
+ */
+static void
+peer_proxy_recv_frame(PeerConnection *conn, ProxyFrame *frame)
+{
+	gaim_debug_info("oscar", "Incoming peer proxy frame with "
+			"type=0x%04hx, unknown=0x%08x, "
+			"flags=0x%04hx, and payload length=%hd\n", frame->type,
+			frame->unknown, frame->flags, frame->payload.len);
+
+	if (frame->type == PEER_PROXY_TYPE_CREATED)
+	{
+		/*
+		 * Read in 2 byte port then 4 byte IP and tell the
+		 * remote user to connect to it by sending an ICBM.
+		 */
+		guint16 pin;
+		int i;
+		guint8 ip[4];
+
+		pin = byte_stream_get16(&frame->payload);
+		for (i = 0; i < 4; i++)
+			ip[i] = byte_stream_get8(&frame->payload);
+		if (conn->type == OSCAR_CAPABILITY_DIRECTIM)
+			aim_im_sendch2_odc_requestproxy(conn->od,
+					conn->cookie,
+					conn->sn, ip, pin, ++conn->lastrequestnumber);
+		else if (conn->type == OSCAR_CAPABILITY_SENDFILE)
+		{
+			aim_im_sendch2_sendfile_requestproxy(conn->od,
+					conn->cookie, conn->sn,
+					ip, pin, ++conn->lastrequestnumber,
+					(const gchar *)conn->xferdata.name,
+					conn->xferdata.size, conn->xferdata.totfiles);
+		}
+	}
+	else if (frame->type == PEER_PROXY_TYPE_READY)
+	{
+		gaim_input_remove(conn->watcher_incoming);
+		conn->watcher_incoming = 0;
+
+		peer_connection_finalize_connection(conn);
+	}
+	else if (frame->type == PEER_PROXY_TYPE_ERROR)
+	{
+		if (byte_stream_empty(&frame->payload) >= 2)
+		{
+			guint16 error;
+			const char *msg;
+			error = byte_stream_get16(&frame->payload);
+			if (error == 0x000d)
+				msg = "bad request";
+			else if (error == 0x0010)
+				msg = "initial request timed out";
+			else if (error == 0x001a)
+				msg ="accept period timed out";
+			else
+				msg = "unknown reason";
+			gaim_debug_info("oscar", "Proxy negotiation failed with "
+					"error 0x%04hx: %s\n", error, msg);
+		}
+		else
+		{
+			gaim_debug_warning("oscar", "Proxy negotiation failed with "
+					"an unknown error\n");
+		}
+		peer_connection_trynext(conn);
+	}
+	else
+	{
+		gaim_debug_warning("oscar", "Unknown peer proxy frame type 0x%04hx.\n",
+				frame->type);
+	}
+}
+
+static void
+peer_proxy_connection_recv_cb(gpointer data, gint source, GaimInputCondition cond)
+{
+	PeerConnection *conn;
+	ssize_t read;
+	guint8 header[12];
+	ProxyFrame *frame;
+
+	conn = data;
+	frame = conn->frame;
+
+	/* Start reading a new proxy frame */
+	if (frame == NULL)
+	{
+		/* Peek at the first 12 bytes to get the length */
+		read = recv(conn->fd, &header, 12, MSG_PEEK);
+
+		/* Check if the proxy server closed the connection */
+		if (read == 0)
+		{
+			gaim_debug_info("oscar", "Peer proxy server closed connection\n");
+			peer_connection_trynext(conn);
+			return;
+		}
+
+		/* If there was an error then close the connection */
+		if (read == -1)
+		{
+			if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
+				/* No worries */
+				return;
+
+			gaim_debug_info("oscar", "Lost connection with peer proxy server\n");
+			peer_connection_trynext(conn);
+			return;
+		}
+
+		conn->lastactivity = time(NULL);
+
+		/* If we don't even have the first 12 bytes then do nothing */
+		if (read < 12)
+			return;
+
+		/* Read the first 12 bytes (frame length and header) */
+		read = recv(conn->fd, &header, 12, 0);
+
+		/* We only support a specific version of the proxy protocol */
+		if (aimutil_get16(&header[2]) != PEER_PROXY_PACKET_VERSION)
+		{
+			gaim_debug_warning("oscar", "Expected peer proxy protocol "
+				"version %u but received version %u.  Closing "
+				"connection.\n", PEER_PROXY_PACKET_VERSION,
+				aimutil_get16(&header[2]));
+			peer_connection_trynext(conn);
+			return;
+		}
+
+		/* Initialize a new temporary ProxyFrame for incoming data */
+		frame = g_new0(ProxyFrame, 1);
+		frame->payload.len = aimutil_get16(&header[0]) - 10;
+		frame->version = aimutil_get16(&header[2]);
+		frame->type = aimutil_get16(&header[4]);
+		frame->unknown = aimutil_get16(&header[6]);
+		frame->flags = aimutil_get16(&header[10]);
+		if (frame->payload.len > 0)
+			frame->payload.data = g_new(guint8, frame->payload.len);
+		conn->frame = frame;
+	}
+
+	/* If this frame has a payload then attempt to read it */
+	if (frame->payload.len - frame->payload.offset > 0)
+	{
+		/* Read data into the temporary buffer until it is complete */
+		read = recv(conn->fd,
+					&frame->payload.data[frame->payload.offset],
+					frame->payload.len - frame->payload.offset,
+					0);
+
+		/* Check if the proxy server closed the connection */
+		if (read == 0)
+		{
+			gaim_debug_info("oscar", "Peer proxy server closed connection\n");
+			g_free(frame->payload.data);
+			g_free(frame);
+			conn->frame = NULL;
+			peer_connection_trynext(conn);
+			return;
+		}
+
+		if (read == -1)
+		{
+			if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
+				/* No worries */
+				return;
+
+			gaim_debug_info("oscar", "Lost connection with peer proxy server\n");
+			g_free(frame->payload.data);
+			g_free(frame);
+			conn->frame = NULL;
+			peer_connection_trynext(conn);
+			return;
+		}
+
+		frame->payload.offset += read;
+	}
+
+	conn->lastactivity = time(NULL);
+	if (frame->payload.offset < frame->payload.len)
+		/* Waiting for more data to arrive */
+		return;
+
+	/* We have a complete proxy frame!  Handle it and continue reading */
+	conn->frame = NULL;
+	byte_stream_rewind(&frame->payload);
+	peer_proxy_recv_frame(conn, frame);
+	g_free(frame->payload.data);
+	g_free(frame);
+}
+
+/**
+ * We tried to make an outgoing connection to a proxy server.  It
+ * either connected or failed to connect.
+ */
+void
+peer_proxy_connection_established_cb(gpointer data, gint source, const gchar *error_message)
+{
+	PeerConnection *conn;
+
+	conn = data;
+
+	conn->connect_info = NULL;
+
+	if (source < 0)
+	{
+		peer_connection_trynext(conn);
+		return;
+	}
+
+	conn->fd = source;
+	conn->watcher_incoming = gaim_input_add(conn->fd,
+			GAIM_INPUT_READ, peer_proxy_connection_recv_cb, conn);
+
+	if (conn->proxyip != NULL)
+		/* Connect to the session created by the remote user */
+		peer_proxy_send_join_existing_conn(conn, conn->port);
+	else
+		/* Create a new session */
+		peer_proxy_send_create_new_conn(conn);
+}