Context Navigation

source: protocols/jabber/iq.c @ 7b71feb

Last change on this file since 7b71feb was 704dd38, checked in by Wilmer van der Gaast <wilmer@…>, at 2010-06-01T21:51:27Z
Merging head.
Property mode set to `100644`
File size: 23.9 KB

Rev	Line
[f06894d]	1	/***************************************************************************\
	2	* *
	3	* BitlBee - An IRC to IM gateway *
	4	* Jabber module - IQ packets *
	5	* *
	6	* Copyright 2006 Wilmer van der Gaast <wilmer@gaast.net> *
	7	* *
	8	* This program is free software; you can redistribute it and/or modify *
	9	* it under the terms of the GNU General Public License as published by *
	10	* the Free Software Foundation; either version 2 of the License, or *
	11	* (at your option) any later version. *
	12	* *
	13	* This program is distributed in the hope that it will be useful, *
	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of *
	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
	16	* GNU General Public License for more details. *
	17	* *
	18	* You should have received a copy of the GNU General Public License along *
	19	* with this program; if not, write to the Free Software Foundation, Inc., *
	20	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. *
	21	* *
	22	\***************************************************************************/
	23
	24	#include "jabber.h"
[77bfd07]	25	#include "sha1.h"
[f06894d]	26
[0da65d5]	27	static xt_status jabber_parse_roster( struct im_connection ic, struct xt_node node, struct xt_node *orig );
	28	static xt_status jabber_iq_display_vcard( struct im_connection ic, struct xt_node node, struct xt_node *orig );
[abbd8ed]	29
[f06894d]	30	xt_status jabber_pkt_iq( struct xt_node *node, gpointer data )
	31	{
[0da65d5]	32	struct im_connection *ic = data;
[58b5f62]	33	struct xt_node c, reply = NULL;
[861c199]	34	char type, s;
[259edd4]	35	int st, pack = 1;
[21167d2]	36
[70f6aab8]	37	type = xt_find_attr( node, "type" );
[f06894d]	38
[70f6aab8]	39	if( !type )
[861c199]	40	{
[84b045d]	41	imcb_error( ic, "Received IQ packet without type." );
[c2fb3809]	42	imc_logout( ic, TRUE );
[861c199]	43	return XT_ABORT;
	44	}
[21167d2]	45
[58b5f62]	46	if( strcmp( type, "result" ) == 0 \|\| strcmp( type, "error" ) == 0 )
[861c199]	47	{
[4306d8b]	48	return jabber_cache_handle_packet( ic, node );
[861c199]	49	}
[58b5f62]	50	else if( strcmp( type, "get" ) == 0 )
	51	{
[eded1f7]	52	if( !( ( c = xt_find_node( node->children, "query" ) ) \|\|
[74349eb]	53	( c = xt_find_node( node->children, "ping" ) ) ) \|\|
[58b5f62]	54	!( s = xt_find_attr( c, "xmlns" ) ) )
	55	{
[74349eb]	56	/* Sigh. Who decided to suddenly invent new elements
	57	instead of just sticking with <query/>? */
[58b5f62]	58	return XT_HANDLED;
	59	}
	60
	61	reply = xt_new_node( "query", NULL, NULL );
	62	xt_add_attr( reply, "xmlns", s );
	63
	64	/* Of course this is a very essential query to support. ;-) */
[47d3ac4]	65	if( strcmp( s, XMLNS_VERSION ) == 0 )
[58b5f62]	66	{
	67	xt_add_child( reply, xt_new_node( "name", "BitlBee", NULL ) );
	68	xt_add_child( reply, xt_new_node( "version", BITLBEE_VERSION, NULL ) );
	69	xt_add_child( reply, xt_new_node( "os", ARCH, NULL ) );
	70	}
[47d3ac4]	71	else if( strcmp( s, XMLNS_TIME ) == 0 )
[a4effbf]	72	{
	73	time_t time_ep;
	74	char buf[1024];
	75
	76	buf[sizeof(buf)-1] = 0;
	77	time_ep = time( NULL );
	78
	79	strftime( buf, sizeof( buf ) - 1, "%Y%m%dT%H:%M:%S", gmtime( &time_ep ) );
	80	xt_add_child( reply, xt_new_node( "utc", buf, NULL ) );
	81
	82	strftime( buf, sizeof( buf ) - 1, "%Z", localtime( &time_ep ) );
	83	xt_add_child( reply, xt_new_node( "tz", buf, NULL ) );
	84	}
[eded1f7]	85	else if( strcmp( s, XMLNS_PING ) == 0 )
	86	{
	87	xt_free_node( reply );
	88	reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), NULL );
	89	if( ( s = xt_find_attr( node, "id" ) ) )
	90	xt_add_attr( reply, "id", s );
	91	pack = 0;
	92	}
[dc0ba9c]	93	else if( strcmp( s, XMLNS_DISCO_INFO ) == 0 )
[58b5f62]	94	{
[1ba7e8f]	95	const char *features[] = { XMLNS_DISCO_INFO,
[8c1eb80]	96	XMLNS_VERSION,
[40ef702]	97	XMLNS_TIME,
	98	XMLNS_CHATSTATES,
	99	XMLNS_MUC,
[eded1f7]	100	XMLNS_PING,
[1c3008a]	101	XMLNS_SI,
	102	XMLNS_BYTESTREAMS,
	103	XMLNS_FILETRANSFER,
[40ef702]	104	NULL };
	105	const char **f;
	106
[58b5f62]	107	c = xt_new_node( "identity", NULL, NULL );
	108	xt_add_attr( c, "category", "client" );
	109	xt_add_attr( c, "type", "pc" );
	110	xt_add_attr( c, "name", "BitlBee" );
	111	xt_add_child( reply, c );
	112
[40ef702]	113	for( f = features; *f; f ++ )
	114	{
	115	c = xt_new_node( "feature", NULL, NULL );
	116	xt_add_attr( c, "var", *f );
	117	xt_add_child( reply, c );
	118	}
[58b5f62]	119	}
	120	else
	121	{
	122	xt_free_node( reply );
[2c2df7d]	123	reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel", NULL );
[259edd4]	124	pack = 0;
[58b5f62]	125	}
[259edd4]	126	}
	127	else if( strcmp( type, "set" ) == 0 )
	128	{
[1c3008a]	129	if( ( c = xt_find_node( node->children, "si" ) ) &&
[aed152f]	130	( s = xt_find_attr( c, "xmlns" ) ) &&
	131	( strcmp( s, XMLNS_SI ) == 0 ) )
[2c2df7d]	132	{
	133	return jabber_si_handle_request( ic, node, c );
[1c3008a]	134	}
	135	else if( !( c = xt_find_node( node->children, "query" ) ) \|\|
	136	!( s = xt_find_attr( c, "xmlns" ) ) )
[dfa41a4]	137	{
	138	return XT_HANDLED;
[1c3008a]	139	}
	140	else if( strcmp( s, XMLNS_ROSTER ) == 0 )
[2c2df7d]	141	{
[9bcbe48]	142	/* This is a roster push. XMPP servers send this when someone
	143	was added to (or removed from) the buddy list. AFAIK they're
	144	sent even if we added this buddy in our own session. */
[0da65d5]	145	int bare_len = strlen( ic->acc->user );
[abbd8ed]	146
	147	if( ( s = xt_find_attr( node, "from" ) ) == NULL \|\|
[0da65d5]	148	( strncmp( s, ic->acc->user, bare_len ) == 0 &&
[abbd8ed]	149	( s[bare_len] == 0 \|\| s[bare_len] == '/' ) ) )
	150	{
[0da65d5]	151	jabber_parse_roster( ic, node, NULL );
[abbd8ed]	152
	153	/* Should we generate a reply here? Don't think it's
	154	very important... */
	155	}
	156	else
	157	{
[43462708]	158	imcb_log( ic, "Warning: %s tried to fake a roster push!", s ? s : "(unknown)" );
[abbd8ed]	159
	160	xt_free_node( reply );
[2c2df7d]	161	reply = jabber_make_error_packet( node, "not-allowed", "cancel", NULL );
[abbd8ed]	162	pack = 0;
	163	}
[1c3008a]	164	}
	165	else if( strcmp( s, XMLNS_BYTESTREAMS ) == 0 )
[2c2df7d]	166	{
[1c3008a]	167	/* Bytestream Request (stage 2 of file transfer) */
[2ff2076]	168	return jabber_bs_recv_request( ic, node, c );
[1c3008a]	169	}
	170	else
[dfa41a4]	171	{
	172	xt_free_node( reply );
[2c2df7d]	173	reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel", NULL );
[dfa41a4]	174	pack = 0;
	175	}
[259edd4]	176	}
	177
	178	/* If we recognized the xmlns and managed to generate a reply,
	179	finish and send it. */
	180	if( reply )
	181	{
	182	/* Normally we still have to pack it into an iq-result
	183	packet, but for errors, for example, we don't. */
	184	if( pack )
[58b5f62]	185	{
	186	reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), reply );
	187	if( ( s = xt_find_attr( node, "id" ) ) )
	188	xt_add_attr( reply, "id", s );
	189	}
[259edd4]	190
[0da65d5]	191	st = jabber_write_packet( ic, reply );
[259edd4]	192	xt_free_node( reply );
	193	if( !st )
	194	return XT_ABORT;
[58b5f62]	195	}
[70f6aab8]	196
[861c199]	197	return XT_HANDLED;
	198	}
	199
[0da65d5]	200	static xt_status jabber_do_iq_auth( struct im_connection ic, struct xt_node node, struct xt_node *orig );
	201	static xt_status jabber_finish_iq_auth( struct im_connection ic, struct xt_node node, struct xt_node *orig );
[861c199]	202
[0da65d5]	203	int jabber_init_iq_auth( struct im_connection *ic )
[861c199]	204	{
[0da65d5]	205	struct jabber_data *jd = ic->proto_data;
[861c199]	206	struct xt_node *node;
	207	int st;
[fe7a554]	208
[861c199]	209	node = xt_new_node( "query", NULL, xt_new_node( "username", jd->username, NULL ) );
[47d3ac4]	210	xt_add_attr( node, "xmlns", XMLNS_AUTH );
[861c199]	211	node = jabber_make_packet( "iq", "get", NULL, node );
	212
[0da65d5]	213	jabber_cache_add( ic, node, jabber_do_iq_auth );
	214	st = jabber_write_packet( ic, node );
[861c199]	215
	216	return st;
	217	}
	218
[0da65d5]	219	static xt_status jabber_do_iq_auth( struct im_connection ic, struct xt_node node, struct xt_node *orig )
[861c199]	220	{
[0da65d5]	221	struct jabber_data *jd = ic->proto_data;
[861c199]	222	struct xt_node reply, query;
	223	xt_status st;
	224	char *s;
	225
[9bcbe48]	226	if( !( query = xt_find_node( node->children, "query" ) ) )
	227	{
[43462708]	228	imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
[c2fb3809]	229	imc_logout( ic, FALSE );
[9bcbe48]	230	return XT_HANDLED;
	231	}
[861c199]	232
	233	/* Time to authenticate ourselves! */
	234	reply = xt_new_node( "query", NULL, NULL );
[47d3ac4]	235	xt_add_attr( reply, "xmlns", XMLNS_AUTH );
[861c199]	236	xt_add_child( reply, xt_new_node( "username", jd->username, NULL ) );
[0da65d5]	237	xt_add_child( reply, xt_new_node( "resource", set_getstr( &ic->acc->set, "resource" ), NULL ) );
[861c199]	238
	239	if( xt_find_node( query->children, "digest" ) && ( s = xt_find_attr( jd->xt->root, "id" ) ) )
[21167d2]	240	{
[861c199]	241	/* We can do digest authentication, it seems, and of
	242	course we prefer that. */
[77bfd07]	243	sha1_state_t sha;
[e727608]	244	char hash_hex[41];
[861c199]	245	unsigned char hash[20];
	246	int i;
[21167d2]	247
[77bfd07]	248	sha1_init( &sha );
	249	sha1_append( &sha, (unsigned char*) s, strlen( s ) );
	250	sha1_append( &sha, (unsigned char*) ic->acc->pass, strlen( ic->acc->pass ) );
	251	sha1_finish( &sha, hash );
[21167d2]	252
[861c199]	253	for( i = 0; i < 20; i ++ )
	254	sprintf( hash_hex + i * 2, "%02x", hash[i] );
[21167d2]	255
[861c199]	256	xt_add_child( reply, xt_new_node( "digest", hash_hex, NULL ) );
[21167d2]	257	}
[861c199]	258	else if( xt_find_node( query->children, "password" ) )
[0b4a0db]	259	{
[861c199]	260	/* We'll have to stick with plaintext. Let's hope we're using SSL/TLS... */
[0da65d5]	261	xt_add_child( reply, xt_new_node( "password", ic->acc->pass, NULL ) );
[0b4a0db]	262	}
[861c199]	263	else
[70f6aab8]	264	{
[861c199]	265	xt_free_node( reply );
[995913b]	266
[84b045d]	267	imcb_error( ic, "Can't find suitable authentication method" );
[c2fb3809]	268	imc_logout( ic, FALSE );
[861c199]	269	return XT_ABORT;
[70f6aab8]	270	}
[861c199]	271
	272	reply = jabber_make_packet( "iq", "set", NULL, reply );
[0da65d5]	273	jabber_cache_add( ic, reply, jabber_finish_iq_auth );
	274	st = jabber_write_packet( ic, reply );
[861c199]	275
	276	return st ? XT_HANDLED : XT_ABORT;
	277	}
	278
[0da65d5]	279	static xt_status jabber_finish_iq_auth( struct im_connection ic, struct xt_node node, struct xt_node *orig )
[861c199]	280	{
[0da65d5]	281	struct jabber_data *jd = ic->proto_data;
[9bcbe48]	282	char *type;
	283
	284	if( !( type = xt_find_attr( node, "type" ) ) )
	285	{
[43462708]	286	imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
[c2fb3809]	287	imc_logout( ic, FALSE );
[9bcbe48]	288	return XT_HANDLED;
	289	}
[861c199]	290
	291	if( strcmp( type, "error" ) == 0 )
[70f6aab8]	292	{
[84b045d]	293	imcb_error( ic, "Authentication failure" );
[c2fb3809]	294	imc_logout( ic, FALSE );
[861c199]	295	return XT_ABORT;
	296	}
	297	else if( strcmp( type, "result" ) == 0 )
	298	{
	299	/* This happens when we just successfully authenticated the
	300	old (non-SASL) way. */
	301	jd->flags \|= JFLAG_AUTHENTICATED;
[0da65d5]	302	if( !jabber_get_roster( ic ) )
[70f6aab8]	303	return XT_ABORT;
	304	}
[f06894d]	305
	306	return XT_HANDLED;
	307	}
	308
[0da65d5]	309	xt_status jabber_pkt_bind_sess( struct im_connection ic, struct xt_node node, struct xt_node *orig )
[21167d2]	310	{
[0da65d5]	311	struct jabber_data *jd = ic->proto_data;
[8fb1263]	312	struct xt_node c, reply = NULL;
[861c199]	313	char *s;
[21167d2]	314
[8fb1263]	315	if( node && ( c = xt_find_node( node->children, "bind" ) ) )
[861c199]	316	{
	317	c = xt_find_node( c->children, "jid" );
	318	if( c && c->text_len && ( s = strchr( c->text, '/' ) ) &&
[0da65d5]	319	strcmp( s + 1, set_getstr( &ic->acc->set, "resource" ) ) != 0 )
[84b045d]	320	imcb_log( ic, "Server changed session resource string to `%s'", s + 1 );
[861c199]	321	}
[21167d2]	322
[8fb1263]	323	if( jd->flags & JFLAG_WANT_BIND )
	324	{
	325	reply = xt_new_node( "bind", NULL, xt_new_node( "resource", set_getstr( &ic->acc->set, "resource" ), NULL ) );
	326	xt_add_attr( reply, "xmlns", XMLNS_BIND );
[315dd4c]	327	jd->flags &= ~JFLAG_WANT_BIND;
[8fb1263]	328	}
	329	else if( jd->flags & JFLAG_WANT_SESSION )
[861c199]	330	{
[8fb1263]	331	reply = xt_new_node( "session", NULL, NULL );
	332	xt_add_attr( reply, "xmlns", XMLNS_SESSION );
[315dd4c]	333	jd->flags &= ~JFLAG_WANT_SESSION;
[861c199]	334	}
[21167d2]	335
[8fb1263]	336	if( reply != NULL )
	337	{
	338	reply = jabber_make_packet( "iq", "set", NULL, reply );
	339	jabber_cache_add( ic, reply, jabber_pkt_bind_sess );
	340
	341	if( !jabber_write_packet( ic, reply ) )
	342	return XT_ABORT;
	343	}
	344	else if( ( jd->flags & ( JFLAG_WANT_BIND \| JFLAG_WANT_SESSION ) ) == 0 )
[861c199]	345	{
[0da65d5]	346	if( !jabber_get_roster( ic ) )
[861c199]	347	return XT_ABORT;
	348	}
[21167d2]	349
[861c199]	350	return XT_HANDLED;
[21167d2]	351	}
[70f6aab8]	352
[0da65d5]	353	int jabber_get_roster( struct im_connection *ic )
[70f6aab8]	354	{
	355	struct xt_node *node;
	356	int st;
	357
[84b045d]	358	imcb_log( ic, "Authenticated, requesting buddy list" );
[70f6aab8]	359
	360	node = xt_new_node( "query", NULL, NULL );
[47d3ac4]	361	xt_add_attr( node, "xmlns", XMLNS_ROSTER );
[70f6aab8]	362	node = jabber_make_packet( "iq", "get", NULL, node );
	363
[0da65d5]	364	jabber_cache_add( ic, node, jabber_parse_roster );
	365	st = jabber_write_packet( ic, node );
[70f6aab8]	366
	367	return st;
	368	}
[cfbb3a6]	369
[0da65d5]	370	static xt_status jabber_parse_roster( struct im_connection ic, struct xt_node node, struct xt_node *orig )
[861c199]	371	{
	372	struct xt_node query, c;
[abbd8ed]	373	int initial = ( orig != NULL );
[861c199]	374
[9bcbe48]	375	if( !( query = xt_find_node( node->children, "query" ) ) )
	376	{
[43462708]	377	imcb_log( ic, "Warning: Received NULL roster packet" );
[9bcbe48]	378	return XT_HANDLED;
	379	}
[861c199]	380
	381	c = query->children;
	382	while( ( c = xt_find_node( c, "item" ) ) )
	383	{
[dcd16c5]	384	struct xt_node *group = xt_find_node( c->children, "group" );
[861c199]	385	char *jid = xt_find_attr( c, "jid" );
	386	char *name = xt_find_attr( c, "name" );
	387	char *sub = xt_find_attr( c, "subscription" );
	388
[f0cb961]	389	if( jid && sub )
[abbd8ed]	390	{
	391	if( ( strcmp( sub, "both" ) == 0 \|\| strcmp( sub, "to" ) == 0 ) )
	392	{
[17a6ee9]	393	if( initial \|\| bee_user_by_handle( ic->bee, ic, jid ) == NULL )
[f0cb961]	394	imcb_add_buddy( ic, jid, ( group && group->text_len ) ?
	395	group->text : NULL );
	396
[d06eabf]	397	if( name )
	398	imcb_rename_buddy( ic, jid, name );
[abbd8ed]	399	}
	400	else if( strcmp( sub, "remove" ) == 0 )
	401	{
[0da65d5]	402	jabber_buddy_remove_bare( ic, jid );
[998b103]	403	imcb_remove_buddy( ic, jid, NULL );
[abbd8ed]	404	}
	405	}
[861c199]	406
	407	c = c->next;
	408	}
	409
[abbd8ed]	410	if( initial )
[84b045d]	411	imcb_connected( ic );
[861c199]	412
	413	return XT_HANDLED;
	414	}
	415
[0da65d5]	416	int jabber_get_vcard( struct im_connection ic, char bare_jid )
[1991be6]	417	{
	418	struct xt_node *node;
	419
	420	if( strchr( bare_jid, '/' ) )
	421	return 1; /* This was an error, but return 0 should only be done if the connection died... */
	422
	423	node = xt_new_node( "vCard", NULL, NULL );
[47d3ac4]	424	xt_add_attr( node, "xmlns", XMLNS_VCARD );
[1991be6]	425	node = jabber_make_packet( "iq", "get", bare_jid, node );
	426
[0da65d5]	427	jabber_cache_add( ic, node, jabber_iq_display_vcard );
	428	return jabber_write_packet( ic, node );
[1991be6]	429	}
	430
[0da65d5]	431	static xt_status jabber_iq_display_vcard( struct im_connection ic, struct xt_node node, struct xt_node *orig )
[1991be6]	432	{
[0da65d5]	433	struct xt_node vc, c, sc; / subchild, ic is already in use ;-) */
[1991be6]	434	GString *reply;
	435	char *s;
	436
	437	if( ( s = xt_find_attr( node, "type" ) ) == NULL \|\|
	438	strcmp( s, "result" ) != 0 \|\|
	439	( vc = xt_find_node( node->children, "vCard" ) ) == NULL )
	440	{
	441	s = xt_find_attr( orig, "to" ); /* If this returns NULL something's wrong.. */
[84b045d]	442	imcb_log( ic, "Could not retrieve vCard of %s", s ? s : "(NULL)" );
[1991be6]	443	return XT_HANDLED;
	444	}
	445
	446	s = xt_find_attr( orig, "to" );
	447	reply = g_string_new( "vCard information for " );
	448	reply = g_string_append( reply, s ? s : "(NULL)" );
	449	reply = g_string_append( reply, ":\n" );
	450
	451	/* I hate this format, I really do... */
	452
	453	if( ( c = xt_find_node( vc->children, "FN" ) ) && c->text_len )
	454	g_string_append_printf( reply, "Name: %s\n", c->text );
	455
	456	if( ( c = xt_find_node( vc->children, "N" ) ) && c->children )
	457	{
	458	reply = g_string_append( reply, "Full name:" );
	459
	460	if( ( sc = xt_find_node( c->children, "PREFIX" ) ) && sc->text_len )
	461	g_string_append_printf( reply, " %s", sc->text );
	462	if( ( sc = xt_find_node( c->children, "GIVEN" ) ) && sc->text_len )
	463	g_string_append_printf( reply, " %s", sc->text );
	464	if( ( sc = xt_find_node( c->children, "MIDDLE" ) ) && sc->text_len )
	465	g_string_append_printf( reply, " %s", sc->text );
	466	if( ( sc = xt_find_node( c->children, "FAMILY" ) ) && sc->text_len )
	467	g_string_append_printf( reply, " %s", sc->text );
	468	if( ( sc = xt_find_node( c->children, "SUFFIX" ) ) && sc->text_len )
	469	g_string_append_printf( reply, " %s", sc->text );
	470
	471	reply = g_string_append_c( reply, '\n' );
	472	}
	473
	474	if( ( c = xt_find_node( vc->children, "NICKNAME" ) ) && c->text_len )
	475	g_string_append_printf( reply, "Nickname: %s\n", c->text );
	476
	477	if( ( c = xt_find_node( vc->children, "BDAY" ) ) && c->text_len )
	478	g_string_append_printf( reply, "Date of birth: %s\n", c->text );
	479
	480	/* Slightly alternative use of for... ;-) */
	481	for( c = vc->children; ( c = xt_find_node( c, "EMAIL" ) ); c = c->next )
	482	{
	483	if( ( sc = xt_find_node( c->children, "USERID" ) ) == NULL \|\| sc->text_len == 0 )
	484	continue;
	485
	486	if( xt_find_node( c->children, "HOME" ) )
	487	s = "Home";
	488	else if( xt_find_node( c->children, "WORK" ) )
	489	s = "Work";
	490	else
	491	s = "Misc.";
	492
	493	g_string_append_printf( reply, "%s e-mail address: %s\n", s, sc->text );
	494	}
	495
	496	if( ( c = xt_find_node( vc->children, "URL" ) ) && c->text_len )
	497	g_string_append_printf( reply, "Homepage: %s\n", c->text );
	498
	499	/* Slightly alternative use of for... ;-) */
	500	for( c = vc->children; ( c = xt_find_node( c, "ADR" ) ); c = c->next )
	501	{
	502	if( xt_find_node( c->children, "HOME" ) )
	503	s = "Home";
	504	else if( xt_find_node( c->children, "WORK" ) )
	505	s = "Work";
	506	else
	507	s = "Misc.";
	508
	509	g_string_append_printf( reply, "%s address: ", s );
	510
	511	if( ( sc = xt_find_node( c->children, "STREET" ) ) && sc->text_len )
	512	g_string_append_printf( reply, "%s ", sc->text );
	513	if( ( sc = xt_find_node( c->children, "EXTADR" ) ) && sc->text_len )
	514	g_string_append_printf( reply, "%s, ", sc->text );
	515	if( ( sc = xt_find_node( c->children, "PCODE" ) ) && sc->text_len )
	516	g_string_append_printf( reply, "%s, ", sc->text );
	517	if( ( sc = xt_find_node( c->children, "LOCALITY" ) ) && sc->text_len )
	518	g_string_append_printf( reply, "%s, ", sc->text );
	519	if( ( sc = xt_find_node( c->children, "REGION" ) ) && sc->text_len )
	520	g_string_append_printf( reply, "%s, ", sc->text );
	521	if( ( sc = xt_find_node( c->children, "CTRY" ) ) && sc->text_len )
	522	g_string_append_printf( reply, "%s", sc->text );
	523
	524	if( reply->str[reply->len-2] == ',' )
	525	reply = g_string_truncate( reply, reply->len-2 );
	526
	527	reply = g_string_append_c( reply, '\n' );
	528	}
	529
	530	for( c = vc->children; ( c = xt_find_node( c, "TEL" ) ); c = c->next )
	531	{
	532	if( ( sc = xt_find_node( c->children, "NUMBER" ) ) == NULL \|\| sc->text_len == 0 )
	533	continue;
	534
	535	if( xt_find_node( c->children, "HOME" ) )
	536	s = "Home";
	537	else if( xt_find_node( c->children, "WORK" ) )
	538	s = "Work";
	539	else
	540	s = "Misc.";
	541
	542	g_string_append_printf( reply, "%s phone number: %s\n", s, sc->text );
	543	}
	544
	545	if( ( c = xt_find_node( vc->children, "DESC" ) ) && c->text_len )
	546	g_string_append_printf( reply, "Other information:\n%s", c->text );
	547
	548	/* sigh */
	549
[84b045d]	550	imcb_log( ic, "%s", reply->str );
[1991be6]	551	g_string_free( reply, TRUE );
	552
	553	return XT_HANDLED;
	554	}
	555
[a73e91a]	556	static xt_status jabber_add_to_roster_callback( struct im_connection ic, struct xt_node node, struct xt_node *orig );
	557
[0da65d5]	558	int jabber_add_to_roster( struct im_connection ic, char handle, char *name )
[cfbb3a6]	559	{
	560	struct xt_node *node;
	561	int st;
	562
	563	/* Build the item entry */
	564	node = xt_new_node( "item", NULL, NULL );
	565	xt_add_attr( node, "jid", handle );
	566	if( name )
	567	xt_add_attr( node, "name", name );
	568
	569	/* And pack it into a roster-add packet */
	570	node = xt_new_node( "query", NULL, node );
[47d3ac4]	571	xt_add_attr( node, "xmlns", XMLNS_ROSTER );
[cfbb3a6]	572	node = jabber_make_packet( "iq", "set", NULL, node );
[a73e91a]	573	jabber_cache_add( ic, node, jabber_add_to_roster_callback );
[cfbb3a6]	574
[0da65d5]	575	st = jabber_write_packet( ic, node );
[cfbb3a6]	576
	577	return st;
	578	}
	579
[a73e91a]	580	static xt_status jabber_add_to_roster_callback( struct im_connection ic, struct xt_node node, struct xt_node *orig )
	581	{
	582	char s, jid = NULL;
	583	struct xt_node *c;
	584
	585	if( ( c = xt_find_node( orig->children, "query" ) ) &&
	586	( c = xt_find_node( c->children, "item" ) ) &&
	587	( jid = xt_find_attr( c, "jid" ) ) &&
	588	( s = xt_find_attr( node, "type" ) ) &&
	589	strcmp( s, "result" ) == 0 )
	590	{
[17a6ee9]	591	if( bee_user_by_handle( ic->bee, ic, jid ) == NULL )
[a73e91a]	592	imcb_add_buddy( ic, jid, NULL );
	593	}
	594	else
	595	{
	596	imcb_log( ic, "Error while adding `%s' to your contact list.",
	597	jid ? jid : "(unknown handle)" );
	598	}
	599
	600	return XT_HANDLED;
	601	}
	602
[0da65d5]	603	int jabber_remove_from_roster( struct im_connection ic, char handle )
[cfbb3a6]	604	{
	605	struct xt_node *node;
	606	int st;
	607
	608	/* Build the item entry */
	609	node = xt_new_node( "item", NULL, NULL );
	610	xt_add_attr( node, "jid", handle );
	611	xt_add_attr( node, "subscription", "remove" );
	612
	613	/* And pack it into a roster-add packet */
	614	node = xt_new_node( "query", NULL, node );
[47d3ac4]	615	xt_add_attr( node, "xmlns", XMLNS_ROSTER );
[cfbb3a6]	616	node = jabber_make_packet( "iq", "set", NULL, node );
	617
[0da65d5]	618	st = jabber_write_packet( ic, node );
[cfbb3a6]	619
	620	xt_free_node( node );
	621	return st;
	622	}
[dc0ba9c]	623
	624	xt_status jabber_iq_parse_features( struct im_connection ic, struct xt_node node, struct xt_node *orig );
	625
	626	xt_status jabber_iq_query_features( struct im_connection ic, char bare_jid )
	627	{
	628	struct xt_node node, query;
	629	struct jabber_buddy *bud;
	630
	631	if( ( bud = jabber_buddy_by_jid( ic, bare_jid , 0 ) ) == NULL )
	632	{
	633	/* Who cares about the unknown... */
[4358b10]	634	imcb_log( ic, "Couldn't find buddy: %s", bare_jid);
[54a2014]	635	return XT_HANDLED;
[dc0ba9c]	636	}
	637
	638	if( bud->features ) /* been here already */
	639	return XT_HANDLED;
	640
	641	node = xt_new_node( "query", NULL, NULL );
	642	xt_add_attr( node, "xmlns", XMLNS_DISCO_INFO );
	643
	644	if( !( query = jabber_make_packet( "iq", "get", bare_jid, node ) ) )
	645	{
	646	imcb_log( ic, "WARNING: Couldn't generate feature query" );
	647	xt_free_node( node );
[54a2014]	648	return XT_HANDLED;
[dc0ba9c]	649	}
	650
	651	jabber_cache_add( ic, query, jabber_iq_parse_features );
	652
[54a2014]	653	return jabber_write_packet( ic, query ) ? XT_HANDLED : XT_ABORT;
[dc0ba9c]	654	}
	655
	656	xt_status jabber_iq_parse_features( struct im_connection ic, struct xt_node node, struct xt_node *orig )
	657	{
	658	struct xt_node *c;
	659	struct jabber_buddy *bud;
[c1a3c27]	660	char feature, xmlns, *from;
[dc0ba9c]	661
[699376f7]	662	if( !( from = xt_find_attr( node, "from" ) ) \|\|
	663	!( c = xt_find_node( node->children, "query" ) ) \|\|
[c1a3c27]	664	!( xmlns = xt_find_attr( c, "xmlns" ) ) \|\|
	665	!( strcmp( xmlns, XMLNS_DISCO_INFO ) == 0 ) )
[dc0ba9c]	666	{
	667	imcb_log( ic, "WARNING: Received incomplete IQ-result packet for discover" );
	668	return XT_HANDLED;
	669	}
[c1a3c27]	670	if( ( bud = jabber_buddy_by_jid( ic, from, 0 ) ) == NULL )
[dc0ba9c]	671	{
	672	/* Who cares about the unknown... */
[c1a3c27]	673	imcb_log( ic, "Couldn't find buddy: %s", from );
[54a2014]	674	return XT_HANDLED;
[dc0ba9c]	675	}
	676
	677	c = c->children;
[1c3008a]	678	while( ( c = xt_find_node( c, "feature" ) ) )
	679	{
[dc0ba9c]	680	feature = xt_find_attr( c, "var" );
[c1a3c27]	681	if( feature )
	682	bud->features = g_slist_append( bud->features, g_strdup( feature ) );
[dc0ba9c]	683	c = c->next;
	684	}
	685
	686	return XT_HANDLED;
	687	}
	688
	689	xt_status jabber_iq_parse_server_features( struct im_connection ic, struct xt_node node, struct xt_node *orig );
	690
	691	xt_status jabber_iq_query_server( struct im_connection ic, char jid, char *xmlns )
	692	{
	693	struct xt_node node, query;
	694	struct jabber_data *jd = ic->proto_data;
	695
	696	node = xt_new_node( "query", NULL, NULL );
	697	xt_add_attr( node, "xmlns", xmlns );
	698
	699	if( !( query = jabber_make_packet( "iq", "get", jid, node ) ) )
	700	{
	701	imcb_log( ic, "WARNING: Couldn't generate server query" );
	702	xt_free_node( node );
	703	}
	704
	705	jd->have_streamhosts--;
	706	jabber_cache_add( ic, query, jabber_iq_parse_server_features );
	707
[54a2014]	708	return jabber_write_packet( ic, query ) ? XT_HANDLED : XT_ABORT;
[dc0ba9c]	709	}
	710
	711	/*
	712	* Query the server for "items", query each "item" for identities, query each "item" that's a proxy for it's bytestream info
	713	*/
	714	xt_status jabber_iq_parse_server_features( struct im_connection ic, struct xt_node node, struct xt_node *orig )
	715	{
	716	struct xt_node *c;
	717	struct jabber_data *jd = ic->proto_data;
[c1a3c27]	718	char xmlns, from;
[dc0ba9c]	719
	720	if( !( c = xt_find_node( node->children, "query" ) ) \|\|
[c1a3c27]	721	!( from = xt_find_attr( node, "from" ) ) \|\|
	722	!( xmlns = xt_find_attr( c, "xmlns" ) ) )
[dc0ba9c]	723	{
	724	imcb_log( ic, "WARNING: Received incomplete IQ-result packet for discover" );
	725	return XT_HANDLED;
	726	}
	727
	728	jd->have_streamhosts++;
	729
[c1a3c27]	730	if( strcmp( xmlns, XMLNS_DISCO_ITEMS ) == 0 )
[dc0ba9c]	731	{
[c1a3c27]	732	char *itemjid;
[dc0ba9c]	733
	734	/* answer from server */
	735
	736	c = c->children;
	737	while( ( c = xt_find_node( c, "item" ) ) )
	738	{
	739	itemjid = xt_find_attr( c, "jid" );
[c1a3c27]	740
	741	if( itemjid )
	742	jabber_iq_query_server( ic, itemjid, XMLNS_DISCO_INFO );
[dc0ba9c]	743
	744	c = c->next;
	745	}
[1c3008a]	746	}
[42fc5b6]	747	else if( strcmp( xmlns, XMLNS_DISCO_INFO ) == 0 )
[dc0ba9c]	748	{
	749	char category, type;
	750
	751	/* answer from potential proxy */
	752
	753	c = c->children;
	754	while( ( c = xt_find_node( c, "identity" ) ) )
	755	{
	756	category = xt_find_attr( c, "category" );
	757	type = xt_find_attr( c, "type" );
	758
	759	if( type && ( strcmp( type, "bytestreams" ) == 0 ) &&
	760	category && ( strcmp( category, "proxy" ) == 0 ) )
[c1a3c27]	761	jabber_iq_query_server( ic, from, XMLNS_BYTESTREAMS );
[dc0ba9c]	762
	763	c = c->next;
	764	}
[1c3008a]	765	}
[42fc5b6]	766	else if( strcmp( xmlns, XMLNS_BYTESTREAMS ) == 0 )
[dc0ba9c]	767	{
[c1a3c27]	768	char host, jid, *port_s;
[dc0ba9c]	769	int port;
	770
	771	/* answer from proxy */
	772
	773	if( ( c = xt_find_node( c->children, "streamhost" ) ) &&
	774	( host = xt_find_attr( c, "host" ) ) &&
[c1a3c27]	775	( port_s = xt_find_attr( c, "port" ) ) &&
	776	( sscanf( port_s, "%d", &port ) == 1 ) &&
[dc0ba9c]	777	( jid = xt_find_attr( c, "jid" ) ) )
	778	{
	779	jabber_streamhost_t *sh = g_new0( jabber_streamhost_t, 1 );
[c1a3c27]	780
[dc0ba9c]	781	sh->jid = g_strdup( jid );
	782	sh->host = g_strdup( host );
[c1a3c27]	783	g_snprintf( sh->port, sizeof( sh->port ), "%u", port );
[dc0ba9c]	784
	785	imcb_log( ic, "Proxy found: jid %s host %s port %u", jid, host, port );
	786	jd->streamhosts = g_slist_append( jd->streamhosts, sh );
	787	}
	788	}
	789
	790	if( jd->have_streamhosts == 0 )
	791	jd->have_streamhosts++;
[1c3008a]	792
[dc0ba9c]	793	return XT_HANDLED;
	794	}

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

Download in other formats: