5 * Copyright (C) 2007-2010 Intel Corporation. All rights reserved.
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
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.
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 St, Fifth Floor, Boston, MA 02110-1301 USA
32 #include <netinet/in.h>
33 #include <arpa/inet.h>
37 #define CONNMAN_API_SUBJECT_TO_CHANGE
38 #include <connman/plugin.h>
39 #include <connman/location.h>
40 #include <connman/log.h>
43 #define PROXY_PORT 911
45 #define HOST "connman.net"
46 #define USER_APP "connman"
47 #define CONNMAN_NET_IP "174.36.13.145"
48 #define CONNMAN_MAX_IP_LENGTH 15
49 #define CONNECT_TIMEOUT 120
50 #define MAX_COUNTER 80
52 #define MAX_HEADER_LINES 13
53 #define PROXY_HEADER_LENGTH 7
55 enum get_page_status {
59 GET_PAGE_REDIRECTED = 3,
63 char host[MAX_COUNTER];
64 char page[MAX_COUNTER];
65 char proxy[MAX_COUNTER];
72 int (*get_page) (struct connman_location *location, char *page, int len,
73 enum get_page_status status);
76 static int create_socket()
80 sk = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
82 connman_error("Can not create TCP socket");
87 static char *get_ip_from_host(char *host)
89 int ip_len = CONNMAN_MAX_IP_LENGTH;
91 struct hostent *host_ent;
93 DBG("Get ip for %s", host);
94 ip = g_try_malloc0(ip_len + 1);
98 host_ent = gethostbyname(host);
99 if (host_ent == NULL) {
100 connman_error("Can not get IP");
104 if (inet_ntop(AF_INET, (void *) host_ent->h_addr_list[0],
105 ip, ip_len) == NULL) {
106 connman_error("Can not resolve host");
117 static char *build_get_query(char *host, char *page)
120 char *host_page = page;
121 char *tpl = "GET /%s HTTP/1.0\r\nHost: %s\r\nUser-Agent: %s\r\n\r\n";
123 if (host_page[0] == '/')
124 host_page = host_page + 1;
126 query = g_try_malloc0(strlen(host) + strlen(host_page) +
127 strlen(USER_APP) + strlen(tpl) - 5);
128 sprintf(query, tpl, host_page, host, USER_APP);
133 static gboolean connect_timeout(gpointer user_data)
135 struct connman_location *location = user_data;
136 struct server_data *data = connman_location_get_data(location);
144 data->get_page(location, NULL, 0, GET_PAGE_TIMEOUT);
149 static void remove_timeout(struct server_data *data)
151 if (data && data->timeout > 0) {
152 g_source_remove(data->timeout);
157 static gboolean tcp_event(GIOChannel *channel, GIOCondition condition,
160 struct connman_location *location = user_data;
161 struct server_data *data = connman_location_get_data(location);
162 enum get_page_status status;
170 if (condition & (G_IO_NVAL | G_IO_ERR | G_IO_HUP)) {
171 connman_error("TCP event error %d", condition);
173 status = GET_PAGE_FAILED;
177 sk = g_io_channel_unix_get_fd(channel);
178 len = recv(sk, buf, BUFSIZ, 0);
181 status = GET_PAGE_SUCCESS;
183 status = GET_PAGE_FAILED;
186 remove_timeout(data);
189 data->get_page(location, buf, len, status);
194 static gboolean socket_event(GIOChannel *channel, GIOCondition condition,
197 struct connman_location *location = user_data;
198 struct server_data *data = connman_location_get_data(location);
201 unsigned int send_counter = 0;
207 if (condition & G_IO_OUT && data->connection_ready == 0) {
208 data->connection_ready = 1;
209 sk = g_io_channel_unix_get_fd(channel);
211 query = build_get_query(data->host, data->page);
212 DBG("query is:\n%s\n", query);
214 while (send_counter < strlen(query)) {
215 ret = send(sk, query+send_counter,
216 strlen(query) - send_counter, 0);
218 DBG("Error sending query");
219 remove_timeout(data);
221 data->get_page(location, NULL, 0,
229 } else if (condition & G_IO_IN)
230 return tcp_event(channel, condition, user_data);
235 static void remove_connection(struct connman_location *location)
237 struct server_data *data = connman_location_get_data(location);
239 data = connman_location_get_data(location);
243 remove_timeout(data);
245 g_source_remove(data->watch);
247 if (data->channel != NULL)
248 g_io_channel_shutdown(data->channel, TRUE, NULL);
254 connman_location_set_data(location, NULL);
257 static int get_html(struct connman_location *location, int ms_time)
259 struct server_data *data;
260 struct sockaddr_in *remote_host = NULL;
266 data = connman_location_get_data(location);
267 data->connection_ready = 0;
268 data->sock = create_socket();
272 DBG("proxy %s port %d", data->proxy, data->proxy_port);
274 if (strlen(data->proxy) > 0)
275 ip = get_ip_from_host(data->proxy);
277 ip = g_try_malloc0(16);
279 strcpy(ip, CONNMAN_NET_IP);
285 DBG("IP from host %s is %s", data->host, ip);
287 remote_host = g_try_new0(struct sockaddr_in, 1);
288 remote_host->sin_family = AF_INET;
289 ret = inet_pton(AF_INET, ip,
290 (void *) (&(remote_host->sin_addr.s_addr)));
292 connman_error("Error Calling inet_pton");
294 } else if (ret == 0) {
295 connman_error("Wrong IP address %s", ip);
298 if (strlen(data->proxy) > 0)
299 remote_host->sin_port = htons(data->proxy_port);
301 remote_host->sin_port = htons(PORT);
303 data->channel = g_io_channel_unix_new(data->sock);
304 g_io_channel_set_flags(data->channel, G_IO_FLAG_NONBLOCK, NULL);
305 g_io_channel_set_close_on_unref(data->channel, TRUE);
306 data->watch = g_io_add_watch(data->channel, G_IO_OUT | G_IO_IN,
307 socket_event, location);
308 data->timeout = g_timeout_add_seconds(ms_time, connect_timeout,
311 ret = connect(data->sock, (struct sockaddr *)remote_host,
312 sizeof(struct sockaddr));
313 if (ret < 0 && errno != EINPROGRESS) {
314 connman_error("Could not connect");
315 remove_timeout(data);
328 data->get_page(location, NULL, 0, GET_PAGE_FAILED);
333 static int get_status(struct server_data *data, char *page, int len)
340 * Right now we are only looking at HTTP response header to figure
341 * out if AP redirected our HTTP request. In the future we are going
342 * to parse the HTTP body and look for certain fixed context.
343 * To figure out if we are redirected we look for some HTTP header line,
344 * if these header was found then we have our page otherwise we
345 * have a redirection page.
347 lines = g_strsplit(page, "\n", MAX_HEADER_LINES);
349 str = g_strrstr(lines[0], "200 OK");
351 for (i = 0; lines[i] != NULL && i < 12; i++) {
353 str = g_strstr_len(lines[i], 12, "Set-Cookie");
357 return GET_PAGE_SUCCESS;
365 return GET_PAGE_REDIRECTED;
368 static int get_page_cb(struct connman_location *location, char *page, int len,
369 enum get_page_status status)
372 struct server_data *data = connman_location_get_data(location);
374 remove_connection(location);
377 ret = get_status(data, page, len);
381 DBG("status %d", status);
384 case GET_PAGE_SUCCESS:
385 connman_location_report_result(location,
386 CONNMAN_LOCATION_RESULT_ONLINE);
389 case GET_PAGE_REDIRECTED:
390 connman_location_report_result(location,
391 CONNMAN_LOCATION_RESULT_PORTAL);
392 DBG("Page redirected");
394 case GET_PAGE_FAILED:
395 connman_location_report_result(location,
396 CONNMAN_LOCATION_RESULT_UNKNOWN);
397 DBG("Could not get the page");
399 case GET_PAGE_TIMEOUT:
400 connman_location_report_result(location,
401 CONNMAN_LOCATION_RESULT_UNKNOWN);
409 static int location_detect(struct connman_location *location)
412 struct server_data *data;
413 enum connman_service_type service_type;
415 service_type = connman_location_get_type(location);
417 DBG("service type %d", service_type);
419 switch (service_type) {
420 case CONNMAN_SERVICE_TYPE_ETHERNET:
421 case CONNMAN_SERVICE_TYPE_WIFI:
422 case CONNMAN_SERVICE_TYPE_WIMAX:
423 case CONNMAN_SERVICE_TYPE_BLUETOOTH:
424 case CONNMAN_SERVICE_TYPE_CELLULAR:
426 case CONNMAN_SERVICE_TYPE_UNKNOWN:
427 case CONNMAN_SERVICE_TYPE_SYSTEM:
428 case CONNMAN_SERVICE_TYPE_GPS:
429 case CONNMAN_SERVICE_TYPE_VPN:
433 data = g_try_new0(struct server_data, 1);
437 strcpy(data->host, HOST);
438 strcpy(data->page, PAGE);
439 data->get_page = get_page_cb;
442 proxy = getenv("http_proxy");
446 if (strncmp(proxy, "http://", PROXY_HEADER_LENGTH) == 0)
447 strcpy(data->proxy, proxy + PROXY_HEADER_LENGTH);
449 strcpy(data->proxy, proxy);
451 delim = strchr(data->proxy, ':');
455 len = delim - data->proxy;
456 data->proxy[len] = '\0';
458 data->proxy_port = atoi(delim + 1);
460 data->proxy_port = PROXY_PORT;
463 connman_location_set_data(location, data);
465 return get_html(location, CONNECT_TIMEOUT);
468 static int location_finish(struct connman_location *location)
471 remove_connection(location);
475 static struct connman_location_driver location = {
476 .name = "wifi and ethernet location",
477 .type = CONNMAN_SERVICE_TYPE_WIFI,
478 .priority = CONNMAN_LOCATION_PRIORITY_HIGH,
479 .detect = location_detect,
480 .finish = location_finish,
483 static int portal_init(void)
485 return connman_location_driver_register(&location);
488 static void portal_exit(void)
490 connman_location_driver_unregister(&location);
493 CONNMAN_PLUGIN_DEFINE(portal, "Portal detection plugin", VERSION,
494 CONNMAN_PLUGIN_PRIORITY_DEFAULT, portal_init, portal_exit)