diff plugins/msn/msn.c @ 1259:7db9121aac80

[gaim-migrate @ 1269] MSN plugin committer: Tailor Script <[e-mail]>

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/msn/msn.c	Thu Dec 14 08:33:41 2000 +0000
@@ -0,0 +1,733 @@
+/*
+ * gaim - MSN Protocol Plugin
+ *
+ * Copyright (C) 2000, Rob Flynn <[e-mail]>
+ * 
+ * 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 "../config.h"
+
+#include <netdb.h>
+#include <gtk/gtk.h>
+#include <unistd.h>
+#include <errno.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <string.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <time.h>
+#include <sys/socket.h>
+#include <sys/stat.h>
+#include "multi.h"
+#include "prpl.h"
+#include "gaim.h"
+#include "gnome_applet_mgr.h"
+#include "md5.h"
+
+#define MSN_BUF_LEN 4096
+
+#define MIME_HEADER "MIME-Version: 1.0\r\nContent-Type: text/plain; charset=UTF-8\r\nX-MMS-IM-Format: FN=MS%20Sans%20Serif; EF=; CO=0; CS=0; PF=0\r\n\r\n"
+
+#define MSN_ONLINE  1
+#define MSN_BUSY    2
+#define MSN_IDLE    3
+#define MSN_BRB     4
+#define MSN_AWAY    5
+#define MSN_PHONE   6
+#define MSN_LUNCH   7
+#define MSN_OFFLINE 8
+#define MSN_HIDDEN  9
+
+
+struct msn_ask_add_permit {
+	struct gaim_connection *gc;
+	char *user;
+	char *friendly;
+};
+
+struct msn_data {
+	int fd;
+
+	char protocol[6];
+	char *friendly;
+	gchar *policy;
+};
+
+struct msn_conn {
+	gchar *user;
+	int inpa;
+	int fd;
+};
+
+void msn_handler(gpointer data, gint source, GdkInputCondition condition);
+
+GSList * msn_connections = NULL;
+
+static char *msn_name() {
+	return "MSN";
+}
+
+char *name() {
+	return "MSN";
+}
+
+char *description() {
+	return "Allows gaim to use the MSN protocol.  For some reason, this frightens me.";
+}
+
+struct msn_conn *find_msn_conn_by_user(gchar *user) {
+	struct msn_conn *mc;
+	GSList *conns = msn_connections;
+
+	while (conns) {
+		mc = (struct msn_conn *)conns->data;
+
+		if (mc != NULL) {
+			if (strcasecmp(mc->user, user) == 0) {
+				return mc;
+			}
+		}
+
+		conns = g_slist_next(conns);
+	}
+
+	return NULL;
+}
+
+void msn_read_line(char *buf, int fd) {
+
+	int status;
+	char c;
+	int i = 0;
+	
+	do {
+		status = recv(fd, &c, 1, 0);
+
+		if (!status)
+			return;
+
+		buf[i] = c;
+		i++;
+	} while (c != '\n');
+
+	buf[i] = '\0';
+	g_strchomp(buf);
+
+	/* I'm a bastard again :-) */
+	printf("MSN: %s\n", buf);
+}
+
+int msn_connect(char *server, int port) {
+	int fd;
+	struct hostent *host;
+	struct sockaddr_in site;
+
+	printf("Connecting to '%s' on '%d'\n", server, port);
+	host = gethostbyname(server);
+	if (!host) {
+		return -1;
+	}
+
+	site.sin_family = AF_INET;
+	site.sin_addr.s_addr = *(long *)(host->h_addr);
+	site.sin_port = htons(port);
+
+	fd = socket(AF_INET, SOCK_STREAM, 0);
+	if (fd < 0) {
+		return -1;
+	}
+
+	if (connect(fd, (struct sockaddr *)&site, sizeof(site)) < 0) {
+		return -1;
+	}
+
+	return fd;
+}
+
+static void msn_add_buddy(struct gaim_connection *gc, char *who) {
+	struct msn_data *mdata = (struct msn_data *)gc->proto_data;
+	time_t trId = time((time_t *)NULL);
+	gchar buf[4096];
+
+	g_snprintf(buf, 4096, "ADD %d FL %s %s\n", trId, who, who);
+	write(mdata->fd, buf, strlen(buf));
+}
+
+static void msn_rem_permit(struct gaim_connection *gc, char *who) {
+	struct msn_data *mdata = (struct msn_data *)gc->proto_data;
+	time_t trId = time((time_t *)NULL);
+	gchar buf[4096];
+
+	g_snprintf(buf, 4096, "REM %d AL %s %s\n", trId, who, who);
+	write(mdata->fd, buf, strlen(buf));
+}
+
+static void msn_add_permit(struct gaim_connection *gc, char *who) {
+	struct msn_data *mdata = (struct msn_data *)gc->proto_data;
+	time_t trId = time((time_t *)NULL);
+	gchar buf[4096];
+
+	g_snprintf(buf, 4096, "ADD %d AL %s %s\n", trId, who, who);
+	write(mdata->fd, buf, strlen(buf));
+}
+
+static void msn_remove_buddy(struct gaim_connection *gc, char *who) {
+	struct msn_data *mdata = (struct msn_data *)gc->proto_data;
+	time_t trId = time((time_t *)NULL);
+	gchar buf[4096];
+
+	g_snprintf(buf, 4096, "REM %d FL %s\n", trId, who);
+	write(mdata->fd, buf, strlen(buf));
+}
+
+void msn_accept_add_permit (gpointer w, struct msn_ask_add_permit *ap ) {
+	gchar buf[4096];
+
+	msn_add_permit(ap->gc, ap->user);
+}
+
+void msn_cancel_add_permit (gpointer w, struct msn_ask_add_permit *ap ) {
+	
+	g_free(ap->user);
+	g_free(ap->friendly);
+	g_free(ap);
+}
+
+void msn_callback (struct gaim_connection * gc, gint fd) {
+	struct msn_data *mdata;
+	char c;
+	int i = 0;
+	int status;
+	gchar buf[4096];
+	gchar **resps;
+	
+	mdata = (struct msn_data *)gc->proto_data;
+
+	do {
+		/* Read data from whatever connection our inpa
+		 * refered us from */
+		status = recv(fd, &c, 1,0);
+
+		if (!status)
+			return;
+
+		buf[i] = c;
+		i++;	
+	} while (c != '\n');
+
+	buf[i] = '\0';
+
+	g_strchomp(buf);
+
+	printf("MSN: %s\n", buf);
+
+	if (strlen(buf) == 0) { return; }
+	
+	resps = g_strsplit(buf, " ", 0);
+
+	/* See if someone is bumping us */
+	if (strcasecmp(resps[0], "BYE") == 0) {
+		struct msn_conn *mc;
+		GSList * conns = msn_connections;
+		
+		/* Yup.  Let's find their convo and kill it */
+
+		mc = find_msn_conn_by_user(resps[1]);
+
+		/* If we have the convo, remove it */
+		if (mc != NULL) {
+			/* and remove it */
+			conns = g_slist_remove(conns, mc);
+
+			g_free(mc->user);
+			gdk_input_remove(mc->inpa);
+			close(mc->fd);
+
+
+			g_free(mc);
+		}
+
+		g_strfreev(resps);
+		return;
+	}
+
+	if (strcasecmp(resps[0], "ADD") == 0) {
+		
+		if (strcasecmp(resps[2], "RL") == 0) {
+			gchar buf[4096];
+			struct msn_ask_add_permit *ap = g_new0(struct msn_ask_add_permit, 1);
+		       
+			g_snprintf(buf, 4096, "The user %s (%s) wants to add you to their buddylist.", resps[4], resps[5]);
+
+			ap->user = g_strdup(resps[4]);
+			ap->friendly = g_strdup(resps[5]);
+			ap->gc = gc;
+
+			do_ask_dialog(buf, ap, (GtkFunction)msn_accept_add_permit, (GtkFunction)msn_cancel_add_permit);
+		}
+
+		g_strfreev(resps);
+		return;
+	}
+
+	if (strcasecmp(resps[0], "REM") == 0) {
+		
+		if (strcasecmp(resps[2], "RL") == 0) {
+			msn_rem_permit(gc, resps[4]);
+		}
+
+		g_strfreev(resps);
+		return;
+	}
+	
+	if (strcasecmp(resps[0], "FLN") == 0) {
+		serv_got_update(gc, resps[1], 0, 0, 0, 0, MSN_OFFLINE, 0);
+	}
+
+	if (strcasecmp(resps[0], "ILN") == 0) {
+		int status;
+
+		if (!strcasecmp(resps[2], "NLN"))
+			status = MSN_ONLINE;
+		else if (!strcasecmp(resps[2], "BSY"))
+			status = MSN_BUSY;
+		else if (!strcasecmp(resps[2], "IDL"))
+			status = MSN_IDLE;
+		else if (!strcasecmp(resps[2], "BRB"))
+			status = MSN_BRB;
+		else if (!strcasecmp(resps[2], "AWY"))
+			status = MSN_AWAY;
+		else if (!strcasecmp(resps[2], "PHN"))
+			status = MSN_PHONE;
+		else if (!strcasecmp(resps[2], "LUN"))
+			status = MSN_LUNCH;
+		else
+			status = MSN_ONLINE;
+
+		serv_got_update(gc, resps[3], 1, 0, 0, 0, status, 0);
+
+		g_strfreev(resps);
+		return;
+		
+	}
+	
+	/* Check buddy update status */
+	if (strcasecmp(resps[0], "NLN") == 0) { 
+		/* FIXME: We currently dont care if they are busy,
+		 * idle, brb, away, phone, our out to lunch. This will
+		 * be supported eventually (BSY,IDL,BRB,AWY,PHN,LUN) 
+		 * respectively */
+
+		serv_got_update(gc, resps[2], 1, 0, 0, 0, MSN_ONLINE, 0);
+	}
+	
+	/* Check to see if we have an incoming buddylist */
+	if (strcasecmp(resps[0], "LST") == 0) { 
+		/* Check to see if there are any buddies in the list */
+		if (atoi(resps[5]) == 0) {
+			/* No buddies */
+			g_strfreev(resps);
+			return;
+		}
+
+		/* FIXME: We should support the permit and deny
+		 * lists as well */
+
+		if (strcasecmp(resps[2], "FL") == 0) {
+			struct buddy *b;
+
+			b = find_buddy(gc, resps[6]);
+
+			if (!b)
+				add_buddy(gc, "Buddies", resps[6], resps[6]);
+		}
+		
+		g_strfreev(resps);
+		return;
+	}
+	
+	/* Check to see if we got a message request */
+	if (strcasecmp(resps[0], "MSG") == 0) {
+		gchar *message;
+		gchar *buf2;
+		int size;
+		int status;
+		
+		/* Determine our message size */
+		size = atoi(resps[3]);
+
+		buf2 = (gchar *)g_malloc(sizeof(gchar) * (size+1));
+		status = recv(fd, buf2, size, 0);
+		buf2[size] = 0;
+
+		/* Looks like we got the message. If it's blank, let's bail */
+		if (strcasecmp(strstr(buf2, "\r\n\r\n")+4, "\r\n") == 0) {
+			g_free(buf2);
+			g_strfreev(resps);
+			return;
+		}
+
+		serv_got_im(gc, resps[1], strstr(buf2, "\r\n\r\n")+4, 0);
+
+		g_free(buf2);
+		g_strfreev(resps);
+		return;
+	}
+	
+
+	/* Check to see if we got a ring request */
+	if (strcasecmp(resps[0], "RNG") == 0) {
+		gchar **address;
+		struct msn_conn *mc = g_new0(struct msn_conn, 1);
+
+		address = g_strsplit(resps[2], ":", 0);
+
+		if (!(mc->fd = msn_connect(address[0], atoi(address[1])))) {
+			do_error_dialog(resps[5], "Msg Err from");
+			g_strfreev(address);
+			g_strfreev(resps);
+			g_free(mc);
+			return;
+		}
+
+		mc->user = g_strdup(resps[5]);
+
+		mc->inpa = gdk_input_add(mc->fd, GDK_INPUT_READ, msn_handler, gc);
+		
+		g_snprintf(buf, 4096, "ANS 1 %s %s %s\n", gc->username, resps[4], resps[1]);
+		write(mc->fd, buf, strlen(buf));
+
+		msn_connections = g_slist_append(msn_connections, mc);
+
+		g_strfreev(address);
+		g_strfreev(resps);
+		return;
+	}
+
+	g_strfreev(resps);
+
+}
+
+
+void msn_handler(gpointer data, gint source, GdkInputCondition condition) {
+	msn_callback(data, source);
+}
+
+void msn_login(struct aim_user *user) {
+	time_t trId = time((time_t *)NULL);
+	char buf[4096];
+	char buf2[4096];
+	
+	struct gaim_connection *gc = new_gaim_conn(user);
+	struct msn_data *mdata = gc->proto_data = g_new0(struct msn_data, 1);
+	char c;
+	int i;
+	int status;
+
+	md5_state_t st;
+	md5_byte_t di[16];
+	int x;
+
+	gchar **results;
+
+	g_snprintf(mdata->protocol, strlen("MSNP2")+1, "MSNP2");
+	
+	set_login_progress(gc, 1,"Connecting");
+
+	while (gtk_events_pending())
+		gtk_main_iteration();
+	if (!g_slist_find(connections, gc))
+		return;
+
+	if (!(mdata->fd = msn_connect("messenger.hotmail.com", 1863))) {
+		hide_login_progress(gc, "Error connection to server");
+		signoff(gc);
+		return;	
+	}
+	
+	g_snprintf(buf, sizeof(buf), "Signon: %s", gc->username);
+	set_login_progress(gc, 2, buf);
+
+	/* This is where we will attempt to sign on */
+	g_snprintf(buf, 4096, "VER %d %s\n", trId, mdata->protocol);
+	write(mdata->fd, buf, strlen(buf));
+
+	msn_read_line(&buf2, mdata->fd);
+
+	buf[strlen(buf)-1] = '\0';
+	if (strcmp(buf, buf2) != 0) {
+		hide_login_progress(gc, buf2);
+		signoff(gc);
+		return;
+	}
+
+	/* Looks like our versions matched up.  Let's find out
+	 * which policy we should use */
+
+	g_snprintf(buf, 4096, "INF %d\n", trId);
+	write(mdata->fd, buf, strlen(buf));
+
+	msn_read_line(&buf2, mdata->fd);
+	results = g_strsplit(buf2, " ", 0);
+	mdata->policy = g_strdup(results[2]);
+	g_strfreev(results);
+
+	/* We've set our policy.  Now, lets attempt a sign on */
+	g_snprintf(buf, 4096, "USR %d %s I %s\n", trId, mdata->policy, gc->username);	
+	write(mdata->fd, buf, strlen(buf));
+
+	msn_read_line(&buf2, mdata->fd);
+
+	/* This is where things get kinky */
+	results = g_strsplit(buf2, " ", 0);
+
+	/* Are we being transfered to another server ?  */
+	if (strcasecmp(results[0], "XFR") == 0) {
+		/* Yup.  We should connect to the _new_ server */
+		strcpy(buf, results[3]);
+		g_strfreev(results);
+
+		results = g_strsplit(buf, ":", 0);
+
+		/* Connect to the new server */
+		if (!(mdata->fd = msn_connect(results[0], atoi(results[1])))) {
+			hide_login_progress(gc, "Error connecting to server");
+			signoff(gc);
+			g_strfreev(results);
+			return;	
+		}
+
+
+		g_strfreev(results);
+
+		/* We're now connected to the new server.  Send signon
+		 * information again */
+		g_snprintf(buf, 4096, "USR %d %s I %s\n", trId, mdata->policy, gc->username);	
+		write(mdata->fd, buf, strlen(buf));
+
+		msn_read_line(&buf, mdata->fd);
+		results = g_strsplit(buf, " ", 0);
+
+	}
+	
+	/* Otherwise, if we have a USR response, let's handle it */
+	if (strcasecmp("USR", results[0]) == 0) {
+		/* Looks like we got a response.  Let's get our challenge
+		 * string */
+		strcpy(buf, results[4]);
+
+	}
+	else {
+		g_strfreev(results);
+		hide_login_progress(gc, "Error signing on");
+		signoff(gc);
+		return;
+	}
+	g_strfreev(results);
+
+	/* Build our response string */
+	snprintf(buf2, 4096, "%s%s", buf, gc->password);
+
+	/* Use the MD5 Hashing */
+	md5_init(&st);
+	md5_append(&st, (const md5_byte_t *)buf2, strlen(buf2));
+	md5_finish(&st, di);
+
+	/* And now encode it in hex */
+	sprintf(buf, "%02x", di[0]);
+	for (x = 1; x < 16; x++) {
+		sprintf(buf, "%s%02x", buf, di[x]);
+	}
+
+	/* And now we should fire back a response */
+	g_snprintf(buf2, 4096, "USR %d %s S %s\n", trId, mdata->policy, buf);
+	write(mdata->fd, buf2, strlen(buf2));
+
+
+	msn_read_line(&buf, mdata->fd);
+
+	results = g_strsplit(buf, " ", 0);
+
+	if ((strcasecmp("USR", results[0]) == 0) && (strcasecmp("OK", results[2]) == 0)) {
+		mdata->friendly = g_strdup(results[4]);
+		g_strfreev(results);
+	}
+	else {
+		g_strfreev(results);
+		hide_login_progress(gc, "Error signing on!");
+		signoff(gc);
+		return;
+
+	}
+	set_login_progress(gc, 3, "Getting Config");
+	g_snprintf(buf, 4096, "SYN %d 0\n", trId);
+	write(mdata->fd, buf, strlen(buf));
+
+	/* Go online */
+	g_snprintf(buf, 4096, "CHG %d NLN\n", trId);
+	write(mdata->fd, buf, strlen(buf));
+
+	account_online(gc);
+	serv_finish_login(gc);
+
+	if (bud_list_cache_exists(gc))
+		do_import(NULL, gc);
+
+	/* We want to do this so that we can read what's going on */
+	gc->inpa = gdk_input_add(mdata->fd, GDK_INPUT_READ, msn_handler, gc);
+}
+
+void msn_send_im(struct gaim_connection *gc, char *who, char *message, int away) {
+	struct msn_conn *mc;
+	struct msn_data *mdata;
+	time_t trId = time((time_t *)NULL);
+	char *buf;
+
+	mdata = (struct msn_data *)gc->proto_data;
+	mc = find_msn_conn_by_user(who);
+
+	if (mc == NULL)
+	{
+		gchar buf2[4096];
+		gchar *address;
+		gchar *auth;
+		gchar **resps;
+
+		/* Request a new switchboard connection */
+		g_snprintf(buf2, 4096, "XFR %d SB\n", trId);
+		write(mdata->fd, buf2, strlen(buf2));
+		
+		/* Read the results */
+		msn_read_line(&buf2, mdata->fd);
+
+		resps = g_strsplit(buf2, " ", 0);
+
+		address = g_strdup(resps[3]);
+		auth = g_strdup(resps[5]);
+		g_strfreev(resps);
+
+		resps = g_strsplit(address, ":", 0);
+
+		mc = g_new0(struct msn_conn, 1);
+
+		if (!(mc->fd = msn_connect(resps[0], atoi(resps[1])))) {
+			g_strfreev(resps);
+			g_free(address);
+			g_free(auth);
+			g_free(mc);
+			return;
+		}
+
+		/* Looks like we got connected ok. Now, let's verify */
+		g_snprintf(buf2, 4096, "USR %d %s %s\n", trId, gc->username, auth);
+		write(mc->fd, buf2, strlen(buf2));
+
+		/* Read the results */
+		msn_read_line(&buf2, mc->fd);
+		g_strfreev(resps);
+		
+		resps = g_strsplit(buf2, " ", 0);
+		
+		if (!(strcasecmp("OK", resps[2]) == 0)) {
+			g_free(auth);
+			g_free(address);
+			g_strfreev(resps);
+			g_free(mc);
+			return;
+		}
+
+		mc->user = g_strdup(who);
+		mc->inpa = gdk_input_add(mc->fd, GDK_INPUT_READ, msn_handler, gc);
+
+		msn_connections = g_slist_append(msn_connections, mc);
+
+		/* Now we must invite our new user to the switchboard session */
+		g_snprintf(buf2, 4096, "CAL %d %s\n", trId, who);
+		write(mc->fd, buf2, strlen(buf2));
+
+		/* FIXME: This causes a delay.  I will make some sort of queing feature to prevent
+		 * this from being needed */
+
+		while (!strstr(buf2, "JOI")) {
+			msn_read_line(&buf2, mc->fd);
+		}
+		
+		g_free(auth);
+		g_free(address);
+		g_strfreev(resps);
+
+	}
+
+	/* Always practice safe sets :-) */ 
+	buf = (gchar *)g_malloc(sizeof(gchar) * (strlen(message) + strlen(MIME_HEADER) + 64));
+
+	g_snprintf(buf, strlen(message) + strlen(MIME_HEADER) + 64, "MSG %d N %d\r\n%s%s", trId, strlen(message)+strlen(MIME_HEADER), MIME_HEADER, message);
+
+	write(mc->fd, buf, strlen(buf));
+
+	g_free(buf);
+}
+
+static struct prpl *my_protocol = NULL;
+
+void msn_init(struct prpl *ret) {
+	ret->protocol = PROTO_MSN;
+	ret->name = msn_name;
+	ret->list_icon = NULL;
+	ret->action_menu = NULL;
+	ret->user_opts = NULL;
+	ret->login = msn_login;
+	ret->close = NULL;
+	ret->send_im = msn_send_im;
+	ret->set_info = NULL;
+	ret->get_info = NULL;
+	ret->set_away = NULL;
+	ret->get_away_msg = NULL;
+	ret->set_dir = NULL;
+	ret->get_dir = NULL;
+	ret->dir_search = NULL;
+	ret->set_idle = NULL;
+	ret->change_passwd = NULL;
+	ret->add_buddy = msn_add_buddy;
+	ret->add_buddies = NULL;
+	ret->remove_buddy = msn_remove_buddy;
+	ret->add_permit = msn_add_permit;
+	ret->rem_permit = msn_rem_permit;
+	ret->add_deny = NULL;
+	ret->warn = NULL;
+	ret->accept_chat = NULL;
+	ret->join_chat = NULL;
+	ret->chat_invite = NULL;
+	ret->chat_leave = NULL;
+	ret->chat_whisper = NULL;
+	ret->chat_send = NULL;
+	ret->keepalive = NULL;
+
+	my_protocol = ret;
+}
+
+char *gaim_plugin_init(GModule *handle) {
+	load_protocol(msn_init);
+	return NULL;
+}
+
+void gaim_plugin_remove() {
+	struct prpl *p = find_prpl(PROTO_MSN);
+	if (p == my_protocol)
+		unload_protocol(p);
+}