← Back to branch summary

~rye/ubuntuone-client/trash-support

« back to all changes in this revision

Viewing changes to tests/syncdaemon/test_sync.py

  • Committer: Tarmac
  • Author(s): Alejandro J. Cura
  • Date: 2010-12-14 18:05:35 UTC
  • mfrom: (748.4.18 ziggy-for-filesync)
  • Revision ID: tarmac-20101214180535-0fmlie4syn3dd33x
Remaining SyncDaemon events to be logged into Zeitgeist.

Show diffs side-by-side

added added

removed removed

Lines of Context:
tests/syncdaemon/test_sync.py
1518
1518
        self.sync.handle_AQ_RESCAN_FROM_SCRATCH_OK(ROOT, [self.rootdt],
1519
1519
                                                   100, 100)
1520
1520
 
1521
 
        self.assertEqual(called, [((ROOT, self.filetxtdelta.node_id), {})])
 
1521
        args = (ROOT, self.filetxtdelta.node_id, False)
 
1522
        self.assertEqual(called, [(args, {})])
1522
1523
 
1523
1524
    def test_deletes_file_in_delta(self):
1524
1525
        """Files in delta should not be deleted."""
1569
1570
            [self.rootdt], 100, 100)
1570
1571
 
1571
1572
        self.assertEqual(called, [
1572
 
            (ROOT, dt.node_id),
1573
 
            (ROOT, self.dirdelta.node_id)])
 
1573
            (ROOT, dt.node_id, False),
 
1574
            (ROOT, self.dirdelta.node_id, True)])
 
1575
 
 
1576
 
 
1577
class TestSyncEvents(BaseSync):
 
1578
    """Testing sync stuff related to events."""
 
1579
 
 
1580
    def setUp(self):
 
1581
        """Do the setUp."""
 
1582
        super(TestSyncEvents, self).setUp()
 
1583
        self.sync = Sync(main=self.main)
 
1584
        self.handler.setLevel(logging.DEBUG)
 
1585
 
 
1586
        key = FSKey(self.main.fs, share_id='', node_id='node_id')
 
1587
        self.ssmr = SyncStateMachineRunner(fsm=self.main.fs, main=self.main,
 
1588
                                           key=key, logger=None)
 
1589
        self.vm = self.main.vm
 
1590
        self.listener = Listener()
 
1591
        self.main.event_q.subscribe(self.listener)
 
1592
 
 
1593
    def test_server_new_file_sends_event(self):
 
1594
        """When a new file is created on the server, an event is sent."""
 
1595
        # create the fake file
 
1596
        self.main.vm._got_root("parent_id")
 
1597
        self.sync._handle_SV_FILE_NEW(ROOT, "node_id", "parent_id", "file")
 
1598
 
 
1599
        # check event
 
1600
        kwargs = dict(volume_id=ROOT, node_id='node_id', parent_id="parent_id",
 
1601
                      name="file")
 
1602
        self.assertIn(("SV_FILE_NEW", (), kwargs), self.listener.events)
 
1603
 
 
1604
    def test_server_new_dir_sends_event(self):
 
1605
        """When a new directory is created on the server, an event is sent."""
 
1606
 
 
1607
        # create the fake dir
 
1608
        self.main.vm._got_root("parent_id")
 
1609
        self.sync._handle_SV_DIR_NEW(ROOT, "node_id", "parent_id", "file")
 
1610
 
 
1611
        # check event
 
1612
        kwargs = dict(volume_id=ROOT, node_id='node_id', parent_id="parent_id",
 
1613
                      name="file")
 
1614
        self.assertIn(("SV_DIR_NEW", (), kwargs), self.listener.events)
 
1615
 
 
1616
    def test_server_file_deleted_sends_event(self):
 
1617
        """When a file is deleted, an event is sent."""
 
1618
 
 
1619
        # delete the fake file
 
1620
        self.main.vm._got_root("parent_id")
 
1621
        self.sync._handle_SV_FILE_DELETED(ROOT, "node_id", True)
 
1622
 
 
1623
        # check event
 
1624
        kwargs = dict(volume_id=ROOT, node_id='node_id', is_dir=True)
 
1625
        self.assertIn(("SV_FILE_DELETED", (), kwargs), self.listener.events)