Merge lp:~nataliabidart/ubuntuone-control-panel/replication-to-the-backend into lp:ubuntuone-control-panel

[Natalia Bidart]

Desktopcouch replication service is managed in the backend and exposed in the DBus service (LP: #696782).

There is no easy way to test this except by running the backen with:

DEBUG=True PYTHONPATH=. ./bin/ubuntuone-control-panel-backend

and using d-feet to play with the replication methods. The merge proposal:

https://code.launchpad.net/~nataliabidart/ubuntuone-control-panel/start-dc-on-backend/+merge/45440

provides the GUI that accesses this service directly.

[lp:~nataliabidart/ubuntuone-control-panel/replication-to-the-backend]

45. By Natalia Bidart on 2011-01-06

Forgot some files!

[Eric Casteleijn (thisfred)]

Minor point: I don't like exclude/replicate as complementary method names, I'd prefer exclude/include or maybe even include_in_replication/exclude_from_replication for clarity.

[Eric Casteleijn (thisfred)]

I'm not sure I understand the 'dependency' field in the replication record. Bookmarks and contacts should be replicated, or at least replicatable, regardless of what is installed. Am I missing the point?

[Eric Casteleijn (thisfred)]

Looks good otherwise.

review: Approve

[Roberto Alsina (ralsina)]

Approved. I agree with Eric and Natalia (on IRC) that the spec needs some improvements because what dbs you replicate shouldn't depend on installed packages, but this is according to the current spec.

review: Approve

=== modified file 'ubuntuone/controlpanel/backend.py'
--- ubuntuone/controlpanel/backend.py	2010-12-23 18:20:56 +0000
+++ ubuntuone/controlpanel/backend.py	2011-01-06 20:44:10 +0000
@@ -22,6 +22,7 @@
 from twisted.internet.defer import inlineCallbacks, returnValue
 
 from ubuntuone.controlpanel import dbus_client
+from ubuntuone.controlpanel import replication_client
 from ubuntuone.controlpanel.logger import setup_logging, log_call
 from ubuntuone.controlpanel.webclient import WebClient
 
@@ -48,6 +49,9 @@
 MSG_KEY = 'message'
 STATUS_KEY = 'status'
 
+BOOKMARKS_PKG = 'xul-ext-bindwood'
+CONTACTS_PKG = 'evolution-couchdb'
+
 
 def bool_str(value):
     """Return the string representation of a bool (dbus-compatible)."""
@@ -300,7 +304,7 @@
 
         """
         if 'subscribed' in settings:
-            subscribed = settings['subscribed']
+            subscribed = bool(settings['subscribed'])
             if subscribed:
                 yield self.subscribe_volume(volume_id)
             else:
@@ -321,6 +325,42 @@
         yield dbus_client.unsubscribe_folder(volume_id)
 
     @log_call(logger.debug)
+    @inlineCallbacks
+    def replications_info(self):
+        """Get the user replications info."""
+        replications = yield replication_client.get_replications()
+        exclusions = yield replication_client.get_exclusions()
+
+        result = []
+        for rep in replications:
+            dependency = ''
+            if rep == replication_client.BOOKMARKS:
+                dependency = BOOKMARKS_PKG
+            elif rep == replication_client.CONTACTS:
+                dependency = CONTACTS_PKG
+
+            repd = {
+                "replication_id": rep,
+                "name": rep,  # this may change to be more user friendly
+                "enabled": bool_str(rep not in exclusions),
+                "dependency": dependency,
+            }
+            result.append(repd)
+
+        returnValue(result)
+
+    @log_call(logger.info)
+    @inlineCallbacks
+    def change_replication_settings(self, replication_id, settings):
+        """Change the settings for the given replication."""
+        if 'enabled' in settings:
+            if bool(settings['enabled']):
+                yield replication_client.replicate(replication_id)
+            else:
+                yield replication_client.exclude(replication_id)
+        returnValue(replication_id)
+
+    @log_call(logger.debug)
     def query_bookmark_extension(self):
         """True if the bookmark extension has been installed."""
         # still pending (LP: #673672)
 
=== modified file 'ubuntuone/controlpanel/dbus_service.py'
--- ubuntuone/controlpanel/dbus_service.py	2010-12-23 18:20:56 +0000
+++ ubuntuone/controlpanel/dbus_service.py	2011-01-06 20:44:10 +0000
@@ -339,6 +339,47 @@
 
     @log_call(logger.debug)
     @method(dbus_interface=DBUS_PREFERENCES_IFACE, in_signature="")
+    def replications_info(self):
+        """Return the replications info."""
+        d = self.backend.replications_info()
+        d.addCallback(self.ReplicationsInfoReady)
+        d.addErrback(transform_failure(self.ReplicationsInfoError))
+
+    @log_call(logger.debug)
+    @signal(dbus_interface=DBUS_PREFERENCES_IFACE, signature="aa{ss}")
+    def ReplicationsInfoReady(self, info):
+        """The replications info is ready."""
+
+    @log_call(logger.error)
+    @signal(dbus_interface=DBUS_PREFERENCES_IFACE, signature="a{ss}")
+    def ReplicationsInfoError(self, error):
+        """Problem getting the replications info."""
+
+    #---
+
+    @log_call(logger.info)
+    @method(dbus_interface=DBUS_PREFERENCES_IFACE, in_signature="sa{ss}")
+    def change_replication_settings(self, replication_id, settings):
+        """Configure a given replication."""
+        d = self.backend.change_replication_settings(replication_id, settings)
+        d.addCallback(self.ReplicationSettingsChanged)
+        d.addErrback(transform_failure(self.ReplicationSettingsChangeError),
+                     replication_id)
+
+    @log_call(logger.info)
+    @signal(dbus_interface=DBUS_PREFERENCES_IFACE, signature="s")
+    def ReplicationSettingsChanged(self, replication_id):
+        """The settings for the replication were changed."""
+
+    @log_call(logger.error)
+    @signal(dbus_interface=DBUS_PREFERENCES_IFACE, signature="sa{ss}")
+    def ReplicationSettingsChangeError(self, replication_id, error):
+        """Problem changing settings for the replication."""
+
+    #---
+
+    @log_call(logger.debug)
+    @method(dbus_interface=DBUS_PREFERENCES_IFACE, in_signature="")
     def query_bookmark_extension(self):
         """Check if the extension to sync bookmarks is installed."""
         d = self.backend.query_bookmark_extension()
 
=== modified file 'ubuntuone/controlpanel/integrationtests/test_dbus_service.py'
--- ubuntuone/controlpanel/integrationtests/test_dbus_service.py	2010-12-23 18:20:56 +0000
+++ ubuntuone/controlpanel/integrationtests/test_dbus_service.py	2011-01-06 20:44:10 +0000
@@ -84,6 +84,11 @@
     },
 ]
 
+SAMPLE_REPLICATIONS_INFO = [
+    {'replication_id': 'yadda', 'wait for it': 'awesome'},
+    {'replication_id': 'yoda', 'something else': 'awesome'},
+]
+
 
 class DBusServiceMainTestCase(mocker.MockerTestCase):
     """Tests for the main function."""
@@ -166,6 +171,19 @@
         """Configure a given volume."""
         return self._process(volume_id)
 
+    def replications_info(self):
+        """Start the replication exclusion service if needed.
+
+        Return the replication info, which is a dictionary of (replication
+        name, enabled).
+
+        """
+        return self._process(SAMPLE_REPLICATIONS_INFO)
+
+    def change_replication_settings(self, replication_id, settings):
+        """Configure a given replication."""
+        return self._process(replication_id)
+
     def query_bookmark_extension(self):
         """True if the bookmark extension has been installed."""
         return self._process(False)
@@ -258,13 +276,13 @@
         self.assertEqual(expected, result)
 
 
-class OperationsTestCase(TestCase):
-    """Test for the DBus service operations."""
+class BaseTestCase(TestCase):
+    """Base test case for the DBus service."""
 
     timeout = 3
 
     def setUp(self):
-        super(OperationsTestCase, self).setUp()
+        super(BaseTestCase, self).setUp()
         dbus_service.init_mainloop()
         be = dbus_service.publish_backend(MockBackend())
         self.addCleanup(be.remove_from_connection)
@@ -279,7 +297,7 @@
     def tearDown(self):
         self.backend = None
         self.deferred = None
-        super(OperationsTestCase, self).tearDown()
+        super(BaseTestCase, self).tearDown()
 
     def got_error(self, *a):
         """Some error happened in the DBus call."""
@@ -322,6 +340,10 @@
 
         return self.deferred
 
+
+class OperationsTestCase(BaseTestCase):
+    """Test for the DBus service operations."""
+
     def test_account_info_returned(self):
         """The account info is successfully returned."""
 
@@ -416,9 +438,9 @@
     def test_volumes_info(self):
         """The volumes info is reported."""
 
-        def got_signal(volumes_dict):
+        def got_signal(volumes):
             """The correct info was received."""
-            self.assertEqual(volumes_dict, SAMPLE_VOLUMES_INFO)
+            self.assertEqual(volumes, SAMPLE_VOLUMES_INFO)
             self.deferred.callback("success")
 
         args = ("VolumesInfoReady", "VolumesInfoError", got_signal,
@@ -439,6 +461,32 @@
                 expected_volume_id, {'subscribed': ''})
         return self.assert_correct_method_call(*args)
 
+    def test_replications_info(self):
+        """The replications info is reported."""
+
+        def got_signal(replications):
+            """The correct info was received."""
+            self.assertEqual(replications, SAMPLE_REPLICATIONS_INFO)
+            self.deferred.callback("success")
+
+        args = ("ReplicationsInfoReady", "ReplicationsInfoError", got_signal,
+                self.backend.replications_info)
+        return self.assert_correct_method_call(*args)
+
+    def test_change_replication_settings(self):
+        """The replication settings are successfully changed."""
+        expected_replication_id = SAMPLE_REPLICATIONS_INFO[0]['replication_id']
+
+        def got_signal(replication_id):
+            """The correct replication was changed."""
+            self.assertEqual(replication_id, expected_replication_id)
+            self.deferred.callback("success")
+
+        args = ("ReplicationSettingsChanged", "ReplicationSettingsChangeError",
+                got_signal, self.backend.change_replication_settings,
+                expected_replication_id, {'enabled': ''})
+        return self.assert_correct_method_call(*args)
+
     def test_query_bookmarks_extension(self):
         """The bookmarks extension is queried."""
 
@@ -495,7 +543,7 @@
             error_sig, success_sig, got_error_signal, method, *args)
 
 
-class FileSyncTestCase(OperationsTestCase):
+class FileSyncTestCase(BaseTestCase):
     """Test for the DBus service when requesting file sync status."""
 
     def assert_correct_status_signal(self, status, sync_signal,
 
=== added file 'ubuntuone/controlpanel/replication_client.py'
--- ubuntuone/controlpanel/replication_client.py	1970-01-01 00:00:00 +0000
+++ ubuntuone/controlpanel/replication_client.py	2011-01-06 20:44:10 +0000
@@ -0,0 +1,115 @@
+# -*- coding: utf-8 -*-
+
+# Authors: Natalia B. Bidart <[e-mail]>
+#
+# Copyright 2010 Canonical Ltd.
+#
+# This program is free software: you can redistribute it and/or modify it
+# under the terms of the GNU General Public License version 3, 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 warranties of
+# MERCHANTABILITY, SATISFACTORY QUALITY, 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, see <http://www.gnu.org/licenses/>.
+
+"""Client to use replication services."""
+
+from twisted.internet.defer import Deferred, inlineCallbacks, returnValue
+
+from ubuntuone.controlpanel.logger import setup_logging
+
+
+logger = setup_logging('replication_client')
+
+BOOKMARKS = 'bookmarks'
+CONTACTS = 'contacts'
+# we should get this list from somewhere else
+REPLICATIONS = set([BOOKMARKS, CONTACTS])
+
+
+class ReplicationError(Exception):
+    """A replication error."""
+
+
+class NoPairingRecord(ReplicationError):
+    """There is no pairing record."""
+
+
+class InvalidIdError(ReplicationError):
+    """The replication id is not valid."""
+
+
+class NotExcludedError(ReplicationError):
+    """The replication can not be replicated since is not excluded."""
+
+
+class AlreadyExcludedError(ReplicationError):
+    """The replication can not be excluded since is already excluded."""
+
+
+def get_replication_proxy(replication_module=None):
+    """Return a proxy to the replication client."""
+    d = Deferred()
+    if replication_module is None:
+        # delay import in case DC is not installed at module import time
+        # Unable to import 'desktopcouch.application.replication_services'
+        # pylint: disable=F0401
+        from desktopcouch.application.replication_services \
+            import ubuntuone as replication_module
+    try:
+        result = replication_module.ReplicationExclusion()
+    except ValueError:
+        d.errback(NoPairingRecord())
+    else:
+        d.callback(result)
+
+    return d
+
+
+@inlineCallbacks
+def get_replications():
+    """Retrieve the list of replications."""
+    yield get_replication_proxy()
+    returnValue(REPLICATIONS)
+
+
+@inlineCallbacks
+def get_exclusions():
+    """Retrieve the list of exclusions."""
+    proxy = yield get_replication_proxy()
+    result = proxy.all_exclusions()
+    returnValue(result)
+
+
+@inlineCallbacks
+def replicate(replication_id):
+    """Remove replication_id from the exclusions list."""
+    replications = yield get_replications()
+    if replication_id not in replications:
+        raise InvalidIdError(replication_id)
+
+    exclusions = yield get_exclusions()
+    if replication_id not in exclusions:
+        raise NotExcludedError(replication_id)
+
+    proxy = yield get_replication_proxy()
+    yield proxy.replicate(replication_id)
+
+
+@inlineCallbacks
+def exclude(replication_id):
+    """Add replication_id to the exclusions list."""
+    replications = yield get_replications()
+    if replication_id not in replications:
+        raise InvalidIdError(replication_id)
+
+    exclusions = yield get_exclusions()
+    if replication_id in exclusions:
+        raise AlreadyExcludedError(replication_id)
+
+    proxy = yield get_replication_proxy()
+    yield proxy.exclude(replication_id)
 
=== modified file 'ubuntuone/controlpanel/tests/__init__.py'
--- ubuntuone/controlpanel/tests/__init__.py	2010-12-20 16:11:13 +0000
+++ ubuntuone/controlpanel/tests/__init__.py	2011-01-06 20:44:10 +0000
@@ -24,9 +24,157 @@
 TOKEN = {u'consumer_key': u'xQ7xDAz',
          u'consumer_secret': u'KzCJWCTNbbntwfyCKKjomJDzlgqxLy',
          u'token_name': u'test',
-         u'token': u'GkInOfSMGwTXAUoVQwLUoPxElEEUdhsLVNTPhxHJDUIeHCPNEo',
+         u'token': u'ABCDEF01234-localtoken',
          u'token_secret': u'qFYImEtlczPbsCnYyuwLoPDlPEnvNcIktZphPQklAWrvyfFMV'}
 
+SAMPLE_ACCOUNT_JSON = """
+{
+    "username": "andrewpz",
+    "openid": "https://login.launchpad.net/+id/abcdefg",
+    "first_name": "Andrew P.",
+    "last_name": "Zoilo",
+    "couchdb": {
+        "host": "https://couchdb.one.ubuntu.com",
+        "root": "https://couchdb.one.ubuntu.com/u/abc/def/12345",
+        "dbpath": "u/abc/def/12345"
+    },
+    "couchdb_root": "https://couchdb.one.ubuntu.com/u/abc/def/12345",
+    "email": "[e-mail]",%s
+    "nickname": "Andrew P. Zoilo",
+    "id": 12345,
+    "subscription": {
+        "upgrade_available": false,
+        "description": "Paid Plan, 50 GB of storage",
+        "trial": false,
+        "started": "2010-03-24T18:38:38Z",
+        "is_paid": true,
+        "expires": null,
+        "qty": 1,
+        "price": 0.0,
+        "currency": null,
+        "id": 654321,
+        "name": "50 GB"
+    }
+}
+"""
+
+CURRENT_PLAN = "Ubuntu One Basic (2 GB) + 1 x 20-Pack with 20 GB (monthly)"
+SAMPLE_CURRENT_PLAN = '\n    "current_plan": "%s",' % CURRENT_PLAN
+
+SAMPLE_ACCOUNT_NO_CURRENT_PLAN = SAMPLE_ACCOUNT_JSON % ''
+SAMPLE_ACCOUNT_WITH_CURRENT_PLAN = SAMPLE_ACCOUNT_JSON % SAMPLE_CURRENT_PLAN
+
+
+SAMPLE_QUOTA_JSON = """
+{
+    "total": 53687091200,
+    "used": 2350345156
+}
+"""
+
+EXPECTED_ACCOUNT_INFO = {
+    "quota_used": "2350345156",
+    "quota_total": "53687091200",
+    "type": "Paid Plan, 50 GB of storage",
+    "name": "Andrew P. Zoilo",
+    "email": "[e-mail]",
+}
+
+EXPECTED_ACCOUNT_INFO_WITH_CURRENT_PLAN = {
+    "quota_used": "2350345156",
+    "quota_total": "53687091200",
+    "type": CURRENT_PLAN,
+    "name": "Andrew P. Zoilo",
+    "email": "[e-mail]",
+}
+
+SAMPLE_DEVICES_JSON = """
+[
+    {
+        "token": "ABCDEF01234token",
+        "description": "Ubuntu One @ darkstar",
+        "kind": "Computer"
+    },
+    {
+        "token": "ABCDEF01234-localtoken",
+        "description": "Ubuntu One @ localhost",
+        "kind": "Computer"
+    },
+    {
+        "kind": "Phone",
+        "description": "Nokia E65",
+        "id": 1000
+    }
+]
+"""
+
+EXPECTED_DEVICES_INFO = [
+    {
+        "device_id": "ComputerABCDEF01234token",
+        "name": "Ubuntu One @ darkstar",
+        "type": "Computer",
+        "is_local": '',
+        "configurable": '',
+    },
+    {
+        'is_local': 'True',
+        'configurable': 'True',
+        'device_id': 'ComputerABCDEF01234-localtoken',
+        'limit_bandwidth': '',
+        'max_download_speed': '-1',
+        'max_upload_speed': '-1',
+        'name': 'Ubuntu One @ localhost',
+        'type': 'Computer'
+    },
+    {
+        "device_id": "Phone1000",
+        "name": "Nokia E65",
+        "type": "Phone",
+        "configurable": '',
+        "is_local": '',
+    },
+]
+
+SAMPLE_FOLDERS = [
+    {u'generation': u'2', u'node_id': u'341da068-81d8-437a-8f75-5bb9d86455ba',
+     u'path': u'/home/tester/Public', u'subscribed': u'True',
+     u'suggested_path': u'~/Public',
+     u'type': u'UDF', u'volume_id': u'9ea892f8-15fa-4201-bdbf-8de99fa5f588'},
+    {u'generation': u'', u'node_id': u'11fbc86c-0d7a-49f5-ae83-8402caf66c6a',
+     u'path': u'/home/tester/Documents', u'subscribed': u'',
+     u'suggested_path': u'~/Documents',
+     u'type': u'UDF', u'volume_id': u'2db262f5-a151-4c19-969c-bb5ced753c61'},
+    {u'generation': u'24', u'node_id': u'9ee0e130-a7c7-4d76-a5e3-5df506221b48',
+     u'path': u'/home/tester/Pictures/Photos', u'subscribed': u'True',
+     u'suggested_path': u'~/Pictures/Photos',
+     u'type': u'UDF', u'volume_id': u'1deb2874-3d28-46ae-9999-d5f48de9f460'},
+]
+
+SAMPLE_SHARES = [
+    {u'accepted': u'True', u'access_level': u'View',
+     u'free_bytes': u'39892622746', u'generation': u'2704',
+     u'name': u're', u'node_id': u'c483f419-ed28-490a-825d-a8c074e2d795',
+     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
+     u'path': u'/home/tester/.local/share/ubuntuone/shares/re from Other User',
+     u'type': u'Share', u'volume_id': u'4a1b263b-a2b3-4f66-9e66-4cd18050810d'},
+    {u'accepted': u'True', u'access_level': u'Modify',
+     u'free_bytes': u'39892622746', u'generation': u'2704',
+     u'name': u'do', u'node_id': u'84544ea4-aefe-4f91-9bb9-ed7b0a805baf',
+     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
+     u'path': u'/home/tester/.local/share/ubuntuone/shares/do from Other User',
+     u'type': u'Share', u'volume_id': u'7d130dfe-98b2-4bd5-8708-9eeba9838ac0'},
+]
+
+SAMPLE_SHARED = [
+    {u'accepted': u'True', u'access_level': u'View',
+     u'free_bytes': u'', u'generation': u'',
+     u'name': u'bar', u'node_id': u'31e47530-9448-4f03-b4dc-4154fdf35225',
+     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
+     u'path': u'/home/tester/Ubuntu One/bar',
+     u'type': u'Shared',
+     u'volume_id': u'79584900-517f-4dff-b2f3-20e8c1e79365'},
+]
+
 
 class TestCase(BaseTestCase):
     """Basics for testing."""
 
=== modified file 'ubuntuone/controlpanel/tests/test_backend.py'
--- ubuntuone/controlpanel/tests/test_backend.py	2010-12-23 18:20:56 +0000
+++ ubuntuone/controlpanel/tests/test_backend.py	2011-01-06 20:44:10 +0000
@@ -25,9 +25,9 @@
 from twisted.internet.defer import inlineCallbacks
 from ubuntuone.devtools.handlers import MementoHandler
 
-from ubuntuone.controlpanel import backend
-from ubuntuone.controlpanel.backend import (ACCOUNT_API,
-    DEVICES_API, DEVICE_REMOVE_API, QUOTA_API,
+from ubuntuone.controlpanel import backend, replication_client
+from ubuntuone.controlpanel.backend import (bool_str,
+    ACCOUNT_API, DEVICES_API, DEVICE_REMOVE_API, QUOTA_API,
     FILE_SYNC_DISABLED,
     FILE_SYNC_DISCONNECTED,
     FILE_SYNC_ERROR,
@@ -37,160 +37,21 @@
     FILE_SYNC_UNKNOWN,
     MSG_KEY, STATUS_KEY,
 )
-
-from ubuntuone.controlpanel.tests import TestCase
+from ubuntuone.controlpanel.tests import (TestCase,
+    EXPECTED_ACCOUNT_INFO,
+    EXPECTED_ACCOUNT_INFO_WITH_CURRENT_PLAN,
+    EXPECTED_DEVICES_INFO,
+    SAMPLE_ACCOUNT_NO_CURRENT_PLAN,
+    SAMPLE_ACCOUNT_WITH_CURRENT_PLAN,
+    SAMPLE_DEVICES_JSON,
+    SAMPLE_FOLDERS,
+    SAMPLE_QUOTA_JSON,
+    SAMPLE_SHARED,
+    SAMPLE_SHARES,
+    TOKEN,
+)
 from ubuntuone.controlpanel.webclient import WebClientError
 
-SAMPLE_CREDENTIALS = {"token": "ABC1234DEF"}
-
-SAMPLE_ACCOUNT_JSON = """
-{
-    "username": "andrewpz",
-    "openid": "https://login.launchpad.net/+id/abcdefg",
-    "first_name": "Andrew P.",
-    "last_name": "Zoilo",
-    "couchdb": {
-        "host": "https://couchdb.one.ubuntu.com",
-        "root": "https://couchdb.one.ubuntu.com/u/abc/def/12345",
-        "dbpath": "u/abc/def/12345"
-    },
-    "couchdb_root": "https://couchdb.one.ubuntu.com/u/abc/def/12345",
-    "email": "[e-mail]",%s
-    "nickname": "Andrew P. Zoilo",
-    "id": 12345,
-    "subscription": {
-        "upgrade_available": false,
-        "description": "Paid Plan, 50 GB of storage",
-        "trial": false,
-        "started": "2010-03-24T18:38:38Z",
-        "is_paid": true,
-        "expires": null,
-        "qty": 1,
-        "price": 0.0,
-        "currency": null,
-        "id": 654321,
-        "name": "50 GB"
-    }
-}
-"""
-
-CURRENT_PLAN = "Ubuntu One Basic (2 GB) + 1 x 20-Pack with 20 GB (monthly)"
-SAMPLE_CURRENT_PLAN = '\n    "current_plan": "%s",' % CURRENT_PLAN
-
-SAMPLE_ACCOUNT_NO_CURRENT_PLAN = SAMPLE_ACCOUNT_JSON % ''
-SAMPLE_ACCOUNT_WITH_CURRENT_PLAN = SAMPLE_ACCOUNT_JSON % SAMPLE_CURRENT_PLAN
-
-
-SAMPLE_QUOTA_JSON = """
-{
-    "total": 53687091200,
-    "used": 2350345156
-}
-"""
-
-EXPECTED_ACCOUNT_INFO = {
-    "quota_used": "2350345156",
-    "quota_total": "53687091200",
-    "type": "Paid Plan, 50 GB of storage",
-    "name": "Andrew P. Zoilo",
-    "email": "[e-mail]",
-}
-
-EXPECTED_ACCOUNT_INFO_WITH_CURRENT_PLAN = {
-    "quota_used": "2350345156",
-    "quota_total": "53687091200",
-    "type": CURRENT_PLAN,
-    "name": "Andrew P. Zoilo",
-    "email": "[e-mail]",
-}
-
-SAMPLE_DEVICES_JSON = """
-[
-    {
-        "token": "ABCDEF01234token",
-        "description": "Ubuntu One @ darkstar",
-        "kind": "Computer"
-    },
-    {
-        "token": "ABC1234DEF",
-        "description": "Ubuntu One @ localhost",
-        "kind": "Computer"
-    },
-    {
-        "kind": "Phone",
-        "description": "Nokia E65",
-        "id": 1000
-    }
-]
-"""
-
-EXPECTED_DEVICES_INFO = [
-    {
-        "device_id": "ComputerABCDEF01234token",
-        "name": "Ubuntu One @ darkstar",
-        "type": "Computer",
-        "is_local": '',
-        "configurable": '',
-    },
-    {
-        'is_local': 'True',
-        'configurable': 'True',
-        'device_id': 'ComputerABC1234DEF',
-        'limit_bandwidth': '',
-        'max_download_speed': '-1',
-        'max_upload_speed': '-1',
-        'name': 'Ubuntu One @ localhost',
-        'type': 'Computer'
-    },
-    {
-        "device_id": "Phone1000",
-        "name": "Nokia E65",
-        "type": "Phone",
-        "configurable": '',
-        "is_local": '',
-    },
-]
-
-SAMPLE_FOLDERS = [
-    {u'generation': u'2', u'node_id': u'341da068-81d8-437a-8f75-5bb9d86455ba',
-     u'path': u'/home/tester/Public', u'subscribed': u'True',
-     u'suggested_path': u'~/Public',
-     u'type': u'UDF', u'volume_id': u'9ea892f8-15fa-4201-bdbf-8de99fa5f588'},
-    {u'generation': u'', u'node_id': u'11fbc86c-0d7a-49f5-ae83-8402caf66c6a',
-     u'path': u'/home/tester/Documents', u'subscribed': u'',
-     u'suggested_path': u'~/Documents',
-     u'type': u'UDF', u'volume_id': u'2db262f5-a151-4c19-969c-bb5ced753c61'},
-    {u'generation': u'24', u'node_id': u'9ee0e130-a7c7-4d76-a5e3-5df506221b48',
-     u'path': u'/home/tester/Pictures/Photos', u'subscribed': u'True',
-     u'suggested_path': u'~/Pictures/Photos',
-     u'type': u'UDF', u'volume_id': u'1deb2874-3d28-46ae-9999-d5f48de9f460'},
-]
-
-SAMPLE_SHARES = [
-    {u'accepted': u'True', u'access_level': u'View',
-     u'free_bytes': u'39892622746', u'generation': u'2704',
-     u'name': u're', u'node_id': u'c483f419-ed28-490a-825d-a8c074e2d795',
-     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
-     u'path': u'/home/tester/.local/share/ubuntuone/shares/re from Other User',
-     u'type': u'Share', u'volume_id': u'4a1b263b-a2b3-4f66-9e66-4cd18050810d'},
-    {u'accepted': u'True', u'access_level': u'Modify',
-     u'free_bytes': u'39892622746', u'generation': u'2704',
-     u'name': u'do', u'node_id': u'84544ea4-aefe-4f91-9bb9-ed7b0a805baf',
-     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
-     u'path': u'/home/tester/.local/share/ubuntuone/shares/do from Other User',
-     u'type': u'Share', u'volume_id': u'7d130dfe-98b2-4bd5-8708-9eeba9838ac0'},
-]
-
-SAMPLE_SHARED = [
-    {u'accepted': u'True', u'access_level': u'View',
-     u'free_bytes': u'', u'generation': u'',
-     u'name': u'bar', u'node_id': u'31e47530-9448-4f03-b4dc-4154fdf35225',
-     u'other_username': u'otheruser', u'other_visible_name': u'Other User',
-     u'path': u'/home/tester/Ubuntu One/bar',
-     u'type': u'Shared',
-     u'volume_id': u'79584900-517f-4dff-b2f3-20e8c1e79365'},
-]
-
 
 class MockWebClient(object):
     """A mock webclient."""
@@ -213,7 +74,7 @@
 class MockDBusClient(object):
     """A mock dbus_client module."""
 
-    creds = SAMPLE_CREDENTIALS
+    creds = TOKEN
     throttling = False
     limits = {"download": -1, "upload": -1}
     file_sync = True
@@ -292,6 +153,36 @@
         return SAMPLE_SHARED
 
 
+class MockReplicationClient(object):
+    """A mock replication_client module."""
+
+    BOOKMARKS = 'awesome'
+    CONTACTS = 'legendary'
+
+    replications = set([BOOKMARKS, CONTACTS, 'other'])
+    exclusions = set([CONTACTS])
+
+    def get_replications(self):
+        """Grab the list of replications in this machine."""
+        return MockReplicationClient.replications
+
+    def get_exclusions(self):
+        """Grab the list of exclusions in this machine."""
+        return MockReplicationClient.exclusions
+
+    def replicate(self, replication_id):
+        """Remove replication_id from the exclusions list."""
+        if replication_id not in MockReplicationClient.replications:
+            raise replication_client.ReplicationError(replication_id)
+        MockReplicationClient.exclusions.remove(replication_id)
+
+    def exclude(self, replication_id):
+        """Add replication_id to the exclusions list."""
+        if replication_id not in MockReplicationClient.replications:
+            raise replication_client.ReplicationError(replication_id)
+        MockReplicationClient.exclusions.add(replication_id)
+
+
 class BackendBasicTestCase(TestCase):
     """Simple tests for the backend."""
 
@@ -301,13 +192,14 @@
         super(BackendBasicTestCase, self).setUp()
         self.patch(backend, "WebClient", MockWebClient)
         self.patch(backend, "dbus_client", MockDBusClient())
-        self.local_token = "Computer" + SAMPLE_CREDENTIALS["token"]
+        self.patch(backend, "replication_client", MockReplicationClient())
+        self.local_token = "Computer" + TOKEN["token"]
         self.be = backend.ControlBackend()
 
         self.memento = MementoHandler()
         backend.logger.addHandler(self.memento)
 
-        MockDBusClient.creds = SAMPLE_CREDENTIALS
+        MockDBusClient.creds = TOKEN
 
     def test_backend_creation(self):
         """The backend instance is successfully created."""
@@ -317,7 +209,7 @@
     def test_get_token(self):
         """The get_token method returns the right token."""
         token = yield self.be.get_token()
-        self.assertEqual(token, SAMPLE_CREDENTIALS["token"])
+        self.assertEqual(token, TOKEN["token"])
 
     @inlineCallbacks
     def test_device_is_local(self):
@@ -388,12 +280,12 @@
         result = yield self.be.remove_device(device_id)
         self.assertEqual(result, device_id)
         # credentials were not cleared
-        self.assertEqual(MockDBusClient.creds, SAMPLE_CREDENTIALS)
+        self.assertEqual(MockDBusClient.creds, TOKEN)
 
     @inlineCallbacks
     def test_remove_device_clear_credentials_if_local_device(self):
         """The remove_device method clears the credentials if is local."""
-        apiurl = DEVICE_REMOVE_API % ('computer', SAMPLE_CREDENTIALS['token'])
+        apiurl = DEVICE_REMOVE_API % ('computer', TOKEN['token'])
         # pylint: disable=E1101
         self.be.wc.results[apiurl] = SAMPLE_DEVICES_JSON
         yield self.be.remove_device(self.local_token)
@@ -487,10 +379,10 @@
         """The volume settings can be changed."""
         fid = '0123-4567'
 
-        yield self.be.change_volume_settings(fid, {'subscribed': True})
+        yield self.be.change_volume_settings(fid, {'subscribed': 'True'})
         self.assertEqual(MockDBusClient.subscribed_folders, [fid])
 
-        yield self.be.change_volume_settings(fid, {'subscribed': False})
+        yield self.be.change_volume_settings(fid, {'subscribed': ''})
         self.assertEqual(MockDBusClient.subscribed_folders, [])
 
     @inlineCallbacks
@@ -671,3 +563,64 @@
 
         self.be.disable_files()
         self.assertFalse(MockDBusClient.file_sync)
+
+
+class BackendReplicationsTestCase(BackendBasicTestCase):
+    """Replications tests for the backend."""
+
+    @inlineCallbacks
+    def test_replications_info(self):
+        """The replications_info method exercises its callback."""
+        result = yield self.be.replications_info()
+
+        # replications_info will use exclusions information
+        expected = []
+        for name in MockReplicationClient.replications:
+            enabled = bool_str(name not in MockReplicationClient.exclusions)
+            dependency = ''
+            if name == MockReplicationClient.BOOKMARKS:
+                dependency = backend.BOOKMARKS_PKG
+            elif name == MockReplicationClient.CONTACTS:
+                dependency = backend.CONTACTS_PKG
+
+            item = {'replication_id': name, 'name': name,
+                    'enabled': enabled, 'dependency': dependency}
+            expected.append(item)
+        self.assertEqual(sorted(expected), sorted(result))
+
+    @inlineCallbacks
+    def test_change_replication_settings(self):
+        """The replication settings can be changed."""
+        rid = '0123-4567'
+        MockReplicationClient.replications.add(rid)
+        self.addCleanup(lambda: MockReplicationClient.replications.remove(rid))
+
+        yield self.be.change_replication_settings(rid, {'enabled': ''})
+        self.assertIn(rid, MockReplicationClient.exclusions)
+
+        yield self.be.change_replication_settings(rid, {'enabled': 'True'})
+        self.assertNotIn(rid, MockReplicationClient.exclusions)
+
+    @inlineCallbacks
+    def test_change_replication_settings_not_in_replications(self):
+        """The settings can not be changed for an item not in replications."""
+        rid = '0123-4567'
+        assert rid not in MockReplicationClient.replications
+
+        d = self.be.change_replication_settings(rid, {'enabled': 'True'})
+        yield self.assertFailure(d, replication_client.ReplicationError)
+
+        d = self.be.change_replication_settings(rid, {'enabled': ''})
+        yield self.assertFailure(d, replication_client.ReplicationError)
+
+    @inlineCallbacks
+    def test_change_replication_settings_no_setting(self):
+        """The change replication settings does not fail on empty settings."""
+        rid = '0123-4567'
+        MockReplicationClient.replications.add(rid)
+        self.addCleanup(lambda: MockReplicationClient.replications.remove(rid))
+
+        prior = MockReplicationClient.exclusions.copy()
+        yield self.be.change_replication_settings(rid, {})
+
+        self.assertEqual(MockReplicationClient.exclusions, prior)
 
=== added file 'ubuntuone/controlpanel/tests/test_replication_client.py'
--- ubuntuone/controlpanel/tests/test_replication_client.py	1970-01-01 00:00:00 +0000
+++ ubuntuone/controlpanel/tests/test_replication_client.py	2011-01-06 20:44:10 +0000
@@ -0,0 +1,160 @@
+# -*- coding: utf-8 -*-
+
+# Authors: Natalia B. Bidart <[e-mail]>
+#
+# Copyright 2010 Canonical Ltd.
+#
+# This program is free software: you can redistribute it and/or modify it
+# under the terms of the GNU General Public License version 3, 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 warranties of
+# MERCHANTABILITY, SATISFACTORY QUALITY, 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, see <http://www.gnu.org/licenses/>.
+
+"""Tests for the DBus service when accessing desktopcouch replications."""
+
+from twisted.internet.defer import inlineCallbacks
+
+from ubuntuone.controlpanel import replication_client
+from ubuntuone.controlpanel.tests import TestCase
+
+EXCLUSIONS = set()
+
+
+class FakedReplication(object):
+    """Faked a DC replication exclusion."""
+
+    def __init__(self):
+        self.all_exclusions = lambda: EXCLUSIONS
+        self.replicate = EXCLUSIONS.remove
+        self.exclude = EXCLUSIONS.add
+
+
+class FakedReplicationModule(object):
+    """Faked a DC replication module."""
+
+    ReplicationExclusion = FakedReplication
+
+
+class ReplicationsTestCase(TestCase):
+    """Test for the replications client methods."""
+
+    def setUp(self):
+        super(ReplicationsTestCase, self).setUp()
+
+        orig_get_proxy = replication_client.get_replication_proxy
+
+        def get_proxy():
+            """Fake the proxy getter."""
+            return orig_get_proxy(replication_module=FakedReplicationModule())
+
+        self.patch(replication_client, 'get_replication_proxy', get_proxy)
+
+    def tearDown(self):
+        EXCLUSIONS.clear()
+        super(ReplicationsTestCase, self).tearDown()
+
+    @inlineCallbacks
+    def test_no_pairing_record(self):
+        """Handle ValueError from replication layer."""
+
+        def no_pairing_record(*args, **kwargs):
+            """Fail with ValueError."""
+            raise ValueError('No pairing record.')
+
+        self.patch(FakedReplicationModule, 'ReplicationExclusion',
+                   no_pairing_record)
+
+        yield self.assertFailure(replication_client.get_replications(),
+                                 replication_client.NoPairingRecord)
+
+    @inlineCallbacks
+    def test_get_replications(self):
+        """Replications are correctly retrieved."""
+        result = yield replication_client.get_replications()
+        self.assertEqual(result, replication_client.REPLICATIONS)
+
+    @inlineCallbacks
+    def test_get_exclusions(self):
+        """Exclusions are correctly retrieved."""
+        replications = yield replication_client.get_replications()
+        for rep in replications:
+            yield replication_client.exclude(rep)
+
+        result = yield replication_client.get_exclusions()
+        self.assertEqual(result, replications)
+
+    @inlineCallbacks
+    def test_replicate(self):
+        """Replicate a service is correct."""
+        replications = yield replication_client.get_replications()
+        rid = list(replications)[0]
+        yield replication_client.exclude(rid)
+
+        yield replication_client.replicate(rid)
+        exclusions = yield replication_client.get_exclusions()
+        self.assertNotIn(rid, exclusions)
+
+    @inlineCallbacks
+    def test_replicate_name_not_in_replications(self):
+        """Replicate a service fails if not in replications."""
+        replications = yield replication_client.get_replications()
+        rid = 'not in replications'
+        assert rid not in replications
+
+        yield self.assertFailure(replication_client.replicate(rid),
+                                 replication_client.InvalidIdError)
+
+    @inlineCallbacks
+    def test_replicate_name_not_in_exclusions(self):
+        """Replicate a service fails if not in exclusions."""
+        replications = yield replication_client.get_replications()
+        rid = list(replications)[0]
+        assert rid in replications
+
+        exclusions = yield replication_client.get_exclusions()
+        assert rid not in exclusions
+
+        yield self.assertFailure(replication_client.replicate(rid),
+                                 replication_client.NotExcludedError)
+
+    @inlineCallbacks
+    def test_exclude(self):
+        """Excluding a service is correct."""
+        replications = yield replication_client.get_replications()
+        rid = list(replications)[0]
+        yield replication_client.exclude(rid)
+        yield replication_client.replicate(rid)
+
+        yield replication_client.exclude(rid)
+        exclusions = yield replication_client.get_exclusions()
+        self.assertIn(rid, exclusions)
+
+    @inlineCallbacks
+    def test_exclude_name_not_in_replications(self):
+        """Excluding a service fails if not in replications."""
+        replications = yield replication_client.get_replications()
+        rid = 'not in replications'
+        assert rid not in replications
+
+        yield self.assertFailure(replication_client.exclude(rid),
+                                 replication_client.InvalidIdError)
+
+    @inlineCallbacks
+    def test_exclude_name_in_exclusions(self):
+        """Excluding a service fails if already on exclusions."""
+        replications = yield replication_client.get_replications()
+        rid = list(replications)[0]
+        assert rid in replications
+
+        yield replication_client.exclude(rid)
+        exclusions = yield replication_client.get_exclusions()
+        assert rid in exclusions
+
+        yield self.assertFailure(replication_client.exclude(rid),
+                                 replication_client.AlreadyExcludedError)