PIM: search for phone number in EDS directly during startup

Bypass folks while it still loads contacts and search for a phone
number directly in EDS. This is necessary to ensure prompt responses
for the caller ID lookup.

Done with a StreamingView which translates EContacts into
FolksIndividuals with the help of folks-eds = edsf.

Combining these intermediate results and switching to the final
results is done by a new MergeView class.

A quiescence signal is emitted after receiving the EDS results and
after folks is done. The first signal will be skipped when folks
finishes first. The second signal will always be send, even if
switching to folks did not change anything.

Together with an artificial delay before folks is considered done,
that approach make testing more reliable.

1 files changed, 118 insertions, 0 deletions

diff --git a/src/dbus/server/pim/edsf-view.cpp b/src/dbus/server/pim/edsf-view.cpp
new file mode 100644
index 00000000..f573df9f
--- /dev/null
+++ b/src/dbus/server/pim/edsf-view.cpp
@@ -0,0 +1,118 @@
+/*
+ * Copyright (C) 2012 Intel Corporation
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) version 3.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+ * 02110-1301  USA
+ */
+
+#include "edsf-view.h"
+#include <syncevo/BoostHelper.h>
+
+SE_GOBJECT_TYPE(EdsfPersona);
+
+SE_BEGIN_CXX
+
+EDSFView::EDSFView(const ESourceRegistryCXX &registry,
+                   const std::string &uuid,
+                   const std::string &query) :
+    m_registry(registry),
+    m_uuid(uuid),
+    m_query(query)
+{
+}
+
+void EDSFView::init(const boost::shared_ptr<EDSFView> &self)
+{
+    m_self = self;
+}
+
+boost::shared_ptr<EDSFView> EDSFView::create(const ESourceRegistryCXX &registry,
+                                             const std::string &uuid,
+                                             const std::string &query)
+{
+    boost::shared_ptr<EDSFView> view(new EDSFView(registry, uuid, query));
+    view->init(view);
+    return view;
+}
+
+void EDSFView::doStart()
+{
+    ESourceCXX source(e_source_registry_ref_source(m_registry, m_uuid.c_str()), false);
+    if (!source) {
+        SE_LOG_DEBUG(NULL, NULL, "edsf %s: address book not found", m_uuid.c_str());
+        return;
+    }
+    m_store = EdsfPersonaStoreCXX::steal(edsf_persona_store_new_with_source_registry(m_registry, source));
+    GErrorCXX gerror;
+    m_ebook = EBookClientCXX::steal(e_book_client_new(source.get(), gerror));
+    if (!m_ebook) {
+        SE_LOG_DEBUG(NULL, NULL, "edfs %s: no client for address book: %s", m_uuid.c_str(), gerror->message);
+        return;
+    }
+    SYNCEVO_GLIB_CALL_ASYNC(e_client_open,
+                            boost::bind(&EDSFView::opened,
+                                        m_self,
+                                        _1,
+                                        _2),
+                            E_CLIENT(m_ebook.get()),
+                            false,
+                            NULL);
+}
+
+void EDSFView::opened(gboolean success, const GError *gerror) throw()
+{
+    try {
+        if (!success) {
+            SE_LOG_DEBUG(NULL, NULL, "edfs %s: opening failed: %s", m_uuid.c_str(), gerror->message);
+            return;
+        }
+        SYNCEVO_GLIB_CALL_ASYNC(e_book_client_get_contacts,
+                                boost::bind(&EDSFView::read,
+                                            m_self,
+                                            _1,
+                                            _2,
+                                            _3),
+                                m_ebook.get(),
+                                m_query.c_str(),
+                                NULL);
+    } catch (...) {
+        Exception::handle(HANDLE_EXCEPTION_NO_ERROR);
+    }
+}
+
+void EDSFView::read(gboolean success, GSList *contactslist, const GError *gerror) throw()
+{
+    try {
+        GListCXX<EContact, GSList, GObjectDestructor> contacts(contactslist);
+        if (!success) {
+            SE_LOG_DEBUG(NULL, NULL, "edfs %s: reading failed: %s", m_uuid.c_str(), gerror->message);
+            return;
+        }
+
+        BOOST_FOREACH (EContact *contact, contacts) {
+            EdsfPersonaCXX persona(edsf_persona_new(m_store, contact), false);
+            GeeHashSetCXX personas(gee_hash_set_new(G_TYPE_OBJECT, g_object_ref, g_object_unref, NULL, NULL), false);
+            gee_collection_add(GEE_COLLECTION(personas.get()), persona.get());
+            FolksIndividualCXX individual(folks_individual_new(GEE_SET(personas.get())), false);
+            m_addedSignal(individual);
+        }
+        m_isQuiescent = true;
+        m_quiescenceSignal();
+    } catch (...) {
+        Exception::handle(HANDLE_EXCEPTION_NO_ERROR);
+    }
+}
+
+SE_END_CXX