comparison libpurple/protocols/jabber/bosh.c @ 25183:62d9bce9ff74

Reorder some functions to eliminate prototypes and export jabber_bosh_connection_refresh()

25182:17b60b844803

static void jabber_bosh_connection_auth_response(PurpleBOSHConnection *conn, xmlnode *node);
static void jabber_bosh_connection_boot_response(PurpleBOSHConnection *conn, xmlnode *node);
static void jabber_bosh_connection_http_received_cb(PurpleHTTPRequest *req, PurpleHTTPResponse *res, void *userdata);
static void jabber_bosh_connection_send_native(PurpleBOSHConnection *conn, xmlnode *node);

static void jabber_bosh_http_connection_receive_parse_header(PurpleHTTPResponse *response, char **data, int *len);
static PurpleHTTPConnection* jabber_bosh_http_connection_init(const char *host, int port);
static void jabber_bosh_http_connection_connect(PurpleHTTPConnection *conn);
static void jabber_bosh_http_connection_send_request(PurpleHTTPConnection *conn, PurpleHTTPRequest *req);
static void jabber_bosh_http_connection_destroy(PurpleHTTPConnection *conn);

static PurpleHTTPRequest* jabber_bosh_http_request_init(const char *method, const char *path, PurpleHTTPRequestCallback cb, void *userdata);
static void jabber_bosh_http_request_add_to_header(PurpleHTTPRequest *req, const char *field, const char *value);
static void jabber_bosh_http_request_set_data(PurpleHTTPRequest *req, char *data, int len);
static void jabber_bosh_http_request_destroy(PurpleHTTPRequest *req);

static PurpleHTTPResponse* jabber_bosh_http_response_init(void);
static void jabber_bosh_http_response_destroy(PurpleHTTPResponse *res);

void jabber_bosh_init(void)
{
	GHashTable *ui_info = purple_core_get_ui_info();
	const char *ui_version = NULL;

{
	g_free(bosh_useragent);
	bosh_useragent = NULL;
}

PurpleBOSHConnection* jabber_bosh_connection_init(JabberStream *js, const char *url)
{
	PurpleBOSHConnection *conn;
	char *host, *path, *user, *passwd;
	int port;

	conn->conn_a->userdata = conn;

	return conn;
}

void jabber_bosh_connection_destroy(PurpleBOSHConnection *conn)
{
	g_free(conn->host);
	g_free(conn->path);

	if (conn->conn_a)

		bosh_conn->receive_cb = jabber_bosh_connection_received;
		bosh_conn->connect_cb(bosh_conn);
	} else jabber_bosh_connection_boot(bosh_conn);
}

static void jabber_bosh_connection_refresh(PurpleHTTPConnection *conn) {
	PurpleBOSHConnection *bosh_conn = conn->userdata;
	jabber_bosh_connection_send(bosh_conn, NULL);
}

static void jabber_bosh_http_connection_disconnected(PurpleHTTPConnection *conn) {
	PurpleBOSHConnection *bosh_conn = conn->userdata;
	bosh_conn->conn_a->connect_cb = jabber_bosh_connection_connected;

	} else {
		purple_debug_info("jabber", "jabber_bosh_http_connection_receive: problem receiving data (%d)\n", len);
	}
}

static PurpleHTTPConnection* jabber_bosh_http_connection_init(const char *host, int port)
{
	PurpleHTTPConnection *conn = g_new0(PurpleHTTPConnection, 1);
	conn->host = g_strdup(host);
	conn->port = port;
	conn->fd = -1;
	conn->requests = g_queue_new();

	return conn;
}

static void jabber_bosh_http_connection_destroy(PurpleHTTPConnection *conn)
{
	g_free(conn->current_data);
	g_free(conn->host);

	if (conn->requests) {
		g_queue_foreach(conn->requests, (GFunc)jabber_bosh_http_request_destroy, NULL);
		g_queue_free(conn->requests);
	}

	if (conn->current_response)
		jabber_bosh_http_response_destroy(conn->current_response);

	if (conn->ie_handle)
			purple_input_remove(conn->ie_handle);
	if (conn->fd > 0)
			close(conn->fd);

	g_free(conn);
}

static void jabber_bosh_http_connection_callback(gpointer data, gint source, const gchar *error)
{
	PurpleHTTPConnection *conn = data;
	PurpleBOSHConnection *bosh_conn = conn->userdata;
	PurpleConnection *gc = bosh_conn->js->gc;

	g_free(tmp);
	if (write(conn->fd, packet, strlen(packet)) == -1) purple_debug_info("jabber", "send error\n");
	g_queue_push_tail(conn->requests, req);
}

static PurpleHTTPRequest* jabber_bosh_http_request_init(const char *method,
        const char *path, PurpleHTTPRequestCallback cb, void *userdata)
{
	PurpleHTTPRequest *req = g_new(PurpleHTTPRequest, 1);
	req->method = g_strdup(method);
	req->path = g_strdup(path);
	req->cb = cb;
	req->userdata = userdata;
	req->header = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, g_free);
	return req;
}

static void jabber_bosh_http_request_add_to_header(PurpleHTTPRequest *req, const char *field, const char *value) {
	char *f = g_strdup(field);
	char *v = g_strdup(value);
	g_hash_table_replace(req->header, f, v);
}

void jabber_bosh_http_request_set_data(PurpleHTTPRequest *req, char *data, int len) {
	req->data = data;
	req->data_len = len;
}

static void jabber_bosh_http_request_destroy(PurpleHTTPRequest *req)
{
	g_hash_table_destroy(req->header);
	g_free(req->method);
	g_free(req->path);
	g_free(req->data);
	g_free(req);
}

static PurpleHTTPResponse* jabber_bosh_http_response_init(void)
{
	PurpleHTTPResponse *res = g_new0(PurpleHTTPResponse, 1);
	res->header = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, g_free);
	return res;
}

static void jabber_bosh_http_response_destroy(PurpleHTTPResponse *res)
{
	g_hash_table_destroy(res->header);
	g_free(res->data);
	g_free(res);
}

25183:62d9bce9ff74

static void jabber_bosh_connection_auth_response(PurpleBOSHConnection *conn, xmlnode *node);
static void jabber_bosh_connection_boot_response(PurpleBOSHConnection *conn, xmlnode *node);
static void jabber_bosh_connection_http_received_cb(PurpleHTTPRequest *req, PurpleHTTPResponse *res, void *userdata);
static void jabber_bosh_connection_send_native(PurpleBOSHConnection *conn, xmlnode *node);

static void jabber_bosh_http_connection_connect(PurpleHTTPConnection *conn);
static void jabber_bosh_http_connection_send_request(PurpleHTTPConnection *conn, PurpleHTTPRequest *req);

static void jabber_bosh_http_request_add_to_header(PurpleHTTPRequest *req, const char *field, const char *value);

void jabber_bosh_init(void)
{
	GHashTable *ui_info = purple_core_get_ui_info();
	const char *ui_version = NULL;

{
	g_free(bosh_useragent);
	bosh_useragent = NULL;
}

static PurpleHTTPRequest*
jabber_bosh_http_request_init(const char *method, const char *path,
                         PurpleHTTPRequestCallback cb, void *userdata)
{
	PurpleHTTPRequest *req = g_new(PurpleHTTPRequest, 1);
	req->method = g_strdup(method);
	req->path = g_strdup(path);
	req->cb = cb;
	req->userdata = userdata;
	req->header = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, g_free);
	return req;
}

static void
jabber_bosh_http_request_destroy(PurpleHTTPRequest *req)
{
	g_hash_table_destroy(req->header);
	g_free(req->method);
	g_free(req->path);
	g_free(req->data);
	g_free(req);
}

static PurpleHTTPResponse*
jabber_bosh_http_response_init(void)
{
	PurpleHTTPResponse *res = g_new0(PurpleHTTPResponse, 1);
	res->header = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, g_free);
	return res;
}

static void
jabber_bosh_http_response_destroy(PurpleHTTPResponse *res)
{
	g_hash_table_destroy(res->header);
	g_free(res->data);
	g_free(res);
}

static PurpleHTTPConnection*
jabber_bosh_http_connection_init(const char *host, int port)
{
	PurpleHTTPConnection *conn = g_new0(PurpleHTTPConnection, 1);
	conn->host = g_strdup(host);
	conn->port = port;
	conn->fd = -1;
	conn->requests = g_queue_new();

	return conn;
}

static void
jabber_bosh_http_connection_destroy(PurpleHTTPConnection *conn)
{
	g_free(conn->current_data);
	g_free(conn->host);

	if (conn->requests) {
		g_queue_foreach(conn->requests, (GFunc)jabber_bosh_http_request_destroy, NULL);
		g_queue_free(conn->requests);
	}

	if (conn->current_response)
		jabber_bosh_http_response_destroy(conn->current_response);

	if (conn->ie_handle)
		purple_input_remove(conn->ie_handle);
	if (conn->fd > 0)
		close(conn->fd);

	g_free(conn);
}

PurpleBOSHConnection*
jabber_bosh_connection_init(JabberStream *js, const char *url)
{
	PurpleBOSHConnection *conn;
	char *host, *path, *user, *passwd;
	int port;

	conn->conn_a->userdata = conn;

	return conn;
}

void
jabber_bosh_connection_destroy(PurpleBOSHConnection *conn)
{
	g_free(conn->host);
	g_free(conn->path);

	if (conn->conn_a)

		bosh_conn->receive_cb = jabber_bosh_connection_received;
		bosh_conn->connect_cb(bosh_conn);
	} else jabber_bosh_connection_boot(bosh_conn);
}

void jabber_bosh_connection_refresh(PurpleBOSHConnection *conn)
{
	jabber_bosh_connection_send(conn, NULL);
}

static void jabber_bosh_http_connection_disconnected(PurpleHTTPConnection *conn) {
	PurpleBOSHConnection *bosh_conn = conn->userdata;
	bosh_conn->conn_a->connect_cb = jabber_bosh_connection_connected;

	} else {
		purple_debug_info("jabber", "jabber_bosh_http_connection_receive: problem receiving data (%d)\n", len);
	}
}

static void jabber_bosh_http_connection_callback(gpointer data, gint source, const gchar *error)
{
	PurpleHTTPConnection *conn = data;
	PurpleBOSHConnection *bosh_conn = conn->userdata;
	PurpleConnection *gc = bosh_conn->js->gc;

	g_free(tmp);
	if (write(conn->fd, packet, strlen(packet)) == -1) purple_debug_info("jabber", "send error\n");
	g_queue_push_tail(conn->requests, req);
}

static void jabber_bosh_http_request_add_to_header(PurpleHTTPRequest *req, const char *field, const char *value) {
	char *f = g_strdup(field);
	char *v = g_strdup(value);
	g_hash_table_replace(req->header, f, v);
}