diff plugins/icq/gaim_icq.c @ 1152:201ec77f3a60

[gaim-migrate @ 1162] icq. whoop de doo committer: Tailor Script <tailor@pidgin.im>
author Eric Warmenhoven <eric@warmenhoven.org>
date Tue, 28 Nov 2000 02:22:42 +0000
parents
children 3063e6743913
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/icq/gaim_icq.c	Tue Nov 28 02:22:42 2000 +0000
@@ -0,0 +1,292 @@
+#include <gtk/gtk.h>
+#include "icq.h"   /* well, we're doing ICQ, right? */
+#include "multi.h" /* needed for gaim_connection */
+#include "prpl.h"  /* needed for prpl */
+#include "gaim.h"  /* needed for every other damn thing */
+
+struct icq_data {
+	ICQLINK *link;
+	int cur_status;
+	int tcp_timer;
+	int ack_timer;
+};
+
+static struct gaim_connection *find_gaim_conn_by_icq_link(ICQLINK *link) {
+	GSList *c = connections;
+	struct gaim_connection *gc = NULL;
+	struct icq_data *id;
+
+	while (c) {
+		gc = (struct gaim_connection *)c->data;
+		if (gc->protocol == PROTO_ICQ) {
+			id = (struct icq_data *)gc->proto_data;
+			if (id->link == link)
+				break;
+		}
+		gc = NULL;
+		c = c->next;
+	}
+
+	return gc;
+}
+
+static char *icq_name() {
+	return "ICQ";
+}
+
+static void icq_do_log(ICQLINK *link, time_t time, unsigned char level, const char *log) {
+	debug_printf("ICQ debug %d: %s", level, log);
+}
+
+static gint icq_tcp_timer(ICQLINK *link) {
+	icq_TCPMain(link);
+	return TRUE;
+}
+
+static void icq_callback(gpointer data, gint source, GdkInputCondition condition) {
+	struct gaim_connection *gc = (struct gaim_connection *)data;
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	debug_printf("ICQ Callback handler\n");
+
+	icq_HandleServerResponse(id->link);
+}
+
+static void icq_online(ICQLINK *link) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	debug_printf("%s is now online.\n", gc->username);
+	account_online(gc);
+	serv_finish_login(gc);
+
+	if (bud_list_cache_exists(gc))
+		do_import(NULL, gc);
+
+	icq_ChangeStatus(id->link, STATUS_ONLINE);
+}
+
+static void icq_logged_off(ICQLINK *link) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	int icqSocket;
+
+	gtk_timeout_remove(id->tcp_timer);
+	gdk_input_remove(gc->inpa);
+
+	if (icq_Connect(link, "icq.mirabilis.com", 4000) < 1) {
+		hide_login_progress(gc, "Unable to connect");
+		g_free(id);
+		signoff(gc);
+		return;
+	}
+
+	icqSocket = icq_GetSok(link);
+	gc->inpa = gdk_input_add(icqSocket, GDK_INPUT_READ | GDK_INPUT_EXCEPTION, icq_callback, gc);
+
+	icq_Login(link, STATUS_ONLINE);
+	id->cur_status = STATUS_ONLINE;
+
+	id->tcp_timer = gtk_timeout_add(100, (GtkFunction)icq_tcp_timer, link);
+}
+
+static void icq_msg_incoming(ICQLINK *link, unsigned long uin, unsigned char hour, unsigned char minute,
+			unsigned char day, unsigned char month, unsigned short year, const char *data) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	char buf[256], *tmp = g_strdup(data);
+	g_snprintf(buf, sizeof buf, "%lu", uin);
+	serv_got_im(gc, buf, tmp, 0);
+	g_free(tmp);
+}
+
+static void icq_user_online(ICQLINK *link, unsigned long uin, unsigned long status,
+				unsigned long ip, unsigned short port, unsigned long real_ip,
+				unsigned char tcp_flags) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	char buf[256]; g_snprintf(buf, sizeof buf, "%lu", uin);
+	serv_got_update(gc, buf, 1, 0, 0, 0, (status==STATUS_ONLINE) ? UC_NORMAL : UC_UNAVAILABLE, 0);
+}
+
+static void icq_user_offline(ICQLINK *link, unsigned long uin) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	char buf[256]; g_snprintf(buf, sizeof buf, "%lu", uin);
+	serv_got_update(gc, buf, 0, 0, 0, 0, 0, 0);
+}
+
+static void icq_user_status(ICQLINK *link, unsigned long uin, unsigned long status) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	char buf[256]; g_snprintf(buf, sizeof buf, "%lu", uin);
+	serv_got_update(gc, buf, 1, 0, 0, 0, (status==STATUS_ONLINE) ? UC_NORMAL : UC_UNAVAILABLE, 0);
+}
+
+static gint icq_set_timeout_cb(struct icq_data *id) {
+	icq_HandleTimeout(id->link);
+	id->ack_timer = -1;
+	return FALSE;
+}
+
+static void icq_set_timeout(ICQLINK *link, long interval) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+
+	debug_printf("icq_SetTimeout: %ld\n", interval);
+	if (interval > 0 && id->ack_timer < 1)
+		id->ack_timer = gtk_timeout_add(interval * 1000, (GtkFunction)icq_set_timeout_cb, id);
+	else if (id->ack_timer > 0) {
+		gtk_timeout_remove(id->ack_timer);
+		id->ack_timer = -1;
+	}
+}
+
+static void icq_url_incoming(struct icq_link *link, unsigned long uin, unsigned char hour,
+				unsigned char minute, unsigned char day, unsigned char month,
+				unsigned short year, const char *url, const char *descr) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	int len = strlen(url) + strlen(descr) + 25; /* 25 is straight out of my ass */
+	char *msg = g_malloc(len), buf[256];
+	g_snprintf(msg, len, "<A HREF=\"%s\">%s</A>", url, descr);
+	g_snprintf(buf, 256, "%lu", uin);
+	serv_got_im(gc, buf, msg, 0);
+	g_free(msg);
+}
+
+static void icq_wrong_passwd(struct icq_link *link) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	hide_login_progress(gc, "Invalid password.");
+	signoff(gc);
+}
+
+static void icq_invalid_uin(struct icq_link *link) {
+	struct gaim_connection *gc = find_gaim_conn_by_icq_link(link);
+	hide_login_progress(gc, "Invalid UIN.");
+	signoff(gc);
+}
+
+static void icq_login(struct aim_user *user) {
+	struct gaim_connection *gc = new_gaim_conn(user);
+	struct icq_data *id = gc->proto_data = g_new0(struct icq_data, 1);
+	ICQLINK *link = id->link = g_new0(ICQLINK, 1);
+	int icqSocket;
+
+	icq_LogLevel = ICQ_LOG_MESSAGE;
+
+	icq_Init(link, atol(user->username), user->password, "gaim user" /* hehe :) */);
+
+	link->icq_Logged = icq_online;
+	link->icq_Disconnected = icq_logged_off;
+	link->icq_RecvMessage = icq_msg_incoming;
+	link->icq_RecvURL = icq_url_incoming;
+	link->icq_UserOnline = icq_user_online;
+	link->icq_UserOffline = icq_user_offline;
+	link->icq_UserStatusUpdate = icq_user_status;
+	link->icq_WrongPassword = icq_wrong_passwd;
+	link->icq_InvalidUIN = icq_invalid_uin;
+	link->icq_Log = icq_do_log;
+	link->icq_SetTimeout = icq_set_timeout;
+
+	icq_UnsetProxy(link);
+
+	if (icq_Connect(link, "icq.mirabilis.com", 4000) < 1) {
+		hide_login_progress(gc, "Unable to connect");
+		g_free(id);
+		signoff(gc);
+		return;
+	}
+
+	icqSocket = icq_GetSok(link);
+	gc->inpa = gdk_input_add(icqSocket, GDK_INPUT_READ | GDK_INPUT_EXCEPTION, icq_callback, gc);
+
+	icq_Login(link, STATUS_ONLINE);
+	id->cur_status = STATUS_ONLINE;
+
+	id->tcp_timer = gtk_timeout_add(100, (GtkFunction)icq_tcp_timer, link);
+
+	set_login_progress(gc, 0, "Connecting...");
+}
+
+static void icq_close(struct gaim_connection *gc) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+
+	gtk_timeout_remove(id->tcp_timer);
+	gdk_input_remove(gc->inpa);
+	icq_Logout(id->link);
+	icq_Disconnect(id->link);
+	icq_Done(id->link);
+	g_free(id->link);
+}
+
+static struct prpl *my_protocol = NULL;
+
+static void icq_send_msg(struct gaim_connection *gc, char *who, char *msg, int away) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	icq_SendMessage(id->link, atol(who), msg, !away);
+}
+
+static void icq_keepalive(struct gaim_connection *gc) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	icq_KeepAlive(id->link);
+}
+
+static void icq_add_buddy(struct gaim_connection *gc, char *who) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	icq_ContactAdd(id->link, atol(who));
+	icq_ContactSetVis(id->link, atol(who), TRUE);
+	icq_SendNewUser(id->link, atol(who));
+}
+
+static void icq_add_buddies(struct gaim_connection *gc, GList *whos) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	while (whos) {
+		icq_ContactAdd(id->link, atol(whos->data));
+		icq_ContactSetVis(id->link, atol(whos->data), TRUE);
+		icq_SendNewUser(id->link, atol(whos->data));
+		whos = whos->next;
+	}
+}
+
+static void icq_rem_buddy(struct gaim_connection *gc, char *who) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+	icq_ContactRemove(id->link, atol(who));
+}
+
+static void icq_set_away(struct gaim_connection *gc, char *msg) {
+	struct icq_data *id = (struct icq_data *)gc->proto_data;
+
+	if (msg && msg[0]) {
+		icq_ChangeStatus(id->link, STATUS_NA);
+	} else {
+		icq_ChangeStatus(id->link, STATUS_ONLINE);
+	}
+}
+
+static void icq_init(struct prpl *ret) {
+	ret->protocol = PROTO_ICQ;
+	ret->name = icq_name;
+	ret->login = icq_login;
+	ret->close = icq_close;
+	ret->send_im = icq_send_msg;
+	ret->add_buddy = icq_add_buddy;
+	ret->add_buddies = icq_add_buddies;
+	ret->remove_buddy = icq_rem_buddy;
+	ret->set_away = icq_set_away;
+	ret->keepalive = icq_keepalive;
+
+	my_protocol = ret;
+}
+
+char *gaim_plugin_init(GModule *handle) {
+	load_protocol(icq_init);
+	return NULL;
+}
+
+void gaim_plugin_remove() {
+	struct prpl *p = find_prpl(PROTO_ICQ);
+	if (p == my_protocol)
+		unload_protocol(p);
+}
+
+char *name() {
+	return "ICQ";
+}
+
+char *description() {
+	return "Allows gaim to use the ICQ protocol";
+}