diff options
| -rw-r--r-- | combox/events.py | 11 | ||||
| -rw-r--r-- | tests/events_test.py | 10 |
2 files changed, 21 insertions, 0 deletions
diff --git a/combox/events.py b/combox/events.py index 71431c6..973a79d 100644 --- a/combox/events.py +++ b/combox/events.py @@ -202,6 +202,17 @@ class NodeDirMonitor(LoggingEventHandler): self.silo = ComboxSilo(self.config) + def shardp(self, path): + """Returns True if `path' is a shard + + Shards end with `.shardN' where `N' is a natural number. + """ + if path[:-1].endswith('.shard'): + return True + else: + return False + + def housekeep(self): """Recursively traverses node directory, discovers changes and updates silo and combox directory. diff --git a/tests/events_test.py b/tests/events_test.py index bdb1c1a..1212d69 100644 --- a/tests/events_test.py +++ b/tests/events_test.py @@ -314,6 +314,16 @@ class TestEvents(object): observer.join() + def test_NDM_shardp(self): + """Testing shardp method in NodeDirMonitor class""" + shard = 'some.shard0' + not_shard = 'some.extension' + ndm = NodeDirMonitor(self.config) + + assert_equal(True, ndm.shardp(shard)) + assert_equal(False, ndm.shardp(not_shard)) + + def teardown(self): """Cleans up things after each test in this class""" purge_nodedirs(self.config) |