Merge lp:~ubuntu-branches/ubuntu/precise/ubuntuone-client/precise-201112142106 into lp:ubuntu/precise/ubuntuone-client

[Ubuntu Package Importer]

The package importer has detected a possible inconsistency between the package history in the archive and the history in bzr. As the archive is authoritative the importer has made lp:ubuntu/precise/ubuntuone-client reflect what is in the archive and the old bzr branch has been pushed to lp:~ubuntu-branches/ubuntu/precise/ubuntuone-client/precise-201112142106. This merge proposal was created so that an Ubuntu developer can review the situations and perform a merge/upload if necessary. There are three typical cases where this can happen.
  1. Where someone pushes a change to bzr and someone else uploads the package without that change. This is the reason that this check is done by the importer. If this appears to be the case then a merge/upload should be done if the changes that were in bzr are still desirable.
  2. The importer incorrectly detected the above situation when someone made a change in bzr and then uploaded it.
  3. The importer incorrectly detected the above situation when someone just uploaded a package and didn't touch bzr.

If this case doesn't appear to be the first situation then set the status of the merge proposal to "Rejected" and help avoid the problem in future by filing a bug at https://bugs.launchpad.net/udd linking to this merge proposal.

(this is an automatically generated message)

Unmerged revisions

92. By Ken VanDine on 2011-12-14

releasing version 2.0.0-0ubuntu4

=== added directory '.pc/03_reset_notify_name.patch'
=== renamed directory '.pc/03_reset_notify_name.patch' => '.pc/03_reset_notify_name.patch.moved'
=== added file '.pc/03_reset_notify_name.patch/.timestamp'
=== added directory '.pc/03_reset_notify_name.patch/tests'
=== added directory '.pc/03_reset_notify_name.patch/tests/status'
=== added file '.pc/03_reset_notify_name.patch/tests/status/test_aggregator.py'
--- .pc/03_reset_notify_name.patch/tests/status/test_aggregator.py	1970-01-01 00:00:00 +0000
+++ .pc/03_reset_notify_name.patch/tests/status/test_aggregator.py	2011-12-14 21:11:28 +0000
@@ -0,0 +1,1560 @@
+# tests.status.test_aggregator
+#
+# Author: Alejandro J. Cura <[e-mail]>
+#
+# Copyright 2011 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 status events aggregator."""
+
+import logging
+
+from twisted.internet import defer
+from twisted.internet.task import Clock
+from twisted.trial.unittest import TestCase
+from mocker import Mocker
+
+from contrib.testing.testcase import BaseTwistedTestCase
+from ubuntuone.devtools.handlers import MementoHandler
+from ubuntuone.status import aggregator
+from ubuntuone.status.notification import AbstractNotification
+from ubuntuone.status.messaging import AbstractMessaging
+from ubuntuone.syncdaemon import status_listener
+from ubuntuone.syncdaemon.volume_manager import Share, UDF, Root
+
+FILENAME = 'example.txt'
+FILENAME2 = 'another_example.mp3'
+
+
+class PatchedClock(Clock):
+    """Patch the clock to fix twisted bug #4823."""
+
+    def advance(self, amount):
+        """Sort the calls before advancing the clock."""
+        self.calls.sort(lambda a, b: cmp(a.getTime(), b.getTime()))
+        Clock.advance(self, amount)
+
+
+class TimerTestCase(TestCase):
+    """Test the Timer class."""
+
+    TIMEOUT = 3.0
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(TimerTestCase, self).setUp()
+        self.clock = PatchedClock()
+        self.timer = aggregator.Timer(delay=3.0, clock=self.clock)
+
+    def test_not_fired_initially(self):
+        """The timer is not fired initially"""
+        self.assertFalse(self.timer.called)
+
+    def test_fired_after_delay(self):
+        """The timer is fired after the initial delay."""
+        self.clock.advance(self.timer.delay)
+        self.assertTrue(self.timer.called)
+
+    def test_cleanup_cancels_delay_call(self):
+        """Calling cleanup cancels the delay call."""
+        self.timer.cleanup()
+        self.assertTrue(self.timer.delay_call.cancelled)
+
+    def test_not_fired_immediately(self):
+        """The timer is not fired immediately."""
+        self.timer.reset()
+        self.assertFalse(self.timer.called)
+
+    def test_fired_after_initial_wait(self):
+        """The timer is fired after an initial wait."""
+        self.timer.reset()
+        self.clock.advance(self.timer.delay)
+        self.assertTrue(self.timer.called)
+
+    def test_not_fired_if_reset_within_delay(self):
+        """The timer is not fired if it is reset within the delay."""
+        self.timer.reset()
+        self.clock.advance(self.timer.delay / 0.8)
+        self.timer.reset()
+        self.clock.advance(self.timer.delay / 0.8)
+        self.assertTrue(self.timer.called)
+
+    def test_active(self):
+        """The timer is active until the delay is reached."""
+        self.timer.reset()
+        self.assertTrue(self.timer.active)
+        self.clock.advance(self.timer.delay + 1)
+        self.assertFalse(self.timer.active)
+
+
+class DeadlineTimerTestCase(TimerTestCase):
+    """Test the DeadlineTimer class."""
+
+    DELAY = 0.5
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(DeadlineTimerTestCase, self).setUp()
+        self.clock = PatchedClock()
+        self.timer = aggregator.DeadlineTimer(delay=0.5, timeout=3.0,
+                                            clock=self.clock)
+
+    def test_fired_if_initial_timeout_exceeded(self):
+        """Timer is fired if the initial timeout is exceeded."""
+        small_delay = self.timer.delay * 0.8
+        for n in range(int(self.timer.timeout / small_delay) + 1):
+            self.timer.reset()
+            self.clock.advance(small_delay)
+        self.assertTrue(self.timer.called)
+
+    def test_not_fired_twice_if_delay_exceeded(self):
+        """Timer is not fired twice if the delay is exceeded."""
+        large_delay = self.timer.delay * 1.2
+        for n in range(int(self.timer.timeout / large_delay) + 1):
+            self.timer.reset()
+            self.clock.advance(large_delay)
+        self.clock.advance(self.timer.delay)
+        self.assertTrue(self.timer.called)
+
+    def test_not_fired_twice_if_timeout_exceeded(self):
+        """Timer is not fired twice if the timeout is exceeded."""
+        small_delay = self.timer.delay * 0.8
+        for n in range(int(self.timer.timeout / small_delay) + 1):
+            self.timer.reset()
+            self.clock.advance(small_delay)
+        self.clock.advance(self.timer.delay)
+        self.assertTrue(self.timer.called)
+
+    def test_cleanup_cancels_timeout_call(self):
+        """Calling cleanup cancels the delay call."""
+        self.timer.cleanup()
+        self.assertTrue(self.timer.timeout_call.cancelled)
+
+
+class FakeNotification(AbstractNotification):
+    """A fake notification class."""
+
+    def __init__(self, application_name="fake app"):
+        """Initialize this instance."""
+        self.notifications_shown = []
+        self.notification_switch = None
+        self.application_name = application_name
+        self.notification = None
+
+    def send_notification(self, title, message, icon=None, append=False):
+        """Show a notification to the user."""
+        if (self.notification_switch is not None
+            and not self.notification_switch.enabled):
+            return
+        self.notification = (title, message, icon, append)
+        self.notifications_shown.append((title, message, icon, append))
+        return len(self.notifications_shown) - 1
+
+
+def FakeNotificationSingleton():
+    """Builds a notification singleton, that logs all notifications shown."""
+    instance = FakeNotification()
+
+    def get_instance(notification_switch):
+        """Returns the single instance."""
+        instance.notification_switch = notification_switch
+        return instance
+
+    return get_instance
+
+
+class FakeMessaging(AbstractMessaging):
+    """A fake messaging class."""
+
+    def __init__(self):  # pylint: disable=W0231
+        self.messages_shown = {}
+        self.messages_updated = {}
+        self.callbacks = []
+
+    # pylint: disable=R0913
+    def show_message(self, sender, callback=None, message_time=None,
+                     message_count=None, icon=None):
+        """Show a message to the user."""
+        if message_count and sender in self.messages_shown:
+            self.update_count(sender, message_count)
+        self.messages_shown[sender] = (
+            callback, message_time, message_count, icon)
+    # pylint: enable=R0913
+
+    def update_count(self, sender, add_count):
+        """Update the count for an existing indicator."""
+        self.messages_updated[sender] = (sender, add_count)
+
+    def _callback(self, indicator, message_time=None):
+        """Fake callback."""
+        self.callbacks.append((indicator, message_time))
+
+    def create_callback(self):
+        """Create the callback."""
+        return self._callback
+
+
+class FakeStatusAggregator(object):
+    """A fake status aggregator."""
+
+    def __init__(self, clock):          # pylint: disable=W0613
+        """Initialize this instance."""
+        self.discovered = 0
+        self.completed = 0
+        self.notification_switch = aggregator.NotificationSwitch()
+
+    def get_discovery_message(self):
+        """Return the file discovery message."""
+        self.discovered += 1
+        return self.build_discovery_message()
+
+    def build_discovery_message(self):
+        """Build the file discovery message."""
+        return "a lot of files found (%d).""" % self.discovered
+
+    def get_progress_message(self):
+        """Return the progress message."""
+        self.completed += 1
+        return self.build_progress_message()
+
+    def build_progress_message(self):
+        """Build the progress message."""
+        params = (self.discovered, self.completed)
+        return "a lot of files transferring (%d/%d).""" % params
+
+    def get_final_status_message(self):
+        """Return the final status message."""
+        return "a lot of files completed."""
+
+    def get_notification(self):
+        """Create a new toggleable notification object."""
+        return self.notification_switch.get_notification()
+
+
+class ToggleableNotificationTestCase(TestCase):
+    """Test the ToggleableNotification class."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(ToggleableNotificationTestCase, self).setUp()
+        self.patch(aggregator, "Notification", FakeNotification)
+        self.notification_switch = aggregator.NotificationSwitch()
+        self.toggleable = self.notification_switch.get_notification()
+
+    def assertShown(self, notification):
+        """Assert that the notification was shown."""
+        self.assertIn(notification,
+                      self.toggleable.notification.notifications_shown)
+
+    def assertNotShown(self, notification):
+        """Assert that the notification was shown."""
+        self.assertNotIn(notification,
+                         self.toggleable.notification.notifications_shown)
+
+    def test_send_notification_passes_thru(self):
+        """The send_notification method passes thru."""
+        args = (1, 2, 3, 4)
+        self.toggleable.send_notification(*args)
+        self.assertShown(args)
+
+    def test_send_notification_honored_when_enabled(self):
+        """The send_notification method is honored when enabled."""
+        self.notification_switch.enable_notifications()
+        args = (aggregator.UBUNTUONE_TITLE, "hello", None, False)
+        self.toggleable.send_notification(*args)
+        self.assertShown(args)
+
+    def test_send_notification_ignored_when_disabled(self):
+        """The send_notification method is ignored when disabled."""
+        self.notification_switch.disable_notifications()
+        args = (aggregator.UBUNTUONE_TITLE, "hello", None, False)
+        self.toggleable.send_notification(*args)
+        self.assertNotShown(args)
+
+
+class NotificationSwitchTestCase(TestCase):
+    """Test the NotificationSwitch class."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(NotificationSwitchTestCase, self).setUp()
+        self.notification_switch = aggregator.NotificationSwitch()
+
+    def test_get_notification(self):
+        """A new notification instance is returned."""
+        notification = self.notification_switch.get_notification()
+        self.assertEqual(notification.notification_switch,
+                         self.notification_switch)
+
+    def test_enable_notifications(self):
+        """The switch is turned on."""
+        self.notification_switch.enable_notifications()
+        self.assertTrue(self.notification_switch.enabled)
+
+    def test_disable_notifications(self):
+        """The switch is turned off."""
+        self.notification_switch.disable_notifications()
+        self.assertFalse(self.notification_switch.enabled)
+
+
+class FileDiscoveryBubbleTestCase(TestCase):
+    """Test the FileDiscoveryBubble class."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(FileDiscoveryBubbleTestCase, self).setUp()
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.clock = PatchedClock()
+        self.aggregator = FakeStatusAggregator(clock=self.clock)
+        self.bubble = aggregator.FileDiscoveryBubble(self.aggregator,
+                                                     clock=self.clock)
+        self.addCleanup(self.bubble.cleanup)
+        fdis = aggregator.FileDiscoveryGatheringState
+        self.initial_delay = fdis.initial_delay
+        self.smaller_delay = self.initial_delay * 0.8
+        self.initial_timeout = fdis.initial_timeout
+        fdus = aggregator.FileDiscoveryUpdateState
+        self.updates_delay = fdus.updates_delay
+        self.updates_timeout = fdus.updates_timeout
+        fdss = aggregator.FileDiscoverySleepState
+        self.sleep_delay = fdss.sleep_delay
+
+        self.handler = MementoHandler()
+        self.handler.setLevel(logging.DEBUG)
+        aggregator.logger.addHandler(self.handler)
+        aggregator.logger.setLevel(logging.DEBUG)
+        self.addCleanup(aggregator.logger.removeHandler, self.handler)
+
+    def get_notifications_shown(self):
+        """The list of notifications shown."""
+        return self.bubble.notification.notifications_shown
+
+    def test_popup_shows_notification_when_connected(self):
+        """The popup callback shows notifications."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        message = self.aggregator.build_discovery_message()
+        notification = (aggregator.UBUNTUONE_TITLE, message, None, False)
+        self.assertIn(notification, self.get_notifications_shown())
+
+    def test_popup_shows_notification_after_connected(self):
+        """The popup callback shows notifications."""
+        self.bubble.new_file_found()
+        self.bubble.connection_made()
+        message = self.aggregator.build_discovery_message()
+        notification = (aggregator.UBUNTUONE_TITLE, message, None, False)
+        self.assertIn(notification, self.get_notifications_shown())
+
+    def test_popup_shows_no_notification_before_connection_made(self):
+        """The popup callback shows notifications."""
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        message = self.aggregator.build_discovery_message()
+        notification = (aggregator.UBUNTUONE_TITLE, message, None, False)
+        self.assertNotIn(notification, self.get_notifications_shown())
+
+    def test_popup_shows_no_notification_after_connection_lost(self):
+        """The popup callback shows notifications."""
+        self.bubble.connection_made()
+        self.bubble.connection_lost()
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        message = self.aggregator.build_discovery_message()
+        notification = (aggregator.UBUNTUONE_TITLE, message, None, False)
+        self.assertNotIn(notification, self.get_notifications_shown())
+
+    def test_notification_is_logged_in_debug(self):
+        """The notification is printed in the debug log."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        msg = "notification shown: %s" % self.get_notifications_shown()[0][1]
+        self.assertTrue(self.handler.check_debug(msg))
+
+    def test_bubble_is_not_shown_initially(self):
+        """The bubble is not shown initially."""
+        self.bubble.new_file_found()
+        self.assertEqual(0, len(self.get_notifications_shown()))
+
+    def test_bubble_is_shown_after_delay(self):
+        """The bubble is shown after a delay."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.assertEqual(1, len(self.get_notifications_shown()))
+
+    def test_bubble_not_shown_if_more_files_found(self):
+        """The bubble is not shown if more files found within delay."""
+        self.clock.advance(self.smaller_delay)
+        self.bubble.new_file_found()
+        self.clock.advance(self.smaller_delay)
+        self.assertEqual(0, len(self.get_notifications_shown()))
+
+    def test_bubble_shown_if_timeout_exceeded(self):
+        """The bubble is shown if the timeout is exceeded."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        count = int(self.initial_timeout / self.smaller_delay) + 1
+        for n in range(count):
+            self.clock.advance(self.smaller_delay)
+            self.bubble.new_file_found()
+        self.assertEqual(1, len(self.get_notifications_shown()))
+
+    def test_idle_state(self):
+        """The idle state is verified."""
+        self.assertEqual(type(self.bubble.state),
+                                   aggregator.FileDiscoveryIdleState)
+
+    def test_gathering_state(self):
+        """The gathering state is set after the first file is found."""
+        self.bubble.new_file_found()
+        self.assertEqual(type(self.bubble.state),
+                                   aggregator.FileDiscoveryGatheringState)
+
+    def test_update_state(self):
+        """When the gathering state finishes, the update state is started."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.assertEqual(type(self.bubble.state),
+                                   aggregator.FileDiscoveryUpdateState)
+
+    def test_sleeping_state(self):
+        """When the update state finishes, the sleeping state is started."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.clock.advance(self.updates_timeout)
+        self.assertEqual(type(self.bubble.state),
+                                   aggregator.FileDiscoverySleepState)
+
+    def test_back_to_initial_state(self):
+        """When the last state finishes, we return to the idle state."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.clock.advance(self.updates_timeout)
+        self.clock.advance(self.sleep_delay)
+        self.assertEqual(type(self.bubble.state),
+                                   aggregator.FileDiscoveryIdleState)
+
+    def test_new_files_found_while_updating_not_shown_immediately(self):
+        """New files found in the updating state are not shown immediately."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.bubble.new_file_found()
+        self.assertEqual(1, len(self.get_notifications_shown()))
+
+    def test_new_files_found_while_updating_are_shown_after_a_delay(self):
+        """New files found in the updating state are shown after a delay."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.clock.advance(self.initial_delay)
+        self.bubble.new_file_found()
+        self.clock.advance(self.updates_delay)
+        self.assertEqual(2, len(self.get_notifications_shown()))
+
+    def test_update_modifies_notification(self):
+        """The update callback updates notifications."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        self.bubble.new_file_found()
+        self.bubble._update()
+        message = self.aggregator.build_discovery_message()
+        notification = (aggregator.UBUNTUONE_TITLE, message, None, False)
+        self.assertIn(notification, self.get_notifications_shown())
+
+    def test_update_is_logged_in_debug(self):
+        """The notification is logged when _update is called."""
+        self.bubble.connection_made()
+        self.bubble.new_file_found()
+        self.bubble._popup()
+        self.bubble.new_file_found()
+        self.bubble._update()
+        msg = "notification updated: %s" % self.get_notifications_shown()[1][1]
+        self.assertTrue(self.handler.check_debug(msg))
+
+
+class FinalBubbleTestCase(TestCase):
+    """Test for the final status notification bubble."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(FinalBubbleTestCase, self).setUp()
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.clock = PatchedClock()
+        self.aggregator = FakeStatusAggregator(clock=self.clock)
+        self.bubble = aggregator.FinalStatusBubble(self.aggregator)
+        self.addCleanup(self.bubble.cleanup)
+
+    def test_notification_not_shown_initially(self):
+        """The notification is not shown initially."""
+        self.assertEqual(None, self.bubble.notification)
+
+    def test_show_pops_bubble(self):
+        """The show method pops the bubble immediately."""
+        self.bubble.show()
+        self.assertEqual(1, len(self.bubble.notification.notifications_shown))
+
+
+class FakeLauncher(object):
+    """A fake UbuntuOneLauncher."""
+
+    progress_visible = False
+    progress = 0.0
+
+    def show_progressbar(self):
+        """The progressbar is shown."""
+        self.progress_visible = True
+
+    def hide_progressbar(self):
+        """The progressbar is hidden."""
+        self.progress_visible = False
+
+    def set_progress(self, value):
+        """The progressbar value is changed."""
+        self.progress = value
+
+
+class FakeInhibitor(object):
+    """A fake session inhibitor."""
+
+    def inhibit(self, flags, reason):
+        """Inhibit some events with a given reason."""
+        self.flags = flags
+        return defer.succeed(self)
+
+    def cancel(self):
+        """Cancel the inhibition for the current cookie."""
+        self.flags = 0
+        return defer.succeed(self)
+
+
+class ProgressBarTestCase(TestCase):
+    """Tests for the progress bar."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(ProgressBarTestCase, self).setUp()
+        self.patch(aggregator, "UbuntuOneLauncher", FakeLauncher)
+        self.patch(aggregator.session, "Inhibitor", FakeInhibitor)
+        self.clock = PatchedClock()
+        self.bar = aggregator.ProgressBar(clock=self.clock)
+        self.addCleanup(self.bar.cleanup)
+        self.timeout_calls = []
+        original_timeout = self.bar._timeout
+
+        def fake_timeout(result):
+            """A fake _timeout method."""
+            self.timeout_calls.append(self.bar.progress)
+            original_timeout(result)
+
+        self.patch(self.bar, "_timeout", fake_timeout)
+
+    def test_launcher_typeerror_nonfatal(self):
+        """Test that Launcher raising TypeError is not fatal."""
+        def raise_typeerror(*args, **kwargs):
+            raise TypeError
+
+        self.patch(aggregator, "UbuntuOneLauncher", raise_typeerror)
+        aggregator.ProgressBar(clock=self.clock)
+
+    def test_shown_when_progress_made(self):
+        """The progress bar is shown when progress is made."""
+        self.bar.set_progress(0.5)
+        self.assertTrue(self.bar.visible)
+        self.assertTrue(self.bar.launcher.progress_visible)
+
+    def test_progress_made_updates_counter(self):
+        """Progress made updates the counter."""
+        self.bar.set_progress(0.5)
+        self.assertEqual(self.bar.progress, 0.5)
+
+    def test_no_timer_set_initially(self):
+        """There's no timer set initially."""
+        self.assertEqual(self.bar.timer, None)
+
+    def test_progress_made_sets_timer(self):
+        """Progress made sets up a timer."""
+        self.bar.set_progress(0.5)
+        self.assertNotEqual(self.bar.timer, None)
+
+    def test_cleanup_resets_timer(self):
+        """The cleanup method resets the timer."""
+        self.bar.set_progress(0.5)
+        self.bar.cleanup()
+        self.assertEqual(self.bar.timer, None)
+
+    def test_progress_made_not_updated_initially(self):
+        """Progress made is not updated initially."""
+        self.bar.set_progress(0.5)
+        self.assertEqual(0, len(self.timeout_calls))
+        self.assertEqual(0.0, self.bar.launcher.progress)
+
+    def test_progress_made_updated_after_a_delay(self):
+        """The progressbar is updated after a delay."""
+        self.bar.set_progress(0.5)
+        self.clock.advance(aggregator.ProgressBar.updates_delay)
+        self.assertIn(0.5, self.timeout_calls)
+        self.assertEqual(0.5, self.bar.launcher.progress)
+
+    def test_progress_updates_are_aggregated(self):
+        """The progressbar is updated after a delay."""
+        self.bar.set_progress(0.5)
+        self.clock.advance(aggregator.ProgressBar.updates_delay / 2)
+        self.bar.set_progress(0.6)
+        self.clock.advance(aggregator.ProgressBar.updates_delay / 2)
+        self.assertEqual(1, len(self.timeout_calls))
+
+    def test_progress_updates_are_continuous(self):
+        """The progressbar updates are continuous."""
+        self.bar.set_progress(0.5)
+        self.clock.advance(aggregator.ProgressBar.updates_delay)
+        self.assertEqual(0.5, self.bar.launcher.progress)
+        self.bar.set_progress(0.6)
+        self.clock.advance(aggregator.ProgressBar.updates_delay)
+        self.assertEqual(0.6, self.bar.launcher.progress)
+        self.assertEqual(2, len(self.timeout_calls))
+
+    def test_hidden_when_completed(self):
+        """The progressbar is hidden when everything completes."""
+        self.bar.set_progress(0.5)
+        self.bar.completed()
+        self.assertFalse(self.bar.visible)
+        self.assertFalse(self.bar.launcher.progress_visible)
+
+    @defer.inlineCallbacks
+    def test_progress_made_inhibits_logout_suspend(self):
+        """Suspend and logout are inhibited when the progressbar is shown."""
+        self.bar.set_progress(0.5)
+        expected = aggregator.session.INHIBIT_LOGOUT_SUSPEND
+        inhibitor = yield self.bar.inhibitor_defer
+        self.assertEqual(inhibitor.flags, expected)
+
+    @defer.inlineCallbacks
+    def test_completed_uninhibits_logout_suspend(self):
+        """Suspend and logout are uninhibited when all has completed."""
+        self.bar.set_progress(0.5)
+        d = self.bar.inhibitor_defer
+        self.bar.completed()
+        inhibitor = yield d
+        self.assertEqual(inhibitor.flags, 0)
+
+
+class FakeDelayedBuffer(object):
+    """Appends all status pushed into a list."""
+    timer_reset = False
+    processed = False
+
+    def __init__(self, *args, **kwargs):
+        """Initialize this instance."""
+        self.events = []
+
+    def push_event(self, event):
+        """Push an event into this buffer."""
+        self.events.append(event)
+
+    def reset_threshold_timer(self):
+        """The status has changed."""
+        self.timer_reset = True
+
+    def process_accumulated(self):
+        """Process accumulated events."""
+        self.processed = True
+
+
+class FakeCommand(object):
+    """A fake command."""
+
+    def __init__(self, path=''):
+        self.path = path
+        self.share_id = path
+        self.node_id = path
+        self.deflated_size = 10000
+
+
+class FakeVolumeManager(object):
+    """A fake vm."""
+
+    def __init__(self):
+        """Initialize this instance."""
+        self.volumes = {}
+        self.root = None
+
+    def get_volume(self, volume_id):
+        """Return a volume given its id."""
+        return self.volumes[volume_id]
+
+
+class FakeAggregator(object):
+    """A fake aggregator object."""
+
+    def __init__(self, clock):
+        """Initialize this fake instance."""
+        self.queued_commands = set()
+        self.notification_switch = aggregator.NotificationSwitch()
+        self.connected = False
+        self.clock = PatchedClock()
+        self.files_uploading = []
+        self.files_downloading = []
+        self.progress_events = []
+
+    def queue_done(self):
+        """The queue completed all operations."""
+        self.queued_commands.clear()
+
+    def get_notification(self):
+        """Create a new toggleable notification object."""
+        return self.notification_switch.get_notification()
+
+    def download_started(self, command):
+        """A download just started."""
+        self.files_downloading.append(command)
+        self.queued_commands.add(command)
+
+    def download_finished(self, command):
+        """A download just finished."""
+        if command in self.files_downloading:
+            self.files_downloading.remove(command)
+        self.queued_commands.discard(command)
+
+    def upload_started(self, command):
+        """An upload just started."""
+        self.files_uploading.append(command)
+        self.queued_commands.add(command)
+
+    def upload_finished(self, command):
+        """An upload just finished."""
+        if command in self.files_uploading:
+            self.files_uploading.remove(command)
+        self.queued_commands.discard(command)
+
+    def progress_made(self, share_id, node_id, n_bytes, deflated_size):
+        """Progress made on up- or download."""
+        self.progress_events.append(
+            (share_id, node_id, n_bytes, deflated_size))
+
+    def connection_made(self):
+        """The client made the connection to the server."""
+        self.connected = True
+
+    def connection_lost(self):
+        """The client lost the connection to the server."""
+        self.connected = False
+
+
+class StatusFrontendTestCase(BaseTwistedTestCase):
+    """Test the status frontend."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(StatusFrontendTestCase, self).setUp()
+        self.patch(aggregator, "StatusAggregator", FakeAggregator)
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.patch(aggregator, "Messaging", FakeMessaging)
+        self.fakefsm = None
+        self.fakevm = FakeVolumeManager()
+        self.status_frontend = aggregator.StatusFrontend()
+        self.listener = status_listener.StatusListener(self.fakefsm,
+                                                       self.fakevm,
+                                                       self.status_frontend)
+
+    def test_file_published(self):
+        """A file published event is processed."""
+        share_id = "fake share id"
+        node_id = "fake node id"
+        is_public = True
+        public_url = "http://fake_public/url"
+        self.listener.handle_AQ_CHANGE_PUBLIC_ACCESS_OK(share_id, node_id,
+                                                        is_public, public_url)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+
+    def test_file_unpublished(self):
+        """A file unpublished event is processed."""
+        share_id = "fake share id"
+        node_id = "fake node id"
+        is_public = False
+        public_url = None  # SD sends None when unpublishing
+
+        self.listener.handle_AQ_CHANGE_PUBLIC_ACCESS_OK(share_id, node_id,
+                                                        is_public, public_url)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+
+    def test_download_started(self):
+        """A download was added to the queue."""
+        self.patch(status_listener.action_queue, "Download", FakeCommand)
+        fake_command = FakeCommand()
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertIn(fake_command, qc)
+
+    def test_download_started_with_no_deflated_size(self):
+        """A download of unknown size was added to the queue."""
+        self.patch(status_listener.action_queue, "Download", FakeCommand)
+        fake_command = FakeCommand()
+        fake_command.deflated_size = None
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertIn(fake_command, qc)
+
+    def test_download_finished(self):
+        """A download was removed from the queue."""
+        self.patch(status_listener.action_queue, "Download", FakeCommand)
+        fake_command = FakeCommand()
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        self.listener.handle_SYS_QUEUE_REMOVED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertNotIn(fake_command, qc)
+
+    def test_upload_started(self):
+        """An upload was added to the queue."""
+        self.patch(status_listener.action_queue, "Upload", FakeCommand)
+        fake_command = FakeCommand()
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertIn(fake_command, qc)
+
+    def test_upload_started_with_no_deflated_size(self):
+        """An upload of unknown size was added to the queue."""
+        self.patch(status_listener.action_queue, "Upload", FakeCommand)
+        fake_command = FakeCommand()
+        fake_command.deflated_size = None
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertIn(fake_command, qc)
+
+    def test_upload_finished(self):
+        """An upload was removed from the queue."""
+        self.patch(status_listener.action_queue, "Upload", FakeCommand)
+        fake_command = FakeCommand()
+        self.listener.handle_SYS_QUEUE_ADDED(fake_command)
+        self.listener.handle_SYS_QUEUE_REMOVED(fake_command)
+        qc = self.status_frontend.aggregator.queued_commands
+        self.assertNotIn(fake_command, qc)
+
+    def test_progress_made_on_upload(self):
+        """Progress was made on an uploading file."""
+        share_id = 'fake_share'
+        node_id = 'fake_node'
+        n_bytes_written = 100
+        deflated_size = 10000
+        self.listener.handle_AQ_UPLOAD_FILE_PROGRESS(
+            share_id, node_id, n_bytes_written, deflated_size)
+        pe = self.status_frontend.aggregator.progress_events
+        self.assertEqual(
+            [(share_id, node_id, n_bytes_written, deflated_size)], pe,
+            "progress_made was not called (exactly once) on aggregator.")
+
+    def test_progress_made_on_download(self):
+        """Progress was made on an downloading file."""
+        share_id = 'fake_share'
+        node_id = 'fake_node'
+        n_bytes_written = 200
+        deflated_size = 20000
+        self.listener.handle_AQ_DOWNLOAD_FILE_PROGRESS(
+            share_id, node_id, n_bytes_written, deflated_size)
+        pe = self.status_frontend.aggregator.progress_events
+        self.assertEqual(
+            [(share_id, node_id, n_bytes_written, deflated_size)], pe,
+            "progress_made was not called (exactly once) on aggregator.")
+
+    def test_queue_done(self):
+        """The queue is empty."""
+        fake_command = FakeCommand()
+        qc = self.status_frontend.aggregator.queued_commands
+        qc.add(fake_command)
+        self.listener.handle_SYS_QUEUE_DONE()
+        self.assertEqual(0, len(qc))
+
+    def test_new_share_available(self):
+        """A new share is available for subscription."""
+        SHARE_ID = "fake share id"
+        FAKE_SENDER = 'Mom'
+        share = Share(volume_id=SHARE_ID, other_visible_name=FAKE_SENDER)
+        self.fakevm.volumes[SHARE_ID] = share
+        self.listener.handle_VM_SHARE_CREATED(SHARE_ID)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+        msg = self.status_frontend.messaging.messages_shown[FAKE_SENDER]
+        # msg did not receive a time argument
+        self.assertEqual(None, msg[1])
+        # msg did not receive a count argument
+        self.assertEqual(None, msg[2])
+
+    def test_already_subscribed_new_udf_available(self):
+        """A new udf that was already subscribed."""
+        udf = UDF()
+        udf.subscribed = True
+        self.listener.handle_VM_UDF_CREATED(udf)
+        self.assertEqual(
+            0, len(self.status_frontend.notification.notifications_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_updated))
+
+    def test_new_udf_available(self):
+        """A new udf is available for subscription."""
+        udf = UDF()
+        self.listener.handle_VM_UDF_CREATED(udf)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_updated))
+        self.assertEqual(0, len(self.status_frontend.messaging.callbacks))
+
+    def test_two_new_udfs_available(self):
+        """A new udf is available for subscription."""
+        udf1 = UDF()
+        self.listener.handle_VM_UDF_CREATED(udf1)
+        udf2 = UDF()
+        self.listener.handle_VM_UDF_CREATED(udf2)
+        self.assertEqual(
+            2, len(self.status_frontend.notification.notifications_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_shown))
+        self.assertEqual(
+            0, len(self.status_frontend.messaging.messages_updated))
+
+    def test_server_connection_lost(self):
+        """The client connected to the server."""
+        self.status_frontend.aggregator.connected = True
+        self.listener.handle_SYS_CONNECTION_LOST()
+        self.assertEqual(
+            0, len(self.status_frontend.notification.notifications_shown))
+        self.assertFalse(self.status_frontend.aggregator.connected)
+
+    def test_server_connection_made(self):
+        """The client connected to the server."""
+        self.status_frontend.aggregator.connected = False
+        self.listener.handle_SYS_CONNECTION_MADE()
+        self.assertEqual(
+            0, len(self.status_frontend.notification.notifications_shown))
+        self.assertTrue(self.status_frontend.aggregator.connected)
+
+    def test_set_show_all_notifications(self):
+        """Test the set_show_all_notifications method."""
+        self.status_frontend.set_show_all_notifications(False)
+        self.assertFalse(self.status_frontend.aggregator.
+                         notification_switch.enabled)
+
+    def test_udf_quota_exceeded(self):  # pylint: disable=R0201
+        """Quota exceeded in udf."""
+        mocker = Mocker()
+        launcher = mocker.replace(
+            "ubuntuone.platform.launcher.UbuntuOneLauncher")
+        launcher()
+        mock_launcher = mocker.mock()
+        mocker.result(mock_launcher)
+        mock_launcher.set_urgent()
+        mocker.replay()
+        UDF_ID = 'fake udf id'
+        udf = UDF(volume_id=UDF_ID)
+        self.fakevm.volumes[UDF_ID] = udf
+        self.listener.handle_SYS_QUOTA_EXCEEDED(
+            volume_id=UDF_ID, free_bytes=0)
+        self.assertEqual(
+            0, len(self.status_frontend.notification.notifications_shown))
+        mocker.restore()
+        mocker.verify()
+
+    def test_root_quota_exceeded(self):  # pylint: disable=R0201
+        """Quota exceeded in root."""
+        mocker = Mocker()
+        launcher = mocker.replace(
+            "ubuntuone.platform.launcher.UbuntuOneLauncher")
+        launcher()
+        mock_launcher = mocker.mock()
+        mocker.result(mock_launcher)
+        mock_launcher.set_urgent()
+        mocker.replay()
+        ROOT_ID = 'fake root id'
+        root = Root(volume_id=ROOT_ID)
+        self.fakevm.volumes[ROOT_ID] = root
+        self.fakevm.root = root
+        self.listener.handle_SYS_QUOTA_EXCEEDED(
+            volume_id=ROOT_ID, free_bytes=0)
+        self.assertEqual(
+            0, len(self.status_frontend.notification.notifications_shown))
+        mocker.restore()
+        mocker.verify()
+
+    def test_share_quota_exceeded(self):
+        """Quota exceeded in share."""
+        mocker = Mocker()
+        launcher = mocker.replace(
+            "ubuntuone.platform.launcher.UbuntuOneLauncher")
+        launcher()
+        mock_launcher = mocker.mock()
+        mocker.result(mock_launcher)
+        mock_launcher.set_urgent()
+        launcher()
+        mock_launcher = mocker.mock()
+        mocker.result(mock_launcher)
+        mock_launcher.set_urgent()
+        mocker.replay()
+        SHARE_ID = 'fake share id'
+        BYTES = 0
+        share = Share(volume_id=SHARE_ID)
+        self.fakevm.volumes[SHARE_ID] = share
+        self.listener.handle_SYS_QUOTA_EXCEEDED(SHARE_ID, BYTES)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+        self.listener.handle_SYS_QUOTA_EXCEEDED(SHARE_ID, BYTES)
+        self.listener.handle_SYS_QUOTA_EXCEEDED(SHARE_ID, BYTES)
+        self.assertEqual(
+            1, len(self.status_frontend.notification.notifications_shown))
+        self.status_frontend.aggregator.clock.advance(aggregator.ONE_DAY + 1)
+        self.listener.handle_SYS_QUOTA_EXCEEDED(SHARE_ID, BYTES)
+        self.assertEqual(
+            2, len(self.status_frontend.notification.notifications_shown))
+        mocker.restore()
+        mocker.verify()
+
+
+class StatusEventTestCase(TestCase):
+    """Test the status event class and children."""
+
+    CLASS = aggregator.StatusEvent
+    CLASS_KWARGS = {}
+    status = None
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(StatusEventTestCase, self).setUp()
+        if type(self) == StatusEventTestCase:
+            self.assertRaises(AssertionError, self.CLASS, **self.CLASS_KWARGS)
+        else:
+            self.status = self.CLASS(**self.CLASS_KWARGS)
+
+    def test_one_message_defined(self):
+        """The singular message is defined as MESSAGE_ONE."""
+        if self.status:
+            self.assertNotEqual(None, self.CLASS.MESSAGE_ONE)
+
+    def test_one_message_built_correctly(self):
+        """The message returned by one() is returned ok."""
+        if self.status:
+            self.assertEqual(self.status.one(), self.CLASS.MESSAGE_ONE)
+
+
+class FilePublishingStatusTestCase(StatusEventTestCase):
+    """Test the file publishing status class."""
+
+    CLASS = aggregator.FilePublishingStatus
+    CLASS_KWARGS = {"new_public_url": "http://fake_public/url"}
+
+    def test_one_message_built_correctly(self):
+        """The message returned by one() should include the url."""
+        expected = self.CLASS.MESSAGE_ONE % self.status.kwargs
+        self.assertEqual(self.status.one(), expected)
+
+
+class FileUnpublishingStatusTestCase(StatusEventTestCase):
+    """Test the file unpublishing status class."""
+
+    CLASS = aggregator.FileUnpublishingStatus
+    CLASS_KWARGS = {"old_public_url": None}
+
+
+class ShareAvailableEventTestCase(StatusEventTestCase):
+    """Test the folder available status class with a Share."""
+
+    FOLDER_NAME = "folder name"
+    OTHER_USER_NAME = "person name"
+    SAMPLE_SHARE = Share(accepted=False, name=FOLDER_NAME,
+                         other_visible_name=OTHER_USER_NAME)
+    CLASS = aggregator.ShareAvailableStatus
+    CLASS_KWARGS = {"share": SAMPLE_SHARE}
+
+    def test_one_message_built_correctly(self):
+        """one() must return the folder name and user name."""
+        format_args = {
+            "folder_name": self.FOLDER_NAME,
+            "other_user_name": self.OTHER_USER_NAME,
+        }
+        expected = self.CLASS.MESSAGE_ONE % format_args
+        self.assertEqual(self.status.one(), expected)
+
+
+class UDFAvailableEventTestCase(StatusEventTestCase):
+    """Test the folder available status class with a UDF."""
+
+    FOLDER_NAME = "folder name"
+    SAMPLE_UDF = UDF(subscribed=False, suggested_path=FOLDER_NAME)
+    CLASS = aggregator.UDFAvailableStatus
+    CLASS_KWARGS = {'udf': SAMPLE_UDF}
+
+    def test_one_message_built_correctly(self):
+        """one() must return the folder name."""
+        format_args = {"folder_name": self.FOLDER_NAME}
+        expected = self.CLASS.MESSAGE_ONE % format_args
+        self.assertEqual(self.status.one(), expected)
+
+
+class ConnectionLostEventTestCase(StatusEventTestCase):
+    """Test the event when the connection is lost."""
+
+    CLASS = aggregator.ConnectionLostStatus
+
+    def test_many_message_built_correctly(self):
+        """The message returned by many() is returned ok."""
+        if self.status:
+            count = 99
+            test_events = [FakeStatus(88)] * count + [self.CLASS()]
+            expected = self.CLASS.MESSAGE_ONE
+            self.assertEqual(self.status.many(test_events), expected)
+
+
+class ConnectionMadeEventTestCase(ConnectionLostEventTestCase):
+    """Test the event when the connection is made."""
+
+    CLASS = aggregator.ConnectionMadeStatus
+
+
+class FakeStatus(aggregator.StatusEvent):
+    """A fake status to test weight comparisons."""
+
+    def __init__(self, weight):
+        """Initialize with the fake weight."""
+        super(FakeStatus, self).__init__()
+        self.WEIGHT = weight
+
+
+class FakeFileDiscoveryBubble(object):
+    """A fake FileDiscoveryBubble."""
+
+    count = 0
+
+    def __init__(self, status_aggregator, clock=None):
+        """Initialize this instance."""
+        self.status_aggregator = status_aggregator
+
+    def new_file_found(self):
+        """New files were found."""
+        self.count += 1
+
+    def cleanup(self):
+        """Cleanup this instance."""
+
+    def connection_made(self):
+        """Connection made."""
+
+    def connection_lost(self):
+        """Connection lost."""
+
+
+class FakeFinalBubble(object):
+    """A fake FinalStatusBubble."""
+
+    shown = False
+
+    def __init__(self, status_aggregator):
+        """Initialize this fake instance."""
+        self.status_aggregator = status_aggregator
+
+    def cleanup(self):
+        """Cleanup this instance."""
+
+    def show(self):
+        """Show this bubble."""
+        self.shown = True
+
+
+class StatusAggregatorTestCase(TestCase):
+    """Test the backend of the status aggregator."""
+
+    @defer.inlineCallbacks
+    def setUp(self):
+        """Initialize this test instance."""
+        yield super(StatusAggregatorTestCase, self).setUp()
+        self.patch(aggregator, "FileDiscoveryBubble",
+                   FakeFileDiscoveryBubble)
+        self.patch(aggregator, "FinalStatusBubble",
+                   FakeFinalBubble)
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.patch(aggregator, "UbuntuOneLauncher", FakeLauncher)
+        self.patch(aggregator.session, "Inhibitor", FakeInhibitor)
+        clock = PatchedClock()
+        self.status_frontend = aggregator.StatusFrontend(clock=clock)
+        self.aggregator = self.status_frontend.aggregator
+        self.fake_bubble = self.aggregator.file_discovery_bubble
+
+        self.handler = MementoHandler()
+        self.handler.setLevel(logging.DEBUG)
+        aggregator.logger.addHandler(self.handler)
+        aggregator.logger.setLevel(logging.DEBUG)
+        self.addCleanup(aggregator.logger.removeHandler, self.handler)
+        self.addCleanup(self.aggregator.progress_bar.cleanup)
+
+    def assertStatusReset(self):
+        """Assert that the status is at zero."""
+        self.assertEqual(0, self.aggregator.download_done)
+        self.assertEqual(0, self.aggregator.upload_done)
+        self.assertEqual(0, len(self.aggregator.files_uploading))
+        self.assertEqual(0, len(self.aggregator.files_downloading))
+        self.assertEqual({}, self.aggregator.progress)
+        self.assertEqual({}, self.aggregator.to_do)
+        self.assertIdentical(None, self.aggregator.queue_done_timer)
+
+    def assertMiscCommandQueued(self, fc):
+        """Assert that some command was queued."""
+        self.assertEqual(len(self.aggregator.to_do), 1)
+        message = "queueing command (total: 1): %s" % fc.__class__.__name__
+        self.assertEqual(fc.deflated_size, sum(self.aggregator.to_do.values()))
+        self.assertTrue(self.handler.check_debug(message))
+        self.assertTrue(self.aggregator.progress_bar.visible)
+
+    def assertMiscCommandUnqueued(self, fc):
+        """Assert that some command was unqueued."""
+        self.assertEqual(
+            1, self.aggregator.download_done + self.aggregator.upload_done)
+        message = "unqueueing command: %s" % fc.__class__.__name__
+        self.assertTrue(self.handler.check_debug(message))
+
+    def test_counters_start_at_zero(self):
+        """Test that the counters start at zero."""
+        self.assertStatusReset()
+
+    def test_file_download_started(self):
+        """Test that a file has started download."""
+        fc = FakeCommand(path='testfile.txt')
+        self.assertEqual('', self.aggregator.downloading_filename)
+        self.status_frontend.download_started(fc)
+        self.assertEqual(1, len(self.aggregator.files_downloading))
+        self.assertEqual('testfile.txt', self.aggregator.downloading_filename)
+        self.assertMiscCommandQueued(fc)
+        self.assertEqual(1, self.fake_bubble.count)
+        self.assertEqual(
+            {(fc.share_id, fc.node_id): (fc.deflated_size)},
+            self.aggregator.to_do)
+
+    def test_file_download_finished(self):
+        """Test that a file has finished downloading."""
+        fc = FakeCommand()
+        self.status_frontend.download_started(fc)
+        self.status_frontend.download_finished(fc)
+        self.assertEqual(self.aggregator.download_done, 1)
+        self.assertMiscCommandUnqueued(fc)
+        self.assertEqual(
+            {(fc.share_id, fc.node_id): (fc.deflated_size)},
+            self.aggregator.progress)
+
+    def test_file_upload_started(self):
+        """Test that a file has started upload."""
+        fc = FakeCommand(path='testfile.txt')
+        self.assertEqual('', self.aggregator.uploading_filename)
+        self.status_frontend.upload_started(fc)
+        self.assertEqual(1, len(self.aggregator.files_uploading))
+        self.assertEqual('testfile.txt', self.aggregator.uploading_filename)
+        self.assertMiscCommandQueued(fc)
+        self.assertEqual(1, self.fake_bubble.count)
+        self.assertEqual(
+            {(fc.share_id, fc.node_id): (fc.deflated_size)},
+            self.aggregator.to_do)
+
+    def test_file_upload_finished(self):
+        """Test that a file has finished uploading."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        self.status_frontend.upload_finished(fc)
+        self.assertEqual(self.aggregator.upload_done, 1)
+        self.assertMiscCommandUnqueued(fc)
+        self.assertEqual(
+            {(fc.share_id, fc.node_id): (fc.deflated_size)},
+            self.aggregator.progress)
+
+    def test_progress_made(self):
+        """Progress on up and downloads is tracked."""
+        share_id = 'fake_share'
+        node_id = 'fake_node'
+        n_bytes_written = 200
+        deflated_size = 100000
+        self.aggregator.progress_made(
+            share_id, node_id, n_bytes_written, deflated_size)
+        self.assertEqual(
+            {(share_id, node_id): (n_bytes_written)},
+            self.aggregator.progress)
+
+    def test_get_discovery_message(self):
+        """Test the message that's shown on the discovery bubble."""
+        uploading = 10
+        downloading = 8
+        filename = 'upfile0.ext'
+        filename2 = 'downfile0.ext'
+        self.aggregator.files_uploading.extend([
+            FakeCommand(path='upfile%d.ext' % n) for n in range(uploading)])
+        self.aggregator.uploading_filename = filename
+        self.aggregator.files_downloading.extend([
+            FakeCommand(path='downfile%d.ext' % n) for n in
+            range(downloading)])
+        self.aggregator.downloading_filename = filename2
+        expected = (
+            aggregator.files_being_uploaded(filename, uploading) + "\n" +
+            aggregator.files_being_downloaded(filename2, downloading))
+        result = self.aggregator.get_discovery_message()
+        self.assertEqual(expected, result)
+
+    def test_get_final_status_message(self):
+        """The final status message."""
+        done = (5, 10)
+        self.aggregator.uploading_filename = FILENAME
+        self.aggregator.downloading_filename = FILENAME2
+        self.aggregator.upload_done, self.aggregator.download_done = done
+
+        expected = (
+            aggregator.FINAL_COMPLETED + "\n" +
+            aggregator.files_were_uploaded(
+                FILENAME, self.aggregator.upload_done) + "\n" +
+            aggregator.files_were_downloaded(
+                FILENAME2, self.aggregator.download_done))
+
+        result = self.aggregator.get_final_status_message()
+        self.assertEqual(expected, result)
+
+    def test_get_final_status_message_no_uploads(self):
+        """The final status message when there were no uploads."""
+        done = (0, 12)
+        self.aggregator.upload_done, self.aggregator.download_done = done
+        self.aggregator.downloading_filename = FILENAME2
+
+        expected = (
+            aggregator.FINAL_COMPLETED + "\n" +
+            aggregator.files_were_downloaded(
+                FILENAME2, self.aggregator.download_done))
+
+        result = self.aggregator.get_final_status_message()
+        self.assertEqual(expected, result)
+
+    def test_get_final_status_message_no_downloads(self):
+        """The final status message when there were no downloads."""
+        done = (8, 0)
+        self.aggregator.upload_done, self.aggregator.download_done = done
+        self.aggregator.uploading_filename = FILENAME
+
+        expected = (
+            aggregator.FINAL_COMPLETED + "\n" +
+            aggregator.files_were_uploaded(
+                FILENAME, self.aggregator.upload_done))
+
+        result = self.aggregator.get_final_status_message()
+        self.assertEqual(expected, result)
+
+    def test_queue_done_shows_bubble_when_downloads_happened(self):
+        """On queue done, show final bubble if downloads happened."""
+        fc = FakeCommand()
+        self.status_frontend.download_started(fc)
+        self.status_frontend.download_finished(fc)
+        old_final_bubble = self.aggregator.final_status_bubble
+        self.aggregator.queue_done()
+        self.aggregator.clock.advance(self.aggregator.finished_delay + 1)
+        self.assertTrue(old_final_bubble.shown)
+
+    def test_queue_done_shows_bubble_when_uploads_happened(self):
+        """On queue done, show final bubble if uploads happened."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        self.status_frontend.upload_finished(fc)
+        old_final_bubble = self.aggregator.final_status_bubble
+        self.aggregator.queue_done()
+        self.aggregator.clock.advance(self.aggregator.finished_delay + 1)
+        self.assertTrue(old_final_bubble.shown)
+
+    def test_queue_done_shows_bubble_only_after_delay(self):
+        """On queue_done, show final bubble only after a delay."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        self.status_frontend.upload_finished(fc)
+        old_final_bubble = self.aggregator.final_status_bubble
+        self.aggregator.queue_done()
+        self.assertFalse(old_final_bubble.shown)
+        self.aggregator.clock.advance(self.aggregator.finished_delay - 1)
+        self.assertFalse(old_final_bubble.shown)
+        self.aggregator.queue_done()
+        self.assertFalse(old_final_bubble.shown)
+        self.aggregator.clock.advance(2)
+        self.assertFalse(old_final_bubble.shown)
+        self.aggregator.clock.advance(self.aggregator.finished_delay + 1)
+        self.assertTrue(old_final_bubble.shown)
+
+    def test_queue_done_does_not_show_bubble_when_no_transfers_happened(self):
+        """On queue done, don't show final bubble if no transfers happened."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        old_final_bubble = self.aggregator.final_status_bubble
+        self.aggregator.queue_done()
+        self.assertFalse(old_final_bubble.shown)
+
+    def test_queue_done_resets_status_and_hides_progressbar(self):
+        """On queue done, reset counters and hide progressbar."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        self.aggregator.queue_done()
+        self.aggregator.clock.advance(self.aggregator.finished_delay + 1)
+        self.assertStatusReset()
+        self.assertEqual(0.0, self.aggregator.progress_bar.progress)
+        self.assertFalse(self.aggregator.progress_bar.visible)
+
+    def test_download_started_cancels_timer(self):
+        """Starting a download cancels the queue_done timer."""
+        fc = FakeCommand()
+        self.status_frontend.download_started(fc)
+        self.aggregator.clock.advance(self.aggregator.finished_delay)
+        self.status_frontend.download_finished(fc)
+        self.aggregator.queue_done()
+        self.aggregator.clock.advance(self.aggregator.finished_delay / 2)
+        fc2 = FakeCommand()
+        self.status_frontend.download_started(fc2)
+        self.assertIdentical(self.aggregator.queue_done_timer, None)
+        self.aggregator.clock.advance(self.aggregator.finished_delay)
+        self.status_frontend.download_finished(fc2)
+
+    def test_upload_started_cancels_timer(self):
+        """Starting an upload cancels the queue_done timer."""
+        fc = FakeCommand()
+        self.status_frontend.upload_started(fc)
+        self.aggregator.clock.advance(self.aggregator.finished_delay)
+        self.status_frontend.upload_finished(fc)
+        self.aggregator.queue_done()
+        self.aggregator.clock.advance(self.aggregator.finished_delay / 2)
+        fc2 = FakeCommand()
+        self.status_frontend.upload_started(fc2)
+        self.assertIdentical(self.aggregator.queue_done_timer, None)
+        self.aggregator.clock.advance(self.aggregator.finished_delay)
+        self.status_frontend.upload_finished(fc2)
+
+
+class StatusGrouperTestCase(TestCase):
+    """Tests for the group_statuses function."""
+
+    def test_group_status(self):
+        """The status grouper sorts and groups by weight."""
+        status99 = FakeStatus(99)
+        statuses = [
+            status99,
+            status99,
+            FakeStatus(12),
+            FakeStatus(1)]
+
+        result = [list(k) for _, k in aggregator.group_statuses(statuses)]
+        expected = [
+            [statuses[3]],
+            [statuses[2]],
+            [status99, status99]]
+
+        self.assertEqual(result, expected)
+
+
+class HundredFeetTestCase(TestCase):
+    """Try to make all parts work together."""
+
+    def test_all_together_now(self):
+        """Make all parts work together."""
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.patch(aggregator, "UbuntuOneLauncher", FakeLauncher)
+        self.patch(aggregator.session, "Inhibitor", FakeInhibitor)
+        clock = PatchedClock()
+        upload = FakeCommand(path='upload.foo')
+        sf = aggregator.StatusFrontend(clock=clock)
+        sf.server_connection_made()
+        sf.set_show_all_notifications(True)
+
+        # the progress bar is not visible yet
+        self.assertFalse(sf.aggregator.progress_bar.visible)
+        sf.upload_started(upload)
+        # the progress bar is now shown
+        self.assertTrue(sf.aggregator.progress_bar.visible)
+        notifications_shown = (sf.aggregator.file_discovery_bubble.
+                                             notification.notifications_shown)
+        # no notifications shown yet
+        self.assertEqual(0, len(notifications_shown))
+        clock.advance(aggregator.FileDiscoveryGatheringState.initial_delay)
+        # files found notification
+        self.assertEqual(1, len(notifications_shown))
+        download = FakeCommand('download.bar')
+        sf.download_started(download)
+        self.assertEqual(1, len(notifications_shown))
+        # the progress still is zero
+        self.assertEqual(0.0, sf.aggregator.progress_bar.progress)
+        clock.advance(aggregator.FileDiscoveryUpdateState.updates_delay)
+        # files count update
+        self.assertEqual(2, len(notifications_shown))
+        clock.advance(aggregator.FileDiscoveryUpdateState.updates_timeout -
+                      aggregator.FileDiscoveryUpdateState.updates_delay)
+        sf.upload_finished(upload)
+        sf.download_finished(download)
+        # the progress still is now 100%
+        self.assertEqual(1.0, sf.aggregator.progress_bar.progress)
+        sf.queue_done()
+        clock.advance(sf.aggregator.finished_delay + 1)
+        self.assertEqual(3, len(notifications_shown))
+
+    def test_all_together_now_off(self):
+        """Make all parts work together, but with notifications off."""
+        self.patch(aggregator, "ToggleableNotification",
+                   FakeNotificationSingleton())
+        self.patch(aggregator, "UbuntuOneLauncher", FakeLauncher)
+        self.patch(aggregator.session, "Inhibitor", FakeInhibitor)
+        clock = PatchedClock()
+        upload = FakeCommand('upload.foo')
+        sf = aggregator.StatusFrontend(clock=clock)
+        sf.set_show_all_notifications(False)
+
+        # the progress bar is not visible yet
+        self.assertFalse(sf.aggregator.progress_bar.visible)
+        sf.upload_started(upload)
+        # the progress bar is now shown
+        self.assertTrue(sf.aggregator.progress_bar.visible)
+        notifications_shown = (sf.aggregator.file_discovery_bubble.
+                                             notification.notifications_shown)
+        # no notifications shown, never
+        self.assertEqual(0, len(notifications_shown))
+        clock.advance(aggregator.FileDiscoveryGatheringState.initial_delay)
+        self.assertEqual(0, len(notifications_shown))
+        download = FakeCommand('download.bar')
+        sf.download_started(download)
+        self.assertEqual(0, len(notifications_shown))
+        # the progress still is zero
+        self.assertEqual(0.0, sf.aggregator.progress_bar.progress)
+        clock.advance(aggregator.FileDiscoveryUpdateState.updates_delay)
+        self.assertEqual(0, len(notifications_shown))
+        clock.advance(aggregator.FileDiscoveryUpdateState.updates_timeout -
+                      aggregator.FileDiscoveryUpdateState.updates_delay)
+        sf.upload_finished(upload)
+        sf.download_finished(download)
+        # the progress still is now 100%
+        self.assertEqual(1.0, sf.aggregator.progress_bar.progress)
+        self.assertEqual(0, len(notifications_shown))
+        sf.queue_done()
+        self.assertEqual(0, len(notifications_shown))
 
=== added directory '.pc/03_reset_notify_name.patch/ubuntuone'
=== added directory '.pc/03_reset_notify_name.patch/ubuntuone/status'
=== added file '.pc/03_reset_notify_name.patch/ubuntuone/status/aggregator.py'
--- .pc/03_reset_notify_name.patch/ubuntuone/status/aggregator.py	1970-01-01 00:00:00 +0000
+++ .pc/03_reset_notify_name.patch/ubuntuone/status/aggregator.py	2011-12-14 21:11:28 +0000
@@ -0,0 +1,882 @@
+# ubuntuone.status.aggregator
+#
+# Author: Alejandro J. Cura <[e-mail]>
+#
+# Copyright 2011 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/>.
+"""Aggregate status events."""
+
+import itertools
+import operator
+import os
+
+
+import gettext
+
+from twisted.internet import reactor, defer
+
+from ubuntuone.clientdefs import GETTEXT_PACKAGE
+from ubuntuone.status.logger import logger
+from ubuntuone.platform import session
+from ubuntuone.platform.notification import Notification
+from ubuntuone.platform.messaging import Messaging
+from ubuntuone.platform.launcher import UbuntuOneLauncher, DummyLauncher
+
+ONE_DAY = 24 * 60 * 60
+Q_ = lambda string: gettext.dgettext(GETTEXT_PACKAGE, string)
+
+UBUNTUONE_TITLE = Q_("Ubuntu One")
+NEW_UDFS_SENDER = Q_("New cloud folder(s) available")
+FINAL_COMPLETED = Q_("File synchronization completed.")
+
+PROGRESS_COMPLETED = Q_("%(percentage_completed)d%% completed.")
+FILE_SYNC_IN_PROGRESS = Q_("File synchronization in progress")
+
+SHARE_QUOTA_EXCEEDED = Q_(
+    'There is no available space on the folder:\n"%s" shared by %s')
+
+
+def alert_user():
+    """Set the launcher to urgent to alert the user."""
+    launcher = UbuntuOneLauncher()
+    launcher.set_urgent()
+
+
+def files_being_uploaded(filename, files_uploading):
+    """Get the i18n string for files being uploaded."""
+    other_files = files_uploading - 1
+    if other_files < 1:
+        return Q_(
+            "'%(filename)s' is being uploaded to your personal cloud.") % {
+            'filename': filename}
+    format_args = {
+        "filename": filename, "other_files": other_files}
+    return gettext.dngettext(
+        GETTEXT_PACKAGE,
+        "'%(filename)s' and %(other_files)d other file are being "
+        "uploaded to your personal cloud.",
+        "'%(filename)s' and %(other_files)d other files are being "
+        "uploaded to your personal cloud.", other_files) % format_args
+
+
+def files_being_downloaded(filename, files_downloading):
+    """Get the i18n string for files being downloaded."""
+    other_files = files_downloading - 1
+    if other_files < 1:
+        return Q_(
+            "'%(filename)s' is being downloaded to your computer.") % {
+            'filename': filename}
+    format_args = {
+        "filename": filename, "other_files": other_files}
+    return gettext.dngettext(
+        GETTEXT_PACKAGE,
+        "'%(filename)s' and %(other_files)d other file are being "
+        "downloaded to your computer.",
+        "'%(filename)s' and %(other_files)d other files are being "
+        "downloaded to your computer.", other_files) % format_args
+
+
+def files_were_uploaded(filename, upload_done):
+    """Get the i18n string for files that were uploaded."""
+    other_files = upload_done - 1
+    if other_files < 1:
+        return Q_(
+            "'%(filename)s' was uploaded to your personal cloud.") % {
+            'filename': filename}
+    format_args = {
+        'filename': filename, 'other_files': other_files}
+    return gettext.dngettext(
+        GETTEXT_PACKAGE,
+        "'%(filename)s' and %(other_files)d other file were uploaded to "
+        "your personal cloud.",
+        "'%(filename)s' and %(other_files)d other files were uploaded "
+        "to your personal cloud.", other_files) % format_args
+
+
+def files_were_downloaded(filename, download_done):
+    """Get the i18n string for files that were downloaded."""
+    other_files = download_done - 1
+    if other_files < 1:
+        return Q_(
+            "'%(filename)s' was downloaded to your computer.") % {
+            'filename': filename}
+    format_args = {
+        'filename': filename, 'other_files': other_files}
+    return gettext.dngettext(
+        GETTEXT_PACKAGE,
+        "'%(filename)s' and %(other_files)d other file were "
+        "downloaded to your computer.",
+        "'%(filename)s' and %(other_files)d other files were "
+        "downloaded to your computer.", other_files) % format_args
+
+
+class ToggleableNotification(object):
+    """A controller for notifications that can be turned off."""
+
+    def __init__(self, notification_switch):
+        """Initialize this instance."""
+        self.notification_switch = notification_switch
+        self.notification = Notification()
+
+    def send_notification(self, *args):
+        """Passthru the notification."""
+        if self.notification_switch.enabled:
+            return self.notification.send_notification(*args)
+
+
+class NotificationSwitch(object):
+    """A switch that turns notifications on and off."""
+
+    enabled = True
+
+    def __init__(self):
+        self.toggleable_notification = ToggleableNotification(self)
+
+    def get_notification(self):
+        """Return a new notification instance."""
+        return self.toggleable_notification
+
+    def enable_notifications(self):
+        """Turn the switch on."""
+        self.enabled = True
+
+    def disable_notifications(self):
+        """Turn the switch off."""
+        self.enabled = False
+
+
+class StatusEvent(object):
+    """An event representing a status change."""
+
+    MESSAGE_ONE = None  # to be defined in child classes
+    WEIGHT = 99
+    DO_NOT_INSTANCE = "Do not instance this class, only children."""
+
+    def __init__(self, **kwargs):
+        """Initialize this instance."""
+        assert type(self) != StatusEvent, self.DO_NOT_INSTANCE
+        self.kwargs = kwargs
+
+    def one(self):
+        """A message if this is the only event of this type."""
+        return self.MESSAGE_ONE
+
+
+class FilePublishingStatus(StatusEvent):
+    """Files that are made public with a url."""
+
+    MESSAGE_ONE = Q_("A file was just made public at %(new_public_url)s")
+
+    WEIGHT = 50
+
+    def one(self):
+        """Show the url if only one event of this type."""
+        return self.MESSAGE_ONE % self.kwargs
+
+    def many(self, events):
+        """Show the number of files if many event of this type."""
+        no_of_files = len(events)
+        gettext.dngettext(
+            GETTEXT_PACKAGE,
+            "%(event_count)d file was just made public.",
+            "%(event_count)d files were just made public.",
+            no_of_files) % {'event_count': no_of_files}
+
+
+class FileUnpublishingStatus(StatusEvent):
+    """Files that have stopped being published."""
+
+    MESSAGE_ONE = Q_("A file is no longer published")
+    WEIGHT = 51
+
+    def many(self, events):
+        """Show the number of files if many event of this type."""
+        no_of_files = len(events)
+        gettext.dngettext(
+            GETTEXT_PACKAGE,
+            "%(event_count)d file is no longer published.",
+            "%(event_count)d files are no longer published.",
+            no_of_files) % {'event_count': no_of_files}
+
+
+class FolderAvailableStatus(StatusEvent):
+    """Folders available for subscription."""
+
+    WEIGHT = 60
+
+    def many(self, events):
+        """Show the number of files if many event of this type."""
+        no_of_files = len(events)
+        gettext.dngettext(
+            GETTEXT_PACKAGE,
+            "Found %(event_count)d new cloud folder.",
+            "Found %(event_count)d new cloud folders.",
+            no_of_files) % {'event_count': no_of_files}
+
+
+class ShareAvailableStatus(FolderAvailableStatus):
+    """A Share is available for subscription."""
+
+    MESSAGE_ONE = Q_("New cloud folder available: '%(folder_name)s' "
+                     "shared by %(other_user_name)s")
+
+    def one(self):
+        """Show the folder information."""
+        volume = self.kwargs["share"]
+        format_args = {
+            "folder_name": volume.name,
+            "other_user_name": volume.other_visible_name,
+        }
+        return self.MESSAGE_ONE % format_args
+
+
+class UDFAvailableStatus(FolderAvailableStatus):
+    """An UDF is available for subscription."""
+
+    MESSAGE_ONE = Q_("New cloud folder available: '%(folder_name)s'")
+
+    def one(self):
+        """Show the folder information."""
+        volume = self.kwargs["udf"]
+        format_args = {"folder_name": volume.suggested_path}
+        return self.MESSAGE_ONE % format_args
+
+
+class ConnectionStatusEvent(StatusEvent):
+    """The connection to the server changed status."""
+
+    WEIGHT = 30
+
+    def many(self, events):
+        """Only the last message if there are many events of this type."""
+        return events[-1].one()
+
+
+class ConnectionLostStatus(ConnectionStatusEvent):
+    """The connection to the server was lost."""
+
+    MESSAGE_ONE = Q_("The connection to the server was lost.")
+
+
+class ConnectionMadeStatus(ConnectionStatusEvent):
+    """The connection to the server was made."""
+
+    MESSAGE_ONE = Q_("The connection to the server was restored.")
+
+
+class Timer(defer.Deferred):
+    """A deferred that fires past a given delay."""
+
+    def __init__(self, delay, clock=reactor):
+        """Initialize this instance."""
+        defer.Deferred.__init__(self)
+        self.clock = clock
+        self.delay = delay
+        self.delay_call = self.clock.callLater(delay, self.callback)
+
+    def cancel_if_active(self, call):
+        """Cancel a call if it is active."""
+        if call.active():
+            call.cancel()
+
+    def cleanup(self):
+        """Cancel all active calls."""
+        self.cancel_if_active(self.delay_call)
+
+    def callback(self, result=None):
+        """Make sure the timers are stopped when firing the callback."""
+        self.cleanup()
+        defer.Deferred.callback(self, result)
+
+    def reset(self):
+        """Reset the delay."""
+        if not self.called:
+            self.delay_call.reset(self.delay)
+
+    @property
+    def active(self):
+        """Is the delay still active."""
+        return self.delay_call.active()
+
+
+class DeadlineTimer(Timer):
+    """A Timer with a deadline."""
+
+    def __init__(self, delay, timeout=None, clock=reactor):
+        """Initialize this instance."""
+        Timer.__init__(self, delay, clock)
+        self.timeout = timeout
+        self.timeout_call = self.clock.callLater(timeout, self.callback)
+
+    def cleanup(self):
+        """Cancel all active calls."""
+        Timer.cleanup(self)
+        self.cancel_if_active(self.timeout_call)
+
+
+class FileDiscoveryBaseState(object):
+    """States for file discovery bubble."""
+
+    def __init__(self, bubble):
+        """Initialize this instance."""
+        self.bubble = bubble
+        self.clock = bubble.clock
+
+    def new_file_found(self):
+        """New files found."""
+
+    def cleanup(self):
+        """Cleanup this instance."""
+
+
+class FileDiscoveryIdleState(FileDiscoveryBaseState):
+    """Waiting for first file to appear."""
+
+    def new_file_found(self):
+        """New files found."""
+        self.bubble._start()
+
+
+class FileDiscoveryGatheringState(FileDiscoveryBaseState):
+    """Files are gathered then a notification is shown."""
+
+    initial_delay = 0.5
+    initial_timeout = 3.0
+
+    def __init__(self, *args):
+        """Initialize this instance."""
+        super(FileDiscoveryGatheringState, self).__init__(*args)
+        self.timer = DeadlineTimer(self.initial_delay,
+                                 self.initial_timeout,
+                                 clock=self.clock)
+        self.timer.addCallback(self._timeout)
+
+    def _timeout(self, result):
+        """Show the notification bubble."""
+        self.cleanup()
+        self.bubble._popup()
+
+    def new_file_found(self):
+        """New files found."""
+        self.timer.reset()
+
+    def cleanup(self):
+        """Cleanup this instance."""
+        self.timer.cleanup()
+
+
+class FileDiscoveryUpdateState(FileDiscoveryBaseState):
+    """The bubble is updated if more files are found."""
+
+    updates_delay = 0.5
+    updates_timeout = 10.0
+
+    def __init__(self, *args):
+        """Initialize this instance."""
+        super(FileDiscoveryUpdateState, self).__init__(*args)
+        self.main_timer = Timer(self.updates_timeout, clock=self.clock)
+        self.main_timer.addCallback(self._timeout)
+        self.updates_timer = None
+
+    def _timeout(self, result):
+        """No more updates on the notification bubble."""
+        self.cleanup()
+        self.bubble.start_sleeping()
+
+    def _update(self, result):
+        """The bubble should be updated."""
+        self.bubble._update()
+
+    def new_file_found(self):
+        """New files found."""
+        if self.updates_timer is None:
+            self.updates_timer = Timer(self.updates_delay, clock=self.clock)
+            self.updates_timer.addCallback(self._update)
+
+    def cleanup(self):
+        """Clean up the timers."""
+        self.main_timer.cleanup()
+        if self.updates_timer:
+            self.updates_timer.cleanup()
+
+
+class FileDiscoverySleepState(FileDiscoveryBaseState):
+    """The bubble is not updated while sleeping."""
+
+    sleep_delay = 300.0
+
+    def __init__(self, *args):
+        """Initialize this instance."""
+        super(FileDiscoverySleepState, self).__init__(*args)
+        self.main_timer = Timer(self.sleep_delay, clock=self.clock)
+        self.main_timer.addCallback(self._timeout)
+
+    def _timeout(self, result):
+        """Move the notification to the idle state."""
+        self.bubble._set_idle()
+
+    def cleanup(self):
+        """Clean up the timers."""
+        self.main_timer.cleanup()
+
+
+class FileDiscoveryBubble(object):
+    """
+    Show a notification for file discovery.
+
+    Waits 3 seconds for the file count to coalesce, then pops up a
+    notification. If new files are found the notification is updated,
+    but twice per second at most, and for up to 10 seconds.
+    Finally, sleeps for 10 minutes so it does not get annoying.
+    """
+
+    state = None
+
+    def __init__(self, status_aggregator, clock=reactor):
+        """Initialize this instance."""
+        self.connected = False
+        self.files_found = False
+        self.clock = clock
+        self.status_aggregator = status_aggregator
+        self._set_idle()
+        self.notification = None
+
+    def _change_state(self, new_state_class):
+        """Change to a new state."""
+        if self.state:
+            self.state.cleanup()
+        self.state = new_state_class(self)
+
+    def _set_idle(self):
+        """Reset this bubble to the initial state."""
+        self._change_state(FileDiscoveryIdleState)
+
+    def _start(self):
+        """The first file was found, so start gathering."""
+        self.notification = self.status_aggregator.get_notification()
+        self._change_state(FileDiscoveryGatheringState)
+
+    def _popup(self):
+        """Display the notification."""
+        if not self.connected:
+            return
+        text = self.status_aggregator.get_discovery_message()
+        if text:
+            self.notification.send_notification(UBUNTUONE_TITLE, text)
+            logger.debug("notification shown: %s", text)
+        self._change_state(FileDiscoveryUpdateState)
+
+    def _update(self):
+        """Update the notification."""
+        if not self.connected:
+            return
+        text = self.status_aggregator.get_discovery_message()
+        if text:
+            logger.debug("notification updated: %s", text)
+            self.notification.send_notification(UBUNTUONE_TITLE, text)
+
+    def start_sleeping(self):
+        """Wait for 10 minutes before annoying again."""
+        self._change_state(FileDiscoverySleepState)
+
+    def cleanup(self):
+        """Cleanup this instance."""
+        self.state.cleanup()
+
+    def connection_made(self):
+        """Connection made."""
+        self.connected = True
+        if self.files_found:
+            self._popup()
+
+    def connection_lost(self):
+        """Connection lost."""
+        self.connected = False
+
+    def new_file_found(self):
+        """New files found."""
+        self.files_found = True
+        self.state.new_file_found()
+
+
+class ProgressBar(object):
+    """Update a progressbar no more than 10 times a second."""
+    pulsating = True
+    visible = False
+    progress = 0.0
+    updates_delay = 0.1
+    timer = None
+    inhibitor_defer = None
+
+    def __init__(self, clock=reactor):
+        """Initialize this instance."""
+        self.clock = clock
+        try:
+            self.launcher = UbuntuOneLauncher()
+        except TypeError:
+            # Unity GIR can cause a TypeError here so we should not fail
+            self.launcher = DummyLauncher()
+
+    def cleanup(self):
+        """Cleanup this instance."""
+        if self.timer:
+            self.timer.cleanup()
+            self.timer = None
+
+    def _timeout(self, result):
+        """The aggregating timer has expired, so update the UI."""
+        self.timer = None
+        self.launcher.set_progress(self.progress)
+        logger.debug("progressbar updated: %f", self.progress)
+
+    def set_progress(self, progress):
+        """Steps amount changed. Set up a timer if there isn't one ticking."""
+        self.progress = progress
+        if not self.visible:
+            self.visible = True
+            self.launcher.show_progressbar()
+            logger.debug("progressbar shown")
+            if self.inhibitor_defer is None:
+                self.inhibitor_defer = session.inhibit_logout_suspend(
+                                                         FILE_SYNC_IN_PROGRESS)
+        if not self.timer:
+            self.timer = Timer(self.updates_delay, clock=self.clock)
+            self.timer.addCallback(self._timeout)
+
+    def completed(self):
+        """All has completed."""
+        self.cleanup()
+        self.visible = False
+        self.launcher.hide_progressbar()
+        logger.debug("progressbar hidden")
+        if self.inhibitor_defer is not None:
+
+            def inhibitor_callback(inhibitor):
+                """The inhibitor was found, so cancel it."""
+                self.inhibitor_defer = None
+                return inhibitor.cancel()
+
+            self.inhibitor_defer.addCallback(inhibitor_callback)
+
+
+class FinalStatusBubble(object):
+    """Final bubble that shows the status of transfers."""
+
+    notification = None
+
+    def __init__(self, status_aggregator):
+        """Initialize this instance."""
+        self.status_aggregator = status_aggregator
+
+    def cleanup(self):
+        """Clean up this instance."""
+
+    def show(self):
+        """Show the final status notification."""
+        self.notification = self.status_aggregator.get_notification()
+        text = self.status_aggregator.get_final_status_message()
+        self.notification.send_notification(UBUNTUONE_TITLE, text)
+
+
+def group_statuses(status_events):
+    """Groups statuses by weight."""
+    weight_getter = operator.attrgetter("WEIGHT")
+    sorted_status_events = sorted(status_events, key=weight_getter)
+    return itertools.groupby(sorted_status_events, weight_getter)
+
+
+class StatusAggregator(object):
+    """The status aggregator backend."""
+
+    file_discovery_bubble = None
+    final_status_bubble = None
+
+    def __init__(self, clock=reactor):
+        """Initialize this instance."""
+        self.clock = clock
+        self.notification_switch = NotificationSwitch()
+        self.queue_done_timer = None
+        self.reset()
+        self.progress_bar = ProgressBar(clock=self.clock)
+        self.finished_delay = 10
+        self.progress = {}
+        self.to_do = {}
+
+    def get_notification(self):
+        """Create a new toggleable notification object."""
+        return self.notification_switch.get_notification()
+
+    # pylint: disable=W0201
+    def reset(self):
+        """Reset all counters and notifications."""
+        self.download_done = 0
+        self.upload_done = 0
+        self.files_uploading = []
+        self.uploading_filename = ''
+        self.files_downloading = []
+        self.downloading_filename = ''
+        if self.queue_done_timer is not None:
+            self.queue_done_timer.cleanup()
+            self.queue_done_timer = None
+
+        if self.file_discovery_bubble:
+            self.file_discovery_bubble.cleanup()
+        self.file_discovery_bubble = FileDiscoveryBubble(self,
+                                                         clock=self.clock)
+
+        if self.final_status_bubble:
+            self.final_status_bubble.cleanup()
+        self.final_status_bubble = FinalStatusBubble(self)
+        self.progress = {}
+        self.to_do = {}
+    # pylint: enable=W0201
+
+    def get_discovery_message(self):
+        """Get the text for the discovery bubble."""
+        lines = []
+        files_uploading = len(self.files_uploading)
+        if files_uploading > 0:
+            lines.append(files_being_uploaded(
+                self.uploading_filename, files_uploading))
+        files_downloading = len(self.files_downloading)
+        if files_downloading > 0:
+            self.downloading_filename = self.files_downloading[0].path.split(
+                os.path.sep)[-1]
+            lines.append(files_being_downloaded(
+                self.downloading_filename, files_downloading))
+        return "\n".join(lines)
+
+    def get_final_status_message(self):
+        """Get some lines describing all we did."""
+        parts = []
+        parts.append(FINAL_COMPLETED)
+        upload_done = self.upload_done
+        if upload_done:
+            parts.append(files_were_uploaded(
+                self.uploading_filename, upload_done))
+
+        download_done = self.download_done
+        if download_done:
+            parts.append(files_were_downloaded(
+                self.downloading_filename, download_done))
+        return "\n".join(parts)
+
+    def _queue_done(self, _):
+        """Show final bubble and reset counters."""
+        self.queue_done_timer.cleanup()
+        self.queue_done_timer = None
+        logger.debug("queue done callback fired")
+        if self.upload_done + self.download_done > 0:
+            self.final_status_bubble.show()
+        self.progress_bar.completed()
+        self.reset()
+
+    def queue_done(self):
+        """Queue is finished."""
+        if not self.to_do:
+            return
+        if self.queue_done_timer is None:
+            logger.debug("queue done callback added")
+            self.queue_done_timer = Timer(
+                self.finished_delay, clock=self.clock)
+            self.queue_done_timer.addCallback(self._queue_done)
+            return
+        logger.debug("queue done callback reset")
+        self.queue_done_timer.reset()
+
+    def update_progressbar(self):
+        """Update the counters of the progressbar."""
+        if len(self.to_do) > 0:
+            progress = float(
+                sum(self.progress.values())) / sum(self.to_do.values())
+            self.progress_bar.set_progress(progress)
+
+    def download_started(self, command):
+        """A download just started."""
+        if self.queue_done_timer is not None:
+            self.queue_done_timer.cleanup()
+            self.queue_done_timer = None
+        self.files_downloading.append(command)
+        if command.deflated_size is not None:
+            self.to_do[
+                (command.share_id, command.node_id)] = command.deflated_size
+        # pylint: disable=W0201
+        if not self.downloading_filename:
+            self.downloading_filename = self.files_downloading[0].path.split(
+                os.path.sep)[-1]
+        # pylint: enable=W0201
+        self.update_progressbar()
+        logger.debug(
+            "queueing command (total: %d): %s",
+            len(self.to_do), command.__class__.__name__)
+        self.file_discovery_bubble.new_file_found()
+
+    def download_finished(self, command):
+        """A download just finished."""
+        if command in self.files_downloading:
+            self.files_downloading.remove(command)
+        self.download_done += 1
+        if command.deflated_size is not None:
+            self.progress[
+                (command.share_id, command.node_id)] = command.deflated_size
+        logger.debug("unqueueing command: %s", command.__class__.__name__)
+        self.update_progressbar()
+
+    def upload_started(self, command):
+        """An upload just started."""
+        if self.queue_done_timer is not None:
+            self.queue_done_timer.cleanup()
+            self.queue_done_timer = None
+        self.files_uploading.append(command)
+        if command.deflated_size is not None:
+            self.to_do[
+                (command.share_id, command.node_id)] = command.deflated_size
+        # pylint: disable=W0201
+        if not self.uploading_filename:
+            self.uploading_filename = self.files_uploading[0].path.split(
+                os.path.sep)[-1]
+        # pylint: enable=W0201
+        self.update_progressbar()
+        logger.debug(
+            "queueing command (total: %d): %s", len(self.to_do),
+            command.__class__.__name__)
+        self.file_discovery_bubble.new_file_found()
+
+    def upload_finished(self, command):
+        """An upload just finished."""
+        if command in self.files_uploading:
+            self.files_uploading.remove(command)
+        self.upload_done += 1
+        if command.deflated_size is not None:
+            self.progress[
+                (command.share_id, command.node_id)] = command.deflated_size
+        logger.debug("unqueueing command: %s", command.__class__.__name__)
+        self.update_progressbar()
+
+    def progress_made(self, share_id, node_id, n_bytes_written, deflated_size):
+        """Progress made on up- or download."""
+        if n_bytes_written is not None:
+            # if we haven't gotten the total size yet, set it now
+            if deflated_size and (share_id, node_id) not in self.to_do:
+                self.to_do[(share_id, node_id)] = deflated_size
+            self.progress[(share_id, node_id)] = n_bytes_written
+        self.update_progressbar()
+
+    def connection_lost(self):
+        """The connection to the server was lost."""
+        self.file_discovery_bubble.connection_lost()
+
+    def connection_made(self):
+        """The connection to the server was made."""
+        self.file_discovery_bubble.connection_made()
+
+
+class StatusFrontend(object):
+    """Frontend for the status aggregator, used by the StatusListener."""
+
+    def __init__(self, clock=reactor):
+        """Initialize this instance."""
+        self.aggregator = StatusAggregator(clock=clock)
+        self.notification = self.aggregator.get_notification()
+        self.messaging = Messaging()
+        self.quota_timer = None
+
+    def file_published(self, public_url):
+        """A file was published."""
+        status_event = FilePublishingStatus(new_public_url=public_url)
+        self.notification.send_notification(
+            UBUNTUONE_TITLE, status_event.one())
+
+    def file_unpublished(self, public_url):  # pylint: disable=W0613
+        """A file was unpublished."""
+        self.notification.send_notification(
+            UBUNTUONE_TITLE, FileUnpublishingStatus().one())
+
+    def download_started(self, command):
+        """A file was queued for download."""
+        self.aggregator.download_started(command)
+
+    def download_finished(self, command):
+        """A file download was unqueued."""
+        self.aggregator.download_finished(command)
+
+    def upload_started(self, command):
+        """A file was queued for upload."""
+        self.aggregator.upload_started(command)
+
+    def upload_finished(self, command):
+        """A file upload was unqueued."""
+        self.aggregator.upload_finished(command)
+
+    def progress_made(self, share_id, node_id, n_bytes_written, deflated_size):
+        """Progress made on up- or download."""
+        self.aggregator.progress_made(
+            share_id, node_id, n_bytes_written, deflated_size)
+
+    def queue_done(self):
+        """The queue is empty."""
+        self.aggregator.queue_done()
+
+    def new_share_available(self, share):
+        """A new share is available for subscription."""
+        self.messaging.show_message(share.other_visible_name)
+        self.notification.send_notification(
+            UBUNTUONE_TITLE, ShareAvailableStatus(share=share).one())
+
+    def new_udf_available(self, udf):
+        """A new udf is available for subscription."""
+        if udf.subscribed:
+            return
+        self.notification.send_notification(
+            UBUNTUONE_TITLE, UDFAvailableStatus(udf=udf).one())
+
+    def server_connection_lost(self):
+        """The client lost the connection to the server."""
+        logger.debug("server connection lost")
+        self.aggregator.connection_lost()
+
+    def server_connection_made(self):
+        """The client made the connection to the server."""
+        logger.debug("server connection made")
+        self.aggregator.connection_made()
+
+    def udf_quota_exceeded(self, volume_dict):
+        """Quota exceeded in UDF."""
+        logger.debug("UDF quota exceeded for volume %r." % volume_dict)
+        alert_user()
+
+    def share_quota_exceeded(self, volume_dict):
+        """Sharing user's quota exceeded in share."""
+        logger.debug("Share quota exceeded for volume %r." % volume_dict)
+        if self.quota_timer is not None:
+            if self.quota_timer.active:
+                return
+        else:
+            self.quota_timer = Timer(ONE_DAY, clock=self.aggregator.clock)
+        self.notification.send_notification(
+            UBUNTUONE_TITLE, SHARE_QUOTA_EXCEEDED % (
+                volume_dict['path'], volume_dict['other_visible_name']))
+        alert_user()
+
+    def root_quota_exceeded(self, volume_dict):
+        """Quota exceeded in root."""
+        logger.debug("Root quota exceeded for volume %r." % volume_dict)
+        alert_user()
+
+    def set_show_all_notifications(self, value):
+        """Set the flag to show all notifications."""
+        if value:
+            self.aggregator.notification_switch.enable_notifications()
+        else:
+            self.aggregator.notification_switch.disable_notifications()
 
=== added file 'debian/patches/03_reset_notify_name.patch'
--- debian/patches/03_reset_notify_name.patch	1970-01-01 00:00:00 +0000
+++ debian/patches/03_reset_notify_name.patch	2011-12-14 21:11:28 +0000
@@ -0,0 +1,74 @@
+=== modified file 'tests/status/test_aggregator.py'
+--- old/tests/status/test_aggregator.py	2011-10-27 13:47:09 +0000
++++ new/tests/status/test_aggregator.py	2011-12-07 20:41:48 +0000
+@@ -1327,6 +1327,26 @@
+         result = self.aggregator.get_discovery_message()
+         self.assertEqual(expected, result)
+ 
++    def test_get_discovery_message_clears_filenames(self):
++        """Test the message that's shown on the discovery bubble."""
++        uploading = 10
++        downloading = 8
++        filename = 'upfile0.ext'
++        filename2 = 'downfile0.ext'
++        self.aggregator.files_uploading.extend([
++            FakeCommand(path='upfile%d.ext' % n) for n in range(uploading)])
++        self.aggregator.uploading_filename = filename
++        self.aggregator.files_downloading.extend([
++            FakeCommand(path='downfile%d.ext' % n) for n in
++            range(downloading)])
++        self.aggregator.downloading_filename = 'STALE FILENAME'
++        self.aggregator.uploading_filename = 'STALE FILENAME'
++        expected = (
++            aggregator.files_being_uploaded(filename, uploading) + "\n" +
++            aggregator.files_being_downloaded(filename2, downloading))
++        result = self.aggregator.get_discovery_message()
++        self.assertEqual(expected, result)
++
+     def test_get_final_status_message(self):
+         """The final status message."""
+         done = (5, 10)
+
+=== modified file 'ubuntuone/status/aggregator.py'
+--- old/ubuntuone/status/aggregator.py	2011-10-21 15:49:18 +0000
++++ new/ubuntuone/status/aggregator.py	2011-12-12 22:50:55 +0000
+@@ -646,12 +646,14 @@
+         lines = []
+         files_uploading = len(self.files_uploading)
+         if files_uploading > 0:
++            self.uploading_filename = os.path.basename(
++                self.files_uploading[0].path)
+             lines.append(files_being_uploaded(
+                 self.uploading_filename, files_uploading))
+         files_downloading = len(self.files_downloading)
+         if files_downloading > 0:
+-            self.downloading_filename = self.files_downloading[0].path.split(
+-                os.path.sep)[-1]
++            self.downloading_filename = os.path.basename(
++                self.files_downloading[0].path)
+             lines.append(files_being_downloaded(
+                 self.downloading_filename, files_downloading))
+         return "\n".join(lines)
+@@ -712,8 +714,8 @@
+                 (command.share_id, command.node_id)] = command.deflated_size
+         # pylint: disable=W0201
+         if not self.downloading_filename:
+-            self.downloading_filename = self.files_downloading[0].path.split(
+-                os.path.sep)[-1]
++            self.downloading_filename = os.path.basename(
++                self.files_downloading[0].path)
+         # pylint: enable=W0201
+         self.update_progressbar()
+         logger.debug(
+@@ -743,8 +745,8 @@
+                 (command.share_id, command.node_id)] = command.deflated_size
+         # pylint: disable=W0201
+         if not self.uploading_filename:
+-            self.uploading_filename = self.files_uploading[0].path.split(
+-                os.path.sep)[-1]
++            self.uploading_filename = os.path.basename(
++                self.files_uploading[0].path)
+         # pylint: enable=W0201
+         self.update_progressbar()
+         logger.debug(
+
 
=== renamed file 'debian/patches/03_reset_notify_name.patch' => 'debian/patches/03_reset_notify_name.patch.moved'