comparison src/proxy.c @ 14090:983fbec46eb0

[gaim-migrate @ 16713] Rename struct PHB to struct _GaimProxyConnectInfo committer: Tailor Script <[e-mail]>

14089:10e8eb6a4910

#include "prefs.h"
#include "proxy.h"
#include "util.h"

/* Does anyone know what PHB stands for? */
struct PHB {
	GaimProxyConnectFunction connect_cb;
	GaimProxyErrorFunction error_cb;
	gpointer data;
	char *host;
	int port;

};

static GaimProxyInfo *global_proxy_info = NULL;
static GSList *phbs = NULL;

static void try_connect(struct PHB *);

/**************************************************************************
 * Proxy structure API
 **************************************************************************/
GaimProxyInfo *

/**************************************************************************
 * Proxy API
 **************************************************************************/

static void
gaim_proxy_phb_destroy(struct PHB *phb)
{
	phbs = g_slist_remove(phbs, phb);

	if (phb->inpa > 0)
		gaim_input_remove(phb->inpa);

	g_free(phb->read_buffer);
	g_free(phb);
}

static void
gaim_proxy_phb_connected(struct PHB *phb, int fd)
{
	phb->connect_cb(phb->data, fd);
	gaim_proxy_phb_destroy(phb);
}

 * @param error An error message explaining why the connection
 *        failed.  This will be passed to the callback function
 *        specified in the call to gaim_proxy_connect().
 */
static void
gaim_proxy_phb_error(struct PHB *phb, const gchar *error_message)
{
	if (phb->error_cb == NULL)
	{
		/*
		 * TODO

#endif /* not __unix__ or __APPLE__ or _WIN32 */

static void
no_one_calls(gpointer data, gint source, GaimInputCondition cond)
{
	struct PHB *phb = data;
	socklen_t len;
	int error=0, ret;

	gaim_debug_info("proxy", "Connected.\n");

	gaim_proxy_phb_connected(phb, source);
}

static gboolean clean_connect(gpointer data)
{
	struct PHB *phb = data;

	gaim_proxy_phb_connected(phb, phb->port);

	return FALSE;
}


static int
proxy_connect_none(struct PHB *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("proxy",
			   "Connecting to %s:%d with no proxy\n", phb->host, phb->port);

}

static void
proxy_do_write(gpointer data, gint source, GaimInputCondition cond)
{
	struct PHB *phb = data;
	const guchar *request = phb->write_buffer + phb->written_len;
	gsize request_len = phb->write_buf_len - phb->written_len;

	int ret = write(source, request, request_len);

static void
http_canread(gpointer data, gint source, GaimInputCondition cond)
{
	int len, headers_len, status = 0;
	gboolean error;
	struct PHB *phb = data;
	guchar *p;
	gsize max_read;
	gchar *msg;

	if(phb->read_buffer == NULL) {

static void
http_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	char request[8192];
	int request_len = 0;
	struct PHB *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("http proxy", "Connected.\n");

	proxy_do_write(phb, source, cond);
}

static int
proxy_connect_http(struct PHB *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("http proxy",
			   "Connecting to %s:%d via %s:%d using HTTP\n",

static void
s4_canread(gpointer data, gint source, GaimInputCondition cond)
{
	struct PHB *phb = data;
	guchar *buf;
	int len, max_read;

	/* This is really not going to block under normal circumstances, but to
	 * be correct, we deal with the unlikely scenario */

static void
s4_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	unsigned char packet[9];
	struct hostent *hp;
	struct PHB *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("socks4 proxy", "Connected.\n");

	proxy_do_write(phb, source, cond);
}

static int
proxy_connect_socks4(struct PHB *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("socks4 proxy",
			   "Connecting to %s:%d via %s:%d using SOCKS4\n",

static void
s5_canread_again(gpointer data, gint source, GaimInputCondition cond)
{
	guchar *dest, *buf;
	struct PHB *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 512;
		phb->read_buffer = g_malloc(phb->read_buf_len);

}

static void
s5_sendconnect(gpointer data, int source)
{
	struct PHB *phb = data;
	int hlen = strlen(phb->host);
	phb->write_buf_len = 5 + hlen + 2;
	phb->write_buffer = g_malloc(phb->write_buf_len);
	phb->written_len = 0;

}

static void
s5_readauth(gpointer data, gint source, GaimInputCondition cond)
{
	struct PHB *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 2;
		phb->read_buffer = g_malloc(phb->read_buf_len);

static void
s5_readchap(gpointer data, gint source, GaimInputCondition cond)
{
	guchar *cmdbuf, *buf;
	struct PHB *phb = data;
	int len, navas, currentav;

	gaim_debug(GAIM_DEBUG_INFO, "socks5 proxy", "Got CHAP response.\n");

	if (phb->read_buffer == NULL) {

}

static void
s5_canread(gpointer data, gint source, GaimInputCondition cond)
{
	struct PHB *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 2;
		phb->read_buffer = g_malloc(phb->read_buf_len);

static void
s5_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	unsigned char buf[5];
	int i;
	struct PHB *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("socks5 proxy", "Connected.\n");

	phb->inpa = gaim_input_add(source, GAIM_INPUT_WRITE, proxy_do_write, phb);
	proxy_do_write(phb, source, GAIM_INPUT_WRITE);
}

static int
proxy_connect_socks5(struct PHB *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("socks5 proxy",
			   "Connecting to %s:%d via %s:%d using SOCKS5\n",

	}

	return fd;
}

static void try_connect(struct PHB *phb)
{
	size_t addrlen;
	struct sockaddr *addr;
	int ret = -1;

static void
connection_host_resolved(GSList *hosts, gpointer data,
						 const char *error_message)
{
	struct PHB *phb = (struct PHB*)data;

	phb->hosts = hosts;

	try_connect(phb);
}

				   GaimProxyConnectFunction connect_cb,
				   GaimProxyErrorFunction error_cb, gpointer data)
{
	const char *connecthost = host;
	int connectport = port;
	struct PHB *phb;

	g_return_val_if_fail(host       != NULL, NULL);
	g_return_val_if_fail(port       >  0,    NULL);
	g_return_val_if_fail(connect_cb != NULL, NULL);
	/* g_return_val_if_fail(error_cb   != NULL, NULL); *//* TODO: Soon! */

	phb = g_new0(struct PHB, 1);
	phb->connect_cb = connect_cb;
	phb->error_cb = error_cb;
	phb->data = data;
	phb->host = g_strdup(host);
	phb->port = port;

GaimProxyConnectInfo *
gaim_proxy_connect_socks5(GaimProxyInfo *gpi, const char *host, int port,
				   GaimProxyConnectFunction connect_cb,
				   GaimProxyErrorFunction error_cb, gpointer data)
{
	struct PHB *phb;

	g_return_val_if_fail(host       != NULL, NULL);
	g_return_val_if_fail(port       >  0,    NULL);
	g_return_val_if_fail(connect_cb != NULL, NULL);
	/* g_return_val_if_fail(error_cb   != NULL, NULL); *//* TODO: Soon! */

	phb = g_new0(struct PHB, 1);
	phb->connect_cb = connect_cb;
	phb->error_cb = error_cb;
	phb->data = data;
	phb->host = g_strdup(host);
	phb->port = port;

14090:983fbec46eb0

#include "prefs.h"
#include "proxy.h"
#include "util.h"

/* Does anyone know what PHB stands for? */
struct _GaimProxyConnectInfo {
	GaimProxyConnectFunction connect_cb;
	GaimProxyErrorFunction error_cb;
	gpointer data;
	char *host;
	int port;

};

static GaimProxyInfo *global_proxy_info = NULL;
static GSList *phbs = NULL;

static void try_connect(struct _GaimProxyConnectInfo *);

/**************************************************************************
 * Proxy structure API
 **************************************************************************/
GaimProxyInfo *

/**************************************************************************
 * Proxy API
 **************************************************************************/

static void
gaim_proxy_phb_destroy(struct _GaimProxyConnectInfo *phb)
{
	phbs = g_slist_remove(phbs, phb);

	if (phb->inpa > 0)
		gaim_input_remove(phb->inpa);

	g_free(phb->read_buffer);
	g_free(phb);
}

static void
gaim_proxy_phb_connected(struct _GaimProxyConnectInfo *phb, int fd)
{
	phb->connect_cb(phb->data, fd);
	gaim_proxy_phb_destroy(phb);
}

 * @param error An error message explaining why the connection
 *        failed.  This will be passed to the callback function
 *        specified in the call to gaim_proxy_connect().
 */
static void
gaim_proxy_phb_error(struct _GaimProxyConnectInfo *phb, const gchar *error_message)
{
	if (phb->error_cb == NULL)
	{
		/*
		 * TODO

#endif /* not __unix__ or __APPLE__ or _WIN32 */

static void
no_one_calls(gpointer data, gint source, GaimInputCondition cond)
{
	struct _GaimProxyConnectInfo *phb = data;
	socklen_t len;
	int error=0, ret;

	gaim_debug_info("proxy", "Connected.\n");

	gaim_proxy_phb_connected(phb, source);
}

static gboolean clean_connect(gpointer data)
{
	struct _GaimProxyConnectInfo *phb = data;

	gaim_proxy_phb_connected(phb, phb->port);

	return FALSE;
}


static int
proxy_connect_none(struct _GaimProxyConnectInfo *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("proxy",
			   "Connecting to %s:%d with no proxy\n", phb->host, phb->port);

}

static void
proxy_do_write(gpointer data, gint source, GaimInputCondition cond)
{
	struct _GaimProxyConnectInfo *phb = data;
	const guchar *request = phb->write_buffer + phb->written_len;
	gsize request_len = phb->write_buf_len - phb->written_len;

	int ret = write(source, request, request_len);

static void
http_canread(gpointer data, gint source, GaimInputCondition cond)
{
	int len, headers_len, status = 0;
	gboolean error;
	struct _GaimProxyConnectInfo *phb = data;
	guchar *p;
	gsize max_read;
	gchar *msg;

	if(phb->read_buffer == NULL) {

static void
http_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	char request[8192];
	int request_len = 0;
	struct _GaimProxyConnectInfo *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("http proxy", "Connected.\n");

	proxy_do_write(phb, source, cond);
}

static int
proxy_connect_http(struct _GaimProxyConnectInfo *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("http proxy",
			   "Connecting to %s:%d via %s:%d using HTTP\n",

static void
s4_canread(gpointer data, gint source, GaimInputCondition cond)
{
	struct _GaimProxyConnectInfo *phb = data;
	guchar *buf;
	int len, max_read;

	/* This is really not going to block under normal circumstances, but to
	 * be correct, we deal with the unlikely scenario */

static void
s4_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	unsigned char packet[9];
	struct hostent *hp;
	struct _GaimProxyConnectInfo *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("socks4 proxy", "Connected.\n");

	proxy_do_write(phb, source, cond);
}

static int
proxy_connect_socks4(struct _GaimProxyConnectInfo *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("socks4 proxy",
			   "Connecting to %s:%d via %s:%d using SOCKS4\n",

static void
s5_canread_again(gpointer data, gint source, GaimInputCondition cond)
{
	guchar *dest, *buf;
	struct _GaimProxyConnectInfo *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 512;
		phb->read_buffer = g_malloc(phb->read_buf_len);

}

static void
s5_sendconnect(gpointer data, int source)
{
	struct _GaimProxyConnectInfo *phb = data;
	int hlen = strlen(phb->host);
	phb->write_buf_len = 5 + hlen + 2;
	phb->write_buffer = g_malloc(phb->write_buf_len);
	phb->written_len = 0;

}

static void
s5_readauth(gpointer data, gint source, GaimInputCondition cond)
{
	struct _GaimProxyConnectInfo *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 2;
		phb->read_buffer = g_malloc(phb->read_buf_len);

static void
s5_readchap(gpointer data, gint source, GaimInputCondition cond)
{
	guchar *cmdbuf, *buf;
	struct _GaimProxyConnectInfo *phb = data;
	int len, navas, currentav;

	gaim_debug(GAIM_DEBUG_INFO, "socks5 proxy", "Got CHAP response.\n");

	if (phb->read_buffer == NULL) {

}

static void
s5_canread(gpointer data, gint source, GaimInputCondition cond)
{
	struct _GaimProxyConnectInfo *phb = data;
	int len;

	if (phb->read_buffer == NULL) {
		phb->read_buf_len = 2;
		phb->read_buffer = g_malloc(phb->read_buf_len);

static void
s5_canwrite(gpointer data, gint source, GaimInputCondition cond)
{
	unsigned char buf[5];
	int i;
	struct _GaimProxyConnectInfo *phb = data;
	socklen_t len;
	int error = ETIMEDOUT;

	gaim_debug_info("socks5 proxy", "Connected.\n");

	phb->inpa = gaim_input_add(source, GAIM_INPUT_WRITE, proxy_do_write, phb);
	proxy_do_write(phb, source, GAIM_INPUT_WRITE);
}

static int
proxy_connect_socks5(struct _GaimProxyConnectInfo *phb, struct sockaddr *addr, socklen_t addrlen)
{
	int fd = -1;

	gaim_debug_info("socks5 proxy",
			   "Connecting to %s:%d via %s:%d using SOCKS5\n",

	}

	return fd;
}

static void try_connect(struct _GaimProxyConnectInfo *phb)
{
	size_t addrlen;
	struct sockaddr *addr;
	int ret = -1;

static void
connection_host_resolved(GSList *hosts, gpointer data,
						 const char *error_message)
{
	struct _GaimProxyConnectInfo *phb = (struct _GaimProxyConnectInfo*)data;

	phb->hosts = hosts;

	try_connect(phb);
}

				   GaimProxyConnectFunction connect_cb,
				   GaimProxyErrorFunction error_cb, gpointer data)
{
	const char *connecthost = host;
	int connectport = port;
	struct _GaimProxyConnectInfo *phb;

	g_return_val_if_fail(host       != NULL, NULL);
	g_return_val_if_fail(port       >  0,    NULL);
	g_return_val_if_fail(connect_cb != NULL, NULL);
	/* g_return_val_if_fail(error_cb   != NULL, NULL); *//* TODO: Soon! */

	phb = g_new0(struct _GaimProxyConnectInfo, 1);
	phb->connect_cb = connect_cb;
	phb->error_cb = error_cb;
	phb->data = data;
	phb->host = g_strdup(host);
	phb->port = port;

GaimProxyConnectInfo *
gaim_proxy_connect_socks5(GaimProxyInfo *gpi, const char *host, int port,
				   GaimProxyConnectFunction connect_cb,
				   GaimProxyErrorFunction error_cb, gpointer data)
{
	struct _GaimProxyConnectInfo *phb;

	g_return_val_if_fail(host       != NULL, NULL);
	g_return_val_if_fail(port       >  0,    NULL);
	g_return_val_if_fail(connect_cb != NULL, NULL);
	/* g_return_val_if_fail(error_cb   != NULL, NULL); *//* TODO: Soon! */

	phb = g_new0(struct _GaimProxyConnectInfo, 1);
	phb->connect_cb = connect_cb;
	phb->error_cb = error_cb;
	phb->data = data;
	phb->host = g_strdup(host);
	phb->port = port;