comparison src/protocols/oscar/oscar.c @ 14109:a21da42126d6

[gaim-migrate @ 16743] Almost all of oscar is using gaim_proxy_connect_cancel() now committer: Tailor Script <[e-mail]>

14108:7a205b430d19

static guint8 features_aim[] = {0x01, 0x01, 0x01, 0x02};
static guint8 features_icq[] = {0x01, 0x06};
static guint8 features_icq_offline[] = {0x01};
static guint8 ck[] = {0x00, 0x00, 0x00, 0x00, 0x00, 0x00};

typedef struct _NewFlapConnectionData NewFlapConnectionData;
struct _NewFlapConnectionData
{
	GaimConnection *gc;
	FlapConnection *conn;
	guint16 cookielen;
	guint8 *cookie;
	gpointer data;
};

struct create_room {
	char *name;
	int exchange;
};

struct chat_connection
{
	char *name;
	char *show; /* AOL did something funny to us */
	guint16 exchange;
	guint16 instance;
	FlapConnection *conn;
	int id;
	GaimConnection *gc; /* i hate this. */
	GaimConversation *conv; /* bah. */
	int maxlen;
	int maxvis;
};

struct oscar_ask_directim_data
{
	OscarData *od;

	}

	return NULL;
}

static void
oscar_chat_destroy(struct chat_connection *cc)
{
	g_free(cc->name);
	g_free(cc->show);
	g_free(cc);

	/* Destroy the chat_connection */
	od->oscar_chats = g_slist_remove(od->oscar_chats, cc);
	flap_connection_schedule_destroy(cc->conn, OSCAR_DISCONNECT_DONE);
	oscar_chat_destroy(cc);
}

static void
destroy_new_conn_data(NewFlapConnectionData *new_conn_data)
{
	if ((new_conn_data->data != NULL) &&
		(new_conn_data->conn->type == SNAC_FAMILY_CHAT))
	{
		oscar_chat_destroy(new_conn_data->data);
	}
	g_free(new_conn_data->cookie);
	g_free(new_conn_data);
}

/**
 * This is the callback function anytime gaim_proxy_connect()
 * establishes a new TCP connection with an oscar host.  Depending
 * on the type of host, we do a few different things here.
 */
static void
connection_established_cb(gpointer data, gint source)
{
	NewFlapConnectionData *new_conn_data;
	GaimConnection *gc;
	OscarData *od;
	GaimAccount *account;
	FlapConnection *conn;

	new_conn_data = data;
	gc = new_conn_data->gc;

	if (!GAIM_CONNECTION_IS_VALID(gc))
	{
		if (source >= 0)
			close(source);
		destroy_new_conn_data(new_conn_data);
		return;
	}

	od = gc->proto_data;
	account = gaim_connection_get_account(gc);
	conn = new_conn_data->conn;
	conn->fd = source;

	if (source < 0)
	{
		gaim_debug_error("oscar", "unable to connect FLAP server "

		if (conn->type == SNAC_FAMILY_LOCATE)
			gaim_connection_error(gc, _("Could not connect to BOS server"));
		else /* Maybe we should call this for BOS connections, too? */
			flap_connection_schedule_destroy(conn,
					OSCAR_DISCONNECT_COULD_NOT_CONNECT);
		destroy_new_conn_data(new_conn_data);
		return;
	}

	gaim_debug_info("oscar", "connected to FLAP server of type 0x%04hx\n",
			conn->type);
	conn->watcher_incoming = gaim_input_add(conn->fd,
			GAIM_INPUT_READ, flap_connection_recv_cb, conn);
	if (new_conn_data->cookie == NULL)
	{
		if (!aim_sn_is_icq(gaim_account_get_username(account)))
			/*
			 * We don't send this when authenticating an ICQ account
			 * because for some reason ICQ is still using the
			 * assy/insecure authentication procedure.
			 */
			flap_connection_send_version(od, conn);
	}
	else
		flap_connection_send_version_with_cookie(od, conn,
				new_conn_data->cookielen, new_conn_data->cookie);

	if (conn->type == SNAC_FAMILY_AUTH)
	{
		aim_request_login(od, conn, gaim_account_get_username(account));
		gaim_debug_info("oscar", "Screen name sent, waiting for response\n");

		gaim_connection_update_progress(gc, _("Connection established, cookie sent"), 4, OSCAR_CONNECT_STEPS);
		ck[4] = 0x61;
	}
	else if (conn->type == SNAC_FAMILY_CHAT)
	{
		od->oscar_chats = g_slist_append(od->oscar_chats, new_conn_data->data);
		new_conn_data->data = NULL;
	}

	destroy_new_conn_data(new_conn_data);
}

static void
flap_connection_established_bos(OscarData *od, FlapConnection *conn)
{

static void
oscar_login(GaimAccount *account)
{
	GaimConnection *gc;
	OscarData *od;
	NewFlapConnectionData *new_conn_data;

	gc = gaim_account_get_connection(account);
	od = gc->proto_data = oscar_data_new();
	od->gc = gc;

	}

	/* Connect to core Gaim signals */
	gaim_prefs_connect_callback(gc, "/plugins/prpl/oscar/recent_buddies", recent_buddies_cb, gc);

	new_conn_data = g_new(NewFlapConnectionData, 1);
	new_conn_data->gc = gc;
	new_conn_data->conn = flap_connection_new(od, SNAC_FAMILY_AUTH);
	new_conn_data->cookielen = 0;
	new_conn_data->cookie = NULL;
	new_conn_data->data = NULL;

	if (gaim_proxy_connect(account,
			gaim_account_get_string(account, "server", OSCAR_DEFAULT_LOGIN_SERVER),
			gaim_account_get_int(account, "port", OSCAR_DEFAULT_LOGIN_PORT),
			connection_established_cb, new_conn_data) == NULL)
	{
		gaim_connection_error(gc, _("Couldn't connect to host"));
		return;
	}

{
	GaimConnection *gc = od->gc;
	GaimAccount *account = gc->account;
	char *host; int port;
	int i;
	GaimProxyConnectInfo *connect_info;
	NewFlapConnectionData *new_conn_data;
	va_list ap;
	struct aim_authresp_info *info;

	port = gaim_account_get_int(account, "port", OSCAR_DEFAULT_LOGIN_PORT);

			port = atoi(&(info->bosip[i+1]));
			break;
		}
	}
	host = g_strndup(info->bosip, i);
	new_conn_data = g_new(NewFlapConnectionData, 1);
	new_conn_data->gc = gc;
	new_conn_data->conn = flap_connection_new(od, SNAC_FAMILY_LOCATE);
	new_conn_data->cookielen = info->cookielen;
	new_conn_data->cookie = g_memdup(info->cookie, info->cookielen);
	new_conn_data->data = NULL;
	connect_info = gaim_proxy_connect(gc->account, host, port,
			connection_established_cb, new_conn_data);
	g_free(host);
	if (connect_info == NULL) {
		gaim_connection_error(gc, _("Could Not Connect"));
		od->killme = TRUE;
		return 0;
	}

	aim_sendmemblock(od, pos->conn, 0, 16, m, AIM_SENDMEMBLOCK_FLAG_ISHASH);
	g_free(pos);
}

static void
straight_to_hell(gpointer data, gint source)
{
	struct pieceofcrap *pos = data;
	gchar *buf;

	pos->fd = source;

	if (source < 0) {
		buf = g_strdup_printf(_("You may be disconnected shortly.  You may want to use TOC until "
			"this is fixed.  Check %s for updates."), GAIM_WEBSITE);
		gaim_notify_warning(pos->gc, NULL,
							_("Gaim was unable to get a valid AIM login hash."),
							buf);
		g_free(buf);
		if (pos->modname)
			g_free(pos->modname);
		g_free(pos);
		return;
	}

	buf = g_strdup_printf("GET " AIMHASHDATA "?offset=%ld&len=%ld&modname=%s HTTP/1.0\n\n",
			pos->offset, pos->len, pos->modname ? pos->modname : "");
	write(pos->fd, buf, strlen(buf));
	g_free(buf);
	if (pos->modname)
		g_free(pos->modname);
	pos->inpa = gaim_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
	return;
}

/* size of icbmui.ocm, the largest module in AIM 3.5 */

	pos->offset = offset;
	pos->len = len;
	pos->modname = g_strdup(modname);

	if (gaim_proxy_connect(pos->gc->account, "gaim.sourceforge.net", 80,
			straight_to_hell, pos) == NULL)
	{
		char buf[256];
		if (pos->modname)

{
	GaimConnection *gc = od->gc;
	GaimAccount *account = gaim_connection_get_account(gc);
	char *host, *separator;
	int port;
	NewFlapConnectionData *new_conn_data;
	va_list ap;
	struct aim_redirect_data *redir;

	va_start(ap, fr);
	redir = va_arg(ap, struct aim_redirect_data *);

	else
		host = g_strdup(redir->ip);

	gaim_debug_info("oscar", "Connecting to FLAP server %s:%d of type 0x%04hx\n",
					host, port, redir->group);
	new_conn_data = g_new(NewFlapConnectionData, 1);
	new_conn_data->gc = gc;
	new_conn_data->conn = flap_connection_new(od, redir->group);
	new_conn_data->cookielen = redir->cookielen;
	new_conn_data->cookie = g_memdup(redir->cookie, redir->cookielen);
	if (new_conn_data->conn->type == SNAC_FAMILY_CHAT)
	{
		struct chat_connection *cc;
		cc = g_new0(struct chat_connection, 1);
		cc->conn = new_conn_data->conn;
		cc->gc = gc;
		cc->name = g_strdup(redir->chat.room);
		cc->exchange = redir->chat.exchange;
		cc->instance = redir->chat.instance;
		cc->show = extract_name(redir->chat.room);
		new_conn_data->data = cc;
		gaim_debug_info("oscar", "Connecting to chat room %s exchange %hu\n", cc->name, cc->exchange);
	}
	else
	{
		new_conn_data->data = NULL;
	}

	if (gaim_proxy_connect(account, host, port, connection_established_cb, new_conn_data) == NULL)
	{
		flap_connection_schedule_destroy(new_conn_data->conn,
				OSCAR_DISCONNECT_COULD_NOT_CONNECT);
		gaim_debug_error("oscar", "Unable to connect to FLAP server "
				"of type 0x%04hx\n", redir->group);
		destroy_new_conn_data(new_conn_data);
	}
	g_free(host);

	return 1;
}

14109:a21da42126d6

static guint8 features_aim[] = {0x01, 0x01, 0x01, 0x02};
static guint8 features_icq[] = {0x01, 0x06};
static guint8 features_icq_offline[] = {0x01};
static guint8 ck[] = {0x00, 0x00, 0x00, 0x00, 0x00, 0x00};

struct create_room {
	char *name;
	int exchange;
};

struct oscar_ask_directim_data
{
	OscarData *od;

	}

	return NULL;
}

void
oscar_chat_destroy(struct chat_connection *cc)
{
	g_free(cc->name);
	g_free(cc->show);
	g_free(cc);

	/* Destroy the chat_connection */
	od->oscar_chats = g_slist_remove(od->oscar_chats, cc);
	flap_connection_schedule_destroy(cc->conn, OSCAR_DISCONNECT_DONE);
	oscar_chat_destroy(cc);
}

/**
 * This is the callback function anytime gaim_proxy_connect()
 * establishes a new TCP connection with an oscar host.  Depending
 * on the type of host, we do a few different things here.
 */
static void
connection_established_cb(gpointer data, gint source, const gchar *error_message)
{
	GaimConnection *gc;
	OscarData *od;
	GaimAccount *account;
	FlapConnection *conn;

	conn = data;
	od = conn->od;
	gc = od->gc;
	account = gaim_connection_get_account(gc);

	conn->connect_info = NULL;
	conn->fd = source;

	if (source < 0)
	{
		gaim_debug_error("oscar", "unable to connect FLAP server "

		if (conn->type == SNAC_FAMILY_LOCATE)
			gaim_connection_error(gc, _("Could not connect to BOS server"));
		else /* Maybe we should call this for BOS connections, too? */
			flap_connection_schedule_destroy(conn,
					OSCAR_DISCONNECT_COULD_NOT_CONNECT);
		return;
	}

	gaim_debug_info("oscar", "connected to FLAP server of type 0x%04hx\n",
			conn->type);
	conn->watcher_incoming = gaim_input_add(conn->fd,
			GAIM_INPUT_READ, flap_connection_recv_cb, conn);
	if (conn->cookie == NULL)
	{
		if (!aim_sn_is_icq(gaim_account_get_username(account)))
			/*
			 * We don't send this when authenticating an ICQ account
			 * because for some reason ICQ is still using the
			 * assy/insecure authentication procedure.
			 */
			flap_connection_send_version(od, conn);
	}
	else
	{
		flap_connection_send_version_with_cookie(od, conn,
				conn->cookielen, conn->cookie);
		g_free(conn->cookie);
		conn->cookie = NULL;
	}

	if (conn->type == SNAC_FAMILY_AUTH)
	{
		aim_request_login(od, conn, gaim_account_get_username(account));
		gaim_debug_info("oscar", "Screen name sent, waiting for response\n");

		gaim_connection_update_progress(gc, _("Connection established, cookie sent"), 4, OSCAR_CONNECT_STEPS);
		ck[4] = 0x61;
	}
	else if (conn->type == SNAC_FAMILY_CHAT)
	{
		od->oscar_chats = g_slist_append(od->oscar_chats, conn->connect_data);
		conn->connect_data = NULL;
	}
}

static void
flap_connection_established_bos(OscarData *od, FlapConnection *conn)
{

static void
oscar_login(GaimAccount *account)
{
	GaimConnection *gc;
	OscarData *od;
	FlapConnection *newconn;

	gc = gaim_account_get_connection(account);
	od = gc->proto_data = oscar_data_new();
	od->gc = gc;

	}

	/* Connect to core Gaim signals */
	gaim_prefs_connect_callback(gc, "/plugins/prpl/oscar/recent_buddies", recent_buddies_cb, gc);

	newconn = flap_connection_new(od, SNAC_FAMILY_AUTH);
	newconn->connect_info = gaim_proxy_connect(account,
			gaim_account_get_string(account, "server", OSCAR_DEFAULT_LOGIN_SERVER),
			gaim_account_get_int(account, "port", OSCAR_DEFAULT_LOGIN_PORT),
			connection_established_cb, newconn);
	if (newconn->connect_info == NULL)
	{
		gaim_connection_error(gc, _("Couldn't connect to host"));
		return;
	}

{
	GaimConnection *gc = od->gc;
	GaimAccount *account = gc->account;
	char *host; int port;
	int i;
	FlapConnection *newconn;
	va_list ap;
	struct aim_authresp_info *info;

	port = gaim_account_get_int(account, "port", OSCAR_DEFAULT_LOGIN_PORT);

			port = atoi(&(info->bosip[i+1]));
			break;
		}
	}
	host = g_strndup(info->bosip, i);
	newconn = flap_connection_new(od, SNAC_FAMILY_LOCATE);
	newconn->cookielen = info->cookielen;
	newconn->cookie = g_memdup(info->cookie, info->cookielen);
	newconn->connect_info = gaim_proxy_connect(account, host, port,
			connection_established_cb, newconn);
	g_free(host);
	if (newconn->connect_info == NULL)
	{
		gaim_connection_error(gc, _("Could Not Connect"));
		od->killme = TRUE;
		return 0;
	}

	aim_sendmemblock(od, pos->conn, 0, 16, m, AIM_SENDMEMBLOCK_FLAG_ISHASH);
	g_free(pos);
}

static void
straight_to_hell(gpointer data, gint source, const gchar *error_message)
{
	struct pieceofcrap *pos = data;
	gchar *buf;

	if (!GAIM_CONNECTION_IS_VALID(pos->gc))
	{
		g_free(pos->modname);
		g_free(pos);
		return;
	}

	pos->fd = source;

	if (source < 0) {
		buf = g_strdup_printf(_("You may be disconnected shortly.  You may want to use TOC until "
			"this is fixed.  Check %s for updates."), GAIM_WEBSITE);
		gaim_notify_warning(pos->gc, NULL,
							_("Gaim was unable to get a valid AIM login hash."),
							buf);
		g_free(buf);
		g_free(pos->modname);
		g_free(pos);
		return;
	}

	buf = g_strdup_printf("GET " AIMHASHDATA "?offset=%ld&len=%ld&modname=%s HTTP/1.0\n\n",
			pos->offset, pos->len, pos->modname ? pos->modname : "");
	write(pos->fd, buf, strlen(buf));
	g_free(buf);
	g_free(pos->modname);
	pos->inpa = gaim_input_add(pos->fd, GAIM_INPUT_READ, damn_you, pos);
	return;
}

/* size of icbmui.ocm, the largest module in AIM 3.5 */

	pos->offset = offset;
	pos->len = len;
	pos->modname = g_strdup(modname);

	/* TODO: Keep track of this return value. */
	if (gaim_proxy_connect(pos->gc->account, "gaim.sourceforge.net", 80,
			straight_to_hell, pos) == NULL)
	{
		char buf[256];
		if (pos->modname)

{
	GaimConnection *gc = od->gc;
	GaimAccount *account = gaim_connection_get_account(gc);
	char *host, *separator;
	int port;
	FlapConnection *newconn;
	va_list ap;
	struct aim_redirect_data *redir;

	va_start(ap, fr);
	redir = va_arg(ap, struct aim_redirect_data *);

	else
		host = g_strdup(redir->ip);

	gaim_debug_info("oscar", "Connecting to FLAP server %s:%d of type 0x%04hx\n",
					host, port, redir->group);
	newconn = flap_connection_new(od, redir->group);
	newconn->cookielen = redir->cookielen;
	newconn->cookie = g_memdup(redir->cookie, redir->cookielen);
	if (newconn->type == SNAC_FAMILY_CHAT)
	{
		struct chat_connection *cc;
		cc = g_new0(struct chat_connection, 1);
		cc->conn = newconn;
		cc->gc = gc;
		cc->name = g_strdup(redir->chat.room);
		cc->exchange = redir->chat.exchange;
		cc->instance = redir->chat.instance;
		cc->show = extract_name(redir->chat.room);
		newconn->connect_data = cc;
		gaim_debug_info("oscar", "Connecting to chat room %s exchange %hu\n", cc->name, cc->exchange);
	}

	newconn->connect_info = gaim_proxy_connect(account, host, port,
			connection_established_cb, newconn);
	if (newconn->connect_info == NULL)
	{
		flap_connection_schedule_destroy(newconn, OSCAR_DISCONNECT_COULD_NOT_CONNECT);
		gaim_debug_error("oscar", "Unable to connect to FLAP server "
				"of type 0x%04hx\n", redir->group);
	}
	g_free(host);

	return 1;
}