summaryrefslogtreecommitdiff
path: root/src/google-relay.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/google-relay.c')
-rw-r--r--src/google-relay.c325
1 files changed, 0 insertions, 325 deletions
diff --git a/src/google-relay.c b/src/google-relay.c
deleted file mode 100644
index 000deaa86..000000000
--- a/src/google-relay.c
+++ /dev/null
@@ -1,325 +0,0 @@
-/*
- * google-relay.c - Support for Google relays for Jingle
- *
- * Copyright (C) 2006-2008 Collabora Ltd.
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2.1 of the License, or (at your option) any later version.
- *
- * This library 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
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
- */
-
-#include "config.h"
-#include "google-relay.h"
-
-#include <string.h>
-
-#ifdef ENABLE_GOOGLE_RELAY
-#include <libsoup/soup.h>
-#endif
-
-#define DEBUG_FLAG GABBLE_DEBUG_MEDIA
-
-#ifdef G_OS_WIN32
-#undef ERROR
-#endif
-
-#include "debug.h"
-
-#define RELAY_HTTP_TIMEOUT 5
-
-struct _WockyGoogleRelayResolver {
-#ifdef ENABLE_GOOGLE_RELAY
- SoupSession *soup;
-#else
- GObject *soup;
-#endif
-};
-
-typedef struct
-{
- GPtrArray *relays;
- guint component;
- guint requests_to_do;
- WockyJingleInfoRelaySessionCb callback;
- gpointer user_data;
-} RelaySessionData;
-
-static RelaySessionData *
-relay_session_data_new (guint requests_to_do,
- WockyJingleInfoRelaySessionCb callback,
- gpointer user_data)
-{
- RelaySessionData *rsd = g_slice_new0 (RelaySessionData);
-
- rsd->relays = g_ptr_array_sized_new (requests_to_do);
- g_ptr_array_set_free_func (rsd->relays, (GDestroyNotify) wocky_jingle_relay_free);
- rsd->component = 1;
- rsd->requests_to_do = requests_to_do;
- rsd->callback = callback;
- rsd->user_data = user_data;
-
- return rsd;
-}
-
-/* This is a GSourceFunc */
-static gboolean
-relay_session_data_call (gpointer p)
-{
- RelaySessionData *rsd = p;
-
- g_assert (rsd->callback != NULL);
-
- rsd->callback (rsd->relays, rsd->user_data);
-
- return FALSE;
-}
-
-/* This is a GDestroyNotify */
-static void
-relay_session_data_destroy (gpointer p)
-{
- RelaySessionData *rsd = p;
-
- g_ptr_array_unref (rsd->relays);
-
- g_slice_free (RelaySessionData, rsd);
-}
-
-#ifdef ENABLE_GOOGLE_RELAY
-
-static void
-translate_relay_info (GPtrArray *relays,
- const gchar *relay_ip,
- const gchar *username,
- const gchar *password,
- WockyJingleRelayType relay_type,
- const gchar *port_string,
- guint component)
-{
- guint64 portll;
- guint port;
-
- if (port_string == NULL)
- {
- DEBUG ("no relay port for %u found", relay_type);
- return;
- }
-
- portll = g_ascii_strtoull (port_string, NULL, 10);
-
- if (portll == 0 || portll > G_MAXUINT16)
- {
- DEBUG ("failed to parse relay port '%s' for %u", port_string,
- relay_type);
- return;
- }
- port = (guint) portll;
-
- DEBUG ("type=%u ip=%s port=%u username=%s password=%s component=%u",
- relay_type, relay_ip, port, username, password, component);
-
- g_ptr_array_add (relays,
- wocky_jingle_relay_new (relay_type, relay_ip, port, username, password,
- component));
-}
-
-static void
-on_http_response (SoupSession *soup,
- SoupMessage *msg,
- gpointer user_data)
-{
- RelaySessionData *rsd = user_data;
-
- if (msg->status_code != 200)
- {
- DEBUG ("Google session creation failed, relaying not used: %d %s",
- msg->status_code, msg->reason_phrase);
- }
- else
- {
- /* parse a=b lines into GHashTable
- * (key, value both borrowed from items of the strv 'lines') */
- GHashTable *map = g_hash_table_new (g_str_hash, g_str_equal);
- gchar **lines;
- guint i;
- const gchar *relay_ip;
- const gchar *relay_udp_port;
- const gchar *relay_tcp_port;
- const gchar *relay_ssltcp_port;
- const gchar *username;
- const gchar *password;
- gchar *escaped_str;
-
- escaped_str = g_strescape (msg->response_body->data, "\r\n");
- DEBUG ("Response from Google:\n====\n%s\n====", escaped_str);
- g_free (escaped_str);
-
- lines = g_strsplit (msg->response_body->data, "\n", 0);
-
- if (lines != NULL)
- {
- for (i = 0; lines[i] != NULL; i++)
- {
- gchar *delim = strchr (lines[i], '=');
- size_t len;
-
- if (delim == NULL || delim == lines[i])
- {
- /* ignore empty keys or lines without '=' */
- continue;
- }
-
- len = strlen (lines[i]);
-
- if (lines[i][len - 1] == '\r')
- {
- lines[i][len - 1] = '\0';
- }
-
- *delim = '\0';
- g_hash_table_insert (map, lines[i], delim + 1);
- }
- }
-
- relay_ip = g_hash_table_lookup (map, "relay.ip");
- relay_udp_port = g_hash_table_lookup (map, "relay.udp_port");
- relay_tcp_port = g_hash_table_lookup (map, "relay.tcp_port");
- relay_ssltcp_port = g_hash_table_lookup (map, "relay.ssltcp_port");
- username = g_hash_table_lookup (map, "username");
- password = g_hash_table_lookup (map, "password");
-
- if (relay_ip == NULL)
- {
- DEBUG ("No relay.ip found");
- }
- else if (username == NULL)
- {
- DEBUG ("No username found");
- }
- else if (password == NULL)
- {
- DEBUG ("No password found");
- }
- else
- {
- translate_relay_info (rsd->relays, relay_ip, username, password,
- WOCKY_JINGLE_RELAY_TYPE_UDP, relay_udp_port, rsd->component);
- translate_relay_info (rsd->relays, relay_ip, username, password,
- WOCKY_JINGLE_RELAY_TYPE_TCP, relay_tcp_port, rsd->component);
- translate_relay_info (rsd->relays, relay_ip, username, password,
- WOCKY_JINGLE_RELAY_TYPE_TLS, relay_ssltcp_port, rsd->component);
- }
-
- g_strfreev (lines);
- g_hash_table_unref (map);
- }
-
- rsd->component++;
-
- if ((--rsd->requests_to_do) == 0)
- {
- relay_session_data_call (rsd);
- relay_session_data_destroy (rsd);
- }
-}
-
-#endif /* ENABLE_GOOGLE_RELAY */
-
-WockyGoogleRelayResolver *
-wocky_google_relay_resolver_new (void)
-{
- WockyGoogleRelayResolver *resolver =
- g_slice_new0 (WockyGoogleRelayResolver);
-
-#ifdef ENABLE_GOOGLE_RELAY
-
- resolver->soup = soup_session_async_new ();
-
- /* If we don't get answer in a few seconds, relay won't do
- * us much help anyways. */
- g_object_set (resolver->soup, "timeout", RELAY_HTTP_TIMEOUT, NULL);
-
-#endif
-
- return resolver;
-}
-
-void
-wocky_google_relay_resolver_destroy (WockyGoogleRelayResolver *self)
-{
- g_clear_object (&self->soup);
-
- g_slice_free (WockyGoogleRelayResolver, self);
-}
-
-void
-wocky_google_relay_resolver_resolve (WockyGoogleRelayResolver *self,
- guint components,
- const gchar *server,
- guint16 port,
- const gchar *token,
- WockyJingleInfoRelaySessionCb callback,
- gpointer user_data)
-{
- RelaySessionData *rsd =
- relay_session_data_new (components, callback, user_data);
-
-#ifdef ENABLE_GOOGLE_RELAY
-
- gchar *url;
- guint i;
-
- if (server == NULL)
- {
- DEBUG ("No relay server provided, not creating google relay session");
- g_idle_add_full (G_PRIORITY_DEFAULT, relay_session_data_call, rsd,
- relay_session_data_destroy);
- return;
- }
-
- if (token == NULL)
- {
- DEBUG ("No relay token provided, not creating google relay session");
- g_idle_add_full (G_PRIORITY_DEFAULT, relay_session_data_call, rsd,
- relay_session_data_destroy);
- return;
- }
-
- url = g_strdup_printf ("http://%s:%u/create_session", server, (guint) port);
-
- for (i = 0; i < components; i++)
- {
- SoupMessage *msg = soup_message_new ("GET", url);
-
- DEBUG ("Trying to create a new relay session on %s", url);
-
- /* libjingle sets both headers, so shall we */
- soup_message_headers_append (msg->request_headers,
- "X-Talk-Google-Relay-Auth", token);
- soup_message_headers_append (msg->request_headers,
- "X-Google-Relay-Auth", token);
-
- soup_session_queue_message (self->soup, msg, on_http_response, rsd);
- }
-
- g_free (url);
-
-#else /* !ENABLE_GOOGLE_RELAY */
-
- DEBUG ("Google relay service is not supported");
-
- g_idle_add_full (G_PRIORITY_DEFAULT, relay_session_data_call, rsd,
- relay_session_data_destroy);
-
-#endif
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-05-30 09:00:09 +0000