aboutsummaryrefslogtreecommitdiffstats
path: root/protocols/jabber/iq.c
diff options
context:
space:
mode:
Diffstat (limited to 'protocols/jabber/iq.c')
-rw-r--r--protocols/jabber/iq.c594
1 files changed, 594 insertions, 0 deletions
diff --git a/protocols/jabber/iq.c b/protocols/jabber/iq.c
new file mode 100644
index 00000000..38c5a5a9
--- /dev/null
+++ b/protocols/jabber/iq.c
@@ -0,0 +1,594 @@
+/***************************************************************************\
+* *
+* BitlBee - An IRC to IM gateway *
+* Jabber module - IQ packets *
+* *
+* Copyright 2006 Wilmer van der Gaast <wilmer@gaast.net> *
+* *
+* 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., *
+* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. *
+* *
+\***************************************************************************/
+
+#include "jabber.h"
+#include "sha1.h"
+
+static xt_status jabber_parse_roster( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
+static xt_status jabber_iq_display_vcard( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
+
+xt_status jabber_pkt_iq( struct xt_node *node, gpointer data )
+{
+ struct im_connection *ic = data;
+ struct xt_node *c, *reply = NULL;
+ char *type, *s;
+ int st, pack = 1;
+
+ type = xt_find_attr( node, "type" );
+
+ if( !type )
+ {
+ imcb_error( ic, "Received IQ packet without type." );
+ imc_logout( ic, TRUE );
+ return XT_ABORT;
+ }
+
+ if( strcmp( type, "result" ) == 0 || strcmp( type, "error" ) == 0 )
+ {
+ return jabber_cache_handle_packet( ic, node );
+ }
+ else if( strcmp( type, "get" ) == 0 )
+ {
+ if( !( ( c = xt_find_node( node->children, "query" ) ) ||
+ ( c = xt_find_node( node->children, "ping" ) ) ) || /* O_o WHAT is wrong with just <query/> ????? */
+ !( s = xt_find_attr( c, "xmlns" ) ) )
+ {
+ imcb_log( ic, "Warning: Received incomplete IQ-%s packet", type );
+ return XT_HANDLED;
+ }
+
+ reply = xt_new_node( "query", NULL, NULL );
+ xt_add_attr( reply, "xmlns", s );
+
+ /* Of course this is a very essential query to support. ;-) */
+ if( strcmp( s, XMLNS_VERSION ) == 0 )
+ {
+ xt_add_child( reply, xt_new_node( "name", "BitlBee", NULL ) );
+ xt_add_child( reply, xt_new_node( "version", BITLBEE_VERSION, NULL ) );
+ xt_add_child( reply, xt_new_node( "os", ARCH, NULL ) );
+ }
+ else if( strcmp( s, XMLNS_TIME ) == 0 )
+ {
+ time_t time_ep;
+ char buf[1024];
+
+ buf[sizeof(buf)-1] = 0;
+ time_ep = time( NULL );
+
+ strftime( buf, sizeof( buf ) - 1, "%Y%m%dT%H:%M:%S", gmtime( &time_ep ) );
+ xt_add_child( reply, xt_new_node( "utc", buf, NULL ) );
+
+ strftime( buf, sizeof( buf ) - 1, "%Z", localtime( &time_ep ) );
+ xt_add_child( reply, xt_new_node( "tz", buf, NULL ) );
+ }
+ else if( strcmp( s, XMLNS_PING ) == 0 )
+ {
+ xt_free_node( reply );
+ reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), NULL );
+ if( ( s = xt_find_attr( node, "id" ) ) )
+ xt_add_attr( reply, "id", s );
+ pack = 0;
+ }
+ else if( strcmp( s, XMLNS_DISCOVER ) == 0 )
+ {
+ const char *features[] = { XMLNS_DISCOVER,
+ XMLNS_VERSION,
+ XMLNS_TIME,
+ XMLNS_CHATSTATES,
+ XMLNS_MUC,
+ XMLNS_PING,
+ NULL };
+ const char **f;
+
+ c = xt_new_node( "identity", NULL, NULL );
+ xt_add_attr( c, "category", "client" );
+ xt_add_attr( c, "type", "pc" );
+ xt_add_attr( c, "name", "BitlBee" );
+ xt_add_child( reply, c );
+
+ for( f = features; *f; f ++ )
+ {
+ c = xt_new_node( "feature", NULL, NULL );
+ xt_add_attr( c, "var", *f );
+ xt_add_child( reply, c );
+ }
+ }
+ else
+ {
+ xt_free_node( reply );
+ reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel" );
+ pack = 0;
+ }
+ }
+ else if( strcmp( type, "set" ) == 0 )
+ {
+ if( !( c = xt_find_node( node->children, "query" ) ) ||
+ !( s = xt_find_attr( c, "xmlns" ) ) )
+ {
+ imcb_log( ic, "Warning: Received incomplete IQ-%s packet", type );
+ return XT_HANDLED;
+ }
+
+ /* This is a roster push. XMPP servers send this when someone
+ was added to (or removed from) the buddy list. AFAIK they're
+ sent even if we added this buddy in our own session. */
+ if( strcmp( s, XMLNS_ROSTER ) == 0 )
+ {
+ int bare_len = strlen( ic->acc->user );
+
+ if( ( s = xt_find_attr( node, "from" ) ) == NULL ||
+ ( strncmp( s, ic->acc->user, bare_len ) == 0 &&
+ ( s[bare_len] == 0 || s[bare_len] == '/' ) ) )
+ {
+ jabber_parse_roster( ic, node, NULL );
+
+ /* Should we generate a reply here? Don't think it's
+ very important... */
+ }
+ else
+ {
+ imcb_log( ic, "Warning: %s tried to fake a roster push!", s ? s : "(unknown)" );
+
+ xt_free_node( reply );
+ reply = jabber_make_error_packet( node, "not-allowed", "cancel" );
+ pack = 0;
+ }
+ }
+ else
+ {
+ xt_free_node( reply );
+ reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel" );
+ pack = 0;
+ }
+ }
+
+ /* If we recognized the xmlns and managed to generate a reply,
+ finish and send it. */
+ if( reply )
+ {
+ /* Normally we still have to pack it into an iq-result
+ packet, but for errors, for example, we don't. */
+ if( pack )
+ {
+ reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), reply );
+ if( ( s = xt_find_attr( node, "id" ) ) )
+ xt_add_attr( reply, "id", s );
+ }
+
+ st = jabber_write_packet( ic, reply );
+ xt_free_node( reply );
+ if( !st )
+ return XT_ABORT;
+ }
+
+ return XT_HANDLED;
+}
+
+static xt_status jabber_do_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
+static xt_status jabber_finish_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
+
+int jabber_init_iq_auth( struct im_connection *ic )
+{
+ struct jabber_data *jd = ic->proto_data;
+ struct xt_node *node;
+ int st;
+
+ node = xt_new_node( "query", NULL, xt_new_node( "username", jd->username, NULL ) );
+ xt_add_attr( node, "xmlns", XMLNS_AUTH );
+ node = jabber_make_packet( "iq", "get", NULL, node );
+
+ jabber_cache_add( ic, node, jabber_do_iq_auth );
+ st = jabber_write_packet( ic, node );
+
+ return st;
+}
+
+static xt_status jabber_do_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ struct jabber_data *jd = ic->proto_data;
+ struct xt_node *reply, *query;
+ xt_status st;
+ char *s;
+
+ if( !( query = xt_find_node( node->children, "query" ) ) )
+ {
+ imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
+ imc_logout( ic, FALSE );
+ return XT_HANDLED;
+ }
+
+ /* Time to authenticate ourselves! */
+ reply = xt_new_node( "query", NULL, NULL );
+ xt_add_attr( reply, "xmlns", XMLNS_AUTH );
+ xt_add_child( reply, xt_new_node( "username", jd->username, NULL ) );
+ xt_add_child( reply, xt_new_node( "resource", set_getstr( &ic->acc->set, "resource" ), NULL ) );
+
+ if( xt_find_node( query->children, "digest" ) && ( s = xt_find_attr( jd->xt->root, "id" ) ) )
+ {
+ /* We can do digest authentication, it seems, and of
+ course we prefer that. */
+ sha1_state_t sha;
+ char hash_hex[41];
+ unsigned char hash[20];
+ int i;
+
+ sha1_init( &sha );
+ sha1_append( &sha, (unsigned char*) s, strlen( s ) );
+ sha1_append( &sha, (unsigned char*) ic->acc->pass, strlen( ic->acc->pass ) );
+ sha1_finish( &sha, hash );
+
+ for( i = 0; i < 20; i ++ )
+ sprintf( hash_hex + i * 2, "%02x", hash[i] );
+
+ xt_add_child( reply, xt_new_node( "digest", hash_hex, NULL ) );
+ }
+ else if( xt_find_node( query->children, "password" ) )
+ {
+ /* We'll have to stick with plaintext. Let's hope we're using SSL/TLS... */
+ xt_add_child( reply, xt_new_node( "password", ic->acc->pass, NULL ) );
+ }
+ else
+ {
+ xt_free_node( reply );
+
+ imcb_error( ic, "Can't find suitable authentication method" );
+ imc_logout( ic, FALSE );
+ return XT_ABORT;
+ }
+
+ reply = jabber_make_packet( "iq", "set", NULL, reply );
+ jabber_cache_add( ic, reply, jabber_finish_iq_auth );
+ st = jabber_write_packet( ic, reply );
+
+ return st ? XT_HANDLED : XT_ABORT;
+}
+
+static xt_status jabber_finish_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ struct jabber_data *jd = ic->proto_data;
+ char *type;
+
+ if( !( type = xt_find_attr( node, "type" ) ) )
+ {
+ imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
+ imc_logout( ic, FALSE );
+ return XT_HANDLED;
+ }
+
+ if( strcmp( type, "error" ) == 0 )
+ {
+ imcb_error( ic, "Authentication failure" );
+ imc_logout( ic, FALSE );
+ return XT_ABORT;
+ }
+ else if( strcmp( type, "result" ) == 0 )
+ {
+ /* This happens when we just successfully authenticated the
+ old (non-SASL) way. */
+ jd->flags |= JFLAG_AUTHENTICATED;
+ if( !jabber_get_roster( ic ) )
+ return XT_ABORT;
+ }
+
+ return XT_HANDLED;
+}
+
+xt_status jabber_pkt_bind_sess( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ struct jabber_data *jd = ic->proto_data;
+ struct xt_node *c;
+ char *s;
+
+ if( ( c = xt_find_node( node->children, "bind" ) ) )
+ {
+ c = xt_find_node( c->children, "jid" );
+ if( c && c->text_len && ( s = strchr( c->text, '/' ) ) &&
+ strcmp( s + 1, set_getstr( &ic->acc->set, "resource" ) ) != 0 )
+ imcb_log( ic, "Server changed session resource string to `%s'", s + 1 );
+
+ jd->flags &= ~JFLAG_WAIT_BIND;
+ }
+ else
+ {
+ jd->flags &= ~JFLAG_WAIT_SESSION;
+ }
+
+ if( ( jd->flags & ( JFLAG_WAIT_BIND | JFLAG_WAIT_SESSION ) ) == 0 )
+ {
+ if( !jabber_get_roster( ic ) )
+ return XT_ABORT;
+ }
+
+ return XT_HANDLED;
+}
+
+int jabber_get_roster( struct im_connection *ic )
+{
+ struct xt_node *node;
+ int st;
+
+ imcb_log( ic, "Authenticated, requesting buddy list" );
+
+ node = xt_new_node( "query", NULL, NULL );
+ xt_add_attr( node, "xmlns", XMLNS_ROSTER );
+ node = jabber_make_packet( "iq", "get", NULL, node );
+
+ jabber_cache_add( ic, node, jabber_parse_roster );
+ st = jabber_write_packet( ic, node );
+
+ return st;
+}
+
+static xt_status jabber_parse_roster( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ struct xt_node *query, *c;
+ int initial = ( orig != NULL );
+
+ if( !( query = xt_find_node( node->children, "query" ) ) )
+ {
+ imcb_log( ic, "Warning: Received NULL roster packet" );
+ return XT_HANDLED;
+ }
+
+ c = query->children;
+ while( ( c = xt_find_node( c, "item" ) ) )
+ {
+ struct xt_node *group = xt_find_node( node->children, "group" );
+ char *jid = xt_find_attr( c, "jid" );
+ char *name = xt_find_attr( c, "name" );
+ char *sub = xt_find_attr( c, "subscription" );
+
+ if( jid && sub )
+ {
+ if( ( strcmp( sub, "both" ) == 0 || strcmp( sub, "to" ) == 0 ) )
+ {
+ if( initial || imcb_find_buddy( ic, jid ) == NULL )
+ imcb_add_buddy( ic, jid, ( group && group->text_len ) ?
+ group->text : NULL );
+
+ if( name )
+ imcb_rename_buddy( ic, jid, name );
+ }
+ else if( strcmp( sub, "remove" ) == 0 )
+ {
+ jabber_buddy_remove_bare( ic, jid );
+ imcb_remove_buddy( ic, jid, NULL );
+ }
+ }
+
+ c = c->next;
+ }
+
+ if( initial )
+ imcb_connected( ic );
+
+ return XT_HANDLED;
+}
+
+int jabber_get_vcard( struct im_connection *ic, char *bare_jid )
+{
+ struct xt_node *node;
+
+ if( strchr( bare_jid, '/' ) )
+ return 1; /* This was an error, but return 0 should only be done if the connection died... */
+
+ node = xt_new_node( "vCard", NULL, NULL );
+ xt_add_attr( node, "xmlns", XMLNS_VCARD );
+ node = jabber_make_packet( "iq", "get", bare_jid, node );
+
+ jabber_cache_add( ic, node, jabber_iq_display_vcard );
+ return jabber_write_packet( ic, node );
+}
+
+static xt_status jabber_iq_display_vcard( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ struct xt_node *vc, *c, *sc; /* subchild, ic is already in use ;-) */
+ GString *reply;
+ char *s;
+
+ if( ( s = xt_find_attr( node, "type" ) ) == NULL ||
+ strcmp( s, "result" ) != 0 ||
+ ( vc = xt_find_node( node->children, "vCard" ) ) == NULL )
+ {
+ s = xt_find_attr( orig, "to" ); /* If this returns NULL something's wrong.. */
+ imcb_log( ic, "Could not retrieve vCard of %s", s ? s : "(NULL)" );
+ return XT_HANDLED;
+ }
+
+ s = xt_find_attr( orig, "to" );
+ reply = g_string_new( "vCard information for " );
+ reply = g_string_append( reply, s ? s : "(NULL)" );
+ reply = g_string_append( reply, ":\n" );
+
+ /* I hate this format, I really do... */
+
+ if( ( c = xt_find_node( vc->children, "FN" ) ) && c->text_len )
+ g_string_append_printf( reply, "Name: %s\n", c->text );
+
+ if( ( c = xt_find_node( vc->children, "N" ) ) && c->children )
+ {
+ reply = g_string_append( reply, "Full name:" );
+
+ if( ( sc = xt_find_node( c->children, "PREFIX" ) ) && sc->text_len )
+ g_string_append_printf( reply, " %s", sc->text );
+ if( ( sc = xt_find_node( c->children, "GIVEN" ) ) && sc->text_len )
+ g_string_append_printf( reply, " %s", sc->text );
+ if( ( sc = xt_find_node( c->children, "MIDDLE" ) ) && sc->text_len )
+ g_string_append_printf( reply, " %s", sc->text );
+ if( ( sc = xt_find_node( c->children, "FAMILY" ) ) && sc->text_len )
+ g_string_append_printf( reply, " %s", sc->text );
+ if( ( sc = xt_find_node( c->children, "SUFFIX" ) ) && sc->text_len )
+ g_string_append_printf( reply, " %s", sc->text );
+
+ reply = g_string_append_c( reply, '\n' );
+ }
+
+ if( ( c = xt_find_node( vc->children, "NICKNAME" ) ) && c->text_len )
+ g_string_append_printf( reply, "Nickname: %s\n", c->text );
+
+ if( ( c = xt_find_node( vc->children, "BDAY" ) ) && c->text_len )
+ g_string_append_printf( reply, "Date of birth: %s\n", c->text );
+
+ /* Slightly alternative use of for... ;-) */
+ for( c = vc->children; ( c = xt_find_node( c, "EMAIL" ) ); c = c->next )
+ {
+ if( ( sc = xt_find_node( c->children, "USERID" ) ) == NULL || sc->text_len == 0 )
+ continue;
+
+ if( xt_find_node( c->children, "HOME" ) )
+ s = "Home";
+ else if( xt_find_node( c->children, "WORK" ) )
+ s = "Work";
+ else
+ s = "Misc.";
+
+ g_string_append_printf( reply, "%s e-mail address: %s\n", s, sc->text );
+ }
+
+ if( ( c = xt_find_node( vc->children, "URL" ) ) && c->text_len )
+ g_string_append_printf( reply, "Homepage: %s\n", c->text );
+
+ /* Slightly alternative use of for... ;-) */
+ for( c = vc->children; ( c = xt_find_node( c, "ADR" ) ); c = c->next )
+ {
+ if( xt_find_node( c->children, "HOME" ) )
+ s = "Home";
+ else if( xt_find_node( c->children, "WORK" ) )
+ s = "Work";
+ else
+ s = "Misc.";
+
+ g_string_append_printf( reply, "%s address: ", s );
+
+ if( ( sc = xt_find_node( c->children, "STREET" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s ", sc->text );
+ if( ( sc = xt_find_node( c->children, "EXTADR" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s, ", sc->text );
+ if( ( sc = xt_find_node( c->children, "PCODE" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s, ", sc->text );
+ if( ( sc = xt_find_node( c->children, "LOCALITY" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s, ", sc->text );
+ if( ( sc = xt_find_node( c->children, "REGION" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s, ", sc->text );
+ if( ( sc = xt_find_node( c->children, "CTRY" ) ) && sc->text_len )
+ g_string_append_printf( reply, "%s", sc->text );
+
+ if( reply->str[reply->len-2] == ',' )
+ reply = g_string_truncate( reply, reply->len-2 );
+
+ reply = g_string_append_c( reply, '\n' );
+ }
+
+ for( c = vc->children; ( c = xt_find_node( c, "TEL" ) ); c = c->next )
+ {
+ if( ( sc = xt_find_node( c->children, "NUMBER" ) ) == NULL || sc->text_len == 0 )
+ continue;
+
+ if( xt_find_node( c->children, "HOME" ) )
+ s = "Home";
+ else if( xt_find_node( c->children, "WORK" ) )
+ s = "Work";
+ else
+ s = "Misc.";
+
+ g_string_append_printf( reply, "%s phone number: %s\n", s, sc->text );
+ }
+
+ if( ( c = xt_find_node( vc->children, "DESC" ) ) && c->text_len )
+ g_string_append_printf( reply, "Other information:\n%s", c->text );
+
+ /* *sigh* */
+
+ imcb_log( ic, "%s", reply->str );
+ g_string_free( reply, TRUE );
+
+ return XT_HANDLED;
+}
+
+static xt_status jabber_add_to_roster_callback( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
+
+int jabber_add_to_roster( struct im_connection *ic, char *handle, char *name )
+{
+ struct xt_node *node;
+ int st;
+
+ /* Build the item entry */
+ node = xt_new_node( "item", NULL, NULL );
+ xt_add_attr( node, "jid", handle );
+ if( name )
+ xt_add_attr( node, "name", name );
+
+ /* And pack it into a roster-add packet */
+ node = xt_new_node( "query", NULL, node );
+ xt_add_attr( node, "xmlns", XMLNS_ROSTER );
+ node = jabber_make_packet( "iq", "set", NULL, node );
+ jabber_cache_add( ic, node, jabber_add_to_roster_callback );
+
+ st = jabber_write_packet( ic, node );
+
+ return st;
+}
+
+static xt_status jabber_add_to_roster_callback( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
+{
+ char *s, *jid = NULL;
+ struct xt_node *c;
+
+ if( ( c = xt_find_node( orig->children, "query" ) ) &&
+ ( c = xt_find_node( c->children, "item" ) ) &&
+ ( jid = xt_find_attr( c, "jid" ) ) &&
+ ( s = xt_find_attr( node, "type" ) ) &&
+ strcmp( s, "result" ) == 0 )
+ {
+ if( imcb_find_buddy( ic, jid ) == NULL )
+ imcb_add_buddy( ic, jid, NULL );
+ }
+ else
+ {
+ imcb_log( ic, "Error while adding `%s' to your contact list.",
+ jid ? jid : "(unknown handle)" );
+ }
+
+ return XT_HANDLED;
+}
+
+int jabber_remove_from_roster( struct im_connection *ic, char *handle )
+{
+ struct xt_node *node;
+ int st;
+
+ /* Build the item entry */
+ node = xt_new_node( "item", NULL, NULL );
+ xt_add_attr( node, "jid", handle );
+ xt_add_attr( node, "subscription", "remove" );
+
+ /* And pack it into a roster-add packet */
+ node = xt_new_node( "query", NULL, node );
+ xt_add_attr( node, "xmlns", XMLNS_ROSTER );
+ node = jabber_make_packet( "iq", "set", NULL, node );
+
+ st = jabber_write_packet( ic, node );
+
+ xt_free_node( node );
+ return st;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2025-04-27 19:38:25 +0000