source: protocols/jabber/iq.c @ 78e103e

Last change on this file since 78e103e was 1444be5, checked in by Michael Stapelberg <michael@…>, at 2012-10-17T07:23:00Z

Implement jabber message receipts (XEP-0184)

This change will make BitlBee acknowledge messages when requested.
It will not request message receipts from other clients, mainly because I am
not sure if this feature can be mapped to IRC cleanly.
  • Property mode set to 100644
File size: 28.0 KB
Line 
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#include "sha1.h"
26
27static xt_status jabber_parse_roster( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
28static xt_status jabber_iq_display_vcard( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
29static int jabber_iq_disco_server( struct im_connection *ic );
30
31xt_status jabber_pkt_iq( struct xt_node *node, gpointer data )
32{
33        struct im_connection *ic = data;
34        struct jabber_data *jd = ic->proto_data;
35        struct xt_node *c, *reply = NULL;
36        char *type, *s;
37        int st, pack = 1;
38       
39        type = xt_find_attr( node, "type" );
40       
41        if( !type )
42        {
43                imcb_error( ic, "Received IQ packet without type." );
44                imc_logout( ic, TRUE );
45                return XT_ABORT;
46        }
47       
48        if( strcmp( type, "result" ) == 0 || strcmp( type, "error" ) == 0 )
49        {
50                return jabber_cache_handle_packet( ic, node );
51        }
52        else if( strcmp( type, "get" ) == 0 )
53        {
54                if( !( ( c = xt_find_node( node->children, "query" ) ) ||
55                       ( c = xt_find_node( node->children, "ping" ) ) ||
56                       ( c = xt_find_node( node->children, "time" ) ) ) ||
57                    !( s = xt_find_attr( c, "xmlns" ) ) )
58                {
59                        /* Sigh. Who decided to suddenly invent new elements
60                           instead of just sticking with <query/>? */
61                        return XT_HANDLED;
62                }
63               
64                reply = xt_new_node( "query", NULL, NULL );
65                xt_add_attr( reply, "xmlns", s );
66               
67                /* Of course this is a very essential query to support. ;-) */
68                if( strcmp( s, XMLNS_VERSION ) == 0 )
69                {
70                        xt_add_child( reply, xt_new_node( "name", set_getstr( &ic->acc->set, "user_agent" ), NULL ) );
71                        xt_add_child( reply, xt_new_node( "version", BITLBEE_VERSION, NULL ) );
72                        xt_add_child( reply, xt_new_node( "os", ARCH, NULL ) );
73                }
74                else if( strcmp( s, XMLNS_TIME_OLD ) == 0 )
75                {
76                        time_t time_ep;
77                        char buf[1024];
78                       
79                        buf[sizeof(buf)-1] = 0;
80                        time_ep = time( NULL );
81                       
82                        strftime( buf, sizeof( buf ) - 1, "%Y%m%dT%H:%M:%S", gmtime( &time_ep ) );
83                        xt_add_child( reply, xt_new_node( "utc", buf, NULL ) );
84                       
85                        strftime( buf, sizeof( buf ) - 1, "%Z", localtime( &time_ep ) );
86                        xt_add_child( reply, xt_new_node( "tz", buf, NULL ) );
87                }
88                else if( strcmp( s, XMLNS_TIME ) == 0 )
89                {
90                        time_t time_ep;
91                        char buf[1024];
92                       
93                        buf[sizeof(buf)-1] = 0;
94                        time_ep = time( NULL );
95                       
96                        xt_free_node( reply );
97                        reply = xt_new_node( "time", NULL, NULL );
98                        xt_add_attr( reply, "xmlns", XMLNS_TIME );
99                       
100                        strftime( buf, sizeof( buf ) - 1, "%Y%m%dT%H:%M:%SZ", gmtime( &time_ep ) );
101                        xt_add_child( reply, xt_new_node( "utc", buf, NULL ) );
102                       
103                        strftime( buf, sizeof( buf ) - 1, "%z", localtime( &time_ep ) );
104                        if( strlen( buf ) >= 5 )
105                        {
106                                buf[6] = '\0';
107                                buf[5] = buf[4];
108                                buf[4] = buf[3];
109                                buf[3] = ':';
110                        }
111                        xt_add_child( reply, xt_new_node( "tzo", buf, NULL ) );
112                }
113                else if( strcmp( s, XMLNS_PING ) == 0 )
114                {
115                        xt_free_node( reply );
116                        reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), NULL );
117                        if( ( s = xt_find_attr( node, "id" ) ) )
118                                xt_add_attr( reply, "id", s );
119                        pack = 0;
120                }
121                else if( strcmp( s, XMLNS_DISCO_INFO ) == 0 )
122                {
123                        const char *features[] = { XMLNS_DISCO_INFO,
124                                                   XMLNS_VERSION,
125                                                   XMLNS_TIME_OLD,
126                                                   XMLNS_TIME,
127                                                   XMLNS_CHATSTATES,
128                                                   XMLNS_MUC,
129                                                   XMLNS_PING,
130                                                   XMLNS_RECEIPTS,
131                                                   XMLNS_SI,
132                                                   XMLNS_BYTESTREAMS,
133                                                   XMLNS_FILETRANSFER,
134                                                   NULL };
135                        const char **f;
136                       
137                        c = xt_new_node( "identity", NULL, NULL );
138                        xt_add_attr( c, "category", "client" );
139                        xt_add_attr( c, "type", "pc" );
140                        xt_add_attr( c, "name", set_getstr( &ic->acc->set, "user_agent" ) );
141                        xt_add_child( reply, c );
142                       
143                        for( f = features; *f; f ++ )
144                        {
145                                c = xt_new_node( "feature", NULL, NULL );
146                                xt_add_attr( c, "var", *f );
147                                xt_add_child( reply, c );
148                        }
149                }
150                else
151                {
152                        xt_free_node( reply );
153                        reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel", NULL );
154                        pack = 0;
155                }
156        }
157        else if( strcmp( type, "set" ) == 0 )
158        {
159                if( ( c = xt_find_node( node->children, "si" ) ) &&
160                    ( s = xt_find_attr( c, "xmlns" ) ) &&
161                    ( strcmp( s, XMLNS_SI ) == 0 ) )
162                {
163                        return jabber_si_handle_request( ic, node, c );
164                }
165                else if( !( c = xt_find_node( node->children, "query" ) ) ||
166                         !( s = xt_find_attr( c, "xmlns" ) ) )
167                {
168                        return XT_HANDLED;
169                }
170                else if( strcmp( s, XMLNS_ROSTER ) == 0 )
171                {
172                /* This is a roster push. XMPP servers send this when someone
173                   was added to (or removed from) the buddy list. AFAIK they're
174                   sent even if we added this buddy in our own session. */
175                        int bare_len = strlen( jd->me );
176                       
177                        if( ( s = xt_find_attr( node, "from" ) ) == NULL ||
178                            ( strncmp( s, jd->me, bare_len ) == 0 &&
179                              ( s[bare_len] == 0 || s[bare_len] == '/' ) ) )
180                        {
181                                jabber_parse_roster( ic, node, NULL );
182                               
183                                /* Should we generate a reply here? Don't think it's
184                                   very important... */
185                        }
186                        else
187                        {
188                                imcb_log( ic, "Warning: %s tried to fake a roster push!", s ? s : "(unknown)" );
189                               
190                                xt_free_node( reply );
191                                reply = jabber_make_error_packet( node, "not-allowed", "cancel", NULL );
192                                pack = 0;
193                        }
194                }
195                else if( strcmp( s, XMLNS_BYTESTREAMS ) == 0 )
196                {
197                        /* Bytestream Request (stage 2 of file transfer) */
198                        return jabber_bs_recv_request( ic, node, c );
199                }
200                else
201                {
202                        xt_free_node( reply );
203                        reply = jabber_make_error_packet( node, "feature-not-implemented", "cancel", NULL );
204                        pack = 0;
205                }
206        }
207       
208        /* If we recognized the xmlns and managed to generate a reply,
209           finish and send it. */
210        if( reply )
211        {
212                /* Normally we still have to pack it into an iq-result
213                   packet, but for errors, for example, we don't. */
214                if( pack )
215                {
216                        reply = jabber_make_packet( "iq", "result", xt_find_attr( node, "from" ), reply );
217                        if( ( s = xt_find_attr( node, "id" ) ) )
218                                xt_add_attr( reply, "id", s );
219                }
220               
221                st = jabber_write_packet( ic, reply );
222                xt_free_node( reply );
223                if( !st )
224                        return XT_ABORT;
225        }
226       
227        return XT_HANDLED;
228}
229
230static xt_status jabber_do_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
231static xt_status jabber_finish_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
232
233int jabber_init_iq_auth( struct im_connection *ic )
234{
235        struct jabber_data *jd = ic->proto_data;
236        struct xt_node *node;
237        int st;
238       
239        node = xt_new_node( "query", NULL, xt_new_node( "username", jd->username, NULL ) );
240        xt_add_attr( node, "xmlns", XMLNS_AUTH );
241        node = jabber_make_packet( "iq", "get", NULL, node );
242       
243        jabber_cache_add( ic, node, jabber_do_iq_auth );
244        st = jabber_write_packet( ic, node );
245       
246        return st;
247}
248
249static xt_status jabber_do_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
250{
251        struct jabber_data *jd = ic->proto_data;
252        struct xt_node *reply, *query;
253        xt_status st;
254        char *s;
255       
256        if( !( query = xt_find_node( node->children, "query" ) ) )
257        {
258                imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
259                imc_logout( ic, FALSE );
260                return XT_HANDLED;
261        }
262       
263        /* Time to authenticate ourselves! */
264        reply = xt_new_node( "query", NULL, NULL );
265        xt_add_attr( reply, "xmlns", XMLNS_AUTH );
266        xt_add_child( reply, xt_new_node( "username", jd->username, NULL ) );
267        xt_add_child( reply, xt_new_node( "resource", set_getstr( &ic->acc->set, "resource" ), NULL ) );
268       
269        if( xt_find_node( query->children, "digest" ) && ( s = xt_find_attr( jd->xt->root, "id" ) ) )
270        {
271                /* We can do digest authentication, it seems, and of
272                   course we prefer that. */
273                sha1_state_t sha;
274                char hash_hex[41];
275                unsigned char hash[20];
276                int i;
277               
278                sha1_init( &sha );
279                sha1_append( &sha, (unsigned char*) s, strlen( s ) );
280                sha1_append( &sha, (unsigned char*) ic->acc->pass, strlen( ic->acc->pass ) );
281                sha1_finish( &sha, hash );
282               
283                for( i = 0; i < 20; i ++ )
284                        sprintf( hash_hex + i * 2, "%02x", hash[i] );
285               
286                xt_add_child( reply, xt_new_node( "digest", hash_hex, NULL ) );
287        }
288        else if( xt_find_node( query->children, "password" ) )
289        {
290                /* We'll have to stick with plaintext. Let's hope we're using SSL/TLS... */
291                xt_add_child( reply, xt_new_node( "password", ic->acc->pass, NULL ) );
292        }
293        else
294        {
295                xt_free_node( reply );
296               
297                imcb_error( ic, "Can't find suitable authentication method" );
298                imc_logout( ic, FALSE );
299                return XT_ABORT;
300        }
301       
302        reply = jabber_make_packet( "iq", "set", NULL, reply );
303        jabber_cache_add( ic, reply, jabber_finish_iq_auth );
304        st = jabber_write_packet( ic, reply );
305       
306        return st ? XT_HANDLED : XT_ABORT;
307}
308
309static xt_status jabber_finish_iq_auth( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
310{
311        struct jabber_data *jd = ic->proto_data;
312        char *type;
313       
314        if( !( type = xt_find_attr( node, "type" ) ) )
315        {
316                imcb_log( ic, "Warning: Received incomplete IQ packet while authenticating" );
317                imc_logout( ic, FALSE );
318                return XT_HANDLED;
319        }
320       
321        if( strcmp( type, "error" ) == 0 )
322        {
323                imcb_error( ic, "Authentication failure" );
324                imc_logout( ic, FALSE );
325                return XT_ABORT;
326        }
327        else if( strcmp( type, "result" ) == 0 )
328        {
329                /* This happens when we just successfully authenticated the
330                   old (non-SASL) way. */
331                jd->flags |= JFLAG_AUTHENTICATED;
332                if( !jabber_get_roster( ic ) )
333                        return XT_ABORT;
334                if( !jabber_iq_disco_server( ic ) )
335                        return XT_ABORT;
336        }
337       
338        return XT_HANDLED;
339}
340
341xt_status jabber_pkt_bind_sess( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
342{
343        struct jabber_data *jd = ic->proto_data;
344        struct xt_node *c, *reply = NULL;
345        char *s;
346       
347        if( node && ( c = xt_find_node( node->children, "bind" ) ) )
348        {
349                c = xt_find_node( c->children, "jid" );
350                if( !c || !c->text )
351                {
352                        /* Server is crap, but this is no disaster. */
353                }
354                else if( strncmp( jd->me, c->text, strlen( jd->me ) ) != 0 )
355                {
356                        s = strchr( c->text, '/' );
357                        if( s )
358                                *s = '\0';
359                        jabber_set_me( ic, c->text );
360                        imcb_log( ic, "Server claims your JID is `%s' instead of `%s'. "
361                                  "This mismatch may cause problems with groupchats "
362                                  "and possibly other things.",
363                                  c->text, ic->acc->user );
364                        if( s )
365                                *s = '/';
366                }
367                else if( c && c->text_len && ( s = strchr( c->text, '/' ) ) &&
368                         strcmp( s + 1, set_getstr( &ic->acc->set, "resource" ) ) != 0 )
369                        imcb_log( ic, "Server changed session resource string to `%s'", s + 1 );
370        }
371       
372        if( jd->flags & JFLAG_WANT_BIND )
373        {
374                reply = xt_new_node( "bind", NULL, xt_new_node( "resource", set_getstr( &ic->acc->set, "resource" ), NULL ) );
375                xt_add_attr( reply, "xmlns", XMLNS_BIND );
376                jd->flags &= ~JFLAG_WANT_BIND;
377        }
378        else if( jd->flags & JFLAG_WANT_SESSION )
379        {
380                reply = xt_new_node( "session", NULL, NULL );
381                xt_add_attr( reply, "xmlns", XMLNS_SESSION );
382                jd->flags &= ~JFLAG_WANT_SESSION;
383        }
384       
385        if( reply != NULL )
386        {
387                reply = jabber_make_packet( "iq", "set", NULL, reply );
388                jabber_cache_add( ic, reply, jabber_pkt_bind_sess );
389               
390                if( !jabber_write_packet( ic, reply ) )
391                        return XT_ABORT;
392        }
393        else if( ( jd->flags & ( JFLAG_WANT_BIND | JFLAG_WANT_SESSION ) ) == 0 )
394        {
395                if( !jabber_get_roster( ic ) )
396                        return XT_ABORT;
397                if( !jabber_iq_disco_server( ic ) )
398                        return XT_ABORT;
399        }
400       
401        return XT_HANDLED;
402}
403
404int jabber_get_roster( struct im_connection *ic )
405{
406        struct xt_node *node;
407        int st;
408       
409        imcb_log( ic, "Authenticated, requesting buddy list" );
410       
411        node = xt_new_node( "query", NULL, NULL );
412        xt_add_attr( node, "xmlns", XMLNS_ROSTER );
413        node = jabber_make_packet( "iq", "get", NULL, node );
414       
415        jabber_cache_add( ic, node, jabber_parse_roster );
416        st = jabber_write_packet( ic, node );
417       
418        return st;
419}
420
421static xt_status jabber_parse_roster( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
422{
423        struct xt_node *query, *c;
424        int initial = ( orig != NULL );
425       
426        if( !( query = xt_find_node( node->children, "query" ) ) )
427        {
428                imcb_log( ic, "Warning: Received NULL roster packet" );
429                return XT_HANDLED;
430        }
431       
432        c = query->children;
433        while( ( c = xt_find_node( c, "item" ) ) )
434        {
435                struct xt_node *group = xt_find_node( c->children, "group" );
436                char *jid = xt_find_attr( c, "jid" );
437                char *name = xt_find_attr( c, "name" );
438                char *sub = xt_find_attr( c, "subscription" );
439               
440                if( jid && sub )
441                {
442                        if( ( strcmp( sub, "both" ) == 0 || strcmp( sub, "to" ) == 0 ) )
443                        {
444                                imcb_add_buddy( ic, jid, ( group && group->text_len ) ?
445                                                           group->text : NULL );
446                               
447                                if( name )
448                                        imcb_rename_buddy( ic, jid, name );
449                        }
450                        else if( strcmp( sub, "remove" ) == 0 )
451                        {
452                                jabber_buddy_remove_bare( ic, jid );
453                                imcb_remove_buddy( ic, jid, NULL );
454                        }
455                }
456               
457                c = c->next;
458        }
459       
460        if( initial )
461                imcb_connected( ic );
462       
463        return XT_HANDLED;
464}
465
466int jabber_get_vcard( struct im_connection *ic, char *bare_jid )
467{
468        struct xt_node *node;
469       
470        if( strchr( bare_jid, '/' ) )
471                return 1;       /* This was an error, but return 0 should only be done if the connection died... */
472       
473        node = xt_new_node( "vCard", NULL, NULL );
474        xt_add_attr( node, "xmlns", XMLNS_VCARD );
475        node = jabber_make_packet( "iq", "get", bare_jid, node );
476       
477        jabber_cache_add( ic, node, jabber_iq_display_vcard );
478        return jabber_write_packet( ic, node );
479}
480
481static xt_status jabber_iq_display_vcard( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
482{
483        struct xt_node *vc, *c, *sc; /* subchild, ic is already in use ;-) */
484        GString *reply;
485        char *s;
486       
487        if( ( s = xt_find_attr( node, "type" ) ) == NULL ||
488            strcmp( s, "result" ) != 0 ||
489            ( vc = xt_find_node( node->children, "vCard" ) ) == NULL )
490        {
491                s = xt_find_attr( orig, "to" ); /* If this returns NULL something's wrong.. */
492                imcb_log( ic, "Could not retrieve vCard of %s", s ? s : "(NULL)" );
493                return XT_HANDLED;
494        }
495       
496        s = xt_find_attr( orig, "to" );
497        reply = g_string_new( "vCard information for " );
498        reply = g_string_append( reply, s ? s : "(NULL)" );
499        reply = g_string_append( reply, ":\n" );
500       
501        /* I hate this format, I really do... */
502       
503        if( ( c = xt_find_node( vc->children, "FN" ) ) && c->text_len )
504                g_string_append_printf( reply, "Name: %s\n", c->text );
505       
506        if( ( c = xt_find_node( vc->children, "N" ) ) && c->children )
507        {
508                reply = g_string_append( reply, "Full name:" );
509               
510                if( ( sc = xt_find_node( c->children, "PREFIX" ) ) && sc->text_len )
511                        g_string_append_printf( reply, " %s", sc->text );
512                if( ( sc = xt_find_node( c->children, "GIVEN" ) ) && sc->text_len )
513                        g_string_append_printf( reply, " %s", sc->text );
514                if( ( sc = xt_find_node( c->children, "MIDDLE" ) ) && sc->text_len )
515                        g_string_append_printf( reply, " %s", sc->text );
516                if( ( sc = xt_find_node( c->children, "FAMILY" ) ) && sc->text_len )
517                        g_string_append_printf( reply, " %s", sc->text );
518                if( ( sc = xt_find_node( c->children, "SUFFIX" ) ) && sc->text_len )
519                        g_string_append_printf( reply, " %s", sc->text );
520               
521                reply = g_string_append_c( reply, '\n' );
522        }
523       
524        if( ( c = xt_find_node( vc->children, "NICKNAME" ) ) && c->text_len )
525                g_string_append_printf( reply, "Nickname: %s\n", c->text );
526       
527        if( ( c = xt_find_node( vc->children, "BDAY" ) ) && c->text_len )
528                g_string_append_printf( reply, "Date of birth: %s\n", c->text );
529       
530        /* Slightly alternative use of for... ;-) */
531        for( c = vc->children; ( c = xt_find_node( c, "EMAIL" ) ); c = c->next )
532        {
533                if( ( sc = xt_find_node( c->children, "USERID" ) ) == NULL || sc->text_len == 0 )
534                        continue;
535               
536                if( xt_find_node( c->children, "HOME" ) )
537                        s = "Home";
538                else if( xt_find_node( c->children, "WORK" ) )
539                        s = "Work";
540                else
541                        s = "Misc.";
542               
543                g_string_append_printf( reply, "%s e-mail address: %s\n", s, sc->text );
544        }
545       
546        if( ( c = xt_find_node( vc->children, "URL" ) ) && c->text_len )
547                g_string_append_printf( reply, "Homepage: %s\n", c->text );
548       
549        /* Slightly alternative use of for... ;-) */
550        for( c = vc->children; ( c = xt_find_node( c, "ADR" ) ); c = c->next )
551        {
552                if( xt_find_node( c->children, "HOME" ) )
553                        s = "Home";
554                else if( xt_find_node( c->children, "WORK" ) )
555                        s = "Work";
556                else
557                        s = "Misc.";
558               
559                g_string_append_printf( reply, "%s address: ", s );
560               
561                if( ( sc = xt_find_node( c->children, "STREET" ) ) && sc->text_len )
562                        g_string_append_printf( reply, "%s ", sc->text );
563                if( ( sc = xt_find_node( c->children, "EXTADR" ) ) && sc->text_len )
564                        g_string_append_printf( reply, "%s, ", sc->text );
565                if( ( sc = xt_find_node( c->children, "PCODE" ) ) && sc->text_len )
566                        g_string_append_printf( reply, "%s, ", sc->text );
567                if( ( sc = xt_find_node( c->children, "LOCALITY" ) ) && sc->text_len )
568                        g_string_append_printf( reply, "%s, ", sc->text );
569                if( ( sc = xt_find_node( c->children, "REGION" ) ) && sc->text_len )
570                        g_string_append_printf( reply, "%s, ", sc->text );
571                if( ( sc = xt_find_node( c->children, "CTRY" ) ) && sc->text_len )
572                        g_string_append_printf( reply, "%s", sc->text );
573               
574                if( reply->str[reply->len-2] == ',' )
575                        reply = g_string_truncate( reply, reply->len-2 );
576               
577                reply = g_string_append_c( reply, '\n' );
578        }
579       
580        for( c = vc->children; ( c = xt_find_node( c, "TEL" ) ); c = c->next )
581        {
582                if( ( sc = xt_find_node( c->children, "NUMBER" ) ) == NULL || sc->text_len == 0 )
583                        continue;
584               
585                if( xt_find_node( c->children, "HOME" ) )
586                        s = "Home";
587                else if( xt_find_node( c->children, "WORK" ) )
588                        s = "Work";
589                else
590                        s = "Misc.";
591               
592                g_string_append_printf( reply, "%s phone number: %s\n", s, sc->text );
593        }
594       
595        if( ( c = xt_find_node( vc->children, "DESC" ) ) && c->text_len )
596                g_string_append_printf( reply, "Other information:\n%s", c->text );
597       
598        /* *sigh* */
599       
600        imcb_log( ic, "%s", reply->str );
601        g_string_free( reply, TRUE );
602       
603        return XT_HANDLED;
604}
605
606static xt_status jabber_add_to_roster_callback( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
607
608int jabber_add_to_roster( struct im_connection *ic, const char *handle, const char *name, const char *group )
609{
610        struct xt_node *node;
611        int st;
612       
613        /* Build the item entry */
614        node = xt_new_node( "item", NULL, NULL );
615        xt_add_attr( node, "jid", handle );
616        if( name )
617                xt_add_attr( node, "name", name );
618        if( group )
619                xt_add_child( node, xt_new_node( "group", group, NULL ) );
620       
621        /* And pack it into a roster-add packet */
622        node = xt_new_node( "query", NULL, node );
623        xt_add_attr( node, "xmlns", XMLNS_ROSTER );
624        node = jabber_make_packet( "iq", "set", NULL, node );
625        jabber_cache_add( ic, node, jabber_add_to_roster_callback );
626       
627        st = jabber_write_packet( ic, node );
628       
629        return st;
630}
631
632static xt_status jabber_add_to_roster_callback( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
633{
634        char *s, *jid = NULL;
635        struct xt_node *c;
636       
637        if( ( c = xt_find_node( orig->children, "query" ) ) &&
638            ( c = xt_find_node( c->children, "item" ) ) &&
639            ( jid = xt_find_attr( c, "jid" ) ) &&
640            ( s = xt_find_attr( node, "type" ) ) &&
641            strcmp( s, "result" ) == 0 )
642        {
643                if( bee_user_by_handle( ic->bee, ic, jid ) == NULL )
644                        imcb_add_buddy( ic, jid, NULL );
645        }
646        else
647        {
648                imcb_log( ic, "Error while adding `%s' to your contact list.",
649                          jid ? jid : "(unknown handle)" );
650        }
651       
652        return XT_HANDLED;
653}
654
655int jabber_remove_from_roster( struct im_connection *ic, char *handle )
656{
657        struct xt_node *node;
658        int st;
659       
660        /* Build the item entry */
661        node = xt_new_node( "item", NULL, NULL );
662        xt_add_attr( node, "jid", handle );
663        xt_add_attr( node, "subscription", "remove" );
664       
665        /* And pack it into a roster-add packet */
666        node = xt_new_node( "query", NULL, node );
667        xt_add_attr( node, "xmlns", XMLNS_ROSTER );
668        node = jabber_make_packet( "iq", "set", NULL, node );
669       
670        st = jabber_write_packet( ic, node );
671       
672        xt_free_node( node );
673        return st;
674}
675
676xt_status jabber_iq_parse_features( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
677
678xt_status jabber_iq_query_features( struct im_connection *ic, char *bare_jid )
679{
680        struct xt_node *node, *query;
681        struct jabber_buddy *bud;
682       
683        if( ( bud = jabber_buddy_by_jid( ic, bare_jid , 0 ) ) == NULL )
684        {
685                /* Who cares about the unknown... */
686                imcb_log( ic, "Couldn't find buddy: %s", bare_jid);
687                return XT_HANDLED;
688        }
689       
690        if( bud->features ) /* been here already */
691                return XT_HANDLED;
692       
693        node = xt_new_node( "query", NULL, NULL );
694        xt_add_attr( node, "xmlns", XMLNS_DISCO_INFO );
695       
696        if( !( query = jabber_make_packet( "iq", "get", bare_jid, node ) ) )
697        {
698                imcb_log( ic, "WARNING: Couldn't generate feature query" );
699                xt_free_node( node );
700                return XT_HANDLED;
701        }
702
703        jabber_cache_add( ic, query, jabber_iq_parse_features );
704
705        return jabber_write_packet( ic, query ) ? XT_HANDLED : XT_ABORT;
706}
707
708xt_status jabber_iq_parse_features( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
709{
710        struct xt_node *c;
711        struct jabber_buddy *bud;
712        char *feature, *xmlns, *from;
713
714        if( !( from = xt_find_attr( node, "from" ) ) ||
715            !( c = xt_find_node( node->children, "query" ) ) ||
716            !( xmlns = xt_find_attr( c, "xmlns" ) ) ||
717            !( strcmp( xmlns, XMLNS_DISCO_INFO ) == 0 ) )
718        {
719                imcb_log( ic, "WARNING: Received incomplete IQ-result packet for discover" );
720                return XT_HANDLED;
721        }
722        if( ( bud = jabber_buddy_by_jid( ic, from, 0 ) ) == NULL )
723        {
724                /* Who cares about the unknown... */
725                imcb_log( ic, "Couldn't find buddy: %s", from );
726                return XT_HANDLED;
727        }
728       
729        c = c->children;
730        while( ( c = xt_find_node( c, "feature" ) ) )
731        {
732                feature = xt_find_attr( c, "var" );
733                if( feature )
734                        bud->features = g_slist_append( bud->features, g_strdup( feature ) );
735                c = c->next;
736        }
737
738        return XT_HANDLED;
739}
740
741xt_status jabber_iq_parse_server_features( struct im_connection *ic, struct xt_node *node, struct xt_node *orig );
742
743xt_status jabber_iq_query_server( struct im_connection *ic, char *jid, char *xmlns )
744{
745        struct xt_node *node, *query;
746        struct jabber_data *jd = ic->proto_data;
747       
748        node = xt_new_node( "query", NULL, NULL );
749        xt_add_attr( node, "xmlns", xmlns );
750       
751        if( !( query = jabber_make_packet( "iq", "get", jid, node ) ) )
752        {
753                imcb_log( ic, "WARNING: Couldn't generate server query" );
754                xt_free_node( node );
755        }
756
757        jd->have_streamhosts--;
758        jabber_cache_add( ic, query, jabber_iq_parse_server_features );
759
760        return jabber_write_packet( ic, query ) ? XT_HANDLED : XT_ABORT;
761}
762
763/*
764 * Query the server for "items", query each "item" for identities, query each "item" that's a proxy for it's bytestream info
765 */
766xt_status jabber_iq_parse_server_features( struct im_connection *ic, struct xt_node *node, struct xt_node *orig )
767{
768        struct xt_node *c;
769        struct jabber_data *jd = ic->proto_data;
770        char *xmlns, *from;
771
772        if( !( c = xt_find_node( node->children, "query" ) ) ||
773            !( from = xt_find_attr( node, "from" ) ) ||
774            !( xmlns = xt_find_attr( c, "xmlns" ) ) )
775        {
776                imcb_log( ic, "WARNING: Received incomplete IQ-result packet for discover" );
777                return XT_HANDLED;
778        }
779
780        jd->have_streamhosts++;
781
782        if( strcmp( xmlns, XMLNS_DISCO_ITEMS ) == 0 )
783        {
784                char *itemjid;
785
786                /* answer from server */
787       
788                c = c->children;
789                while( ( c = xt_find_node( c, "item" ) ) )
790                {
791                        itemjid = xt_find_attr( c, "jid" );
792                       
793                        if( itemjid )
794                                jabber_iq_query_server( ic, itemjid, XMLNS_DISCO_INFO );
795
796                        c = c->next;
797                }
798        }
799        else if( strcmp( xmlns, XMLNS_DISCO_INFO ) == 0 )
800        {
801                char *category, *type;
802
803                /* answer from potential proxy */
804
805                c = c->children;
806                while( ( c = xt_find_node( c, "identity" ) ) )
807                {
808                        category = xt_find_attr( c, "category" );
809                        type = xt_find_attr( c, "type" );
810
811                        if( type && ( strcmp( type, "bytestreams" ) == 0 ) &&
812                            category && ( strcmp( category, "proxy" ) == 0 ) )
813                                jabber_iq_query_server( ic, from, XMLNS_BYTESTREAMS );
814
815                        c = c->next;
816                }
817        }
818        else if( strcmp( xmlns, XMLNS_BYTESTREAMS ) == 0 )
819        {
820                char *host, *jid, *port_s;
821                int port;
822
823                /* answer from proxy */
824
825                if( ( c = xt_find_node( c->children, "streamhost" ) ) &&
826                    ( host = xt_find_attr( c, "host" ) ) &&
827                    ( port_s = xt_find_attr( c, "port" ) ) &&
828                    ( sscanf( port_s, "%d", &port ) == 1 ) &&
829                    ( jid = xt_find_attr( c, "jid" ) ) )
830                {
831                        jabber_streamhost_t *sh = g_new0( jabber_streamhost_t, 1 );
832                       
833                        sh->jid = g_strdup( jid );
834                        sh->host = g_strdup( host );
835                        g_snprintf( sh->port, sizeof( sh->port ), "%u", port );
836
837                        imcb_log( ic, "Proxy found: jid %s host %s port %u", jid, host, port );
838                        jd->streamhosts = g_slist_append( jd->streamhosts, sh );
839                }
840        }
841
842        if( jd->have_streamhosts == 0 )
843                jd->have_streamhosts++;
844
845        return XT_HANDLED;
846}
847
848static xt_status jabber_iq_version_response( struct im_connection *ic,
849        struct xt_node *node, struct xt_node *orig );
850
851void jabber_iq_version_send( struct im_connection *ic, struct jabber_buddy *bud, void *data )
852{
853        struct xt_node *node, *query;
854       
855        node = xt_new_node( "query", NULL, NULL );
856        xt_add_attr( node, "xmlns", XMLNS_VERSION );
857        query = jabber_make_packet( "iq", "get", bud->full_jid, node );
858        jabber_cache_add( ic, query, jabber_iq_version_response );
859
860        jabber_write_packet( ic, query );
861}
862
863static xt_status jabber_iq_version_response( struct im_connection *ic,
864        struct xt_node *node, struct xt_node *orig )
865{
866        struct xt_node *query;
867        GString *rets;
868        char *s;
869        char *ret[2] = {};
870        bee_user_t *bu;
871        struct jabber_buddy *bud = NULL;
872       
873        if( ( s = xt_find_attr( node, "from" ) ) &&
874            ( bud = jabber_buddy_by_jid( ic, s, 0 ) ) &&
875            ( query = xt_find_node( node->children, "query" ) ) &&
876            ( bu = bee_user_by_handle( ic->bee, ic, bud->bare_jid ) ) )
877        {
878                rets = g_string_new( "Resource " );
879                g_string_append( rets, bud->resource );
880        }
881        else
882                return XT_HANDLED;
883       
884        for( query = query->children; query; query = query->next )
885                if( query->text_len > 0 )
886                        g_string_append_printf( rets, " %s: %s,", query->name, query->text );
887       
888        g_string_truncate( rets, rets->len - 1 );
889        ret[0] = rets->str;
890        imcb_buddy_action_response( bu, "VERSION", ret, NULL );
891        g_string_free( rets, TRUE );
892       
893        return XT_HANDLED;
894}
895
896static xt_status jabber_iq_disco_server_response( struct im_connection *ic,
897        struct xt_node *node, struct xt_node *orig );
898
899static int jabber_iq_disco_server( struct im_connection *ic )
900{
901        struct xt_node *node, *iq;
902        struct jabber_data *jd = ic->proto_data;
903       
904        node = xt_new_node( "query", NULL, NULL );
905        xt_add_attr( node, "xmlns", XMLNS_DISCO_INFO );
906        iq = jabber_make_packet( "iq", "get", jd->server, node );
907       
908        jabber_cache_add( ic, iq, jabber_iq_disco_server_response );
909        return jabber_write_packet( ic, iq );
910}
911
912static xt_status jabber_iq_disco_server_response( struct im_connection *ic,
913        struct xt_node *node, struct xt_node *orig )
914{
915        struct jabber_data *jd = ic->proto_data;
916        struct xt_node *id;
917       
918        if( ( id = xt_find_path( node, "query/identity" ) ) )
919        {
920                char *cat, *type, *name;
921               
922                if( !( cat = xt_find_attr( id, "category" ) ) ||
923                    !( type = xt_find_attr( id, "type" ) ) ||
924                    !( name = xt_find_attr( id, "name" ) ) )
925                        return XT_HANDLED;
926               
927                if( strcmp( cat, "server" ) == 0 && strcmp( type, "im" ) == 0 &&
928                    strstr( name, "Google" ) != NULL )
929                        jd->flags |= JFLAG_GTALK;
930        }
931       
932        return XT_HANDLED;
933}
Note: See TracBrowser for help on using the repository browser.