[RFC 1/1] GPRS Provisioning Plugin.

--- plugins/gprs-provision.c | 290 ++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 290 insertions(+), 0 deletions(-) create mode 100644 plugins/gprs-provision.c diff --git a/plugins/gprs-provision.c b/plugins/gprs-provision.c new file mode 100644 index 0000000..015ea7e --- /dev/null +++ b/plugins/gprs-provision.c @@ -0,0 +1,290 @@ +/* + * + * oFono - Open Source Telephony + * + * Copyright (C) 2008-2011 Intel Corporation. All rights reserved. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation. + * + * 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 St, Fifth Floor, Boston, MA 02110-1301 USA + * + */ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <sys/stat.h> +#include <sys/mman.h> + +#include <errno.h> +#include <fcntl.h> +#include <stdlib.h> +#include <string.h> +#include <unistd.h> + +#include <glib.h> + +#define OFONO_API_SUBJECT_TO_CHANGE +#include <ofono/types.h> +#include <ofono/log.h> +#include <ofono/plugin.h> +#include <ofono/modem.h> +#include <ofono/gprs-provision.h> + +#define PROVISION_SETTINGS_MAX 10 + +struct parser_data { + struct ofono_gprs_provision_data *settings[PROVISION_SETTINGS_MAX]; + struct ofono_gprs_provision_data *current; + int count; + const char *match_mcc; + const char *match_mnc; + const char *name; + const char *current_element; + gboolean match_found; +}; + +static void parse_element_start(GMarkupParseContext *context, + const gchar *element_name, + const gchar **attribute_names, + const gchar **attribute_values, + gpointer user_data, GError **error) +{ + struct parser_data *data = user_data; + + if (g_str_equal(element_name, "name") == TRUE) { + data->current_element = element_name; + return; + } + + if (g_str_equal(element_name, "network-id") == TRUE) { + const char *mcc = NULL, *mnc = NULL; + int i; + + for (i = 0; attribute_names[i]; i++) { + if (g_str_equal(attribute_names[i], "mcc") == TRUE) + mcc = attribute_values[i]; + if (g_str_equal(attribute_names[i], "mnc") == TRUE) + mnc = attribute_values[i]; + } + + if (g_strcmp0(mcc, data->match_mcc) == 0 && + g_strcmp0(mnc, data->match_mnc) == 0) + data->match_found = TRUE; + } + + if (data->match_found == FALSE) + return; + + data->current_element = element_name; + + if (g_str_equal(element_name, "apn") == TRUE) { + const char *apn = NULL; + int i; + + for (i = 0; attribute_names[i]; i++) { + if (g_str_equal(attribute_names[i], "value") == TRUE) + apn = attribute_values[i]; + } + + if (data->count >= PROVISION_SETTINGS_MAX) { + data->match_found = FALSE; + return; + } + + data->current = g_try_new0(struct ofono_gprs_provision_data, 1); + if (data->current == NULL) + return; + + data->settings[data->count++] = data->current; + + if (data->current->apn == NULL) + data->current->apn = g_strdup(apn); + + if (data->current->name == NULL) + data->current->name = g_strdup(data->name); + } +} + +static void parse_element_end(GMarkupParseContext *context, + const gchar *element_name, + gpointer user_data, GError **error) +{ + struct parser_data *data = user_data; + + if (g_str_equal(element_name, "gsm") == TRUE || + g_str_equal(element_name, "cdma") == TRUE) { + data->match_found = FALSE; + g_free((gpointer)data->name); + data->name = NULL; + } +} + +static void parse_text(GMarkupParseContext *context, + const gchar *text, gsize text_len, + gpointer user_data, GError **error) +{ + struct parser_data *data = user_data; + + if (g_strcmp0(data->current_element, "name") == 0) { + data->name = g_strndup(text, text_len); + return; + } + + if (data->match_found == FALSE || + (data->current && data->current->apn == NULL)) + return; + + if (g_strcmp0(data->current_element, "username") == 0) + data->current->username = g_strndup(text, text_len); + else if (g_strcmp0(data->current_element, "password") == 0) + data->current->password = g_strndup(text, text_len); +} + +static void parser_error(GMarkupParseContext *context, + GError *error, gpointer user_data) +{ + ofono_error("Error parsing %s: %s", PROVIDER_DATABASE, error->message); +} + +static const GMarkupParser parser = { + parse_element_start, + parse_element_end, + parse_text, + NULL, + parser_error, +}; + +static void parse_database(const char *data, ssize_t size, + struct parser_data *parser_data) +{ + GMarkupParseContext *context; + gboolean result; + + parser_data->match_found = FALSE; + + context = g_markup_parse_context_new(&parser, + G_MARKUP_TREAT_CDATA_AS_TEXT, + parser_data, NULL); + + result = g_markup_parse_context_parse(context, data, size, NULL); + if (result == TRUE) + result = g_markup_parse_context_end_parse(context, NULL); + + g_markup_parse_context_free(context); +} + +static int lookup_apn(const char *mcc, const char *mnc, const char *spn, + struct parser_data *data) +{ + struct stat st; + char *map; + int fd; + + if (mcc == NULL || mnc == NULL) + return -1; + + fd = open(PROVIDER_DATABASE, O_RDONLY); + if (fd < 0) + return -1; + + if (fstat(fd, &st) < 0) { + close(fd); + return -1; + } + + map = mmap(NULL, st.st_size, PROT_READ, MAP_SHARED, fd, 0); + if (map == NULL || map == MAP_FAILED) { + close(fd); + return -1; + } + + data->match_mcc = mcc; + data->match_mnc = mnc; + + parse_database(map, st.st_size, data); + + munmap(map, st.st_size); + + close(fd); + + return 0; +} + +static int gprs_provision(const char *mcc, const char *mnc, + const char *spn, + struct ofono_gprs_provision_data **settings, + int *count) +{ + int i; + struct parser_data *data; + *settings = NULL; + + DBG("Provisioning for MCC %s, MNC %s, SPN '%s'", + mcc, mnc, spn); + + data = g_try_new0(struct parser_data, 1); + if (data == NULL) + return -ENOMEM; + + lookup_apn(mcc, mnc, NULL, data); + + *count = data->count; + + DBG("settings count: %d", *count); + + if (!*count) { + g_free(data); + return -ENOENT; + } + + *settings = g_try_new0(struct ofono_gprs_provision_data, *count); + if (*settings == NULL) + return -ENOMEM; + + for (i = 0; i < *count; i++) { + (*settings)[i] = *(data->settings[i]); + + (*settings)[i].proto = OFONO_GPRS_PROTO_IP; + (*settings)[i].type = OFONO_GPRS_CONTEXT_TYPE_INTERNET; + + DBG("Name: %s", (*settings)[i].name); + DBG("APN: %s", (*settings)[i].apn); + DBG("Username: %s", (*settings)[i].username); + DBG("Password: %s", (*settings)[i].password); + } + + g_free(data); + + return 0; +} + +static struct ofono_gprs_provision_driver grps_provision_driver = { + .name = "GPRS context provisioning", + .get_settings = gprs_provision +}; + +static int gprs_provision_init(void) +{ + return ofono_gprs_provision_driver_register(&grps_provision_driver); +} + +static void gprs_provision_exit(void) +{ + ofono_gprs_provision_driver_unregister(&grps_provision_driver); +} + +OFONO_PLUGIN_DEFINE(gprs_provision, "GPRS Provisioning Plugin", + VERSION, OFONO_PLUGIN_PRIORITY_DEFAULT, + gprs_provision_init, + gprs_provision_exit) -- 1.7.1 --------------------------------------------------------------------- Intel Finland Oy Registered Address: PL 281, 00181 Helsinki Business Identity Code: 0357606 - 4 Domiciled in Helsinki This e-mail and any attachments may contain confidential material for the sole use of the intended recipient(s). Any review or distribution by others is strictly prohibited. If you are not the intended recipient, please contact the sender and delete all copies.