Mercurial > pidgin.yaz
view libpurple/protocols/jabber/disco.c @ 27564:3698c7f4d803
On MSN, pop up an "invite message" request similar to oscar, and send that
in the add request. We really should try and move this into the add buddy
dialog instead of an extra prompt.
Fixes #8503.
author | Elliott Sales de Andrade <qulogic@pidgin.im> |
---|---|
date | Mon, 13 Jul 2009 05:01:42 +0000 |
parents | dd7e7071d46d |
children | d953b613a794 |
line wrap: on
line source
/* * purple - Jabber Service Discovery * * Copyright (C) 2003, Nathan Walp <faceprint@faceprint.com> * * 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 02111-1301 USA * */ #include "internal.h" #include "prefs.h" #include "debug.h" #include "request.h" #include "adhoccommands.h" #include "buddy.h" #include "disco.h" #include "google.h" #include "iq.h" #include "jabber.h" #include "jingle/jingle.h" #include "pep.h" #include "presence.h" #include "roster.h" #include "useravatar.h" struct _jabber_disco_info_cb_data { gpointer data; JabberDiscoInfoCallback *callback; }; struct _jabber_disco_items_cb_data { gpointer data; JabberDiscoItemsCallback *callback; }; #define SUPPORT_FEATURE(x) { \ feature = xmlnode_new_child(query, "feature"); \ xmlnode_set_attrib(feature, "var", x); \ } static void jabber_disco_bytestream_server_cb(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *packet, gpointer data) { JabberBytestreamsStreamhost *sh = data; xmlnode *query = xmlnode_get_child_with_namespace(packet, "query", "http://jabber.org/protocol/bytestreams"); if (from && !strcmp(from, sh->jid) && query != NULL) { xmlnode *sh_node = xmlnode_get_child(query, "streamhost"); if (sh_node) { const char *jid = xmlnode_get_attrib(sh_node, "jid"); const char *port = xmlnode_get_attrib(sh_node, "port"); if (jid == NULL || strcmp(jid, from) != 0) purple_debug_error("jabber", "Invalid jid(%s) for bytestream.\n", jid ? jid : "(null)"); sh->host = g_strdup(xmlnode_get_attrib(sh_node, "host")); sh->zeroconf = g_strdup(xmlnode_get_attrib(sh_node, "zeroconf")); if (port != NULL) sh->port = atoi(port); } } purple_debug_info("jabber", "Discovered bytestream proxy server: " "jid='%s' host='%s' port='%d' zeroconf='%s'\n", from ? from : "", sh->host ? sh->host : "", sh->port, sh->zeroconf ? sh->zeroconf : ""); /* TODO: When we support zeroconf proxies, fix this to handle them */ if (!(sh->jid && sh->host && sh->port > 0)) { g_free(sh->jid); g_free(sh->host); g_free(sh->zeroconf); g_free(sh); js->bs_proxies = g_list_remove(js->bs_proxies, sh); } } void jabber_disco_info_parse(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *in_query) { if(!from) return; if(type == JABBER_IQ_GET) { xmlnode *query, *identity, *feature; JabberIq *iq; const char *node = xmlnode_get_attrib(in_query, "node"); char *node_uri = NULL; /* create custom caps node URI */ node_uri = g_strconcat(CAPS0115_NODE, "#", jabber_caps_get_own_hash(js), NULL); iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, "http://jabber.org/protocol/disco#info"); jabber_iq_set_id(iq, id); xmlnode_set_attrib(iq->node, "to", from); query = xmlnode_get_child(iq->node, "query"); if(node) xmlnode_set_attrib(query, "node", node); if(!node || g_str_equal(node, node_uri)) { GList *features, *identities; for(identities = jabber_identities; identities; identities = identities->next) { JabberIdentity *ident = (JabberIdentity*)identities->data; identity = xmlnode_new_child(query, "identity"); xmlnode_set_attrib(identity, "category", ident->category); xmlnode_set_attrib(identity, "type", ident->type); if (ident->lang) xmlnode_set_attrib(identity, "xml:lang", ident->lang); if (ident->name) xmlnode_set_attrib(identity, "name", ident->name); } for(features = jabber_features; features; features = features->next) { JabberFeature *feat = (JabberFeature*)features->data; if (!feat->is_enabled || feat->is_enabled(js, feat->namespace)) { feature = xmlnode_new_child(query, "feature"); xmlnode_set_attrib(feature, "var", feat->namespace); } } #ifdef USE_VV } else if (g_str_equal(node, CAPS0115_NODE "#" "voice-v1")) { /* * HUGE HACK! We advertise this ext (see jabber_presence_create_js * where we add <c/> to the <presence/>) for the Google Talk * clients that don't actually check disco#info features. * * This specific feature is redundant but is what * node='http://mail.google.com/xmpp/client/caps', ver='1.1' * advertises as 'voice-v1'. */ xmlnode *feature = xmlnode_new_child(query, "feature"); xmlnode_set_attrib(feature, "var", "http://www.google.com/xmpp/protocol/voice/v1"); } else if (g_str_equal(node, CAPS0115_NODE "#" "video-v1")) { /* * HUGE HACK! We advertise this ext (see jabber_presence_create_js * where we add <c/> to the <presence/>) for the Google Talk * clients that don't actually check disco#info features. * * This specific feature is redundant but is what * node='http://mail.google.com/xmpp/client/caps', ver='1.1' * advertises as 'video-v1'. */ xmlnode *feature = xmlnode_new_child(query, "feature"); xmlnode_set_attrib(feature, "var", "http://www.google.com/xmpp/protocol/video/v1"); #endif } else { xmlnode *error, *inf; /* XXX: gross hack, implement jabber_iq_set_type or something */ xmlnode_set_attrib(iq->node, "type", "error"); iq->type = JABBER_IQ_ERROR; error = xmlnode_new_child(query, "error"); xmlnode_set_attrib(error, "code", "404"); xmlnode_set_attrib(error, "type", "cancel"); inf = xmlnode_new_child(error, "item-not-found"); xmlnode_set_namespace(inf, "urn:ietf:params:xml:ns:xmpp-stanzas"); } g_free(node_uri); jabber_iq_send(iq); } else if (type == JABBER_IQ_SET) { /* wtf? seriously. wtf‽ */ JabberIq *iq = jabber_iq_new(js, JABBER_IQ_ERROR); xmlnode *error, *bad_request; /* Free the <query/> */ xmlnode_free(xmlnode_get_child(iq->node, "query")); /* Add an error */ error = xmlnode_new_child(iq->node, "error"); xmlnode_set_attrib(error, "type", "modify"); bad_request = xmlnode_new_child(error, "bad-request"); xmlnode_set_namespace(bad_request, "urn:ietf:params:xml:ns:xmpp-stanzas"); jabber_iq_set_id(iq, id); xmlnode_set_attrib(iq->node, "to", from); jabber_iq_send(iq); } } static void jabber_disco_info_cb(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *packet, gpointer data) { struct _jabber_disco_info_cb_data *jdicd = data; xmlnode *query; query = xmlnode_get_child_with_namespace(packet, "query", "http://jabber.org/protocol/disco#info"); if (type == JABBER_IQ_RESULT && query) { xmlnode *child; JabberID *jid; JabberBuddy *jb; JabberBuddyResource *jbr = NULL; JabberCapabilities capabilities = JABBER_CAP_NONE; if((jid = jabber_id_new(from))) { if(jid->resource && (jb = jabber_buddy_find(js, from, TRUE))) jbr = jabber_buddy_find_resource(jb, jid->resource); jabber_id_free(jid); } if(jbr) capabilities = jbr->capabilities; for(child = query->child; child; child = child->next) { if(child->type != XMLNODE_TYPE_TAG) continue; if(!strcmp(child->name, "identity")) { const char *category = xmlnode_get_attrib(child, "category"); const char *type = xmlnode_get_attrib(child, "type"); if(!category || !type) continue; if(!strcmp(category, "conference") && !strcmp(type, "text")) { /* we found a groupchat or MUC server, add it to the list */ /* XXX: actually check for protocol/muc or gc-1.0 support */ js->chat_servers = g_list_prepend(js->chat_servers, g_strdup(from)); } else if(!strcmp(category, "directory") && !strcmp(type, "user")) { /* we found a JUD */ js->user_directories = g_list_prepend(js->user_directories, g_strdup(from)); } else if(!strcmp(category, "proxy") && !strcmp(type, "bytestreams")) { /* This is a bytestream proxy */ JabberIq *iq; JabberBytestreamsStreamhost *sh; purple_debug_info("jabber", "Found bytestream proxy server: %s\n", from); sh = g_new0(JabberBytestreamsStreamhost, 1); sh->jid = g_strdup(from); js->bs_proxies = g_list_prepend(js->bs_proxies, sh); iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/bytestreams"); xmlnode_set_attrib(iq->node, "to", sh->jid); jabber_iq_set_callback(iq, jabber_disco_bytestream_server_cb, sh); jabber_iq_send(iq); } } else if(!strcmp(child->name, "feature")) { const char *var = xmlnode_get_attrib(child, "var"); if(!var) continue; if(!strcmp(var, "http://jabber.org/protocol/si")) capabilities |= JABBER_CAP_SI; else if(!strcmp(var, "http://jabber.org/protocol/si/profile/file-transfer")) capabilities |= JABBER_CAP_SI_FILE_XFER; else if(!strcmp(var, "http://jabber.org/protocol/bytestreams")) capabilities |= JABBER_CAP_BYTESTREAMS; else if(!strcmp(var, "jabber:iq:search")) capabilities |= JABBER_CAP_IQ_SEARCH; else if(!strcmp(var, "jabber:iq:register")) capabilities |= JABBER_CAP_IQ_REGISTER; else if(!strcmp(var, "urn:xmpp:ping")) capabilities |= JABBER_CAP_PING; else if(!strcmp(var, "http://jabber.org/protocol/disco#items")) capabilities |= JABBER_CAP_ITEMS; else if(!strcmp(var, "http://jabber.org/protocol/commands")) { capabilities |= JABBER_CAP_ADHOC; } else if(!strcmp(var, "http://jabber.org/protocol/ibb")) { purple_debug_info("jabber", "remote supports IBB\n"); capabilities |= JABBER_CAP_IBB; } } } capabilities |= JABBER_CAP_RETRIEVED; if(jbr) jbr->capabilities = capabilities; jdicd->callback(js, from, capabilities, jdicd->data); } else { /* type == JABBER_IQ_ERROR or query == NULL */ JabberID *jid; JabberBuddy *jb; JabberBuddyResource *jbr = NULL; JabberCapabilities capabilities = JABBER_CAP_NONE; if((jid = jabber_id_new(from))) { if(jid->resource && (jb = jabber_buddy_find(js, from, TRUE))) jbr = jabber_buddy_find_resource(jb, jid->resource); jabber_id_free(jid); } if(jbr) capabilities = jbr->capabilities; jdicd->callback(js, from, capabilities, jdicd->data); } } void jabber_disco_items_parse(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *query) { if(type == JABBER_IQ_GET) { JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, "http://jabber.org/protocol/disco#items"); /* preserve node */ xmlnode *iq_query = xmlnode_get_child(iq->node, "query"); const char *node = xmlnode_get_attrib(query, "node"); if(node) xmlnode_set_attrib(iq_query,"node",node); jabber_iq_set_id(iq, id); if (from) xmlnode_set_attrib(iq->node, "to", from); jabber_iq_send(iq); } } static void jabber_disco_finish_server_info_result_cb(JabberStream *js) { const char *ft_proxies; /* * This *should* happen only if the server supports vcard-temp, but there * are apparently some servers that don't advertise it even though they * support it. */ jabber_vcard_fetch_mine(js); if (js->pep) jabber_avatar_fetch_mine(js); if (!(js->server_caps & JABBER_CAP_GOOGLE_ROSTER)) { /* If the server supports JABBER_CAP_GOOGLE_ROSTER; we will have already requested it */ jabber_roster_request(js); } if (js->server_caps & JABBER_CAP_ADHOC) { /* The server supports ad-hoc commands, so let's request the list */ jabber_adhoc_server_get_list(js); } /* If the server supports blocking, request the block list */ if (js->server_caps & JABBER_CAP_BLOCKING) { jabber_request_block_list(js); } /* If there are manually specified bytestream proxies, query them */ ft_proxies = purple_account_get_string(js->gc->account, "ft_proxies", NULL); if (ft_proxies) { JabberIq *iq; JabberBytestreamsStreamhost *sh; int i; char *tmp; gchar **ft_proxy_list = g_strsplit(ft_proxies, ",", 0); for(i = 0; ft_proxy_list[i]; i++) { g_strstrip(ft_proxy_list[i]); if(!(*ft_proxy_list[i])) continue; /* We used to allow specifying a port directly here; get rid of it */ if((tmp = strchr(ft_proxy_list[i], ':'))) *tmp = '\0'; sh = g_new0(JabberBytestreamsStreamhost, 1); sh->jid = g_strdup(ft_proxy_list[i]); js->bs_proxies = g_list_prepend(js->bs_proxies, sh); iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/bytestreams"); xmlnode_set_attrib(iq->node, "to", sh->jid); jabber_iq_set_callback(iq, jabber_disco_bytestream_server_cb, sh); jabber_iq_send(iq); } g_strfreev(ft_proxy_list); } } static void jabber_disco_server_info_result_cb(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *packet, gpointer data) { xmlnode *query, *child; if (!from || strcmp(from, js->user->domain)) { jabber_disco_finish_server_info_result_cb(js); return; } if (type == JABBER_IQ_ERROR) { /* A common way to get here is for the server not to support xmlns http://jabber.org/protocol/disco#info */ jabber_disco_finish_server_info_result_cb(js); return; } query = xmlnode_get_child(packet, "query"); if (!query) { jabber_disco_finish_server_info_result_cb(js); return; } for (child = xmlnode_get_child(query, "identity"); child; child = xmlnode_get_next_twin(child)) { const char *category, *type, *name; category = xmlnode_get_attrib(child, "category"); type = xmlnode_get_attrib(child, "type"); if(category && type && !strcmp(category, "pubsub") && !strcmp(type,"pep")) js->pep = TRUE; if (!category || strcmp(category, "server")) continue; if (!type || strcmp(type, "im")) continue; name = xmlnode_get_attrib(child, "name"); if (!name) continue; g_free(js->server_name); js->server_name = g_strdup(name); if (!strcmp(name, "Google Talk")) { purple_debug_info("jabber", "Google Talk!\n"); js->googletalk = TRUE; /* autodiscover stun and relays */ jabber_google_send_jingle_info(js); } else { /* TODO: add external service discovery here... */ } } for (child = xmlnode_get_child(query, "feature"); child; child = xmlnode_get_next_twin(child)) { const char *var; var = xmlnode_get_attrib(child, "var"); if (!var) continue; if (!strcmp("google:mail:notify", var)) { js->server_caps |= JABBER_CAP_GMAIL_NOTIFY; jabber_gmail_init(js); } else if (!strcmp("google:roster", var)) { js->server_caps |= JABBER_CAP_GOOGLE_ROSTER; jabber_google_roster_init(js); } else if (!strcmp("http://jabber.org/protocol/commands", var)) { js->server_caps |= JABBER_CAP_ADHOC; } else if (!strcmp("urn:xmpp:blocking", var)) { js->server_caps |= JABBER_CAP_BLOCKING; } } jabber_disco_finish_server_info_result_cb(js); } static void jabber_disco_server_items_result_cb(JabberStream *js, const char *from, JabberIqType type, const char *id, xmlnode *packet, gpointer data) { xmlnode *query, *child; if (!from || strcmp(from, js->user->domain) != 0) return; if (type == JABBER_IQ_ERROR) return; while(js->chat_servers) { g_free(js->chat_servers->data); js->chat_servers = g_list_delete_link(js->chat_servers, js->chat_servers); } query = xmlnode_get_child(packet, "query"); for(child = xmlnode_get_child(query, "item"); child; child = xmlnode_get_next_twin(child)) { JabberIq *iq; const char *jid, *node; if(!(jid = xmlnode_get_attrib(child, "jid"))) continue; /* we don't actually care about the specific nodes, * so we won't query them */ if((node = xmlnode_get_attrib(child, "node"))) continue; iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/disco#info"); xmlnode_set_attrib(iq->node, "to", jid); jabber_iq_send(iq); } } void jabber_disco_items_server(JabberStream *js) { JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/disco#items"); xmlnode_set_attrib(iq->node, "to", js->user->domain); jabber_iq_set_callback(iq, jabber_disco_server_items_result_cb, NULL); jabber_iq_send(iq); iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/disco#info"); xmlnode_set_attrib(iq->node, "to", js->user->domain); jabber_iq_set_callback(iq, jabber_disco_server_info_result_cb, NULL); jabber_iq_send(iq); } void jabber_disco_info_do(JabberStream *js, const char *who, JabberDiscoInfoCallback *callback, gpointer data) { JabberID *jid; JabberBuddy *jb; JabberBuddyResource *jbr = NULL; struct _jabber_disco_info_cb_data *jdicd; JabberIq *iq; if((jid = jabber_id_new(who))) { if(jid->resource && (jb = jabber_buddy_find(js, who, TRUE))) jbr = jabber_buddy_find_resource(jb, jid->resource); jabber_id_free(jid); } if(jbr && jbr->capabilities & JABBER_CAP_RETRIEVED) { callback(js, who, jbr->capabilities, data); return; } jdicd = g_new0(struct _jabber_disco_info_cb_data, 1); jdicd->data = data; jdicd->callback = callback; iq = jabber_iq_new_query(js, JABBER_IQ_GET, "http://jabber.org/protocol/disco#info"); xmlnode_set_attrib(iq->node, "to", who); jabber_iq_set_callback(iq, jabber_disco_info_cb, jdicd); jabber_iq_send(iq); }