1 /**
2 * Purple is the legal property of its developers, whose names are too numerous
3 * to list here. Please refer to the COPYRIGHT file distributed with this
4 * source distribution.
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02111-1301 USA
19 */
20
21 #include "internal.h"
22 #include "debug.h"
23
24 #include "relay.h"
25
26 typedef struct {
27 GoogleSession *session;
28 JabberGoogleRelayCallback *cb;
29 } JabberGoogleRelayCallbackData;
30
31 static void
jabber_google_relay_parse_response(const gchar * response,gchar ** ip,guint * udp,guint * tcp,guint * ssltcp,gchar ** username,gchar ** password)32 jabber_google_relay_parse_response(const gchar *response, gchar **ip,
33 guint *udp, guint *tcp, guint *ssltcp, gchar **username, gchar **password)
34 {
35 gchar **lines = g_strsplit(response, "\n", -1);
36 int i = 0;
37
38 for (; lines[i] ; i++) {
39 gchar *line = lines[i];
40 gchar **parts = g_strsplit(line, "=", 2);
41
42 if (parts[0] && parts[1]) {
43 if (purple_strequal(parts[0], "relay.ip")) {
44 *ip = g_strdup(parts[1]);
45 } else if (purple_strequal(parts[0], "relay.udp_port")) {
46 *udp = atoi(parts[1]);
47 } else if (purple_strequal(parts[0], "relay.tcp_port")) {
48 *tcp = atoi(parts[1]);
49 } else if (purple_strequal(parts[0], "relay.ssltcp_port")) {
50 *ssltcp = atoi(parts[1]);
51 } else if (purple_strequal(parts[0], "username")) {
52 *username = g_strdup(parts[1]);
53 } else if (purple_strequal(parts[0], "password")) {
54 *password = g_strdup(parts[1]);
55 }
56 }
57 g_strfreev(parts);
58 }
59
60 g_strfreev(lines);
61 }
62
63 static void
jabber_google_relay_remove_url_data(JabberStream * js,PurpleUtilFetchUrlData * url_data)64 jabber_google_relay_remove_url_data(JabberStream *js,
65 PurpleUtilFetchUrlData *url_data)
66 {
67 GList *iter = js->google_relay_requests;
68
69 while (iter) {
70 if (iter->data == url_data) {
71 js->google_relay_requests =
72 g_list_delete_link(js->google_relay_requests, iter);
73 break;
74 }
75 }
76 }
77
78 static void
jabber_google_relay_fetch_cb(PurpleUtilFetchUrlData * url_data,gpointer user_data,const gchar * url_text,gsize len,const gchar * error_message)79 jabber_google_relay_fetch_cb(PurpleUtilFetchUrlData *url_data,
80 gpointer user_data, const gchar *url_text, gsize len,
81 const gchar *error_message)
82 {
83 JabberGoogleRelayCallbackData *data =
84 (JabberGoogleRelayCallbackData *) user_data;
85 GoogleSession *session = data->session;
86 JabberStream *js = session->js;
87 JabberGoogleRelayCallback *cb = data->cb;
88 gchar *relay_ip = NULL;
89 guint relay_udp = 0;
90 guint relay_tcp = 0;
91 guint relay_ssltcp = 0;
92 gchar *relay_username = NULL;
93 gchar *relay_password = NULL;
94
95 g_free(data);
96
97 if (url_data) {
98 jabber_google_relay_remove_url_data(js, url_data);
99 }
100
101 purple_debug_info("jabber", "got response on HTTP request to relay server\n");
102
103 if (url_text && len > 0) {
104 purple_debug_info("jabber", "got Google relay request response:\n%s\n",
105 url_text);
106 jabber_google_relay_parse_response(url_text, &relay_ip, &relay_udp,
107 &relay_tcp, &relay_ssltcp, &relay_username, &relay_password);
108 }
109
110 if (cb)
111 cb(session, relay_ip, relay_udp, relay_tcp, relay_ssltcp,
112 relay_username, relay_password);
113
114 g_free(relay_ip);
115 g_free(relay_username);
116 g_free(relay_password);
117 }
118
119 void
jabber_google_do_relay_request(JabberStream * js,GoogleSession * session,JabberGoogleRelayCallback cb)120 jabber_google_do_relay_request(JabberStream *js, GoogleSession *session,
121 JabberGoogleRelayCallback cb)
122 {
123 PurpleUtilFetchUrlData *url_data = NULL;
124 gchar *url = g_strdup_printf("http://%s", js->google_relay_host);
125 /* yes, the relay token is included twice as different request headers,
126 this is apparently needed to make Google's relay servers work... */
127 gchar *request =
128 g_strdup_printf("GET /create_session HTTP/1.0\r\n"
129 "Host: %s\r\n"
130 "X-Talk-Google-Relay-Auth: %s\r\n"
131 "X-Google-Relay-Auth: %s\r\n\r\n",
132 js->google_relay_host, js->google_relay_token, js->google_relay_token);
133 JabberGoogleRelayCallbackData *data = g_new0(JabberGoogleRelayCallbackData, 1);
134
135 data->session = session;
136 data->cb = cb;
137 purple_debug_info("jabber",
138 "sending Google relay request %s to %s\n", request, url);
139 url_data =
140 purple_util_fetch_url_request(url, FALSE, NULL, FALSE, request, FALSE,
141 jabber_google_relay_fetch_cb, data);
142 if (url_data) {
143 js->google_relay_requests =
144 g_list_prepend(js->google_relay_requests, url_data);
145 } else {
146 purple_debug_error("jabber", "unable to create Google relay request\n");
147 jabber_google_relay_fetch_cb(NULL, data, NULL, 0, NULL);
148 }
149 g_free(url);
150 g_free(request);
151 }