* @file purple-socket.c Generic sockets * Purple is the legal property of its developers, whose names are too numerous * to list here. Please refer to the COPYRIGHT file distributed with this * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA #include "purple-socket.h" PURPLE_SOCKET_STATE_DISCONNECTED = 0, PURPLE_SOCKET_STATE_CONNECTING, PURPLE_SOCKET_STATE_CONNECTED, PURPLE_SOCKET_STATE_ERROR PurpleSslConnection *tls_connection; PurpleProxyConnectData *raw_connection; PurpleSocketConnectCb cb; purple_socket_new(PurpleConnection *gc) PurpleSocket *ps = g_new0(PurpleSocket, 1); ps->data = g_hash_table_new_full(g_str_hash, g_str_equal, g_free, NULL); purple_socket_get_connection(PurpleSocket *ps) g_return_val_if_fail(ps != NULL, NULL); purple_socket_check_state(PurpleSocket *ps, PurpleSocketState wanted_state) g_return_val_if_fail(ps != NULL, FALSE); if (ps->state == wanted_state) purple_debug_error("socket", "invalid state: %d (should be: %d)", ps->state, wanted_state); ps->state = PURPLE_SOCKET_STATE_ERROR; purple_socket_set_tls(PurpleSocket *ps, gboolean is_tls) g_return_if_fail(ps != NULL); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_DISCONNECTED)) purple_socket_set_host(PurpleSocket *ps, const gchar *host) g_return_if_fail(ps != NULL); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_DISCONNECTED)) ps->host = g_strdup(host); purple_socket_set_port(PurpleSocket *ps, int port) g_return_if_fail(ps != NULL); g_return_if_fail(port >= 0); g_return_if_fail(port <= 65535); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_DISCONNECTED)) _purple_socket_connected_raw(gpointer _ps, gint fd, const gchar *error_message) ps->raw_connection = NULL; if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTING)) { ps->cb(ps, _("Invalid socket state"), ps->cb_data); if (fd <= 0 || error_message != NULL) { if (error_message == NULL) error_message = _("Unknown error"); ps->state = PURPLE_SOCKET_STATE_ERROR; ps->cb(ps, error_message, ps->cb_data); ps->state = PURPLE_SOCKET_STATE_CONNECTED; ps->cb(ps, NULL, ps->cb_data); _purple_socket_connected_tls(gpointer _ps, PurpleSslConnection *tls_connection, PurpleInputCondition cond) if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTING)) { purple_ssl_close(tls_connection); ps->tls_connection = NULL; ps->cb(ps, _("Invalid socket state"), ps->cb_data); if (ps->tls_connection->fd <= 0) { ps->state = PURPLE_SOCKET_STATE_ERROR; purple_ssl_close(tls_connection); ps->tls_connection = NULL; ps->cb(ps, _("Invalid file descriptor"), ps->cb_data); ps->state = PURPLE_SOCKET_STATE_CONNECTED; ps->fd = ps->tls_connection->fd; ps->cb(ps, NULL, ps->cb_data); _purple_socket_connected_tls_error(PurpleSslConnection *ssl_connection, PurpleSslErrorType error, gpointer _ps) ps->state = PURPLE_SOCKET_STATE_ERROR; ps->tls_connection = NULL; ps->cb(ps, purple_ssl_strerror(error), ps->cb_data); purple_socket_connect(PurpleSocket *ps, PurpleSocketConnectCb cb, PurpleAccount *account = NULL; g_return_val_if_fail(ps != NULL, FALSE); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_DISCONNECTED)) ps->state = PURPLE_SOCKET_STATE_CONNECTING; if (ps->host == NULL || ps->port < 0) { purple_debug_error("socket", "Host or port is not specified"); ps->state = PURPLE_SOCKET_STATE_ERROR; account = purple_connection_get_account(ps->gc); if (!purple_ssl_is_supported()) { purple_debug_error("socket", "TLS is not supported"); ps->state = PURPLE_SOCKET_STATE_ERROR; ps->tls_connection = purple_ssl_connect(account, ps->host, ps->port, _purple_socket_connected_tls, _purple_socket_connected_tls_error, ps); ps->raw_connection = purple_proxy_connect(ps->gc, account, ps->host, ps->port, _purple_socket_connected_raw, ps); if (ps->tls_connection == NULL && ps->raw_connection == NULL) ps->state = PURPLE_SOCKET_STATE_ERROR; purple_socket_read(PurpleSocket *ps, guchar *buf, size_t len) g_return_val_if_fail(ps != NULL, -1); g_return_val_if_fail(buf != NULL, -1); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTED)) return purple_ssl_read(ps->tls_connection, buf, len); return read(ps->fd, buf, len); purple_socket_write(PurpleSocket *ps, const guchar *buf, size_t len) g_return_val_if_fail(ps != NULL, -1); g_return_val_if_fail(buf != NULL, -1); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTED)) return purple_ssl_write(ps->tls_connection, buf, len); return write(ps->fd, buf, len); purple_socket_watch(PurpleSocket *ps, PurpleInputCondition cond, PurpleInputFunction func, gpointer user_data) g_return_if_fail(ps != NULL); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTED)) purple_input_remove(ps->inpa); g_return_if_fail(ps->fd > 0); ps->inpa = purple_input_add(ps->fd, cond, func, user_data); purple_socket_get_fd(PurpleSocket *ps) g_return_val_if_fail(ps != NULL, -1); if (!purple_socket_check_state(ps, PURPLE_SOCKET_STATE_CONNECTED)) g_return_val_if_fail(ps->fd > 0, -1); purple_socket_set_data(PurpleSocket *ps, const gchar *key, gpointer data) g_return_if_fail(ps != NULL); g_return_if_fail(key != NULL); g_hash_table_remove(ps->data, key); g_hash_table_insert(ps->data, g_strdup(key), data); purple_socket_get_data(PurpleSocket *ps, const gchar *key) g_return_val_if_fail(ps != NULL, NULL); g_return_val_if_fail(key != NULL, NULL); return g_hash_table_lookup(ps->data, key); purple_socket_destroy(PurpleSocket *ps) purple_input_remove(ps->inpa); if (ps->tls_connection != NULL) { purple_ssl_close(ps->tls_connection); if (ps->raw_connection != NULL) purple_proxy_connect_cancel(ps->raw_connection); g_hash_table_destroy(ps->data);