pidgin.yaz: libpurple/protocols/jabber/bosh.c annotate

annotate libpurple/protocols/jabber/bosh.c @ 25610:0a8484372312

* sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open * reconnect if HTTP connection is closed

author	Tobias Markmann <tfar@soc.pidgin.im>
date	Mon, 18 Aug 2008 08:42:37 +0000
parents	5f70e13db5cc
children	8badac6cc7c9

rev	line source
25596 7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	1 /*
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	2 * purple - Jabber Protocol Plugin
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	3 *
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	4 * Copyright (C) 2008, Tobias Markmann <tmarkmann@googlemail.com>
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	5 *
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	6 * This program is free software; you can redistribute it and/or modify
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	7 * it under the terms of the GNU General Public License as published by
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	8 * the Free Software Foundation; either version 2 of the License, or
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	9 * (at your option) any later version.
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	10 *
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	11 * This program is distributed in the hope that it will be useful,
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	14 * GNU General Public License for more details.
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	15 *
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	16 * You should have received a copy of the GNU General Public License
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	17 * along with this program; if not, write to the Free Software
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	19 *
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	20 */
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	21 #include "internal.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	22 #include "cipher.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	23 #include "debug.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	24 #include "imgstore.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	25 #include "prpl.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	26 #include "notify.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	27 #include "request.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	28 #include "util.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	29 #include "xmlnode.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	30
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	31 #include "buddy.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	32 #include "chat.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	33 #include "jabber.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	34 #include "iq.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	35 #include "presence.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	36 #include "xdata.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	37 #include "pep.h"
7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	38 #include "adhoccommands.h"
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	39 #include "connection.h"
25596 7768cad83127 * looking for alternative connection methods if direct connection fails Tobias Markmann <tfar@soc.pidgin.im> parents: diff changeset	40
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	41 void jabber_bosh_connection_init(PurpleBOSHConnection conn, PurpleAccount account, JabberStream js, char url) {
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	42 conn->pipelining = TRUE;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	43 conn->account = account;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	44 if (!purple_url_parse(url, &(conn->host), &(conn->port), &(conn->path), &(conn->user), &(conn->passwd))) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	45 purple_debug_info("jabber", "Unable to parse given URL.\n");
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	46 return;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	47 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	48 if (conn->user \|\| conn->passwd) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	49 purple_debug_info("jabber", "Sorry, HTTP Authentication isn't supported yet. Username and password in the BOSH URL will be ignored.\n");
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	50 }
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	51 conn->js = js;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	52 conn->rid = rand() % 100000 + 1728679472;
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	53 conn->ready = FALSE;
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	54 conn->conn_a = g_new0(PurpleHTTPConnection, 1);
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	55 jabber_bosh_http_connection_init(conn->conn_a, conn->account, conn->host, conn->port);
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	56 conn->conn_a->userdata = conn;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	57 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	58
25608 a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	59 void jabber_bosh_connection_stream_restart(PurpleBOSHConnection *conn) {
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	60 /*
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	61 <body rid='1573741824'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	62 sid='SomeSID'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	63 to='jabber.org'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	64 xml:lang='en'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	65 xmpp:restart='true'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	66 xmlns='http://jabber.org/protocol/httpbind'
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	67 xmlns:xmpp='urn:xmpp:xbosh'/>
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	68 */
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	69 xmlnode *restart = xmlnode_new("body");
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	70 char *tmp = NULL;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	71 conn->rid++;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	72 xmlnode_set_attrib(restart, "rid", tmp = g_strdup_printf("%d", conn->rid));
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	73 g_free(tmp);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	74 xmlnode_set_attrib(restart, "sid", conn->sid);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	75 xmlnode_set_attrib(restart, "to", conn->js->user->domain);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	76 xmlnode_set_attrib(restart, "xml:lang", "en");
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	77 xmlnode_set_attrib(restart, "xmpp:restart", "true");
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	78 xmlnode_set_attrib(restart, "xmlns", "http://jabber.org/protocol/httpbind");
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	79 xmlnode_set_attrib(restart, "xmlns:xmpp", "urn:xmpp:xbosh");
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	80
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	81 jabber_bosh_connection_send_native(conn, restart);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	82 }
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	83
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	84 void jabber_bosh_connection_received(PurpleBOSHConnection conn, xmlnode node) {
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	85 xmlnode *child;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	86 JabberStream *js = conn->js;
25608 a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	87
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	88 if (node == NULL) return;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	89
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	90 child = node->child;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	91 while (child != 0) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	92 if (child->type == XMLNODE_TYPE_TAG) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	93 jabber_process_packet(js, &child);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	94 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	95 child = child->next;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	96 }
25608 a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	97 xmlnode_free(node);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	98 }
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	99
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	100 void jabber_bosh_connection_auth_response(PurpleBOSHConnection conn, xmlnode node) {
25608 a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	101 xmlnode *child = node->child;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	102
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	103 while(child != NULL && child->type != XMLNODE_TYPE_TAG) {
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	104 child = child->next;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	105 }
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	106
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	107 if (child != NULL && child->type == XMLNODE_TYPE_TAG) {
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	108 JabberStream *js = conn->js;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	109 if (!strcmp(child->name, "success")) {
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	110 jabber_bosh_connection_stream_restart(conn);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	111 jabber_process_packet(js, &child);
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	112 conn->ready = TRUE;
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	113 conn->receive_cb = jabber_bosh_connection_received;
25608 a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	114 } else {
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	115 js->state = JABBER_STREAM_AUTHENTICATING;
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	116 jabber_process_packet(js, &child);
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	117 }
a03a953ba63d * moving BOSH interfacing from jabber_send to jabber_send_raw Tobias Markmann <tfar@soc.pidgin.im> parents: 25607 diff changeset	118 } else printf("\n!! no child!!\n");
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	119 }
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	120
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	121 void jabber_bosh_connection_boot_response(PurpleBOSHConnection conn, xmlnode node) {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	122 char *version;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	123 if (xmlnode_get_attrib(node, "sid")) {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	124 conn->sid = g_strdup(xmlnode_get_attrib(node, "sid"));
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	125 } else {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	126 purple_debug_info("jabber", "Connection manager doesn't behave BOSH-like!\n");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	127 }
25605 f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	128
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	129 if (version = xmlnode_get_attrib(node, "ver")) {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	130 version[1] = 0;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	131 if (!(atoi(version) >= 1 && atoi(&version[2]) >= 6)) purple_debug_info("jabber", "Unsupported version of BOSH protocol. The connection manager must at least support version 1.6!\n");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	132 else {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	133 xmlnode *packet = xmlnode_get_child(node, "features");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	134 conn->js->use_bosh = TRUE;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	135 conn->receive_cb = jabber_bosh_connection_auth_response;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	136 jabber_stream_features_parse(conn->js, packet);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	137 }
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	138 version[1] = '.';
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	139 } else {
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	140 purple_debug_info("jabber", "Missing version in session creation response!\n");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	141 }
25605 f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	142 }
f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	143
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	144 static void jabber_bosh_connection_boot(PurpleBOSHConnection *conn) {
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	145 char *tmp;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	146 xmlnode *init = xmlnode_new("body");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	147 xmlnode_set_attrib(init, "content", "text/xml; charset=utf-8");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	148 xmlnode_set_attrib(init, "secure", "true");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	149 //xmlnode_set_attrib(init, "route", tmp = g_strdup_printf("xmpp:%s:5222", conn->js->user->domain));
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	150 //g_free(tmp);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	151 xmlnode_set_attrib(init, "to", conn->js->user->domain);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	152 xmlnode_set_attrib(init, "xml:lang", "en");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	153 xmlnode_set_attrib(init, "xmpp:version", "1.0");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	154 xmlnode_set_attrib(init, "ver", "1.6");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	155 xmlnode_set_attrib(init, "xmlns:xmpp", "urn:xmpp:xbosh");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	156 xmlnode_set_attrib(init, "rid", tmp = g_strdup_printf("%d", conn->rid));
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	157 g_free(tmp);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	158 xmlnode_set_attrib(init, "wait", "60"); /* this should be adjusted automatically according to real time network behavior */
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	159 xmlnode_set_attrib(init, "xmlns", "http://jabber.org/protocol/httpbind");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	160 xmlnode_set_attrib(init, "hold", "1");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	161
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	162 conn->receive_cb = jabber_bosh_connection_boot_response;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	163 jabber_bosh_connection_send_native(conn, init);
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	164 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	165
25605 f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	166 void jabber_bosh_connection_http_received_cb(PurpleHTTPRequest req, PurpleHTTPResponse res, void *userdata) {
f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	167 PurpleBOSHConnection *conn = userdata;
f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	168 if (conn->receive_cb) {
f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	169 xmlnode *node = xmlnode_from_str(res->data, res->data_len);
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	170 if (node) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	171 char *txt = xmlnode_to_formatted_str(node, NULL);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	172 printf("\njabber_bosh_connection_http_received_cb\n%s\n", txt);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	173 g_free(txt);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	174 conn->receive_cb(conn, node);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	175 } else {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	176 printf("\njabber_bosh_connection_http_received_cb: XML ERROR: %s\n", res->data);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	177 }
25605 f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	178 } else purple_debug_info("jabber", "missing receive_cb of PurpleBOSHConnection.\n");
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	179 }
15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	180
15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	181 void jabber_bosh_connection_send(PurpleBOSHConnection conn, xmlnode node) {
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	182 xmlnode *packet = xmlnode_new("body");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	183 char *tmp;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	184 conn->rid++;
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	185 xmlnode_set_attrib(packet, "xmlns", "http://jabber.org/protocol/httpbind");
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	186 xmlnode_set_attrib(packet, "sid", conn->sid);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	187 tmp = g_strdup_printf("%d", conn->rid);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	188 xmlnode_set_attrib(packet, "rid", tmp);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	189 g_free(tmp);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	190
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	191 if (node) xmlnode_insert_child(packet, node);
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	192
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	193 jabber_bosh_connection_send_native(conn, packet);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	194 }
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	195
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	196 void jabber_bosh_connection_send_native(PurpleBOSHConnection conn, xmlnode node) {
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	197 PurpleHTTPRequest *request = g_new0(PurpleHTTPRequest, 1);
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	198
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	199 char *txt = xmlnode_to_formatted_str(node, NULL);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	200 printf("\njabber_bosh_connection_send\n%s\n", txt);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	201 g_free(txt);
f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	202
25605 f747c682a0d9 * calling PurpleBOSHConnection's receive_cb Tobias Markmann <tfar@soc.pidgin.im> parents: 25604 diff changeset	203 jabber_bosh_http_request_init(request, "POST", g_strdup_printf("/%s", conn->path), jabber_bosh_connection_http_received_cb, conn);
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	204 jabber_bosh_http_request_add_to_header(request, "Content-Encoding", "text/xml; charset=utf-8");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	205 request->data = xmlnode_to_str(node, &(request->data_len));
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	206 jabber_bosh_http_request_add_to_header(request, "Content-Length", g_strdup_printf("%d", (int)strlen(request->data)));
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	207 jabber_bosh_http_connection_send_request(conn->conn_a, request);
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	208 }
15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	209
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	210 static void jabber_bosh_connection_connected(PurpleHTTPConnection *conn) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	211 PurpleBOSHConnection *bosh_conn = conn->userdata;
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	212 if (bosh_conn->ready == TRUE && bosh_conn->connect_cb) {
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	213 purple_debug_info("jabber", "BOSH session already exists. Trying to reuse it.\n");
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	214 bosh_conn->receive_cb = jabber_bosh_connection_received;
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	215 bosh_conn->connect_cb(bosh_conn);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	216 } else jabber_bosh_connection_boot(bosh_conn);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	217 }
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	218
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	219 static void jabber_bosh_connection_refresh(PurpleHTTPConnection *conn) {
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	220 PurpleBOSHConnection *bosh_conn = conn->userdata;
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	221 jabber_bosh_connection_send(bosh_conn, NULL);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	222 }
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	223
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	224 static void jabber_bosh_http_connection_disconnected(PurpleHTTPConnection *conn) {
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	225 PurpleBOSHConnection *bosh_conn = conn->userdata;
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	226 bosh_conn->conn_a->connect_cb = jabber_bosh_connection_connected;
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	227 jabber_bosh_http_connection_connect(bosh_conn->conn_a);
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	228 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	229
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	230 void jabber_bosh_connection_connect(PurpleBOSHConnection *conn) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	231 conn->conn_a->connect_cb = jabber_bosh_connection_connected;
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	232 jabber_bosh_http_connection_connect(conn->conn_a);
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	233 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	234
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	235 void jabber_bosh_http_connection_receive_parse_header(PurpleHTTPResponse response, char data, int len) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	236 GHashTable *header = response->header;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	237 char beginning = data;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	238 char found = g_strstr_len(data, len, "\r\n\r\n");
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	239 char *field = NULL;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	240 char *value = NULL;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	241 char old_data = data;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	242
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	243 while (*beginning != 'H') ++beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	244 beginning[12] = 0;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	245 response->status = atoi(&beginning[9]);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	246 beginning = &beginning[13];
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	247 do {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	248 ++beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	249 } while (*beginning != '\n');
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	250 ++beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	251 /* parse HTTP response header */
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	252 for (;beginning != found; ++beginning) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	253 if (!field) field = beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	254 if (*beginning == ':') {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	255 *beginning = 0;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	256 value = beginning + 1;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	257 } else if (*beginning == '\r') {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	258 *beginning = 0;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	259 g_hash_table_replace(header, g_strdup(field), g_strdup(value));
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	260 value = field = 0;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	261 ++beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	262 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	263 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	264 ++beginning; ++beginning; ++beginning; ++beginning;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	265 /* remove the header from data buffer */
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	266 *data = g_strdup(beginning);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	267 g_free(old_data);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	268 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	269
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	270 static void jabber_bosh_http_connection_receive(gpointer data, gint source, PurpleInputCondition condition) {
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	271 char buffer[1025];
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	272 int len;
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	273 PurpleHTTPConnection *conn = data;
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	274 PurpleBOSHConnection *bosh_conn = conn->userdata;
25603 24b97b8359ff * preparing handling of multiple requests for pipelining support Tobias Markmann <tfar@soc.pidgin.im> parents: 25602 diff changeset	275 PurpleHTTPResponse *response = conn->current_response;
24b97b8359ff * preparing handling of multiple requests for pipelining support Tobias Markmann <tfar@soc.pidgin.im> parents: 25602 diff changeset	276
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	277 purple_debug_info("jabber", "jabber_bosh_http_connection_receive\n");
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	278
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	279 len = read(source, buffer, 1024);
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	280 if (len > 0) {
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	281 buffer[len] = 0;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	282 if (conn->current_data == NULL) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	283 conn->current_len = len;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	284 conn->current_data = g_strdup_printf("%s", buffer);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	285 } else {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	286 char *old_data = conn->current_data;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	287 conn->current_len += len;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	288 conn->current_data = g_strdup_printf("%s%s", conn->current_data, buffer);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	289 g_free(old_data);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	290 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	291
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	292 if (!response) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	293 /* check for header footer */
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	294 char *found = NULL;
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	295 if (found = g_strstr_len(conn->current_data, conn->current_len, "\r\n\r\n")) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	296 // new response
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	297 response = conn->current_response = g_new0(PurpleHTTPResponse, 1);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	298 jabber_bosh_http_response_init(response);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	299 jabber_bosh_http_connection_receive_parse_header(response, &(conn->current_data), &(conn->current_len));
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	300 response->data_len = atoi(g_hash_table_lookup(response->header, "Content-Length"));
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	301 jabber_bosh_http_connection_receive(data, source, condition);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	302 } else {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	303 printf("\nDATA: %s \n", conn->current_data);
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	304 printf("\nDid not receive HTTP header\n");
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	305 }
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	306 }
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	307
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	308 if (response) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	309 if (conn->current_len >= response->data_len) {
5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	310 PurpleHTTPRequest *request = g_queue_pop_head(conn->requests);
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	311
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	312 #warning for a pure HTTP 1.1 stack this would be needed to be handled elsewhereå
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	313 if (bosh_conn->ready == TRUE && g_queue_is_empty(conn->requests) == TRUE) {
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	314 jabber_bosh_connection_send(bosh_conn, NULL);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	315 printf("\n SEND AN EMPTY REQUEST \n");
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	316 }
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	317
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	318 if (request) {
25609 5f70e13db5cc * data buffer for received data. Support for any HTTP resonse size now. Tobias Markmann <tfar@soc.pidgin.im> parents: 25608 diff changeset	319 response->data = g_memdup(conn->current_data, response->data_len);
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	320 request->cb(request, response, conn->userdata);
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	321 jabber_bosh_http_request_clean(request);
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	322 jabber_bosh_http_response_clean(response);
25607 f775f6021654 * using libpurple's internal SASL mechanisms during BOSH authentication phase Tobias Markmann <tfar@soc.pidgin.im> parents: 25606 diff changeset	323 conn->current_response = NULL;
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	324 g_free(request);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	325 g_free(response);
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	326 } else {
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	327 purple_debug_info("jabber", "received HTTP response but haven't requested anything yet.\n");
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	328 }
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	329 }
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	330 }
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	331 } else if (len == 0) {
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	332 purple_input_remove(conn->ie_handle);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	333 if (conn->disconnect_cb) conn->disconnect_cb(conn);
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	334 } else {
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	335 purple_debug_info("jabber", "jabber_bosh_http_connection_receive: problem receiving data (%d)\n", len);
25603 24b97b8359ff * preparing handling of multiple requests for pipelining support Tobias Markmann <tfar@soc.pidgin.im> parents: 25602 diff changeset	336 }
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	337 }
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	338
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	339 void jabber_bosh_http_connection_init(PurpleHTTPConnection conn, PurpleAccount account, char *host, int port) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	340 conn->account = account;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	341 conn->host = host;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	342 conn->port = port;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	343 conn->connect_cb = NULL;
25603 24b97b8359ff * preparing handling of multiple requests for pipelining support Tobias Markmann <tfar@soc.pidgin.im> parents: 25602 diff changeset	344 conn->current_response = NULL;
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	345 conn->current_data = NULL;
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	346 conn->requests = g_queue_new();
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	347 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	348
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	349 void jabber_bosh_http_connection_clean(PurpleHTTPConnection *conn) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	350 g_queue_free(conn->requests);
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	351 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	352
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	353 static void jabber_bosh_http_connection_callback(gpointer data, gint source, const gchar *error) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	354 PurpleHTTPConnection *conn = data;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	355 if (source < 0) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	356 purple_debug_info("jabber", "Couldn't connect becasue of: %s\n", error);
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	357 return;
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	358 }
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	359 conn->fd = source;
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	360 if (conn->connect_cb) conn->connect_cb(conn);
0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	361 else purple_debug_info("jabber", "No connect callback for HTTP connection.\n");
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	362 conn->ie_handle = purple_input_add(conn->fd, PURPLE_INPUT_READ, jabber_bosh_http_connection_receive, conn);
25598 b238da95f39a * some refactoring Tobias Markmann <tfar@soc.pidgin.im> parents: 25596 diff changeset	363 }
b238da95f39a * some refactoring Tobias Markmann <tfar@soc.pidgin.im> parents: 25596 diff changeset	364
b238da95f39a * some refactoring Tobias Markmann <tfar@soc.pidgin.im> parents: 25596 diff changeset	365 void jabber_bosh_http_connection_connect(PurpleHTTPConnection *conn) {
25600 1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	366 if((purple_proxy_connect(&(conn->handle), conn->account, conn->host, conn->port, jabber_bosh_http_connection_callback, conn)) == NULL) {
1cbe5a9f6efb * adding bosh files to Makefile.am & .mingw Tobias Markmann <tfar@soc.pidgin.im> parents: 25598 diff changeset	367 purple_debug_info("jabber", "Unable to connect to %s.\n", conn->host);
25601 15d9825a5621 * adding receive callback; preparing receiving and boot code Tobias Markmann <tfar@soc.pidgin.im> parents: 25600 diff changeset	368 }
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	369 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	370
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	371 static void jabber_bosh_http_connection_send_request_add_field_to_string(gpointer key, gpointer value, gpointer user_data) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	372 char **ppacket = user_data;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	373 char tmp = ppacket;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	374 char *field = key;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	375 char *val = value;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	376 *ppacket = g_strdup_printf("%s%s: %s\r\n", tmp, field, val);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	377 g_free(tmp);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	378 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	379
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	380 void jabber_bosh_http_connection_send_request(PurpleHTTPConnection conn, PurpleHTTPRequest req) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	381 char *packet;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	382 char *tmp;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	383 jabber_bosh_http_request_add_to_header(req, "Host", conn->host);
25606 b175b16768ac * sending some User-Agent Tobias Markmann <tfar@soc.pidgin.im> parents: 25605 diff changeset	384 jabber_bosh_http_request_add_to_header(req, "User-Agent", "libpurple");
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	385 packet = tmp = g_strdup_printf("%s %s HTTP/1.1\r\n", req->method, req->path);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	386 g_hash_table_foreach(req->header, jabber_bosh_http_connection_send_request_add_field_to_string, &packet);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	387 tmp = packet;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	388 packet = g_strdup_printf("%s\r\n%s", tmp, req->data);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	389 g_free(tmp);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	390 if (write(conn->fd, packet, strlen(packet)) == -1) purple_debug_info("jabber", "send error\n");
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	391 g_queue_push_tail(conn->requests, req);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	392 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	393
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	394 void jabber_bosh_http_request_init(PurpleHTTPRequest req, const char method, const char path, PurpleHTTPRequestCallback cb, void userdata) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	395 req->method = g_strdup(method);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	396 req->path = g_strdup(path);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	397 req->cb = cb;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	398 req->userdata = userdata;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	399 req->header = g_hash_table_new(g_str_hash, g_str_equal);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	400 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	401
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	402 void jabber_bosh_http_request_add_to_header(PurpleHTTPRequest req, const char field, const char *value) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	403 g_hash_table_replace(req->header, field, value);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	404 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	405
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	406 void jabber_bosh_http_request_set_data(PurpleHTTPRequest req, char data, int len) {
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	407 req->data = data;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	408 req->data_len = len;
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	409 }
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	410
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	411 void jabber_bosh_http_request_clean(PurpleHTTPRequest *req) {
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	412 g_hash_table_destroy(req->header);
25602 f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	413 g_free(req->method);
f9322be084c4 * doing HTTP requests Tobias Markmann <tfar@soc.pidgin.im> parents: 25601 diff changeset	414 g_free(req->path);
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	415 }
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	416
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	417 void jabber_bosh_http_response_init(PurpleHTTPResponse *res) {
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	418 res->status = 0;
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	419 res->header = g_hash_table_new(g_str_hash, g_str_equal);
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	420 }
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	421
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	422
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	423 void jabber_bosh_http_response_clean(PurpleHTTPResponse *res) {
25610 0a8484372312 * sending empty <body> requests if there are not othere requests to be answered to keep a CM -> client channel open Tobias Markmann <tfar@soc.pidgin.im> parents: 25609 diff changeset	424 //g_hash_table_destroy(res->header);
25604 e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	425 g_free(res->data);
e28f1711f402 * parsing HTTP response and emitting HTTP request callback Tobias Markmann <tfar@soc.pidgin.im> parents: 25603 diff changeset	426 }

Mercurial > pidgin.yaz

annotate libpurple/protocols/jabber/bosh.c @ 25610:0a8484372312