Merge lp:~mandel/ubuntuone-client/add_public_files_remote_object_tests into lp:ubuntuone-client

[Manuel de la Peña]

Add the rests of the tests to be passed by the implementation of the remote objects on Windows.

Add the rests of the tests to be passed by the implementation of the remote objects on Windows.

[Alejandro J. Cura (alecu)]

Thanks for all the fish!

review: Approve

[Roberto Alsina (ralsina)]

+1

review: Approve

[Ubuntu One Auto Pilot (otto-pilot)]

No proposals found for merge of lp:~mandel/ubuntuone-client/add_syncdaemon_remote_object_tests into lp:ubuntuone-client.

=== modified file 'tests/platform/windows/test_ipc.py'
--- tests/platform/windows/test_ipc.py	2011-02-23 12:43:22 +0000
+++ tests/platform/windows/test_ipc.py	2011-02-23 12:43:22 +0000
@@ -33,6 +33,9 @@
         self.status = None
         self.events = None
         self.sync = None
+        self.shares = None
+        self.folders = None
+        self.public_files = None
 
 class TestSignalBroadcaster(MockerTestCase):
     """Test the signal brocaster code."""
@@ -209,3 +212,276 @@
         self.signal_method('on_quota_exceeded', volume_dict)
         self.mocker.replay()
         self.sync.emit_quota_exceeded(volume_dict)
+
+
+class TestSharesEmitSignals(PerspectiveBrokerTestCase, MockerTestCase):
+    """Test that the emit method have been correctly implemented."""
+
+    def setUp(self):
+        """Setup tests."""       
+        super(TestEventsEmitSignals, self).setUp()
+        self.signal_method = self.mocker.mock()
+        self.shares.emit_signal = self.signal_method
+        self.shares.syncdaemon_shares = self.mocker.mock()
+        self.get_share_dict = self.mocker.replace(
+            'ubuntuone.syncdaemon.interaction_interfaces.get_share_dict')
+
+    def test_emit_share_changed_deleted(self):
+        """Test emit share changed on a delete event."""
+        message = 'deleted'
+        share = 'share'
+        share_dict = 'share_dict'
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method('on_share_deleted', share_dict)
+        self.mocker.replay()
+        self.shares.emit_share_changed(message, share)
+
+    def test_emit_share_changed_changed(self):
+        """Test emit share changed on a changed event."""
+        message = 'changed'
+        share = 'share'
+        share_dict = 'share_dict'
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method('on_share_changed', share_dict)
+        self.mocker.replay()
+        self.shares.emit_share_changed(message, share)
+
+    def test_emit_share_delete_error(self):
+        """Emit ShareDeleteError signal."""
+        share = 'share'
+        error = 'error'
+        share_dict = 'share_dict'
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method('on_share_deleted_error', share_dict, error)
+
+    def test_emit_free_space(self):
+        """Emit ShareChanged when free space changes """
+        free_bytes = '0'
+        share_dict = shares = {'1': 'share', 'free_bytes':'0' }
+        share = 'share'
+        share_id = '1'
+        self.shares.syncdaemon_shares.shares
+        self.mocker.result(shares)
+        self.shares.syncdaemon_shares.shares
+        self.mocker.result(shares)
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method(share_dict)
+        self.mocker.replay()
+        self.shares.emit_free_space(share_id, free_bytes)
+
+    def test_emit_share_created(self):
+        """Emit ShareCreated signal """
+        share_info = 'info'
+        self.signal_method(share_info)
+        self.mocker.replay()
+        self.shares.emit_share_created(share_info)
+
+    def test_emit_share_create_error(self):
+        """Emit ShareCreateError signal."""
+        share_info = 'id'
+        error = 'error'
+        info = 'info'
+        self.shares.syncdaemon_shares.get_create_error_share_info(share_info)
+        self.mocker.result(info)
+        self.signal_method(info, error)
+        self.mocker.replay()
+        self.shares.emit_share_create_error(share_info, error)
+
+    def test_emit_share_answer_response(self):
+        """Emits ShareAnswerResponse signal."""
+        share_id = 'id'
+        answer = 'yes'
+        error = 'boom'
+        answer_info = dict(volume_id=share_id, answer=answer, error=error)
+        self.signal_method(answer_info)
+        self.mocker.replay()
+        self.shares.emit_share_answer_response(share_id, answer, error)
+
+    def test_emit_new_share(self):
+        """Emits NewShare signal."""
+        share_id = 'id'
+        share = 'share'
+        share_dict = {'share':'id'}
+        self.shares.syncdaemon_shares.get_volume(share_id)
+        self.mocker.result(share)
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method(share_dict)
+        self.mocker.replay()
+        self.shares.emit_new_share(share_id)
+
+    def test_emit_share_subscribed(self):
+        """Emit the ShareSubscribed signal"""
+        share = 'share'
+        share_dict = {'share' : 'id'}
+        self.get_share_dict(share)
+        self.mocker.result(share_dict)
+        self.signal_method(share_dict)
+        self.mocker.replay()
+        self.shares.emit_share_subscribed(share)
+
+    def test_emit_share_subscribe_error(self):
+        """Emit the ShareSubscribeError signal"""
+        share_id = 'id'
+        error = 'error'
+        self.signal_method({'id': share_id}, str(error))
+        self.mocker.replay()
+        self.shares.emit_share_subscribe_error(share_id, error)
+
+    def test_emit_share_unsubscribed(self):
+        """Emit the ShareUnSubscribed signal"""
+        share = 'share'
+        share_dict = {'share':'id'}
+        self.get_share_dict(share)
+        self.mocker.result(share_dict) 
+        self.signal_method(share_dict)
+        self.mocker.replay()
+        self.shares.emit_share_unsubscribed(share)
+
+    def test_emit_share_unsubscribe_error(self):
+        """Emit the ShareUnSubscribeError signal"""
+        share_id = 'id'
+        error = 'error'
+        self.signal_method({'id': share_id}, str(error))
+        self.mocker.replay()
+        self.shares.emit_share_unsubscribe_error(share_id, error)
+
+
+class TestFoldersEmitSignals(PerspectiveBrokerTestCase, MockerTestCase):
+    """Test that the emit method have been correctly implemented."""
+
+    def setUp(self):
+        """Setup tests."""
+        super(TestFoldersEmitSignals, self).setUp()
+        self.signal_method = self.mocker.mock()
+        self.get_udf_dict = self.mocker.replace(
+            'ubuntuone.syncdaemon.interaction_interfaces.get_udf_dict')
+
+    def test_emit_folder_deleted(self):
+        """Emit the FolderCreated signal"""
+        folder = 'folder'
+        udf_dict = {'udf':'id'}
+        self.get_udf_dict(folder)
+        self.mocker.result(udf_dict)
+        self.signal_method(udf_dict)
+        self.mocker.replay()
+        self.folders.emit_folder_deleted(folder)
+
+    def test_emit_folder_delete_error(self):
+        """Emit the FolderCreateError signal"""
+        folder = 'folder'
+        error = 'error'
+        udf_dict = {'udf':'id'}
+        self.get_udf_dict(folder)
+        self.mocker.result(udf_dict)
+        self.signal_method(udf_dict, str(error))
+        self.mocker.replay()
+        self.folders.emit_folder_delete_error(folder, error)
+
+    def test_emit_folder_subscribed(self):
+        """Emit the FolderSubscribed signal"""
+        folder = 'folder'
+        udf_dict = {'udf':'id'}
+        self.get_udf_dict(folder)
+        self.mocker.result(udf_dict)
+        self.signal_method(udf_dict)
+        self.mocker.replay()
+        self.folders.emit_folder_subscribed(folder)
+
+    def test_emit_folder_subscribe_error(self):
+        """Emit the FolderSubscribeError signal"""
+        folder_id = 'id'
+        error = 'error'
+        self.signal_method({'id':folder_id}, str(error))
+        self.mocker.replay()
+        self.folders.emit_folder_subscribe_error(folder_id, error)
+
+    def test_emit_folder_unsubscribed(self):
+        """Emit the FolderUnSubscribed signal"""
+        folder = 'folder'
+        udf_dict = {'udf':'id'}
+        self.get_udf_dict(folder)
+        self.mocker.result(udf_dict)
+        self.signal_method(udf_dict)
+        self.mocker.replay()
+        self.folders.emit_folder_unsubscribed(folder)
+
+    def test_emit_folder_unsubscribe_error(self):
+        """Emit the FolderUnSubscribeError signal"""
+        folder_id = 'id'
+        error = 'error'
+        self.signal_method({'id':folder_id}, str(error))
+        self.mocker.replay()
+        self.folders.emit_folder_unsubscribe_error(folder_id, error)
+
+
+class TestPublicFilesEmitSignals(PerspectiveBrokerTestCase, MockerTestCase):
+    """Test that the emit method have been correctly implemented."""
+
+    def setUp(self):
+        """Setup tests."""
+        super(TestPublicFilesEmitSignals, self).setUp()
+        self.signal_method = self.mocker.mock()
+        self.public_files.syncdaemon_public_files = self.mocker.mock()
+        self.bool_str = self.mocker.replace(
+            'ubuntuone.syncdaemon.interaction_interfaces.bool_str')
+
+    def test_emit_public_access_changed(self): 
+        """Emit the PublicAccessChanged signal."""
+        share_id = 'share_id'
+        node_id = 'node_id'
+        path = 'path'
+        is_public = True
+        public_url = 'url' 
+        self.public_files.syncdaemon_public_files.get_path(share_id, node_id)
+        self.mocker.result(path)
+        self.bool_str(is_public)
+        self.mocker.result('True')
+        self.signal_method(dict(share_id=share_id, node_id=node_id,
+                                is_public='True', public_url=public_url,
+                                path=path))
+        self.mocker.replay()
+        self.public_files.emit_public_access_changed(share_id, node_id, 
+                                                     is_public, public_url)
+
+    def test_emit_public_access_change_error(self):
+        """Emit the PublicAccessChangeError signal."""
+        share_id = 'share_id'
+        node_id = 'node_id'
+        error = 'error'
+        path = 'path'
+        self.public_files.syncdaemon_public_files.get_path(share_id, node_id)
+        self.mocker.result(path)
+        self.signal_method(dict(share_id=share_id, node_id=node_id, path=path),
+                           error)
+        self.mocker.replay()
+        self.public_files.emit_public_access_change_error(share_id, node_id,
+                                                          error)
+
+    def test_emit_public_files_list(self):
+        """Emit the PublicFilesList signal."""
+        volume_id = 'volume_id'
+        node_id = 'node_id'
+        public_url = 'url'
+        path = 'path'
+        public_files = [dict(volume_id=volume_id, node_id=node_id,
+                             public_url=public_url)]
+        files = [dict(volume_id=volume_id, node_id=node_id,
+                      public_url=public_url, path=path)]
+        self.public_files.syncdaemon_public_files.get_path(volume_id, node_id)
+        self.mocker.result(path)
+        self.signal_method(files)
+        self.mocker.replay()
+        self.public_files.emit_public_files_list(public_files)
+
+    def test_emit_public_files_list_error(self):
+        """Emit the PublicFilesListError signal."""
+        error = 'error'
+        self.signal_method(error)
+        self.mocker.replay()
+        self.public_files.emit_public_files_list_error(error)
+