/***************************************************************************\ * * * BitlBee - An IRC to IM gateway * * Jabber module - IQ packets * * * * Copyright 2006-2012 Wilmer van der Gaast * * * * 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); static xt_status jabber_gmail_handle_new(struct im_connection *ic, struct xt_node *node); static xt_status jabber_iq_carbons_response(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 jabber_data *jd = ic->proto_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")) || (c = xt_find_node(node->children, "time"))) || !(s = xt_find_attr(c, "xmlns"))) { reply = jabber_make_error_packet(node, "service-unavailable", "cancel", NULL); st = jabber_write_packet(ic, reply); xt_free_node(reply); return st; } 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", set_getstr(&ic->acc->set, "user_agent"), NULL)); xt_add_child(reply, xt_new_node("version", BITLBEE_VERSION, NULL)); } else if (strcmp(s, XMLNS_TIME_OLD) == 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_TIME) == 0) { time_t time_ep; char buf[1024]; buf[sizeof(buf) - 1] = 0; time_ep = time(NULL); xt_free_node(reply); reply = xt_new_node("time", NULL, NULL); xt_add_attr(reply, "xmlns", XMLNS_TIME); strftime(buf, sizeof(buf) - 1, "%Y%m%dT%H:%M:%SZ", gmtime(&time_ep)); xt_add_child(reply, xt_new_node("utc", buf, NULL)); strftime(buf, sizeof(buf) - 1, "%z", localtime(&time_ep)); if (strlen(buf) >= 5) { buf[6] = '\0'; buf[5] = buf[4]; buf[4] = buf[3]; buf[3] = ':'; } xt_add_child(reply, xt_new_node("tzo", 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_DISCO_INFO) == 0) { const char *features[] = { XMLNS_DISCO_INFO, XMLNS_VERSION, XMLNS_TIME_OLD, XMLNS_TIME, XMLNS_CHATSTATES, XMLNS_MUC, XMLNS_PING, XMLNS_RECEIPTS, XMLNS_SI, XMLNS_BYTESTREAMS, XMLNS_FILETRANSFER, XMLNS_CARBONS, 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", set_getstr(&ic->acc->set, "user_agent")); 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, "service-unavailable", "cancel", NULL); pack = 0; } } else if (strcmp(type, "set") == 0) { if ((c = xt_find_node(node->children, "si")) && (s = xt_find_attr(c, "xmlns")) && (strcmp(s, XMLNS_SI) == 0)) { return jabber_si_handle_request(ic, node, c); } else if ((c = xt_find_node(node->children, "new-mail")) && (s = xt_find_attr(c, "xmlns")) && (strcmp(s, XMLNS_GMAILNOTIFY) == 0)) { return jabber_gmail_handle_new(ic, node); } else if (!(c = xt_find_node(node->children, "query")) || !(s = xt_find_attr(c, "xmlns"))) { return XT_HANDLED; } else if (strcmp(s, XMLNS_ROSTER) == 0) { /* 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. */ int bare_len = strlen(jd->me); if ((s = xt_find_attr(node, "from")) == NULL || (strncmp(s, jd->me, 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", NULL); pack = 0; } } else if (strcmp(s, XMLNS_BYTESTREAMS) == 0) { /* Bytestream Request (stage 2 of file transfer) */ return jabber_bs_recv_request(ic, node, c); } else { xt_free_node(reply); reply = jabber_make_error_packet(node, "feature-not-implemented", "cancel", NULL); 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_ABORT; } /* 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_ABORT; } 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; } if (!jabber_iq_disco_server(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, *reply = NULL; char *s; if (node && (c = xt_find_node(node->children, "bind"))) { c = xt_find_node(c->children, "jid"); if (!c || !c->text) { /* Server is crap, but this is no disaster. */ } else if (jabber_compare_jid(jd->me, c->text) == 0) { s = strchr(c->text, '/'); if (s) { *s = '\0'; } jabber_set_me(ic, c->text); if (s) { *s = '/'; } } else 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); } } if (jd->flags & JFLAG_WANT_BIND) { reply = xt_new_node("bind", NULL, xt_new_node("resource", set_getstr(&ic->acc->set, "resource"), NULL)); xt_add_attr(reply, "xmlns", XMLNS_BIND); jd->flags &= ~JFLAG_WANT_BIND; } else if (jd->flags & JFLAG_WANT_SESSION) { reply = xt_new_node("session", NULL, NULL); xt_add_attr(reply, "xmlns", XMLNS_SESSION); jd->flags &= ~JFLAG_WANT_SESSION; } if (reply != NULL) { reply = jabber_make_packet("iq", "set", NULL, reply); jabber_cache_add(ic, reply, jabber_pkt_bind_sess); if (!jabber_write_packet(ic, reply)) { return XT_ABORT; } if (jd->flags & JFLAG_GMAILNOTIFY && node == NULL) { jabber_iq_query_server(ic, jd->server, XMLNS_DISCO_INFO); } } else if ((jd->flags & (JFLAG_WANT_BIND | JFLAG_WANT_SESSION)) == 0) { if (!jabber_get_roster(ic)) { return XT_ABORT; } if (!jabber_iq_disco_server(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; } xt_status jabber_iq_query_gmail(struct im_connection *ic); static xt_status jabber_gmail_handle_new(struct im_connection *ic, struct xt_node *node) { struct xt_node *response; struct jabber_data *jd = ic->proto_data; response = jabber_make_packet("iq", "result", jd->me, NULL); jabber_cache_add(ic, response, NULL); if (!jabber_write_packet(ic, response)) { return XT_ABORT; } jabber_iq_query_gmail(ic); return XT_HANDLED; } static xt_status jabber_parse_roster(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct jabber_data *jd = ic->proto_data; 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(c->children, "group"); char *jid = xt_find_attr(c, "jid"); char *name = xt_find_attr(c, "name"); char *sub = xt_find_attr(c, "subscription"); char *mention_name = xt_find_attr(c, "mention_name"); if (jid && sub) { if ((strcmp(sub, "both") == 0 || strcmp(sub, "to") == 0)) { imcb_add_buddy(ic, jid, (group && group->text_len) ? group->text : NULL); if (name) { imcb_rename_buddy(ic, jid, name); } /* This could also be used to set the full name as nick for fb/gtalk, * but i'm keeping the old (ugly?) default behavior just to be safe */ if (mention_name && (jd->flags & JFLAG_HIPCHAT)) { imcb_buddy_nick_hint(ic, jid, mention_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, const char *handle, const char *name, const char *group) { 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); } if (group) { xt_add_child(node, xt_new_node("group", group, NULL)); } /* 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 (bee_user_by_handle(ic->bee, 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; } xt_status jabber_iq_parse_features(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); xt_status jabber_iq_query_features(struct im_connection *ic, char *bare_jid) { struct xt_node *node, *query; struct jabber_buddy *bud; if ((bud = jabber_buddy_by_jid(ic, bare_jid, 0)) == NULL) { /* Who cares about the unknown... */ imcb_log(ic, "Couldn't find buddy: %s", bare_jid); return XT_HANDLED; } if (bud->features) { /* been here already */ return XT_HANDLED; } node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", XMLNS_DISCO_INFO); if (!(query = jabber_make_packet("iq", "get", bare_jid, node))) { imcb_log(ic, "WARNING: Couldn't generate feature query"); xt_free_node(node); return XT_HANDLED; } jabber_cache_add(ic, query, jabber_iq_parse_features); return jabber_write_packet(ic, query) ? XT_HANDLED : XT_ABORT; } xt_status jabber_iq_parse_features(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct xt_node *c; struct jabber_buddy *bud; char *feature, *xmlns, *from; if (!(from = xt_find_attr(node, "from")) || !(c = xt_find_node(node->children, "query")) || !(xmlns = xt_find_attr(c, "xmlns")) || !(strcmp(xmlns, XMLNS_DISCO_INFO) == 0)) { imcb_log(ic, "WARNING: Received incomplete IQ-result packet for discover"); return XT_HANDLED; } if ((bud = jabber_buddy_by_jid(ic, from, 0)) == NULL) { /* Who cares about the unknown... */ imcb_log(ic, "Couldn't find buddy: %s", from); return XT_HANDLED; } c = c->children; while ((c = xt_find_node(c, "feature"))) { feature = xt_find_attr(c, "var"); if (feature) { bud->features = g_slist_append(bud->features, g_strdup(feature)); } c = c->next; } return XT_HANDLED; } xt_status jabber_iq_parse_gmail(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); xt_status jabber_iq_query_gmail(struct im_connection *ic) { struct xt_node *node, *query; struct jabber_data *jd = ic->proto_data; node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", XMLNS_GMAILNOTIFY); if (jd->gmail_time) { char *formatted = g_strdup_printf("%" G_GUINT64_FORMAT, (jd->gmail_time + 1)); xt_add_attr(node, "newer-than-time", formatted); g_free(formatted); } if (jd->gmail_tid) { xt_add_attr(node, "newer-than-tid", jd->gmail_tid); } if (!(query = jabber_make_packet("iq", "get", jd->me, node))) { imcb_log(ic, "WARNING: Couldn't generate server query"); xt_free_node(node); } jabber_cache_add(ic, query, jabber_iq_parse_gmail); return jabber_write_packet(ic, query) ? XT_HANDLED : XT_ABORT; } xt_status jabber_iq_parse_server_features(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); xt_status jabber_iq_query_server(struct im_connection *ic, char *jid, char *xmlns) { struct xt_node *node, *query; struct jabber_data *jd = ic->proto_data; node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", xmlns); if (!(query = jabber_make_packet("iq", "get", jid, node))) { imcb_log(ic, "WARNING: Couldn't generate server query"); xt_free_node(node); } jd->have_streamhosts--; jabber_cache_add(ic, query, jabber_iq_parse_server_features); return jabber_write_packet(ic, query) ? XT_HANDLED : XT_ABORT; } xt_status jabber_iq_parse_gmail(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct xt_node *c; struct jabber_data *jd = ic->proto_data; char *xmlns, *from; guint64 l_time = 0; char *tid = NULL; int max = 0; if (!(c = xt_find_node(node->children, "mailbox")) || !(from = xt_find_attr(node, "from")) || !(xmlns = xt_find_attr(c, "xmlns")) || (g_strcmp0(xmlns, XMLNS_GMAILNOTIFY) != 0)) { imcb_log(ic, "WARNING: Received incomplete mailbox packet for gmail notify"); return XT_HANDLED; } max = set_getint(&ic->acc->set, "mail_notifications_limit"); c = c->children; while ((max-- > 0) && (c = xt_find_node(c, "mail-thread-info"))) { struct xt_node *s; char *subject = ""; char *sender = ""; guint64 t_time; t_time = g_ascii_strtoull(xt_find_attr(c, "date"), NULL, 10); if (t_time && t_time > l_time) { l_time = t_time; tid = xt_find_attr(c, "tid"); } if ((s = xt_find_node(c->children, "senders")) && (s = xt_find_node_by_attr(s->children, "sender", "unread", "1"))) { sender = xt_find_attr(s, "name"); } if ((s = xt_find_node(c->children, "subject")) && s->text) { subject = s->text; } imcb_notify_email(ic, "New mail from %s: %s", sender, subject); c = c->next; } if (l_time && (!jd->gmail_time || l_time > jd->gmail_time)) { jd->gmail_time = l_time; if (tid) { g_free(jd->gmail_tid); jd->gmail_tid = g_strdup(tid); } } return XT_HANDLED; } /* * Query the server for "items", query each "item" for identities, query each "item" that's a proxy for it's bytestream info */ xt_status jabber_iq_parse_server_features(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct xt_node *c; struct jabber_data *jd = ic->proto_data; char *xmlns, *from; if (!(c = xt_find_node(node->children, "query")) || !(from = xt_find_attr(node, "from")) || !(xmlns = xt_find_attr(c, "xmlns"))) { imcb_log(ic, "WARNING: Received incomplete IQ-result packet for discover"); return XT_HANDLED; } jd->have_streamhosts++; if (strcmp(xmlns, XMLNS_DISCO_ITEMS) == 0) { char *itemjid; /* answer from server */ c = c->children; while ((c = xt_find_node(c, "item"))) { itemjid = xt_find_attr(c, "jid"); if (itemjid) { jabber_iq_query_server(ic, itemjid, XMLNS_DISCO_INFO); } c = c->next; } } else if (strcmp(xmlns, XMLNS_DISCO_INFO) == 0) { char *category, *type; /* answer from potential proxy */ c = c->children; while ((c = xt_find_node(c, "identity"))) { category = xt_find_attr(c, "category"); type = xt_find_attr(c, "type"); if (type && (strcmp(type, "bytestreams") == 0) && category && (strcmp(category, "proxy") == 0)) { jabber_iq_query_server(ic, from, XMLNS_BYTESTREAMS); } c = c->next; } if (jd->flags & JFLAG_GMAILNOTIFY) { /* search for gmail notification feature */ c = xt_find_node(node->children, "query"); c = c->children; while ((c = xt_find_node(c, "feature"))) { if (strcmp(xt_find_attr(c, "var"), XMLNS_GMAILNOTIFY) == 0) { jabber_iq_query_gmail(ic); } c = c->next; } } } else if (strcmp(xmlns, XMLNS_BYTESTREAMS) == 0) { char *host, *jid, *port_s; int port; /* answer from proxy */ if ((c = xt_find_node(c->children, "streamhost")) && (host = xt_find_attr(c, "host")) && (port_s = xt_find_attr(c, "port")) && (sscanf(port_s, "%d", &port) == 1) && (jid = xt_find_attr(c, "jid"))) { jabber_streamhost_t *sh = g_new0(jabber_streamhost_t, 1); sh->jid = g_strdup(jid); sh->host = g_strdup(host); g_snprintf(sh->port, sizeof(sh->port), "%u", port); imcb_log(ic, "Proxy found: jid %s host %s port %u", jid, host, port); jd->streamhosts = g_slist_append(jd->streamhosts, sh); } } if (jd->have_streamhosts == 0) { jd->have_streamhosts++; } return XT_HANDLED; } static xt_status jabber_iq_version_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); void jabber_iq_version_send(struct im_connection *ic, struct jabber_buddy *bud, void *data) { struct xt_node *node, *query; node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", XMLNS_VERSION); query = jabber_make_packet("iq", "get", bud->full_jid, node); jabber_cache_add(ic, query, jabber_iq_version_response); jabber_write_packet(ic, query); } static xt_status jabber_iq_version_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct xt_node *query; GString *rets; char *s; char *ret[2] = {}; bee_user_t *bu; struct jabber_buddy *bud = NULL; if ((s = xt_find_attr(node, "from")) && (bud = jabber_buddy_by_jid(ic, s, 0)) && (query = xt_find_node(node->children, "query")) && (bu = bee_user_by_handle(ic->bee, ic, bud->bare_jid))) { rets = g_string_new("Resource "); g_string_append(rets, bud->resource); } else { return XT_HANDLED; } for (query = query->children; query; query = query->next) { if (query->text_len > 0) { g_string_append_printf(rets, " %s: %s,", query->name, query->text); } } g_string_truncate(rets, rets->len - 1); ret[0] = rets->str; imcb_buddy_action_response(bu, "VERSION", ret, NULL); g_string_free(rets, TRUE); return XT_HANDLED; } static xt_status jabber_iq_disco_server_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); int jabber_iq_disco_server(struct im_connection *ic) { struct xt_node *node, *iq; struct jabber_data *jd = ic->proto_data; node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", XMLNS_DISCO_INFO); iq = jabber_make_packet("iq", "get", jd->server, node); jabber_cache_add(ic, iq, jabber_iq_disco_server_response); return jabber_write_packet(ic, iq); } static xt_status jabber_iq_disco_server_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct jabber_data *jd = ic->proto_data; struct xt_node *query, *id, *c; char *feature; if (!(query = xt_find_node(node->children, "query"))) { return XT_HANDLED; } c = query->children; while ((c = xt_find_node(c, "feature"))) { feature = xt_find_attr(c, "var"); if (feature) { jd->features = g_slist_append(jd->features, g_strdup(feature)); } c = c->next; } if (xt_find_node_by_attr(query->children, "feature", "var", XMLNS_CARBONS) && set_getbool(&ic->acc->set, "carbons")) { struct xt_node *enable, *iq; enable = xt_new_node("enable", NULL, NULL); xt_add_attr(enable, "xmlns", XMLNS_CARBONS); iq = jabber_make_packet("iq", "set", NULL, enable); jabber_cache_add(ic, iq, jabber_iq_carbons_response); jabber_write_packet(ic, iq); } if ((id = xt_find_node(query->children, "identity"))) { char *cat, *type, *name; if (!(cat = xt_find_attr(id, "category")) || !(type = xt_find_attr(id, "type")) || !(name = xt_find_attr(id, "name"))) { return XT_HANDLED; } if (strcmp(cat, "server") == 0 && strcmp(type, "im") == 0 && strstr(name, "Google") != NULL) { jd->flags |= JFLAG_GTALK; } } jabber_block_feature(ic); return XT_HANDLED; } static xt_status jabber_iq_carbons_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct jabber_error *err; if ((err = jabber_error_parse(xt_find_node(node->children, "error"), XMLNS_STANZA_ERROR))) { imcb_error(ic, "Error enabling carbons: %s%s%s", err->code, err->text ? ": " : "", err->text ? err->text : ""); jabber_error_free(err); } else { imcb_log(ic, "Carbons enabled"); } return XT_HANDLED; } xt_status jabber_iq_disco_muc_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig); int jabber_iq_disco_muc(struct im_connection *ic, const char *muc_server) { struct xt_node *node; int st; node = xt_new_node("query", NULL, NULL); xt_add_attr(node, "xmlns", XMLNS_DISCO_ITEMS); node = jabber_make_packet("iq", "get", (char *) muc_server, node); jabber_cache_add(ic, node, jabber_iq_disco_muc_response); st = jabber_write_packet(ic, node); return st; } xt_status jabber_iq_disco_muc_response(struct im_connection *ic, struct xt_node *node, struct xt_node *orig) { struct xt_node *query, *c; struct jabber_error *err; GSList *rooms = NULL; if ((err = jabber_error_parse(xt_find_node(node->children, "error"), XMLNS_STANZA_ERROR))) { imcb_error(ic, "The server replied with an error: %s%s%s", err->code, err->text ? ": " : "", err->text ? err->text : ""); jabber_error_free(err); return XT_HANDLED; } if (!(query = xt_find_node(node->children, "query"))) { imcb_error(ic, "Received incomplete MUC list reply"); return XT_HANDLED; } c = query->children; while ((c = xt_find_node(c, "item"))) { char *jid = xt_find_attr(c, "jid"); if (!jid || !strchr(jid, '@')) { c = c->next; continue; } bee_chat_info_t *ci = g_new(bee_chat_info_t, 1); ci->title = g_strdup(xt_find_attr(c, "jid")); ci->topic = g_strdup(xt_find_attr(c, "name")); rooms = g_slist_prepend(rooms, ci); c = c->next; } imcb_chat_list_free(ic); ic->chatlist = g_slist_reverse(rooms); imcb_chat_list_finish(ic); return XT_HANDLED; }