From 1f91f748cb2ff193011aaab714442298a231aa10 Mon Sep 17 00:00:00 2001 From: Siddharth Ravikumar Date: Fri, 13 Mar 2015 12:03:20 -0400 Subject: Added `shardp' method to combox.events.NodeDirMonitor + test for it. modified: combox/events.py modified: tests/events_test.py --- combox/events.py | 11 +++++++++++ tests/events_test.py | 10 ++++++++++ 2 files changed, 21 insertions(+) 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) -- cgit v1.2.3