[folks] tests: linking: libsocialweb

[Alban Crequy <albanc src gnome org>]

commit f40389e0edb590e3fa19bc02982a86fba4f16871
Author: Alban Crequy <alban crequy collabora co uk>
Date:   Wed Mar 30 18:01:10 2011 +0100

    tests: linking: libsocialweb

 tests/lib/libsocialweb/backend.vala          |    6 +-
 tests/libsocialweb/Makefile.am               |    6 +
 tests/libsocialweb/aggregation.vala          |  256 ++++++++++++++++++++++++++
 tests/libsocialweb/data/backend-lsw-only.ini |   13 +-
 4 files changed, 268 insertions(+), 13 deletions(-)
---
diff --git a/tests/lib/libsocialweb/backend.vala b/tests/lib/libsocialweb/backend.vala
index c59dc6e..434798d 100644
--- a/tests/lib/libsocialweb/backend.vala
+++ b/tests/lib/libsocialweb/backend.vala
@@ -202,7 +202,7 @@ public class LibsocialwebTest.LibsocialwebServiceTest : Object,
     LibsocialwebTest.LibsocialwebServiceCapabilitiesTest,
     LibsocialwebTest.LibsocialwebServiceQueryTest
 {
-  private int count = 0;
+  static int view_count = 0;
   private string service_name;
   public Gee.HashMap<string,LibsocialwebTest.LibsocialwebContactViewTest>
       contact_views;
@@ -217,7 +217,7 @@ public class LibsocialwebTest.LibsocialwebServiceTest : Object,
   public ObjectPath OpenView (string query, HashTable<string, string> p)
     {
       string path = LibsocialwebTest.Backend.LIBSOCIALWEB_PATH + "/View"
-          + count.to_string();
+          + view_count.to_string();
       try
         {
           var conn = Bus.get_sync (BusType.SESSION);
@@ -225,7 +225,7 @@ public class LibsocialwebTest.LibsocialwebServiceTest : Object,
               (query, p, path);
           conn.register_object (path, contact_view);
           contact_views[path] = contact_view;
-          this.count++;
+          this.view_count++;
         }
       catch (GLib.IOError e)
         {
diff --git a/tests/libsocialweb/Makefile.am b/tests/libsocialweb/Makefile.am
index a94af28..2eae22b 100644
--- a/tests/libsocialweb/Makefile.am
+++ b/tests/libsocialweb/Makefile.am
@@ -43,6 +43,7 @@ AM_VALAFLAGS = \
 # in order from least to most complex
 noinst_PROGRAMS = \
 	dummy-lsw \
+	aggregation \
 	$(NULL)
 
 SESSION_CONF = $(top_builddir)/tests/lib/libsocialweb/session.conf
@@ -60,6 +61,10 @@ dummy_lsw_SOURCES = \
 	dummy-lsw.vala \
 	$(NULL)
 
+aggregation_SOURCES = \
+	aggregation.vala \
+	$(NULL)
+
 CLEANFILES = \
         *.pid \
         *.address \
@@ -69,6 +74,7 @@ CLEANFILES = \
 MAINTAINERCLEANFILES = \
         $(addsuffix .c,$(noinst_PROGRAMS)) \
         dummy_lsw_vala.stamp \
+        aggregation_vala.stamp \
         $(NULL)
 
 EXTRA_DIST = \
diff --git a/tests/libsocialweb/aggregation.vala b/tests/libsocialweb/aggregation.vala
new file mode 100644
index 0000000..344f1e1
--- /dev/null
+++ b/tests/libsocialweb/aggregation.vala
@@ -0,0 +1,256 @@
+/*
+ * Copyright (C) 2011 Collabora Ltd.
+ *
+ * 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) any later version.
+ *
+ * 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, see <http://www.gnu.org/licenses/>.
+ *
+ * Authors: Alban Crequy <alban crequy collabora co uk>
+ *
+ */
+
+using LibsocialwebTest;
+using Folks;
+using Gee;
+using GLib;
+
+public class AggregationTests : Folks.TestCase
+{
+  private LibsocialwebTest.Backend _lsw_backend;
+  private static const string STORE_FILE_PATH =
+      "folks-test-libsocialweb-aggregation-store.ini";
+  private static const string KF_RELATIONSHIPS_FILE_PATH =
+      "folks-test-libsocialweb-aggregation-relationships.ini";
+
+  public AggregationTests ()
+    {
+      base ("Aggregation");
+
+      this._lsw_backend = new LibsocialwebTest.Backend ();
+
+      this.add_test ("libsocialweb aggregation", this.test_aggregation_libsocialweb);
+    }
+
+  public override void set_up ()
+    {
+      /* Initialize an empty key file for the relationships*/
+      var kf_relationships_path = Path.build_filename (
+          Environment.get_tmp_dir (),
+          this.KF_RELATIONSHIPS_FILE_PATH, null);
+      Environment.set_variable ("FOLKS_BACKEND_KEY_FILE_PATH",
+          kf_relationships_path, true);
+      string kf_relationships_data = "#\n";
+      File kf_relationships_f = File.new_for_path (kf_relationships_path);
+      try
+        {
+          kf_relationships_f.replace_contents (kf_relationships_data,
+              kf_relationships_data.length, null, false,
+              FileCreateFlags.PRIVATE, null);
+        }
+      catch (Error e)
+        {
+          error ("Could not write relationship file '%s': %s",
+              kf_relationships_path, e.message);
+        }
+
+      /* Use a temporary key file for the BackendStore */
+      var kf_path = Path.build_filename (Environment.get_tmp_dir (),
+          this.STORE_FILE_PATH, null);
+
+      FileUtils.remove (kf_path);
+
+      GLib.KeyFile kf = new GLib.KeyFile ();
+      kf.set_boolean("all-others", "enabled", false);
+      kf.set_boolean("libsocialweb", "enabled", true);
+      kf.set_boolean("key-file", "enabled", true);
+
+      try
+        {
+          File backend_f = File.new_for_path (kf_path);
+          string data = kf.to_data ();
+          backend_f.replace_contents (data,
+              data.length, null, false, FileCreateFlags.PRIVATE,
+              null);
+        }
+      catch (Error e)
+        {
+          error ("Could not write updated backend key file '%s': %s",
+              kf_path, e.message);
+        }
+
+      Environment.set_variable ("FOLKS_BACKEND_STORE_KEY_FILE_PATH",
+          kf_path, true);
+    }
+
+  public override void tear_down ()
+    {
+    }
+
+  public void test_aggregation_libsocialweb ()
+    {
+      var main_loop = new GLib.MainLoop (null, false);
+
+      this._lsw_backend.ready.connect(() =>
+        {
+          main_loop.quit ();
+        });
+      uint timer_id = Timeout.add_seconds (5, () =>
+        {
+          assert_not_reached ();
+        });
+      this._lsw_backend.set_up ();
+      main_loop.run ();
+      Source.remove (timer_id);
+
+      var mysocialnetwork1 = this._lsw_backend.add_service ("mysocialnetwork1");
+      var mysocialnetwork2 = this._lsw_backend.add_service ("mysocialnetwork2");
+
+      /* Populate mysocialnetwork1 */
+      mysocialnetwork1.OpenViewCalled.connect((query, p, path) =>
+        {
+          mysocialnetwork1.contact_views[path].StartCalled.connect ( (path) =>
+            {
+              Idle.add (() =>
+                {
+                  string text = "([('mysocialnetwork1', 'garg', %x, "
+                      + "{'id': ['garg'], 'name': ['Gargantua']})],)";
+                  Variant v = new Variant.parsed (text, 1300792578);
+                  try
+                    {
+                      var conn = Bus.get_sync (BusType.SESSION);
+                      conn.emit_signal (null, path,
+                          "com.meego.libsocialweb.ContactView",
+                          "ContactsAdded", v);
+                    }
+                  catch (GLib.IOError e)
+                    {
+                      assert_not_reached ();
+                    }
+                  catch (GLib.Error e)
+                    {
+                      assert_not_reached ();
+                    }
+                  return false;
+                });
+            });
+        });
+
+      /* Populate mysocialnetwork2 */
+      mysocialnetwork2.OpenViewCalled.connect((query, p, path) =>
+        {
+          mysocialnetwork2.contact_views[path].StartCalled.connect ( (path) =>
+            {
+              Idle.add (() =>
+                {
+                  string text = "([('mysocialnetwork2', 'panta', %x, "
+                      + "{'id': ['panta'], 'name': ['Pantagruel']})],)";
+                  Variant v = new Variant.parsed (text, 1300792579);
+                  try
+                    {
+                      var conn = Bus.get_sync (BusType.SESSION);
+                      conn.emit_signal (null, path,
+                          "com.meego.libsocialweb.ContactView",
+                          "ContactsAdded", v);
+                    }
+                  catch (GLib.IOError e)
+                    {
+                      assert_not_reached ();
+                    }
+                  catch (GLib.Error e)
+                    {
+                      assert_not_reached ();
+                    }
+                  return false;
+                });
+            });
+        });
+
+      var aggregator = new IndividualAggregator ();
+      Individual[] individual_gathered = new Individual[0];
+      var handler_id = aggregator.individuals_changed.connect ((added, removed, m, a, r) =>
+        {
+          debug ("initial individuals_changed");
+          foreach (Individual i in added)
+            individual_gathered += i;
+          if (individual_gathered.length >= 2)
+            main_loop.quit ();
+        });
+      aggregator.prepare ();
+
+      timer_id = Timeout.add_seconds (5, () =>
+        {
+          assert_not_reached ();
+        });
+      main_loop.run ();
+      Source.remove (timer_id);
+      aggregator.disconnect (handler_id);
+
+      /* Check the aggregator got the correct data */
+      assert (individual_gathered.length == 2);
+      assert (
+          (((Folks.NameDetails) individual_gathered[0]).nickname == "Gargantua"
+           && ((Folks.NameDetails) individual_gathered[1]).nickname == "Pantagruel")
+          ||
+          (((Folks.NameDetails) individual_gathered[0]).nickname == "Pantagruel"
+           && ((Folks.NameDetails) individual_gathered[1]).nickname == "Gargantua"));
+
+      /* Check the result of link_personas */
+      aggregator.individuals_changed.connect ((added, removed, m, a, r) =>
+        {
+          debug ("individuals_changed after link: added:%u removed:%u",
+              added.length (), removed.length ());
+          assert (added.length () == 1);
+          assert (removed.length () == 2);
+          Individual i = added.nth_data (0);
+          assert (i.personas.length () == 3);
+          debug ("individuals_changed: 1 individual containing %u personas",
+              i.personas.length ());
+          main_loop.quit ();
+        });
+
+      /* Link personas */
+      GLib.List<unowned Persona> personas1 = new GLib.List<unowned Persona> ();
+      personas1.concat (individual_gathered[0].personas.copy ());
+      GLib.List<unowned Persona> personas2 = new GLib.List<unowned Persona> ();
+      personas2.concat (individual_gathered[1].personas.copy ());
+      GLib.List<unowned Persona> personas = new GLib.List<unowned Persona>();
+      personas.concat (personas1.copy ());
+      personas.concat (personas2.copy ());
+      assert (personas.length () == 2);
+      Idle.add (() =>
+        {
+          aggregator.link_personas (personas);
+          return false;
+        });
+
+      timer_id = Timeout.add_seconds (5, () =>
+        {
+          assert_not_reached ();
+        });
+      main_loop.run ();
+      Source.remove (timer_id);
+
+      this._lsw_backend.tear_down ();
+    }
+}
+
+public int main (string[] args)
+{
+  Test.init (ref args);
+
+  TestSuite root = TestSuite.get_root ();
+  root.add_suite (new AggregationTests ().get_suite ());
+
+  Test.run ();
+
+  return 0;
+}
diff --git a/tests/libsocialweb/data/backend-lsw-only.ini b/tests/libsocialweb/data/backend-lsw-only.ini
index 7804b94..cd9acbb 100644
--- a/tests/libsocialweb/data/backend-lsw-only.ini
+++ b/tests/libsocialweb/data/backend-lsw-only.ini
@@ -1,12 +1,5 @@
-
-[key-file]
-enabled=false
-
-[telepathy]
-enabled=false
-
-[tracker]
-enabled=false
-
 [libsocialweb]
 enabled=true
+
+[all-others]
+enabled=false