Context Navigation

source: protocols/jabber/iq.c @ d74c644

Last change on this file since d74c644 was a4effbf, checked in by Wilmer van der Gaast <wilmer@…>, at 2006-10-12T21:01:51Z
Replies to jabber:iq:time packets.
Property mode set to `100644`
File size: 11.0 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"
	25
	26	xt_status jabber_pkt_iq( struct xt_node *node, gpointer data )
	27	{
[21167d2]	28	struct gaim_connection *gc = data;
	29	struct jabber_data *jd = gc->proto_data;
[58b5f62]	30	struct xt_node c, reply = NULL;
[861c199]	31	char type, s;
[259edd4]	32	int st, pack = 1;
[21167d2]	33
[70f6aab8]	34	type = xt_find_attr( node, "type" );
[f06894d]	35
[70f6aab8]	36	if( !type )
[861c199]	37	{
[58b5f62]	38	hide_login_progress_error( gc, "Received IQ packet without type." );
[861c199]	39	signoff( gc );
	40	return XT_ABORT;
	41	}
[21167d2]	42
[58b5f62]	43	if( strcmp( type, "result" ) == 0 \|\| strcmp( type, "error" ) == 0 )
[861c199]	44	{
	45	struct jabber_cache_entry *entry;
	46
[58b5f62]	47	if( ( s = xt_find_attr( node, "id" ) ) == NULL )
	48	{
	49	/* Silently ignore it, without an ID we don't know
	50	how to handle the packet, but it doesn't have
	51	to be a serious problem. */
	52	return XT_HANDLED;
	53	}
	54
[861c199]	55	entry = g_hash_table_lookup( jd->node_cache, s );
	56
	57	if( entry == NULL )
	58	serv_got_crap( gc, "WARNING: Received IQ %s packet with unknown/expired ID %s!", type, s );
	59	else if( entry->func )
	60	return entry->func( gc, node, entry->node );
	61	}
[58b5f62]	62	else if( strcmp( type, "get" ) == 0 )
	63	{
	64	if( !( c = xt_find_node( node->children, "query" ) ) \|\|
	65	!( s = xt_find_attr( c, "xmlns" ) ) )
	66	{
	67	serv_got_crap( gc, "WARNING: Received incomplete IQ-get packet" );
	68	return XT_HANDLED;
	69	}
	70
	71	reply = xt_new_node( "query", NULL, NULL );
	72	xt_add_attr( reply, "xmlns", s );
	73
	74	/* Of course this is a very essential query to support. ;-) */
	75	if( strcmp( s, "jabber:iq:version" ) == 0 )
	76	{
	77	xt_add_child( reply, xt_new_node( "name", "BitlBee", NULL ) );
	78	xt_add_child( reply, xt_new_node( "version", BITLBEE_VERSION, NULL ) );
	79	xt_add_child( reply, xt_new_node( "os", ARCH, NULL ) );
	80	}
[a4effbf]	81	else if( strcmp( s, "jabber:iq:time" ) == 0 )
	82	{
	83	time_t time_ep;
	84	char buf[1024];
	85
	86	buf[sizeof(buf)-1] = 0;
	87	time_ep = time( NULL );
	88
	89	strftime( buf, sizeof( buf ) - 1, "%Y%m%dT%H:%M:%S", gmtime( &time_ep ) );
	90	xt_add_child( reply, xt_new_node( "utc", buf, NULL ) );
	91
	92	strftime( buf, sizeof( buf ) - 1, "%Z", localtime( &time_ep ) );
	93	xt_add_child( reply, xt_new_node( "tz", buf, NULL ) );
	94	}
[58b5f62]	95	else if( strcmp( s, "http://jabber.org/protocol/disco#info" ) == 0 )
	96	{
	97	c = xt_new_node( "identity", NULL, NULL );
	98	xt_add_attr( c, "category", "client" );
	99	xt_add_attr( c, "type", "pc" );
	100	xt_add_attr( c, "name", "BitlBee" );
	101	xt_add_child( reply, c );
	102
	103	c = xt_new_node( "feature", NULL, NULL );
	104	xt_add_attr( c, "var", "jabber:iq:version" );
	105	xt_add_child( reply, c );
	106
[a4effbf]	107	c = xt_new_node( "feature", NULL, NULL );
	108	xt_add_attr( c, "var", "jabber:iq:time" );
	109	xt_add_child( reply, c );
	110
[58b5f62]	111	c = xt_new_node( "feature", NULL, NULL );
	112	xt_add_attr( c, "var", "http://jabber.org/protocol/chatstates" );
	113	xt_add_child( reply, c );
	114
	115	/* Later this can be useful to announce things like
	116	MUC support. */
	117	}
	118	else
	119	{
	120	xt_free_node( reply );
[259edd4]	121	reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel" );
	122	pack = 0;
[58b5f62]	123	}
[259edd4]	124	}
	125	else if( strcmp( type, "set" ) == 0 )
	126	{
	127	xt_free_node( reply );
	128	reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel" );
	129	pack = 0;
	130	}
	131
	132	/* If we recognized the xmlns and managed to generate a reply,
	133	finish and send it. */
	134	if( reply )
	135	{
	136	/* Normally we still have to pack it into an iq-result
	137	packet, but for errors, for example, we don't. */
	138	if( pack )
[58b5f62]	139	{
	140	reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), reply );
	141	if( ( s = xt_find_attr( node, "id" ) ) )
	142	xt_add_attr( reply, "id", s );
	143	}
[259edd4]	144
	145	st = jabber_write_packet( gc, reply );
	146	xt_free_node( reply );
	147	if( !st )
	148	return XT_ABORT;
[58b5f62]	149	}
[70f6aab8]	150
[861c199]	151	return XT_HANDLED;
	152	}
	153
	154	static xt_status jabber_do_iq_auth( struct gaim_connection gc, struct xt_node node, struct xt_node *orig );
	155	static xt_status jabber_finish_iq_auth( struct gaim_connection gc, struct xt_node node, struct xt_node *orig );
	156
	157	int jabber_init_iq_auth( struct gaim_connection *gc )
	158	{
	159	struct jabber_data *jd = gc->proto_data;
	160	struct xt_node *node;
	161	int st;
[fe7a554]	162
[861c199]	163	node = xt_new_node( "query", NULL, xt_new_node( "username", jd->username, NULL ) );
	164	xt_add_attr( node, "xmlns", "jabber:iq:auth" );
	165	node = jabber_make_packet( "iq", "get", NULL, node );
	166
	167	jabber_cache_add( gc, node, jabber_do_iq_auth );
	168	st = jabber_write_packet( gc, node );
	169
	170	return st;
	171	}
	172
	173	static xt_status jabber_do_iq_auth( struct gaim_connection gc, struct xt_node node, struct xt_node *orig )
	174	{
	175	struct jabber_data *jd = gc->proto_data;
	176	struct xt_node reply, query;
	177	xt_status st;
	178	char *s;
	179
	180	query = xt_find_node( node->children, "query" );
	181
	182	/* Time to authenticate ourselves! */
	183	reply = xt_new_node( "query", NULL, NULL );
	184	xt_add_attr( reply, "xmlns", "jabber:iq:auth" );
	185	xt_add_child( reply, xt_new_node( "username", jd->username, NULL ) );
	186	xt_add_child( reply, xt_new_node( "resource", set_getstr( &gc->acc->set, "resource" ), NULL ) );
	187
	188	if( xt_find_node( query->children, "digest" ) && ( s = xt_find_attr( jd->xt->root, "id" ) ) )
[21167d2]	189	{
[861c199]	190	/* We can do digest authentication, it seems, and of
	191	course we prefer that. */
	192	SHA_CTX sha;
	193	char hash_hex[40];
	194	unsigned char hash[20];
	195	int i;
[21167d2]	196
[861c199]	197	shaInit( &sha );
	198	shaUpdate( &sha, (unsigned char*) s, strlen( s ) );
	199	shaUpdate( &sha, (unsigned char*) gc->acc->pass, strlen( gc->acc->pass ) );
	200	shaFinal( &sha, hash );
[21167d2]	201
[861c199]	202	for( i = 0; i < 20; i ++ )
	203	sprintf( hash_hex + i * 2, "%02x", hash[i] );
[21167d2]	204
[861c199]	205	xt_add_child( reply, xt_new_node( "digest", hash_hex, NULL ) );
[21167d2]	206	}
[861c199]	207	else if( xt_find_node( query->children, "password" ) )
[0b4a0db]	208	{
[861c199]	209	/* We'll have to stick with plaintext. Let's hope we're using SSL/TLS... */
	210	xt_add_child( reply, xt_new_node( "password", gc->acc->pass, NULL ) );
[0b4a0db]	211	}
[861c199]	212	else
[70f6aab8]	213	{
[861c199]	214	xt_free_node( reply );
[995913b]	215
[861c199]	216	hide_login_progress( gc, "Can't find suitable authentication method" );
	217	signoff( gc );
	218	return XT_ABORT;
[70f6aab8]	219	}
[861c199]	220
	221	reply = jabber_make_packet( "iq", "set", NULL, reply );
	222	jabber_cache_add( gc, reply, jabber_finish_iq_auth );
	223	st = jabber_write_packet( gc, reply );
	224
	225	return st ? XT_HANDLED : XT_ABORT;
	226	}
	227
	228	static xt_status jabber_finish_iq_auth( struct gaim_connection gc, struct xt_node node, struct xt_node *orig )
	229	{
	230	char *type = xt_find_attr( node, "type" );
	231	struct jabber_data *jd = gc->proto_data;
	232
	233	if( strcmp( type, "error" ) == 0 )
[70f6aab8]	234	{
[861c199]	235	hide_login_progress( gc, "Authentication failure" );
	236	signoff( gc );
	237	return XT_ABORT;
	238	}
	239	else if( strcmp( type, "result" ) == 0 )
	240	{
	241	/* This happens when we just successfully authenticated the
	242	old (non-SASL) way. */
	243	jd->flags \|= JFLAG_AUTHENTICATED;
	244	if( !jabber_get_roster( gc ) )
[70f6aab8]	245	return XT_ABORT;
	246	}
[f06894d]	247
	248	return XT_HANDLED;
	249	}
	250
[861c199]	251	xt_status jabber_pkt_bind_sess( struct gaim_connection gc, struct xt_node node, struct xt_node *orig )
[21167d2]	252	{
	253	struct jabber_data *jd = gc->proto_data;
[861c199]	254	struct xt_node *c;
	255	char *s;
[21167d2]	256
[861c199]	257	if( ( c = xt_find_node( node->children, "bind" ) ) )
	258	{
	259	c = xt_find_node( c->children, "jid" );
	260	if( c && c->text_len && ( s = strchr( c->text, '/' ) ) &&
	261	strcmp( s + 1, set_getstr( &gc->acc->set, "resource" ) ) != 0 )
	262	serv_got_crap( gc, "Server changed session resource string to `%s'", s + 1 );
	263
	264	jd->flags &= ~JFLAG_WAIT_BIND;
	265	}
	266	else
	267	{
	268	jd->flags &= ~JFLAG_WAIT_SESSION;
	269	}
[21167d2]	270
[861c199]	271	if( ( jd->flags & ( JFLAG_WAIT_BIND \| JFLAG_WAIT_SESSION ) ) == 0 )
	272	{
	273	if( !jabber_get_roster( gc ) )
	274	return XT_ABORT;
	275	}
[21167d2]	276
[861c199]	277	return XT_HANDLED;
[21167d2]	278	}
[70f6aab8]	279
[861c199]	280	static xt_status jabber_parse_roster( struct gaim_connection gc, struct xt_node node, struct xt_node *orig );
	281
[70f6aab8]	282	int jabber_get_roster( struct gaim_connection *gc )
	283	{
	284	struct xt_node *node;
	285	int st;
	286
	287	set_login_progress( gc, 1, "Authenticated, requesting buddy list" );
	288
	289	node = xt_new_node( "query", NULL, NULL );
	290	xt_add_attr( node, "xmlns", "jabber:iq:roster" );
	291	node = jabber_make_packet( "iq", "get", NULL, node );
	292
[861c199]	293	jabber_cache_add( gc, node, jabber_parse_roster );
[70f6aab8]	294	st = jabber_write_packet( gc, node );
	295
	296	return st;
	297	}
[cfbb3a6]	298
[861c199]	299	static xt_status jabber_parse_roster( struct gaim_connection gc, struct xt_node node, struct xt_node *orig )
	300	{
	301	struct xt_node query, c;
	302
	303	query = xt_find_node( node->children, "query" );
	304
	305	c = query->children;
	306	while( ( c = xt_find_node( c, "item" ) ) )
	307	{
	308	char *jid = xt_find_attr( c, "jid" );
	309	char *name = xt_find_attr( c, "name" );
	310	char *sub = xt_find_attr( c, "subscription" );
	311
	312	if( jid && sub && ( strcmp( sub, "both" ) == 0 \|\| strcmp( sub, "to" ) == 0 ) )
	313	add_buddy( gc, NULL, jid, name );
	314
	315	c = c->next;
	316	}
	317
	318	account_online( gc );
	319
	320	return XT_HANDLED;
	321	}
	322
[cfbb3a6]	323	int jabber_add_to_roster( struct gaim_connection gc, char handle, char *name )
	324	{
	325	struct xt_node *node;
	326	int st;
	327
	328	/* Build the item entry */
	329	node = xt_new_node( "item", NULL, NULL );
	330	xt_add_attr( node, "jid", handle );
	331	if( name )
	332	xt_add_attr( node, "name", name );
	333
	334	/* And pack it into a roster-add packet */
	335	node = xt_new_node( "query", NULL, node );
	336	xt_add_attr( node, "xmlns", "jabber:iq:roster" );
	337	node = jabber_make_packet( "iq", "set", NULL, node );
	338
	339	st = jabber_write_packet( gc, node );
	340
	341	xt_free_node( node );
	342	return st;
	343	}
	344
	345	int jabber_remove_from_roster( struct gaim_connection gc, char handle )
	346	{
	347	struct xt_node *node;
	348	int st;
	349
	350	/* Build the item entry */
	351	node = xt_new_node( "item", NULL, NULL );
	352	xt_add_attr( node, "jid", handle );
	353	xt_add_attr( node, "subscription", "remove" );
	354
	355	/* And pack it into a roster-add packet */
	356	node = xt_new_node( "query", NULL, node );
	357	xt_add_attr( node, "xmlns", "jabber:iq:roster" );
	358	node = jabber_make_packet( "iq", "set", NULL, node );
	359
	360	st = jabber_write_packet( gc, node );
	361
	362	xt_free_node( node );
	363	return st;
	364	}

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

Download in other formats: