dnsproxy: Only one copy of the relevant buffers will be made to a TCP request
[framework/connectivity/connman.git] / src / provider.c
1 /*
2  *
3  *  Connection Manager
4  *
5  *  Copyright (C) 2007-2012  Intel Corporation. All rights reserved.
6  *
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.
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 St, Fifth Floor, Boston, MA  02110-1301  USA
19  *
20  */
21
22 #ifdef HAVE_CONFIG_H
23 #include <config.h>
24 #endif
25
26 #include <errno.h>
27 #include <stdio.h>
28 #include <string.h>
29 #include <stdlib.h>
30 #include <gdbus.h>
31
32 #include "connman.h"
33
34 static DBusConnection *connection = NULL;
35
36 static GHashTable *provider_hash = NULL;
37
38 static GSList *driver_list = NULL;
39
40 struct connman_route {
41         int family;
42         char *host;
43         char *netmask;
44         char *gateway;
45 };
46
47 struct connman_provider {
48         int refcount;
49         struct connman_service *vpn_service;
50         int index;
51         char *identifier;
52         char *name;
53         char *type;
54         char *host;
55         char *domain;
56         int family;
57         GHashTable *routes;
58         struct connman_provider_driver *driver;
59         void *driver_data;
60         GHashTable *setting_strings;
61         GHashTable *user_routes;
62         gchar **user_networks;
63         gsize num_user_networks;
64 };
65
66 void __connman_provider_append_properties(struct connman_provider *provider,
67                                                         DBusMessageIter *iter)
68 {
69         if (provider->host != NULL)
70                 connman_dbus_dict_append_basic(iter, "Host",
71                                         DBUS_TYPE_STRING, &provider->host);
72
73         if (provider->domain != NULL)
74                 connman_dbus_dict_append_basic(iter, "Domain",
75                                         DBUS_TYPE_STRING, &provider->domain);
76
77         if (provider->type != NULL)
78                 connman_dbus_dict_append_basic(iter, "Type", DBUS_TYPE_STRING,
79                                                  &provider->type);
80 }
81
82 int __connman_provider_append_user_route(struct connman_provider *provider,
83                         int family, const char *network, const char *netmask)
84 {
85         struct connman_route *route;
86         char *key = g_strdup_printf("%d/%s/%s", family, network, netmask);
87
88         DBG("family %d network %s netmask %s", family, network, netmask);
89
90         route = g_hash_table_lookup(provider->user_routes, key);
91         if (route == NULL) {
92                 route = g_try_new0(struct connman_route, 1);
93                 if (route == NULL) {
94                         connman_error("out of memory");
95                         return -ENOMEM;
96                 }
97
98                 route->family = family;
99                 route->host = g_strdup(network);
100                 route->netmask = g_strdup(netmask);
101
102                 g_hash_table_replace(provider->user_routes, key, route);
103         } else
104                 g_free(key);
105
106         return 0;
107 }
108
109 static void set_user_networks(struct connman_provider *provider,
110                                                         char **networks)
111 {
112         int i = 0;
113
114         while (networks[i] != NULL) {
115                 char **elems = g_strsplit(networks[i], "/", 0);
116                 char *network, *netmask;
117                 int family = PF_UNSPEC, ret;
118
119                 if (elems == NULL)
120                         break;
121
122                 network = elems[0];
123                 if (network == NULL || *network == '\0') {
124                         DBG("no network/netmask set");
125                         g_strfreev(elems);
126                         break;
127                 }
128
129                 netmask = elems[1];
130                 if (netmask != NULL && *netmask == '\0') {
131                         DBG("no netmask set");
132                         g_strfreev(elems);
133                         break;
134                 }
135
136                 if (g_strrstr(network, ":") != NULL)
137                         family = AF_INET6;
138                 else if (g_strrstr(network, ".") != NULL) {
139                         family = AF_INET;
140
141                         if (g_strrstr(netmask, ".") == NULL) {
142                                 /* We have netmask length */
143                                 in_addr_t addr;
144                                 struct in_addr netmask_in;
145                                 unsigned char prefix_len = 32;
146
147                                 if (netmask != NULL)
148                                         prefix_len = atoi(netmask);
149
150                                 addr = 0xffffffff << (32 - prefix_len);
151                                 netmask_in.s_addr = htonl(addr);
152                                 netmask = inet_ntoa(netmask_in);
153
154                                 DBG("network %s netmask %s", network, netmask);
155                         }
156                 }
157
158                 ret = __connman_provider_append_user_route(provider,
159                                                 family, network, netmask);
160                 g_strfreev(elems);
161
162                 if (ret != 0)
163                         break;
164
165                 i++;
166         }
167 }
168
169 static int provider_load_from_keyfile(struct connman_provider *provider,
170                 GKeyFile *keyfile)
171 {
172         gsize idx = 0;
173         gchar **settings;
174         gchar *key, *value;
175         gsize length;
176
177         settings = g_key_file_get_keys(keyfile, provider->identifier, &length,
178                                 NULL);
179         if (settings == NULL) {
180                 g_key_file_free(keyfile);
181                 return -ENOENT;
182         }
183
184         while (idx < length) {
185                 key = settings[idx];
186                 if (key != NULL) {
187                         if (g_str_equal(key, "Networks") == TRUE) {
188                                 g_strfreev(provider->user_networks);
189                                 provider->user_networks =
190                                         g_key_file_get_string_list(keyfile,
191                                                 provider->identifier,
192                                                 key,
193                                                 &provider->num_user_networks,
194                                                 NULL);
195                         } else {
196                                 value = g_key_file_get_string(keyfile,
197                                                         provider->identifier,
198                                                         key, NULL);
199                                 connman_provider_set_string(provider, key,
200                                                         value);
201                                 g_free(value);
202                         }
203                 }
204                 idx += 1;
205         }
206         g_strfreev(settings);
207
208         if (provider->user_networks != NULL)
209                 set_user_networks(provider, provider->user_networks);
210
211         return 0;
212 }
213
214 static int connman_provider_load(struct connman_provider *provider)
215 {
216         GKeyFile *keyfile;
217
218         DBG("provider %p", provider);
219
220         keyfile = __connman_storage_load_provider(provider->identifier);
221         if (keyfile == NULL)
222                 return -ENOENT;
223
224         provider_load_from_keyfile(provider, keyfile);
225
226         g_key_file_free(keyfile);
227         return 0;
228 }
229
230 static int connman_provider_save(struct connman_provider *provider)
231 {
232         GKeyFile *keyfile;
233
234         DBG("provider %p", provider);
235
236         keyfile = g_key_file_new();
237         if (keyfile == NULL)
238                 return -ENOMEM;
239
240         g_key_file_set_string(keyfile, provider->identifier,
241                         "Name", provider->name);
242         g_key_file_set_string(keyfile, provider->identifier,
243                         "Type", provider->type);
244         g_key_file_set_string(keyfile, provider->identifier,
245                         "Host", provider->host);
246         g_key_file_set_string(keyfile, provider->identifier,
247                         "VPN.Domain", provider->domain);
248         if (provider->user_networks != NULL)
249                 g_key_file_set_string_list(keyfile, provider->identifier,
250                                 "Networks",
251                                 (const gchar **)provider->user_networks,
252                                 provider->num_user_networks);
253
254         if (provider->driver != NULL && provider->driver->save != NULL)
255                 provider->driver->save(provider, keyfile);
256
257         __connman_storage_save_provider(keyfile, provider->identifier);
258         g_key_file_free(keyfile);
259
260         return 0;
261 }
262
263 static struct connman_provider *connman_provider_lookup(const char *identifier)
264 {
265         struct connman_provider *provider = NULL;
266
267         provider = g_hash_table_lookup(provider_hash, identifier);
268
269         return provider;
270 }
271
272 static gboolean match_driver(struct connman_provider *provider,
273                                 struct connman_provider_driver *driver)
274 {
275         if (g_strcmp0(driver->name, provider->type) == 0)
276                 return TRUE;
277
278         return FALSE;
279 }
280
281 static int provider_probe(struct connman_provider *provider)
282 {
283         GSList *list;
284
285         DBG("provider %p name %s", provider, provider->name);
286
287         if (provider->driver != NULL)
288                 return -EALREADY;
289
290         for (list = driver_list; list; list = list->next) {
291                 struct connman_provider_driver *driver = list->data;
292
293                 if (match_driver(provider, driver) == FALSE)
294                         continue;
295
296                 DBG("driver %p name %s", driver, driver->name);
297
298                 if (driver->probe != NULL && driver->probe(provider) == 0) {
299                         provider->driver = driver;
300                         break;
301                 }
302         }
303
304         if (provider->driver == NULL)
305                 return -ENODEV;
306
307         return 0;
308 }
309
310 static void provider_remove(struct connman_provider *provider)
311 {
312         if (provider->driver != NULL) {
313                 provider->driver->remove(provider);
314                 provider->driver = NULL;
315         }
316 }
317
318 static int provider_register(struct connman_provider *provider)
319 {
320         return provider_probe(provider);
321 }
322
323 static void provider_unregister(struct connman_provider *provider)
324 {
325         provider_remove(provider);
326 }
327
328 struct connman_provider *
329 connman_provider_ref_debug(struct connman_provider *provider,
330                         const char *file, int line, const char *caller)
331 {
332         DBG("%p ref %d by %s:%d:%s()", provider, provider->refcount + 1,
333                 file, line, caller);
334
335         __sync_fetch_and_add(&provider->refcount, 1);
336
337         return provider;
338 }
339
340 static void provider_destruct(struct connman_provider *provider)
341 {
342         DBG("provider %p", provider);
343
344         g_free(provider->name);
345         g_free(provider->type);
346         g_free(provider->host);
347         g_free(provider->domain);
348         g_free(provider->identifier);
349         g_strfreev(provider->user_networks);
350         g_hash_table_destroy(provider->routes);
351         g_hash_table_destroy(provider->user_routes);
352         g_hash_table_destroy(provider->setting_strings);
353         g_free(provider);
354 }
355
356 void connman_provider_unref_debug(struct connman_provider *provider,
357                                 const char *file, int line, const char *caller)
358 {
359         DBG("%p ref %d by %s:%d:%s()", provider, provider->refcount - 1,
360                 file, line, caller);
361
362         if (__sync_fetch_and_sub(&provider->refcount, 1) != 1)
363                 return;
364
365         provider_remove(provider);
366
367         provider_destruct(provider);
368 }
369
370 static int provider_indicate_state(struct connman_provider *provider,
371                                         enum connman_service_state state)
372 {
373         DBG("state %d", state);
374
375         __connman_service_ipconfig_indicate_state(provider->vpn_service, state,
376                                         CONNMAN_IPCONFIG_TYPE_IPV4);
377
378         return __connman_service_ipconfig_indicate_state(provider->vpn_service,
379                                         state, CONNMAN_IPCONFIG_TYPE_IPV6);
380 }
381
382 int __connman_provider_disconnect(struct connman_provider *provider)
383 {
384         int err;
385
386         DBG("provider %p", provider);
387
388         if (provider->driver != NULL && provider->driver->disconnect != NULL)
389                 err = provider->driver->disconnect(provider);
390         else
391                 return -EOPNOTSUPP;
392
393         if (provider->vpn_service != NULL)
394                 provider_indicate_state(provider,
395                                         CONNMAN_SERVICE_STATE_DISCONNECT);
396
397         if (err < 0) {
398                 if (err != -EINPROGRESS)
399                         return err;
400
401                 return -EINPROGRESS;
402         }
403
404         return 0;
405 }
406
407 int __connman_provider_connect(struct connman_provider *provider)
408 {
409         int err;
410
411         DBG("provider %p", provider);
412
413         if (provider->driver != NULL && provider->driver->connect != NULL)
414                 err = provider->driver->connect(provider);
415         else
416                 return -EOPNOTSUPP;
417
418         if (err < 0) {
419                 if (err != -EINPROGRESS)
420                         return err;
421
422                 provider_indicate_state(provider,
423                                         CONNMAN_SERVICE_STATE_ASSOCIATION);
424
425                 return -EINPROGRESS;
426         }
427
428         return 0;
429 }
430
431 int __connman_provider_remove(const char *path)
432 {
433         struct connman_provider *provider;
434         GHashTableIter iter;
435         gpointer value, key;
436
437         DBG("path %s", path);
438
439         g_hash_table_iter_init(&iter, provider_hash);
440         while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
441                 const char *srv_path;
442                 provider = value;
443
444                 if (provider->vpn_service == NULL)
445                         continue;
446
447                 srv_path = __connman_service_get_path(provider->vpn_service);
448
449                 if (g_strcmp0(srv_path, path) == 0) {
450                         DBG("Removing VPN %s", provider->identifier);
451
452                         provider_unregister(provider);
453                         g_hash_table_remove(provider_hash,
454                                                 provider->identifier);
455                         return 0;
456                 }
457         }
458
459         return -ENXIO;
460 }
461
462 static void provider_append_routes(gpointer key, gpointer value,
463                                         gpointer user_data)
464 {
465         struct connman_route *route = value;
466         struct connman_provider *provider = user_data;
467         int index = provider->index;
468
469         if (route->family == AF_INET6) {
470                 unsigned char prefix_len = atoi(route->netmask);
471
472                 connman_inet_add_ipv6_network_route(index, route->host,
473                                                         route->gateway,
474                                                         prefix_len);
475         } else {
476                 connman_inet_add_network_route(index, route->host,
477                                                 route->gateway,
478                                                 route->netmask);
479         }
480 }
481
482 static int set_connected(struct connman_provider *provider,
483                                         connman_bool_t connected)
484 {
485         struct connman_service *service = provider->vpn_service;
486         struct connman_ipconfig *ipconfig;
487
488         if (service == NULL)
489                 return -ENODEV;
490
491         ipconfig = __connman_service_get_ipconfig(service, provider->family);
492
493         if (connected == TRUE) {
494                 if (ipconfig == NULL) {
495                         provider_indicate_state(provider,
496                                                 CONNMAN_SERVICE_STATE_FAILURE);
497                         return -EIO;
498                 }
499
500                 __connman_ipconfig_address_add(ipconfig);
501                 __connman_ipconfig_gateway_add(ipconfig);
502
503                 provider_indicate_state(provider,
504                                         CONNMAN_SERVICE_STATE_READY);
505
506                 g_hash_table_foreach(provider->routes, provider_append_routes,
507                                         provider);
508
509                 g_hash_table_foreach(provider->user_routes, provider_append_routes,
510                                         provider);
511
512         } else {
513                 if (ipconfig != NULL) {
514                         provider_indicate_state(provider,
515                                         CONNMAN_SERVICE_STATE_DISCONNECT);
516                         __connman_ipconfig_gateway_remove(ipconfig);
517                 }
518
519                 provider_indicate_state(provider,
520                                         CONNMAN_SERVICE_STATE_IDLE);
521         }
522
523         return 0;
524 }
525
526 int connman_provider_set_state(struct connman_provider *provider,
527                                         enum connman_provider_state state)
528 {
529         if (provider == NULL || provider->vpn_service == NULL)
530                 return -EINVAL;
531
532         switch (state) {
533         case CONNMAN_PROVIDER_STATE_UNKNOWN:
534                 return -EINVAL;
535         case CONNMAN_PROVIDER_STATE_IDLE:
536                 return set_connected(provider, FALSE);
537         case CONNMAN_PROVIDER_STATE_CONNECT:
538                 return provider_indicate_state(provider,
539                                         CONNMAN_SERVICE_STATE_ASSOCIATION);
540         case CONNMAN_PROVIDER_STATE_READY:
541                 return set_connected(provider, TRUE);
542         case CONNMAN_PROVIDER_STATE_DISCONNECT:
543                 return provider_indicate_state(provider,
544                                         CONNMAN_SERVICE_STATE_DISCONNECT);
545         case CONNMAN_PROVIDER_STATE_FAILURE:
546                 return provider_indicate_state(provider,
547                                         CONNMAN_SERVICE_STATE_FAILURE);
548         }
549
550         return -EINVAL;
551 }
552
553 int connman_provider_indicate_error(struct connman_provider *provider,
554                                         enum connman_provider_error error)
555 {
556         enum connman_service_error service_error;
557
558         switch (error) {
559         case CONNMAN_PROVIDER_ERROR_LOGIN_FAILED:
560                 service_error = CONNMAN_SERVICE_ERROR_LOGIN_FAILED;
561                 break;
562         case CONNMAN_PROVIDER_ERROR_AUTH_FAILED:
563                 service_error = CONNMAN_SERVICE_ERROR_AUTH_FAILED;
564                 break;
565         case CONNMAN_PROVIDER_ERROR_CONNECT_FAILED:
566                 service_error = CONNMAN_SERVICE_ERROR_CONNECT_FAILED;
567                 break;
568         default:
569                 service_error = CONNMAN_SERVICE_ERROR_UNKNOWN;
570                 break;
571         }
572
573         return __connman_service_indicate_error(provider->vpn_service,
574                                                         service_error);
575 }
576
577 static void unregister_provider(gpointer data)
578 {
579         struct connman_provider *provider = data;
580
581         DBG("provider %p service %p", provider, provider->vpn_service);
582
583         if (provider->vpn_service != NULL) {
584                 connman_service_unref(provider->vpn_service);
585                 provider->vpn_service = NULL;
586         }
587
588         connman_provider_unref(provider);
589 }
590
591 static void destroy_route(gpointer user_data)
592 {
593         struct connman_route *route = user_data;
594
595         g_free(route->host);
596         g_free(route->netmask);
597         g_free(route->gateway);
598         g_free(route);
599 }
600
601 static void provider_initialize(struct connman_provider *provider)
602 {
603         DBG("provider %p", provider);
604
605         provider->index = 0;
606         provider->name = NULL;
607         provider->type = NULL;
608         provider->domain = NULL;
609         provider->identifier = NULL;
610         provider->user_networks = NULL;
611         provider->routes = g_hash_table_new_full(g_direct_hash, g_direct_equal,
612                                         NULL, destroy_route);
613         provider->user_routes = g_hash_table_new_full(g_str_hash, g_str_equal,
614                                         g_free, destroy_route);
615         provider->setting_strings = g_hash_table_new_full(g_str_hash, g_str_equal,
616                                                         g_free, g_free);
617 }
618
619 static struct connman_provider *connman_provider_new(void)
620 {
621         struct connman_provider *provider;
622
623         provider = g_try_new0(struct connman_provider, 1);
624         if (provider == NULL)
625                 return NULL;
626
627         provider->refcount = 1;
628
629         DBG("provider %p", provider);
630         provider_initialize(provider);
631
632         return provider;
633 }
634
635 static struct connman_provider *connman_provider_get(const char *identifier)
636 {
637         struct connman_provider *provider;
638
639         provider = g_hash_table_lookup(provider_hash, identifier);
640         if (provider != NULL)
641                 return provider;
642
643         provider = connman_provider_new();
644         if (provider == NULL)
645                 return NULL;
646
647         DBG("provider %p", provider);
648
649         provider->identifier = g_strdup(identifier);
650
651         g_hash_table_insert(provider_hash, provider->identifier, provider);
652
653         return provider;
654 }
655
656 static void provider_dbus_ident(char *ident)
657 {
658         int i, len = strlen(ident);
659
660         for (i = 0; i < len; i++) {
661                 if (ident[i] >= '0' && ident[i] <= '9')
662                         continue;
663                 if (ident[i] >= 'a' && ident[i] <= 'z')
664                         continue;
665                 if (ident[i] >= 'A' && ident[i] <= 'Z')
666                         continue;
667                 ident[i] = '_';
668         }
669 }
670
671 static struct connman_provider *provider_create_from_keyfile(GKeyFile *keyfile,
672                 const char *ident)
673 {
674         struct connman_provider *provider;
675
676         if (keyfile == NULL || ident == NULL)
677                 return NULL;
678
679         provider = connman_provider_lookup(ident);
680         if (provider == NULL) {
681                 provider = connman_provider_get(ident);
682                 if (provider == NULL) {
683                         DBG("can not create provider");
684                         return NULL;
685                 }
686
687                 provider_load_from_keyfile(provider, keyfile);
688
689                 if (provider->name == NULL || provider->host == NULL ||
690                                 provider->domain == NULL) {
691                         DBG("cannot get name, host or domain");
692                         connman_provider_unref(provider);
693                         return NULL;
694                 }
695
696                 provider_register(provider);
697         }
698         return provider;
699 }
700
701 static int provider_create_service(struct connman_provider *provider)
702 {
703         if (provider->vpn_service != NULL)
704                 return -EALREADY;
705
706         provider->vpn_service =
707                 __connman_service_create_from_provider(provider);
708
709         if (provider->vpn_service == NULL)
710                 return -EOPNOTSUPP;
711
712         return 0;
713 }
714
715 static void provider_create_all_from_type(const char *provider_type)
716 {
717         unsigned int i;
718         char **providers;
719         char *id, *type;
720         GKeyFile *keyfile;
721         struct connman_provider *provider;
722
723         DBG("provider type %s", provider_type);
724
725         providers = __connman_storage_get_providers();
726
727         for (i = 0; providers[i] != NULL; i+=1) {
728
729                 if (strncmp(providers[i], "provider_", 9) != 0)
730                         continue;
731
732                 id = providers[i] + 9;
733                 keyfile = __connman_storage_load_provider(id);
734
735                 if (keyfile == NULL)
736                         continue;
737
738                 type = g_key_file_get_string(keyfile, id, "Type", NULL);
739
740                 DBG("keyfile %p id %s type %s", keyfile, id, type);
741
742                 if (strcmp(provider_type, type) != 0) {
743                         g_free(type);
744                         g_key_file_free(keyfile);
745                         continue;
746                 }
747
748                 provider = provider_create_from_keyfile(keyfile, id);
749                 if (provider != NULL) {
750                         if (provider_create_service(provider) == -EOPNOTSUPP) {
751                                 DBG("could not create service");
752                                 connman_provider_unref(provider);
753                         }
754                 }
755
756                 g_free(type);
757                 g_key_file_free(keyfile);
758         }
759         g_strfreev(providers);
760 }
761
762 static char **get_user_networks(DBusMessageIter *array, int *count)
763 {
764         DBusMessageIter entry;
765         char **networks = NULL;
766         GSList *list = NULL, *l;
767         int len;
768
769         dbus_message_iter_recurse(array, &entry);
770
771         while (dbus_message_iter_get_arg_type(&entry) == DBUS_TYPE_STRING) {
772                 const char *val;
773                 dbus_message_iter_get_basic(&entry, &val);
774
775                 list = g_slist_prepend(list, g_strdup(val));
776                 dbus_message_iter_next(&entry);
777         }
778
779         len = g_slist_length(list);
780         if (len == 0)
781                 goto out;
782
783         networks = g_try_new(char *, len + 1);
784         if (networks == NULL)
785                 goto out;
786
787         *count = len;
788         networks[len] = 0;
789
790         for (l = list; l != NULL; l = g_slist_next(l))
791                 networks[--len] = l->data;
792
793 out:
794         g_slist_free(list);
795
796         return networks;
797 }
798
799 int __connman_provider_create_and_connect(DBusMessage *msg)
800 {
801         struct connman_provider *provider;
802         DBusMessageIter iter, array;
803         const char *type = NULL, *name = NULL, *service_path;
804         const char *host = NULL, *domain = NULL;
805         char **networks = NULL;
806         char *ident;
807         int err, count = 0;
808
809         dbus_message_iter_init(msg, &iter);
810         dbus_message_iter_recurse(&iter, &array);
811
812         while (dbus_message_iter_get_arg_type(&array) == DBUS_TYPE_DICT_ENTRY) {
813                 DBusMessageIter entry, value;
814                 const char *key;
815
816                 dbus_message_iter_recurse(&array, &entry);
817                 dbus_message_iter_get_basic(&entry, &key);
818
819                 dbus_message_iter_next(&entry);
820                 dbus_message_iter_recurse(&entry, &value);
821
822                 switch (dbus_message_iter_get_arg_type(&value)) {
823                 case DBUS_TYPE_STRING:
824                         if (g_str_equal(key, "Type") == TRUE)
825                                 dbus_message_iter_get_basic(&value, &type);
826                         else if (g_str_equal(key, "Name") == TRUE)
827                                 dbus_message_iter_get_basic(&value, &name);
828                         else if (g_str_equal(key, "Host") == TRUE)
829                                 dbus_message_iter_get_basic(&value, &host);
830                         else if (g_str_equal(key, "VPN.Domain") == TRUE)
831                                 dbus_message_iter_get_basic(&value, &domain);
832                         break;
833                 case DBUS_TYPE_ARRAY:
834                         if (g_str_equal(key, "Networks") == TRUE)
835                                 networks = get_user_networks(&value, &count);
836                         break;
837                 }
838
839                 dbus_message_iter_next(&array);
840         }
841
842         if (host == NULL || domain == NULL)
843                 return -EINVAL;
844
845         DBG("Type %s name %s networks %p", type, name, networks);
846
847         if (type == NULL || name == NULL)
848                 return -EOPNOTSUPP;
849
850         ident = g_strdup_printf("%s_%s", host, domain);
851         provider_dbus_ident(ident);
852
853         DBG("ident %s", ident);
854
855         provider = connman_provider_lookup(ident);
856         if (provider == NULL) {
857                 provider = connman_provider_get(ident);
858                 if (provider == NULL) {
859                         DBG("can not create provider");
860                         g_free(ident);
861                         return -EOPNOTSUPP;
862                 }
863
864                 provider->host = g_strdup(host);
865                 provider->domain = g_strdup(domain);
866                 provider->name = g_strdup(name);
867                 provider->type = g_strdup(type);
868
869                 if (provider_register(provider) == 0)
870                         connman_provider_load(provider);
871         }
872
873         if (networks != NULL) {
874                 g_strfreev(provider->user_networks);
875                 provider->user_networks = networks;
876                 provider->num_user_networks = count;
877                 set_user_networks(provider, provider->user_networks);
878         }
879
880         dbus_message_iter_init(msg, &iter);
881         dbus_message_iter_recurse(&iter, &array);
882
883         while (dbus_message_iter_get_arg_type(&array) == DBUS_TYPE_DICT_ENTRY) {
884                 DBusMessageIter entry, value;
885                 const char *key, *str;
886
887                 dbus_message_iter_recurse(&array, &entry);
888                 dbus_message_iter_get_basic(&entry, &key);
889
890                 dbus_message_iter_next(&entry);
891                 dbus_message_iter_recurse(&entry, &value);
892
893                 switch (dbus_message_iter_get_arg_type(&value)) {
894                 case DBUS_TYPE_STRING:
895                         dbus_message_iter_get_basic(&value, &str);
896                         connman_provider_set_string(provider, key, str);
897                         break;
898                 }
899
900                 dbus_message_iter_next(&array);
901         }
902
903         g_free(ident);
904
905         err = provider_create_service(provider);
906         if (err == -EALREADY) {
907                 DBG("provider already connected");
908         } else {
909                 if (err == -EOPNOTSUPP) {
910                         goto unref;
911                 } else {
912                         err = __connman_service_connect(provider->vpn_service);
913
914                         if (err < 0 && err != -EINPROGRESS)
915                                 goto failed;
916                 }
917         }
918
919         connman_provider_save(provider);
920         service_path = __connman_service_get_path(provider->vpn_service);
921         g_dbus_send_reply(connection, msg,
922                                 DBUS_TYPE_OBJECT_PATH, &service_path,
923                                                         DBUS_TYPE_INVALID);
924         return 0;
925
926 failed:
927         connman_service_unref(provider->vpn_service);
928         provider->vpn_service = NULL;
929
930 unref:
931         DBG("can not connect, delete provider");
932
933         g_hash_table_remove(provider_hash, provider->identifier);
934
935         return err;
936 }
937
938 const char * __connman_provider_get_ident(struct connman_provider *provider)
939 {
940         if (provider == NULL)
941                 return NULL;
942
943         return provider->identifier;
944 }
945
946 int connman_provider_set_string(struct connman_provider *provider,
947                                         const char *key, const char *value)
948 {
949         DBG("provider %p key %s value %s", provider, key, value);
950
951         if (g_str_equal(key, "Type") == TRUE) {
952                 g_free(provider->type);
953                 provider->type = g_strdup(value);
954         } else if (g_str_equal(key, "Name") == TRUE) {
955                 g_free(provider->name);
956                 provider->name = g_strdup(value);
957         } else if (g_str_equal(key, "Host") == TRUE) {
958                 g_free(provider->host);
959                 provider->host = g_strdup(value);
960         } else if (g_str_equal(key, "VPN.Domain") == TRUE) {
961                 g_free(provider->domain);
962                 provider->domain = g_strdup(value);
963         } else
964                 g_hash_table_replace(provider->setting_strings,
965                                 g_strdup(key), g_strdup(value));
966         return 0;
967 }
968
969 const char *connman_provider_get_string(struct connman_provider *provider,
970                                                         const char *key)
971 {
972         DBG("provider %p key %s", provider, key);
973
974         if (g_str_equal(key, "Type") == TRUE)
975                 return provider->type;
976         else if (g_str_equal(key, "Name") == TRUE)
977                 return provider->name;
978         else if (g_str_equal(key, "Host") == TRUE)
979                 return provider->host;
980         else if (g_str_equal(key, "VPN.Domain") == TRUE)
981                 return provider->domain;
982
983         return g_hash_table_lookup(provider->setting_strings, key);
984 }
985
986 connman_bool_t
987 __connman_provider_check_routes(struct connman_provider *provider)
988 {
989         if (provider == NULL)
990                 return FALSE;
991
992         if (provider->user_routes != NULL &&
993                         g_hash_table_size(provider->user_routes) > 0)
994                 return TRUE;
995
996         if (provider->routes != NULL &&
997                         g_hash_table_size(provider->routes) > 0)
998                 return TRUE;
999
1000         return FALSE;
1001 }
1002
1003 void *connman_provider_get_data(struct connman_provider *provider)
1004 {
1005         return provider->driver_data;
1006 }
1007
1008 void connman_provider_set_data(struct connman_provider *provider, void *data)
1009 {
1010         provider->driver_data = data;
1011 }
1012
1013 void connman_provider_set_index(struct connman_provider *provider, int index)
1014 {
1015         struct connman_service *service = provider->vpn_service;
1016         struct connman_ipconfig *ipconfig;
1017
1018         DBG("");
1019
1020         if (service == NULL)
1021                 return;
1022
1023         ipconfig = __connman_service_get_ip4config(service);
1024
1025         if (ipconfig == NULL) {
1026                 __connman_service_create_ip4config(service, index);
1027
1028                 ipconfig = __connman_service_get_ip4config(service);
1029                 if (ipconfig == NULL) {
1030                         DBG("Couldnt create ipconfig");
1031                         goto done;
1032                 }
1033         }
1034
1035         __connman_ipconfig_set_method(ipconfig, CONNMAN_IPCONFIG_METHOD_FIXED);
1036         __connman_ipconfig_set_index(ipconfig, index);
1037
1038
1039         ipconfig = __connman_service_get_ip6config(service);
1040
1041         if (ipconfig == NULL) {
1042                 __connman_service_create_ip6config(service, index);
1043
1044                 ipconfig = __connman_service_get_ip6config(service);
1045                 if (ipconfig == NULL) {
1046                         DBG("Couldnt create ipconfig for IPv6");
1047                         goto done;
1048                 }
1049         }
1050
1051         __connman_ipconfig_set_method(ipconfig, CONNMAN_IPCONFIG_METHOD_OFF);
1052         __connman_ipconfig_set_index(ipconfig, index);
1053
1054 done:
1055         provider->index = index;
1056 }
1057
1058 int connman_provider_get_index(struct connman_provider *provider)
1059 {
1060         return provider->index;
1061 }
1062
1063 int connman_provider_set_ipaddress(struct connman_provider *provider,
1064                                         struct connman_ipaddress *ipaddress)
1065 {
1066         struct connman_ipconfig *ipconfig = NULL;
1067
1068         ipconfig = __connman_service_get_ipconfig(provider->vpn_service,
1069                                                         ipaddress->family);
1070         if (ipconfig == NULL)
1071                 return -EINVAL;
1072
1073         provider->family = ipaddress->family;
1074
1075         __connman_ipconfig_set_local(ipconfig, ipaddress->local);
1076         __connman_ipconfig_set_peer(ipconfig, ipaddress->peer);
1077         __connman_ipconfig_set_broadcast(ipconfig, ipaddress->broadcast);
1078         __connman_ipconfig_set_gateway(ipconfig, ipaddress->gateway);
1079         __connman_ipconfig_set_prefixlen(ipconfig, ipaddress->prefixlen);
1080
1081         return 0;
1082 }
1083
1084 int connman_provider_set_pac(struct connman_provider *provider, const char *pac)
1085 {
1086         DBG("provider %p pac %s", provider, pac);
1087
1088         __connman_service_set_pac(provider->vpn_service, pac);
1089
1090         return 0;
1091 }
1092
1093
1094 int connman_provider_set_domain(struct connman_provider *provider,
1095                                         const char *domain)
1096 {
1097         DBG("provider %p domain %s", provider, domain);
1098
1099         g_free(provider->domain);
1100         provider->domain = g_strdup(domain);
1101
1102         __connman_service_set_domainname(provider->vpn_service, domain);
1103
1104         return 0;
1105 }
1106
1107 int connman_provider_set_nameservers(struct connman_provider *provider,
1108                                         const char *nameservers)
1109 {
1110         int i;
1111         char **nameservers_array = NULL;
1112
1113         DBG("provider %p nameservers %s", provider, nameservers);
1114
1115         __connman_service_nameserver_clear(provider->vpn_service);
1116
1117         if (nameservers == NULL)
1118                 return 0;
1119
1120         nameservers_array = g_strsplit(nameservers, " ", 0);
1121
1122         for (i = 0; nameservers_array[i] != NULL; i++) {
1123                 __connman_service_nameserver_append(provider->vpn_service,
1124                                                 nameservers_array[i], FALSE);
1125         }
1126
1127         g_strfreev(nameservers_array);
1128
1129         return 0;
1130 }
1131
1132 enum provider_route_type {
1133         PROVIDER_ROUTE_TYPE_NONE = 0,
1134         PROVIDER_ROUTE_TYPE_MASK = 1,
1135         PROVIDER_ROUTE_TYPE_ADDR = 2,
1136         PROVIDER_ROUTE_TYPE_GW   = 3,
1137 };
1138
1139 static int route_env_parse(struct connman_provider *provider, const char *key,
1140                                 int *family, unsigned long *idx,
1141                                 enum provider_route_type *type)
1142 {
1143         char *end;
1144         const char *start;
1145
1146         DBG("name %s", provider->name);
1147
1148         if (!strcmp(provider->type, "openvpn")) {
1149                 if (g_str_has_prefix(key, "route_network_") == TRUE) {
1150                         start = key + strlen("route_network_");
1151                         *type = PROVIDER_ROUTE_TYPE_ADDR;
1152                 } else if (g_str_has_prefix(key, "route_netmask_") == TRUE) {
1153                         start = key + strlen("route_netmask_");
1154                         *type = PROVIDER_ROUTE_TYPE_MASK;
1155                 } else if (g_str_has_prefix(key, "route_gateway_") == TRUE) {
1156                         start = key + strlen("route_gateway_");
1157                         *type = PROVIDER_ROUTE_TYPE_GW;
1158                 } else
1159                         return -EINVAL;
1160
1161                 *family = AF_INET;
1162                 *idx = g_ascii_strtoull(start, &end, 10);
1163
1164         } else if (!strcmp(provider->type, "openconnect")) {
1165                 if (g_str_has_prefix(key, "CISCO_SPLIT_INC_") == TRUE) {
1166                         *family = AF_INET;
1167                         start = key + strlen("CISCO_SPLIT_INC_");
1168                 } else if (g_str_has_prefix(key, "CISCO_IPV6_SPLIT_INC_") == TRUE) {
1169                         *family = AF_INET6;
1170                         start = key + strlen("CISCO_IPV6_SPLIT_INC_");
1171                 } else
1172                         return -EINVAL;
1173
1174                 *idx = g_ascii_strtoull(start, &end, 10);
1175
1176                 if (strncmp(end, "_ADDR", 5) == 0)
1177                         *type = PROVIDER_ROUTE_TYPE_ADDR;
1178                 else if (strncmp(end, "_MASK", 5) == 0)
1179                         *type = PROVIDER_ROUTE_TYPE_MASK;
1180                 else if (strncmp(end, "_MASKLEN", 8) == 0 &&
1181                                 *family == AF_INET6) {
1182                         *type = PROVIDER_ROUTE_TYPE_MASK;
1183                 } else
1184                         return -EINVAL;
1185         }
1186
1187         return 0;
1188 }
1189
1190 int connman_provider_append_route(struct connman_provider *provider,
1191                                         const char *key, const char *value)
1192 {
1193         struct connman_route *route;
1194         int ret, family = 0;
1195         unsigned long idx = 0;
1196         enum provider_route_type type = PROVIDER_ROUTE_TYPE_NONE;
1197
1198         DBG("key %s value %s", key, value);
1199
1200         ret = route_env_parse(provider, key, &family, &idx, &type);
1201         if (ret < 0)
1202                 return ret;
1203
1204         DBG("idx %lu family %d type %d", idx, family, type);
1205
1206         route = g_hash_table_lookup(provider->routes, GINT_TO_POINTER(idx));
1207         if (route == NULL) {
1208                 route = g_try_new0(struct connman_route, 1);
1209                 if (route == NULL) {
1210                         connman_error("out of memory");
1211                         return -ENOMEM;
1212                 }
1213
1214                 route->family = family;
1215
1216                 g_hash_table_replace(provider->routes, GINT_TO_POINTER(idx),
1217                                                 route);
1218         }
1219
1220         switch (type) {
1221         case PROVIDER_ROUTE_TYPE_NONE:
1222                 break;
1223         case PROVIDER_ROUTE_TYPE_MASK:
1224                 route->netmask = g_strdup(value);
1225                 break;
1226         case PROVIDER_ROUTE_TYPE_ADDR:
1227                 route->host = g_strdup(value);
1228                 break;
1229         case PROVIDER_ROUTE_TYPE_GW:
1230                 route->gateway = g_strdup(value);
1231                 break;
1232         }
1233
1234         return 0;
1235 }
1236
1237 const char *connman_provider_get_driver_name(struct connman_provider *provider)
1238 {
1239         if (provider->driver == NULL)
1240                 return NULL;
1241
1242         return provider->driver->name;
1243 }
1244
1245 const char *connman_provider_get_save_group(struct connman_provider *provider)
1246 {
1247         return provider->identifier;
1248 }
1249
1250 static gint compare_priority(gconstpointer a, gconstpointer b)
1251 {
1252         return 0;
1253 }
1254
1255 static void clean_provider(gpointer key, gpointer value, gpointer user_data)
1256 {
1257         struct connman_provider *provider = value;
1258
1259         if (provider->driver != NULL && provider->driver->remove)
1260                 provider->driver->remove(provider);
1261 }
1262
1263 int connman_provider_driver_register(struct connman_provider_driver *driver)
1264 {
1265         DBG("driver %p name %s", driver, driver->name);
1266
1267         driver_list = g_slist_insert_sorted(driver_list, driver,
1268                                                         compare_priority);
1269         provider_create_all_from_type(driver->name);
1270         return 0;
1271 }
1272
1273 void connman_provider_driver_unregister(struct connman_provider_driver *driver)
1274 {
1275         DBG("driver %p name %s", driver, driver->name);
1276
1277         driver_list = g_slist_remove(driver_list, driver);
1278 }
1279
1280 static void provider_remove_all(gpointer key, gpointer value,
1281                                                 gpointer user_data)
1282 {
1283         struct connman_provider *provider = value;
1284
1285         __connman_provider_remove(provider->identifier);
1286 }
1287
1288 static void provider_offline_mode(connman_bool_t enabled)
1289 {
1290         DBG("enabled %d", enabled);
1291
1292         if (enabled == TRUE)
1293                 g_hash_table_foreach(provider_hash, provider_remove_all, NULL);
1294
1295 }
1296
1297 static struct connman_provider *provider_get(int index)
1298 {
1299         GHashTableIter iter;
1300         gpointer value, key;
1301
1302         g_hash_table_iter_init(&iter, provider_hash);
1303
1304         while (g_hash_table_iter_next(&iter, &key, &value) == TRUE) {
1305                 struct connman_provider *provider = value;
1306
1307                 if (provider->index == index)
1308                         return provider;
1309         }
1310
1311         return NULL;
1312 }
1313
1314 static void provider_service_changed(struct connman_service *service,
1315                                 enum connman_service_state state)
1316 {
1317         struct connman_provider *provider;
1318         int vpn_index, service_index;
1319
1320         if (service == NULL)
1321                 return;
1322
1323         switch (state) {
1324         case CONNMAN_SERVICE_STATE_UNKNOWN:
1325         case CONNMAN_SERVICE_STATE_IDLE:
1326         case CONNMAN_SERVICE_STATE_ASSOCIATION:
1327         case CONNMAN_SERVICE_STATE_CONFIGURATION:
1328         case CONNMAN_SERVICE_STATE_READY:
1329         case CONNMAN_SERVICE_STATE_ONLINE:
1330                 return;
1331         case CONNMAN_SERVICE_STATE_DISCONNECT:
1332         case CONNMAN_SERVICE_STATE_FAILURE:
1333                 break;
1334         }
1335
1336         service_index = __connman_service_get_index(service);
1337
1338         vpn_index = __connman_connection_get_vpn_index(service_index);
1339
1340         DBG("service %p %s state %d index %d/%d", service,
1341                 __connman_service_get_ident(service),
1342                 state, service_index, vpn_index);
1343
1344         if (vpn_index < 0)
1345                 return;
1346
1347         provider = provider_get(vpn_index);
1348         if (provider == NULL)
1349                 return;
1350
1351         DBG("disconnect %p index %d", provider, vpn_index);
1352
1353         __connman_provider_disconnect(provider);
1354
1355         return;
1356 }
1357
1358 static struct connman_notifier provider_notifier = {
1359         .name                   = "provider",
1360         .offline_mode           = provider_offline_mode,
1361         .service_state_changed  = provider_service_changed,
1362 };
1363
1364 int __connman_provider_init(void)
1365 {
1366         int err;
1367
1368         DBG("");
1369
1370         connection = connman_dbus_get_connection();
1371
1372         provider_hash = g_hash_table_new_full(g_str_hash, g_str_equal,
1373                                                 NULL, unregister_provider);
1374
1375         err = connman_notifier_register(&provider_notifier);
1376         if (err < 0) {
1377                 g_hash_table_destroy(provider_hash);
1378                 dbus_connection_unref(connection);
1379         }
1380
1381         return err;
1382 }
1383
1384 void __connman_provider_cleanup(void)
1385 {
1386         DBG("");
1387
1388         connman_notifier_unregister(&provider_notifier);
1389
1390         g_hash_table_foreach(provider_hash, clean_provider, NULL);
1391
1392         g_hash_table_destroy(provider_hash);
1393         provider_hash = NULL;
1394
1395         dbus_connection_unref(connection);
1396 }