diff --git a/obexd/plugins/phonebook-ebook.c b/obexd/plugins/phonebook-ebook.c
index 30be9d9..29ec9d2 100644
--- a/obexd/plugins/phonebook-ebook.c
+++ b/obexd/plugins/phonebook-ebook.c
*
* OBEX Server
*
- * Copyright (C) 2009-2010 Intel Corporation
- * Copyright (C) 2007-2010 Marcel Holtmann <marcel@holtmann.org>
+ * Copyright (C) 2009-2021 Intel Corporation
+ * Copyright (C) 2007-2021 Marcel Holtmann <marcel@holtmann.org>
+ * Copyright (C) 2021 Dylan Van Assche <me@dylanvanassche.be>
*
*
*/
#include <config.h>
#endif
-#include <string.h>
+#define _GNU_SOURCE
+#include <dirent.h>
#include <errno.h>
-
+#include <stdio.h>
+#include <stdint.h>
+#include <string.h>
#include <glib.h>
-#include <libebook/e-book.h>
-
-#include "lib/bluetooth.h"
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <libebook/libebook.h>
+#include <libedataserver/libedataserver.h>
#include "obexd/src/log.h"
-#include "obexd/src/obex.h"
-#include "obexd/src/service.h"
#include "phonebook.h"
-#define QUERY_FN "(contains \"family_name\" \"%s\")"
-#define QUERY_NAME "(contains \"given_name\" \"%s\")"
-#define QUERY_PHONE "(contains \"phone\" \"%s\")"
+#define CONNECTION_TIMEOUT 30 // seconds
+#define PB_FORMAT_VCARD21 0
+#define PB_FORMAT_VCARD30 1
+#define PB_FORMAT_NONE 2
+
+ESourceRegistry *registry;
+ESource *address_book;
+EBookClient *book_client;
struct query_context {
const struct apparam_field *params;
phonebook_cb contacts_cb;
phonebook_entry_cb entry_cb;
phonebook_cache_ready_cb ready_cb;
- EBookQuery *query;
+ gchar *query;
unsigned int count;
GString *buf;
- char *id;
+ char *uid;
unsigned queued_calls;
void *user_data;
- GSList *ebooks;
gboolean canceled;
};
"SORT-STRING",
/* 28 */ "X-IRMC-CALL-DATETIME",
NULL
-
};
-static void close_ebooks(GSList *ebooks)
-{
- g_slist_free_full(ebooks, g_object_unref);
-}
-
static void free_query_context(struct query_context *data)
{
- g_free(data->id);
+ g_free(data->uid);
if (data->buf != NULL)
g_string_free(data->buf, TRUE);
if (data->query != NULL)
- e_book_query_unref(data->query);
-
- close_ebooks(data->ebooks);
+ g_free(data->query);
g_free(data);
}
static char *evcard_to_string(EVCard *evcard, unsigned int format,
- uint64_t filter)
+ uint64_t filter)
{
EVCard *evcard2;
GList *l;
char *vcard;
if (!filter)
- return e_vcard_to_string(evcard, EVC_FORMAT_VCARD_30);
- /* XXX There is no support for VCARD 2.1 at this time */
+ return e_vcard_to_string(evcard, format);
/*
* Mandatory attributes for vCard 2.1 are VERSION ,N and TEL.
continue;
e_vcard_add_attribute(evcard2,
- e_vcard_attribute_copy(attrib));
+ e_vcard_attribute_copy(attrib));
}
}
return vcard;
}
-static void ebookpull_cb(EBook *book, const GError *gerr, GList *contacts,
- void *user_data)
+char *phonebook_set_folder(const char *current_folder, const char *new_folder,
+ uint8_t flags, int *err)
+{
+ gboolean root, child;
+ char *fullname = NULL, *tmp1, *tmp2, *base;
+ int ret = 0, len;
+
+ root = (g_strcmp0("/", current_folder) == 0);
+ child = (new_folder && strlen(new_folder) != 0);
+
+ /* Evolution back-end will support /telecom/pb folder only */
+ switch (flags) {
+ case 0x02:
+ /* Go back to root */
+ if (!child) {
+ fullname = g_strdup("/");
+ goto done;
+ }
+
+ /* Go down 1 level */
+ fullname = g_build_filename(current_folder, new_folder, NULL);
+ if (strcmp(PB_TELECOM_FOLDER, fullname) != 0 &&
+ strcmp(PB_CONTACTS_FOLDER, fullname) != 0) {
+ g_free(fullname);
+ fullname = NULL;
+ ret = -ENOENT;
+ }
+
+ break;
+ case 0x03:
+ /* Go up 1 level */
+ if (root) {
+ /* Already root */
+ ret = -EBADR;
+ goto done;
+ }
+
+ /*
+ * Removing one level of the current folder. Current folder
+ * contains AT LEAST one level since it is not at root folder.
+ * Use glib utility functions to handle invalid chars in the
+ * folder path properly.
+ */
+ tmp1 = g_path_get_basename(current_folder);
+ tmp2 = g_strrstr(current_folder, tmp1);
+ len = tmp2 - (current_folder + 1);
+
+ g_free(tmp1);
+
+ if (len == 0)
+ base = g_strdup("/");
+ else
+ base = g_strndup(current_folder, len);
+
+ /* Return one level only */
+ if (!child) {
+ fullname = base;
+ goto done;
+ }
+
+ fullname = g_build_filename(base, new_folder, NULL);
+ if (strcmp(fullname, PB_TELECOM_FOLDER) != 0 &&
+ strcmp(fullname, PB_CONTACTS_FOLDER) != 0) {
+ g_free(fullname);
+ fullname = NULL;
+ ret = -ENOENT;
+ }
+
+ g_free(base);
+
+ break;
+ default:
+ ret = -EBADR;
+ break;
+ }
+
+done:
+ if (err)
+ *err = ret;
+
+ return fullname;
+}
+
+void phonebook_req_finalize(void *request)
+{
+ /* Free resources after pull request */
+ struct query_context *data = request;
+
+ if (data->queued_calls == 0)
+ free_query_context(data);
+ else
+ data->canceled = TRUE;
+}
+
+void *phonebook_pull(const char *name, const struct apparam_field *params,
+ phonebook_cb cb, void *user_data, int *err)
+{
+ struct query_context *data;
+ EBookQuery *query;
+
+ /* Request should be for '/telecom/pb.vcf', reject others */
+ if (g_strcmp0(PB_CONTACTS, name) != 0) {
+ if (err)
+ *err = -ENOENT;
+ return NULL;
+ }
+
+ data = g_new0(struct query_context, 1);
+ data->contacts_cb = cb;
+ data->params = params;
+ data->user_data = user_data;
+ data->buf = g_string_new("");
+ query = e_book_query_any_field_contains(""); // all contacts
+ data->query = e_book_query_to_string(query);
+ e_book_query_unref(query);
+
+ return data;
+}
+
+static void phonebook_pull_read_ready(GObject *source_object,
+ GAsyncResult *result, gpointer user_data)
{
struct query_context *data = user_data;
- GList *l;
+ GSList *l = NULL;
+ GSList *contacts = NULL;
+ GError *gerr = NULL;
unsigned int count, maxcount;
+ /* Finish async call to retrieve contacts */
data->queued_calls--;
if (data->canceled)
goto canceled;
+ e_book_client_get_contacts_finish(E_BOOK_CLIENT(source_object),
+ result, &contacts, &gerr);
+
if (gerr != NULL) {
- error("E-Book query failed: %s", gerr->message);
+ error("Failed to retrieve contacts, invalid query");
+ g_error_free(gerr);
goto done;
}
- DBG("");
-
/*
* When MaxListCount is zero, PCE wants to know the number of used
* indexes in the phonebook of interest. All other parameters that
*/
maxcount = data->params->maxlistcount;
if (maxcount == 0) {
- data->count += g_list_length(contacts);
+ data->count += g_slist_length(contacts);
goto done;
}
- l = g_list_nth(contacts, data->params->liststartoffset);
-
- for (count = 0; l && count + data->count < maxcount; l = g_list_next(l),
- count++) {
+ /*
+ * Convert each contact to a vCard and append the card to
+ * the buffer string.
+ */
+ l = g_slist_nth(contacts, data->params->liststartoffset);
+ for (count = 0; l && count + data->count < maxcount;
+ l = g_slist_next(l), count++) {
EContact *contact = E_CONTACT(l->data);
EVCard *evcard = E_VCARD(contact);
char *vcard;
- vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_30,
- data->params->filter);
+ if (data->params->format == PB_FORMAT_VCARD30)
+ vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_30,
+ data->params->filter);
+ else if (data->params->format == PB_FORMAT_VCARD21)
+ vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_21,
+ data->params->filter);
+ else
+ error("unknown format: %d", data->params->format);
data->buf = g_string_append(data->buf, vcard);
data->buf = g_string_append(data->buf, "\r\n");
g_free(vcard);
}
- DBG("collected %d vcards", count);
+ DBG("collected %d contacts", count);
data->count += count;
-
- g_list_free_full(contacts, g_object_unref);
+ g_slist_free_full(contacts, (GDestroyNotify) g_object_unref);
done:
if (data->queued_calls == 0) {
GString *buf = data->buf;
data->buf = NULL;
- data->contacts_cb(buf->str, buf->len, data->count,
- 0, TRUE, data->user_data);
-
+ data->contacts_cb(buf->str, buf->len, data->count, 0, TRUE,
+ data->user_data);
g_string_free(buf, TRUE);
-
}
return;
free_query_context(data);
}
-static void ebook_entry_cb(EBook *book, const GError *gerr,
- EContact *contact, void *user_data)
+int phonebook_pull_read(void *request)
{
+ struct query_context *data = request;
+ GError *gerr = NULL;
+
+ if (!data) {
+ error("Request data is empty");
+ return -ENOENT;
+ }
+
+ DBG("retrieving all contacts");
+
+ /* Fetch async contacts from default address book */
+ e_book_client_get_contacts(book_client, data->query, NULL,
+ (GAsyncReadyCallback) phonebook_pull_read_ready, data);
+ data->queued_calls++;
+
+ return 0;
+}
+
+static void phonebook_get_entry_ready(GObject *source_object,
+ GAsyncResult *result, gpointer user_data)
+{
+ GError *gerr = NULL;
+ EContact *contact = NULL;
struct query_context *data = user_data;
EVCard *evcard;
char *vcard;
data->queued_calls--;
+ e_book_client_get_contact_finish(E_BOOK_CLIENT(source_object), result,
+ &contact, &gerr);
if (data->canceled)
goto done;
if (gerr != NULL) {
- error("E-Book query failed: %s", gerr->message);
+ error("Getting contact failed: %s", gerr->message);
+ g_error_free(gerr);
goto done;
}
- DBG("");
-
evcard = E_VCARD(contact);
- vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_30,
- data->params->filter);
+ if (data->params->format == PB_FORMAT_VCARD30)
+ vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_30,
+ data->params->filter);
+ else if (data->params->format == PB_FORMAT_VCARD21)
+ vcard = evcard_to_string(evcard, EVC_FORMAT_VCARD_21,
+ data->params->filter);
+ else
+ error("Unknown vCard format: %d", data->params->format);
len = vcard ? strlen(vcard) : 0;
data->contacts_cb(vcard, len, 1, 0, TRUE, data->user_data);
g_free(vcard);
- g_object_unref(contact);
- return;
+ DBG("retrieving entry successful");
done:
if (data->queued_calls == 0) {
if (data->count == 0)
data->contacts_cb(NULL, 0, 1, 0, TRUE,
- data->user_data);
+ data->user_data);
else if (data->canceled)
free_query_context(data);
}
+
+ g_object_unref(contact);
+}
+
+void *phonebook_get_entry(const char *folder, const char *id,
+ const struct apparam_field *params, phonebook_cb cb,
+ void *user_data, int *err)
+{
+ struct query_context *data;
+ GSList *l;
+
+ DBG("retrieving entry: %s", id);
+
+ data = g_new0(struct query_context, 1);
+ data->contacts_cb = cb;
+ data->params = params;
+ data->user_data = user_data;
+ data->uid = g_strdup(id);
+
+ /* Fetch async contacts from default address book */
+ e_book_client_get_contact(book_client, data->uid, NULL,
+ (GAsyncReadyCallback) phonebook_get_entry_ready, data);
+ data->queued_calls++;
+
+ if (err)
+ *err = (data->queued_calls == 0 ? -ENOENT : 0);
+
+ return data;
}
static char *evcard_name_attribute_to_string(EVCard *evcard)
return g_string_free(name, FALSE);
}
-static void cache_cb(EBook *book, const GError *gerr, GList *contacts,
- void *user_data)
+static void phonebook_create_cache_ready(GObject *source_object,
+ GAsyncResult *result, gpointer user_data)
{
struct query_context *data = user_data;
- GList *l;
+ GSList *l = NULL;
+ GSList *contacts = NULL;
+ GError *gerr = NULL;
data->queued_calls--;
if (data->canceled)
goto canceled;
+ e_book_client_get_contacts_finish(E_BOOK_CLIENT(source_object),
+ result, &contacts, &gerr);
+
if (gerr != NULL) {
- error("E-Book operation failed: %s", gerr->message);
+ error("Getting contacts failed: %s", gerr->message);
goto done;
}
- DBG("");
-
- for (l = contacts; l; l = g_list_next(l)) {
+ for (l = contacts; l; l = g_slist_next(l)) {
EContact *contact = E_CONTACT(l->data);
EVCard *evcard = E_VCARD(contact);
EVCardAttribute *attrib;
g_free(tel);
}
- g_list_free_full(contacts, g_object_unref);
+ DBG("caching successful");
+
+ g_slist_free_full(contacts, (GDestroyNotify) g_object_unref);
done:
if (data->queued_calls == 0)
free_query_context(data);
}
-static GSList *traverse_sources(GSList *ebooks, GSList *sources,
- char **default_src) {
- GError *gerr = NULL;
-
- for (; sources != NULL; sources = g_slist_next(sources)) {
- char *uri;
- ESource *source = E_SOURCE(sources->data);
- EBook *ebook = e_book_new(source, &gerr);
-
- if (ebook == NULL) {
- error("Can't create user's address book: %s",
- gerr->message);
- g_clear_error(&gerr);
- continue;
- }
-
- uri = e_source_get_uri(source);
- if (g_strcmp0(*default_src, uri) == 0) {
- g_free(uri);
- continue;
- }
- g_free(uri);
-
- if (e_book_open(ebook, FALSE, &gerr) == FALSE) {
- error("Can't open e-book address book: %s",
- gerr->message);
- g_object_unref(ebook);
- g_clear_error(&gerr);
- continue;
- }
-
- if (*default_src == NULL)
- *default_src = e_source_get_uri(source);
-
- DBG("%s address book opened", e_source_peek_name(source));
-
- ebooks = g_slist_append(ebooks, ebook);
- }
-
- return ebooks;
-}
-
-int phonebook_init(void)
-{
- g_type_init();
-
- return 0;
-}
-
-static GSList *open_ebooks(void)
-{
- GError *gerr = NULL;
- ESourceList *src_list;
- GSList *list;
- char *default_src = NULL;
- GSList *ebooks = NULL;
-
- if (e_book_get_addressbooks(&src_list, &gerr) == FALSE) {
- error("Can't list user's address books: %s", gerr->message);
- g_error_free(gerr);
- return NULL;
- }
-
- list = e_source_list_peek_groups(src_list);
- while (list != NULL) {
- ESourceGroup *group = E_SOURCE_GROUP(list->data);
- GSList *sources = e_source_group_peek_sources(group);
-
- ebooks = traverse_sources(ebooks, sources, &default_src);
-
- list = list->next;
- }
-
- g_free(default_src);
- g_object_unref(src_list);
-
- return ebooks;
-}
-
-void phonebook_exit(void)
-{
-}
-
-char *phonebook_set_folder(const char *current_folder,
- const char *new_folder, uint8_t flags, int *err)
-{
- gboolean root, child;
- char *fullname = NULL, *tmp1, *tmp2, *base;
- int ret = 0, len;
-
- root = (g_strcmp0("/", current_folder) == 0);
- child = (new_folder && strlen(new_folder) != 0);
-
- /* Evolution back-end will support /telecom/pb folder only */
-
- switch (flags) {
- case 0x02:
- /* Go back to root */
- if (!child) {
- fullname = g_strdup("/");
- goto done;
- }
-
- /* Go down 1 level */
- fullname = g_build_filename(current_folder, new_folder, NULL);
- if (strcmp(PB_TELECOM_FOLDER, fullname) != 0 &&
- strcmp(PB_CONTACTS_FOLDER, fullname) != 0) {
- g_free(fullname);
- fullname = NULL;
- ret = -ENOENT;
- }
-
- break;
- case 0x03:
- /* Go up 1 level */
- if (root) {
- /* Already root */
- ret = -EBADR;
- goto done;
- }
-
- /*
- * Removing one level of the current folder. Current folder
- * contains AT LEAST one level since it is not at root folder.
- * Use glib utility functions to handle invalid chars in the
- * folder path properly.
- */
- tmp1 = g_path_get_basename(current_folder);
- tmp2 = g_strrstr(current_folder, tmp1);
- len = tmp2 - (current_folder + 1);
-
- g_free(tmp1);
-
- if (len == 0)
- base = g_strdup("/");
- else
- base = g_strndup(current_folder, len);
-
- /* Return one level only */
- if (!child) {
- fullname = base;
- goto done;
- }
-
- fullname = g_build_filename(base, new_folder, NULL);
- if (strcmp(fullname, PB_TELECOM_FOLDER) != 0 &&
- strcmp(fullname, PB_CONTACTS_FOLDER) != 0) {
- g_free(fullname);
- fullname = NULL;
- ret = -ENOENT;
- }
-
- g_free(base);
-
- break;
- default:
- ret = -EBADR;
- break;
- }
-
-done:
- if (err)
- *err = ret;
-
- return fullname;
-}
-
-void phonebook_req_finalize(void *request)
-{
- struct query_context *data = request;
-
- if (data->queued_calls == 0)
- free_query_context(data);
- else
- data->canceled = TRUE;
-}
-
-void *phonebook_pull(const char *name, const struct apparam_field *params,
- phonebook_cb cb, void *user_data, int *err)
-{
- struct query_context *data;
-
- if (g_strcmp0(PB_CONTACTS, name) != 0) {
- if (err)
- *err = -ENOENT;
-
- return NULL;
- }
-
- data = g_new0(struct query_context, 1);
- data->contacts_cb = cb;
- data->params = params;
- data->user_data = user_data;
- data->buf = g_string_new("");
- data->query = e_book_query_any_field_contains("");
- data->ebooks = open_ebooks();
-
- if (err)
- *err = data->ebooks == NULL ? -EIO : 0;
-
- return data;
-}
-
-int phonebook_pull_read(void *request)
-{
- struct query_context *data = request;
- GSList *l;
-
- if (!data)
- return -ENOENT;
-
- for (l = data->ebooks; l != NULL; l = g_slist_next(l)) {
- EBook *ebook = l->data;
-
- if (e_book_is_opened(ebook) == FALSE)
- continue;
-
- if (e_book_get_contacts_async(ebook, data->query,
- ebookpull_cb, data) == TRUE)
- data->queued_calls++;
- }
-
- if (data->queued_calls == 0)
- return -ENOENT;
-
- return 0;
-}
-
-void *phonebook_get_entry(const char *folder, const char *id,
- const struct apparam_field *params,
- phonebook_cb cb, void *user_data, int *err)
-{
- struct query_context *data;
- GSList *l;
-
- data = g_new0(struct query_context, 1);
- data->contacts_cb = cb;
- data->params = params;
- data->user_data = user_data;
- data->id = g_strdup(id);
- data->ebooks = open_ebooks();
-
- for (l = data->ebooks; l != NULL; l = g_slist_next(l)) {
- EBook *ebook = l->data;
-
- if (e_book_is_opened(ebook) == FALSE)
- continue;
-
- if (e_book_get_contact_async(ebook, data->id,
- ebook_entry_cb, data) == TRUE)
- data->queued_calls++;
- }
-
- if (err)
- *err = (data->queued_calls == 0 ? -ENOENT : 0);
-
- return data;
-}
-
void *phonebook_create_cache(const char *name, phonebook_entry_cb entry_cb,
- phonebook_cache_ready_cb ready_cb, void *user_data, int *err)
+ phonebook_cache_ready_cb ready_cb, void *user_data, int *err)
{
+ /* Build a cache of contacts */
struct query_context *data;
EBookQuery *query;
- GSList *l;
EContact *me;
+ EBookClient *me_client;
EVCard *evcard;
GError *gerr = NULL;
- EBook *eb;
EVCardAttribute *attrib;
char *uid, *tel, *cname;
return NULL;
}
- DBG("");
-
- query = e_book_query_any_field_contains("");
+ DBG("creating cache");
data = g_new0(struct query_context, 1);
data->entry_cb = entry_cb;
data->ready_cb = ready_cb;
data->user_data = user_data;
- data->query = query;
- data->ebooks = open_ebooks();
+ query = e_book_query_any_field_contains(""); // all contacts
+ data->query = e_book_query_to_string(query);
+ e_book_query_unref(query);
- /* Add 0.vcf */
- if (e_book_get_self(&me, &eb, &gerr) == FALSE) {
+ /* Myself as contact should always be 0.vcf if found in address book */
+ if (!e_book_client_get_self(registry, &me, &me_client, &gerr)) {
+ DBG("owner is not in address book: %s", gerr->message);
g_error_free(gerr);
goto next;
}
+ DBG("caching address book owner");
+
evcard = E_VCARD(me);
cname = evcard_name_attribute_to_string(evcard);
tel = g_strdup("");
data->entry_cb(uid, 0, cname, NULL, tel, data->user_data);
-
data->count++;
g_free(cname);
g_free(uid);
g_free(tel);
- g_object_unref(eb);
next:
- for (l = data->ebooks; l != NULL; l = g_slist_next(l)) {
- EBook *ebook = l->data;
-
- if (e_book_is_opened(ebook) == FALSE)
- continue;
-
- if (e_book_get_contacts_async(ebook, query,
- cache_cb, data) == TRUE)
- data->queued_calls++;
- }
+ /* Fetch async contacts from default address book */
+ DBG("caching contacts");
+ e_book_client_get_contacts(book_client, data->query, NULL,
+ (GAsyncReadyCallback) phonebook_create_cache_ready, data);
+ data->queued_calls++;
if (err)
*err = (data->queued_calls == 0 ? -ENOENT : 0);
return data;
}
+
+int phonebook_init(void)
+{
+ EClient *client;
+ GError *gerr = NULL;
+
+ /* Acquire ESource Registry */
+ registry = e_source_registry_new_sync(NULL, &gerr);
+ if (gerr != NULL) {
+ error("Unable to acquire registery: %s\n", gerr->message);
+ g_error_free(gerr);
+ return -1;
+ }
+
+ /* Get ref to default address book */
+ address_book = e_source_registry_ref_default_address_book(registry);
+ if (address_book == NULL) {
+ error("Unable to get reference to default address book");
+ return -2;
+ }
+
+ /* Allocate e-book client for address book */
+ gerr = NULL;
+ client = e_book_client_connect_sync(address_book, CONNECTION_TIMEOUT,
+ NULL, &gerr);
+ if (gerr != NULL || client == NULL) {
+ error("Cannot connect ebook client to EDS: %s",
+ gerr != NULL ? gerr->message : "NULL");
+ g_error_free(gerr);
+ return -3;
+ }
+ book_client = E_BOOK_CLIENT(client);
+
+ DBG("created address book client");
+
+ return 0;
+}
+
+void phonebook_exit(void)
+{
+ g_object_unref(book_client);
+ g_object_unref(address_book);
+ g_object_unref(registry);
+}