Context Navigation

source: skype/skype.c @ 09be265

Last change on this file since 09be265 was 348a3a2, checked in by VMiklos <vmiklos@…>, at 2007-08-20T22:38:06Z
use SET USERSTATUS on login/logout
Property mode set to `100644`
File size: 8.4 KB

Rev	Line
[f06e3ac]	1	/*
	2	* This is the most simple possible BitlBee plugin. To use, compile it as
	3	* a shared library and place it in the plugin directory:
	4	*
	5	* gcc -o example.so -shared example.c `pkg-config --cflags bitlbee`
	6	* cp example.so /usr/local/lib/bitlbee
	7	*/
	8	#include <stdio.h>
[ed2e37f]	9	#include <poll.h>
[f06e3ac]	10	#include <bitlbee.h>
	11
	12	#define SKYPE_PORT_DEFAULT "2727"
	13
	14	struct skype_data
	15	{
	16	struct im_connection *ic;
[a3d6427]	17	char *username;
[f06e3ac]	18	int fd;
	19	char *txq;
	20	int tx_len;
	21	int r_inpa, w_inpa;
[77c1abe]	22	// when we receive a new message id, we query the handle, then the body
	23	// store the handle here
	24	// TODO: it would be nicer to use a hashmap for this or something
	25	char *handle;
[f06e3ac]	26	};
	27
[adce2de]	28	struct skype_away_state
	29	{
	30	char *code;
	31	char *full_name;
	32	};
	33
	34	const struct skype_away_state skype_away_state_list[] =
	35	{
	36	{ "ONLINE", "Online" },
	37	{ "SKYPEME", "Skype Me" },
	38	{ "AWAY", "Away" },
	39	{ "NA", "Not available" },
	40	{ "DND", "Do Not Disturb" },
	41	{ "INVISIBLE", "Invisible" },
[23411c6]	42	{ "OFFLINE", "Offline" },
	43	{ NULL, NULL}
[adce2de]	44	};
	45
[f06e3ac]	46	static void skype_init( account_t *acc )
	47	{
	48	set_t *s;
	49
	50	s = set_add( &acc->set, "port", SKYPE_PORT_DEFAULT, set_eval_int, acc );
	51	s->flags \|= ACC_SET_OFFLINE_ONLY;
	52
	53	s = set_add( &acc->set, "server", NULL, set_eval_account, acc );
	54	s->flags \|= ACC_SET_NOSAVE \| ACC_SET_OFFLINE_ONLY;
	55	}
	56
	57	int skype_write( struct im_connection ic, char buf, int len )
	58	{
	59	struct skype_data *sd = ic->proto_data;
	60
[9fd4241]	61	printf("write(): %s", buf);
	62	write( sd->fd, buf, len );
[f06e3ac]	63
[9fd4241]	64	return TRUE;
[f06e3ac]	65	}
	66
[1323e36]	67	static gboolean skype_read_callback( gpointer data, gint fd, b_input_condition cond )
	68	{
	69	struct im_connection *ic = data;
	70	struct skype_data *sd = ic->proto_data;
	71	char buf[1024];
	72	int st;
[9fd4241]	73	char lines, lineptr, line, ptr;
[1323e36]	74
[98bca36]	75	if( !sd \|\| sd->fd == -1 )
[1323e36]	76	return FALSE;
	77	st = read( sd->fd, buf, sizeof( buf ) );
	78	if( st > 0 )
	79	{
	80	buf[st] = '\0';
	81	printf("read(): '%s'\n", buf);
[9fd4241]	82	lines = g_strsplit(buf, "\n", 0);
	83	lineptr = lines;
	84	while((line = *lineptr))
	85	{
	86	if(!strlen(line))
	87	break;
	88	printf("skype_read_callback() new line: '%s'\n", line);
	89	if(!strncmp(line, "USERS ", 6))
	90	{
	91	char **i;
	92	char **nicks;
	93
	94	nicks = g_strsplit(line + 6, ", ", 0);
	95	i = nicks;
	96	while(*i)
	97	{
	98	g_snprintf(buf, 1024, "GET USER %s ONLINESTATUS\n", *i);
	99	skype_write( ic, buf, strlen( buf ) );
	100	i++;
	101	}
	102	g_strfreev(nicks);
	103	}
	104	else if(!strncmp(line, "USER ", 5))
	105	{
[adce2de]	106	int flags = 0;
[be975f8]	107	char *status = strrchr(line, ' ');
	108	char *user = strchr(line, ' ');
[adce2de]	109	status++;
[be975f8]	110	ptr = strchr(++user, ' ');
	111	*ptr = '\0';
[6627d92]	112	ptr++;
	113	if(!strncmp(ptr, "ONLINESTATUS ", 13) && strcmp(user, sd->username) != 0 && strcmp(user, "echo123") != 0)
[a3d6427]	114	{
	115	ptr = g_strdup_printf("%s@skype.com", user);
	116	imcb_add_buddy(ic, ptr, NULL);
	117	if(strcmp(status, "OFFLINE") != 0)
	118	flags \|= OPT_LOGGED_IN;
	119	if(strcmp(status, "ONLINE") != 0 && strcmp(status, "SKYPEME") != 0)
	120	flags \|= OPT_AWAY;
	121	imcb_buddy_status(ic, ptr, flags, NULL, NULL);
	122	g_free(ptr);
	123	}
[9fd4241]	124	}
[77c1abe]	125	else if(!strncmp(line, "CHATMESSAGE ", 12))
	126	{
	127	char *id = strchr(line, ' ');
	128	if(++id)
	129	{
	130	char *info = strchr(id, ' ');
	131	*info = '\0';
	132	info++;
	133	if(!strcmp(info, "STATUS RECEIVED"))
	134	{
	135	// new message, request its body
	136	printf("new received message #%s\n", id);
	137	g_snprintf(buf, 1024, "GET CHATMESSAGE %s FROM_HANDLE\n", id);
	138	skype_write( ic, buf, strlen( buf ) );
	139	g_snprintf(buf, 1024, "GET CHATMESSAGE %s BODY\n", id);
	140	skype_write( ic, buf, strlen( buf ) );
[62bb4e4]	141	g_snprintf(buf, 1024, "SET CHATMESSAGE %s SEEN\n", id);
	142	skype_write( ic, buf, strlen( buf ) );
[77c1abe]	143	}
	144	else if(!strncmp(info, "FROM_HANDLE ", 12))
	145	{
	146	info += 12;
	147	// new handle
	148	sd->handle = g_strdup_printf("%s@skype.com", info);
	149	printf("new handle: '%s'\n", info);
	150	}
	151	else if(!strncmp(info, "BODY ", 5))
	152	{
	153	info += 5;
	154	// new body
	155	printf("<%s> %s\n", sd->handle, info);
[ed2e37f]	156	if(sd->handle)
	157	imcb_buddy_msg(ic, sd->handle, info, 0, 0);
[77c1abe]	158	g_free(sd->handle);
	159	sd->handle = NULL;
	160	}
	161	}
	162	}
[9fd4241]	163	lineptr++;
	164	}
	165	g_strfreev(lines);
[1323e36]	166	}
	167	else if( st == 0 \|\| ( st < 0 && !sockerr_again() ) )
	168	{
	169	closesocket( sd->fd );
	170	sd->fd = -1;
	171
	172	imcb_error( ic, "Error while reading from server" );
	173	imc_logout( ic, TRUE );
	174	return FALSE;
	175	}
	176
	177	/* EAGAIN/etc or a successful read. */
	178	return TRUE;
	179	}
	180
[f06e3ac]	181	gboolean skype_start_stream( struct im_connection *ic )
	182	{
[1323e36]	183	struct skype_data *sd = ic->proto_data;
[f06e3ac]	184	char *buf;
	185	int st;
	186
[1323e36]	187	if( sd->r_inpa <= 0 )
	188	sd->r_inpa = b_input_add( sd->fd, GAIM_INPUT_READ, skype_read_callback, ic );
	189
[9fd4241]	190	// download buddies
	191	buf = g_strdup_printf("SEARCH FRIENDS\n");
[f06e3ac]	192	st = skype_write( ic, buf, strlen( buf ) );
	193	g_free(buf);
[348a3a2]	194	buf = g_strdup_printf("SET USERSTATUS ONLINE\n");
	195	skype_write( ic, buf, strlen( buf ) );
	196	g_free(buf);
[f06e3ac]	197	return st;
	198	}
	199
	200	gboolean skype_connected( gpointer data, gint source, b_input_condition cond )
	201	{
	202	struct im_connection *ic = data;
[1323e36]	203	struct skype_data *sd = ic->proto_data;
[ed2e37f]	204	struct pollfd pfd[1];
[f06e3ac]	205
[ed2e37f]	206	pfd[0].fd = sd->fd;
	207	pfd[0].events = POLLOUT;
	208
	209	poll(pfd, 1, 1000);
	210	if(pfd[0].revents & POLLHUP)
[1323e36]	211	{
	212	imcb_error( ic, "Could not connect to server" );
	213	imc_logout( ic, TRUE );
[9fd4241]	214	return FALSE;
[1323e36]	215	}
[ed2e37f]	216	imcb_connected(ic);
[f06e3ac]	217	return skype_start_stream(ic);
	218	}
	219
	220	static void skype_login( account_t *acc )
	221	{
	222	struct im_connection *ic = imcb_new( acc );
	223	struct skype_data *sd = g_new0( struct skype_data, 1 );
	224
	225	ic->proto_data = sd;
	226
	227	imcb_log( ic, "Connecting" );
	228	printf("%s:%d\n", acc->server, set_getint( &acc->set, "port"));
	229	sd->fd = proxy_connect(acc->server, set_getint( &acc->set, "port" ), skype_connected, ic );
	230	printf("sd->fd: %d\n", sd->fd);
[77c1abe]	231	/*imcb_add_buddy(ic, "test@skype.com", NULL);
	232	imcb_buddy_status(ic, "test@skype.com", OPT_LOGGED_IN, NULL, NULL);
	233	imcb_buddy_msg(ic, "test@skype.com", "test from skype plugin", 0, 0);*/
[a3d6427]	234	sd->username = g_strdup( acc->user );
[f06e3ac]	235
	236	sd->ic = ic;
	237	}
	238
	239	static void skype_logout( struct im_connection *ic )
	240	{
	241	struct skype_data *sd = ic->proto_data;
[98bca36]	242	char *buf;
	243
	244	buf = g_strdup_printf("SET USERSTATUS OFFLINE\n");
	245	skype_write( ic, buf, strlen( buf ) );
	246	g_free(buf);
	247
[a3d6427]	248	g_free(sd->username);
[f06e3ac]	249	g_free(sd);
[98bca36]	250	ic->proto_data = NULL;
[f06e3ac]	251	}
	252
[93ece66]	253	static int skype_buddy_msg( struct im_connection ic, char who, char *message, int flags )
	254	{
[77c1abe]	255	char buf, ptr, *nick;
[93ece66]	256	int st;
	257
[cbec0d6]	258	nick = g_strdup(who);
[77c1abe]	259	ptr = strchr(nick, '@');
[0bb1b7f]	260	if(ptr)
	261	*ptr = '\0';
[93ece66]	262
[77c1abe]	263	buf = g_strdup_printf("MESSAGE %s %s\n", nick, message);
	264	g_free(nick);
[93ece66]	265	st = skype_write( ic, buf, strlen( buf ) );
	266	g_free(buf);
	267
	268	return st;
	269	}
	270
[23411c6]	271	const struct skype_away_state skype_away_state_by_name( char name )
	272	{
	273	int i;
	274
	275	for( i = 0; skype_away_state_list[i].full_name; i ++ )
	276	if( g_strcasecmp( skype_away_state_list[i].full_name, name ) == 0 )
	277	return( skype_away_state_list + i );
	278
	279	return NULL;
	280	}
	281
[f06e3ac]	282	static void skype_set_away( struct im_connection ic, char state_txt, char *message )
	283	{
[23411c6]	284	const struct skype_away_state *state;
	285	char *buf;
	286
	287	if( strcmp( state_txt, GAIM_AWAY_CUSTOM ) == 0 )
	288	state = skype_away_state_by_name( "Away" );
	289	else
	290	state = skype_away_state_by_name( state_txt );
	291	printf("would set to: '%s'\n", state->code);
	292	buf = g_strdup_printf("SET USERSTATUS %s\n", state->code);
	293	skype_write( ic, buf, strlen( buf ) );
	294	g_free(buf);
[f06e3ac]	295	}
	296
	297	static GList skype_away_states( struct im_connection ic )
	298	{
[23411c6]	299	GList *l = NULL;
[adce2de]	300	int i;
	301
[23411c6]	302	for( i = 0; skype_away_state_list[i].full_name; i ++ )
	303	l = g_list_append( l, (void*) skype_away_state_list[i].full_name );
[adce2de]	304
[f06e3ac]	305	return l;
	306	}
	307
	308	static void skype_add_buddy( struct im_connection ic, char who, char *group )
	309	{
[6627d92]	310	char buf, nick, *ptr;
	311
[cbec0d6]	312	nick = g_strdup(who);
[6627d92]	313	ptr = strchr(nick, '@');
	314	if(ptr)
	315	*ptr = '\0';
	316	buf = g_strdup_printf("SET USER %s BUDDYSTATUS 2 Please authorize me\n", nick);
	317	skype_write( ic, buf, strlen( buf ) );
	318	printf("add '%s'\n", nick);
	319	g_free(nick);
[f06e3ac]	320	}
	321
	322	static void skype_remove_buddy( struct im_connection ic, char who, char *group )
	323	{
[6627d92]	324	char buf, nick, *ptr;
	325
[cbec0d6]	326	nick = g_strdup(who);
[6627d92]	327	ptr = strchr(nick, '@');
	328	if(ptr)
	329	*ptr = '\0';
	330	buf = g_strdup_printf("SET USER %s BUDDYSTATUS 1\n", nick);
	331	skype_write( ic, buf, strlen( buf ) );
	332	printf("remove '%s'\n", nick);
	333	g_free(nick);
[f06e3ac]	334	}
	335
	336	void init_plugin(void)
	337	{
	338	struct prpl *ret = g_new0( struct prpl, 1 );
	339
	340	ret->name = "skype";
	341	ret->login = skype_login;
	342	ret->init = skype_init;
	343	ret->logout = skype_logout;
[93ece66]	344	ret->buddy_msg = skype_buddy_msg;
[d5a514a]	345	ret->set_away = skype_set_away;
[f06e3ac]	346	ret->away_states = skype_away_states;
	347	ret->add_buddy = skype_add_buddy;
	348	ret->remove_buddy = skype_remove_buddy;
	349	ret->handle_cmp = g_strcasecmp;
	350	register_protocol( ret );
	351	}

Note: See TracBrowser for help on using the repository browser.

Download in other formats: