Skip to content
Snippets Groups Projects
Commit 5e13cce5 authored by Xavier Claessens's avatar Xavier Claessens Committed by Sjoerd Simons
Browse files

tracker: make is_indexed and is_not_indexed raise exception instead

Summary:
They are now assert_indexed and assert_not_indexer. This provides more
useful backtrace if an error occures.

Reviewers: smcv, pwith

Differential Revision: https://phabricator.apertis.org/D395
parent 8ccdd455
No related branches found
No related tags found
No related merge requests found
...@@ -50,11 +50,11 @@ class TrackerTest(unittest.TestCase): ...@@ -50,11 +50,11 @@ class TrackerTest(unittest.TestCase):
def assert_indexed(self, filename, extra=None): def assert_indexed(self, filename, extra=None):
uri = 'file://%s/%s' % (self.homedir, filename) uri = 'file://%s/%s' % (self.homedir, filename)
self.assertTrue(self.indexer.is_indexed(uri, extra)) self.indexer.assert_indexed(uri, extra)
def assert_not_indexed(self, filename): def assert_not_indexed(self, filename):
uri = 'file://%s/%s' % (self.homedir, filename) uri = 'file://%s/%s' % (self.homedir, filename)
self.assertTrue(self.indexer.is_not_indexed(uri)) self.indexer.assert_not_indexed(uri)
def tracker_inital_tests(self): def tracker_inital_tests(self):
playable_query = '?urn bosch:playable true . ' playable_query = '?urn bosch:playable true . '
......
...@@ -110,7 +110,7 @@ class TrackerIndexer(): ...@@ -110,7 +110,7 @@ class TrackerIndexer():
self.wait_files = True self.wait_files = True
self.loop.run() self.loop.run()
def is_indexed(self, uri, extra=None): def assert_indexed(self, uri, extra=None):
query = ('select ?urn where { ' query = ('select ?urn where { '
' ?urn nie:url "%s" ; ' ' ?urn nie:url "%s" ; '
' tracker:available true . ') % (uri) ' tracker:available true . ') % (uri)
...@@ -120,9 +120,13 @@ class TrackerIndexer(): ...@@ -120,9 +120,13 @@ class TrackerIndexer():
# Must have one and only one result # Must have one and only one result
cursor = self.conn.query(query, None) cursor = self.conn.query(query, None)
return cursor.next(None) and not cursor.next(None) if not cursor.next(None):
raise Exception("Query '%s' returned no result" % query)
if cursor.next(None):
raise Exception("Query '%s' returned more than one result" % query)
def is_not_indexed(self, uri): def assert_not_indexed(self, uri):
query = ('select ?urn where { ?urn nie:url "%s" }') % (uri) query = ('select ?urn where { ?urn nie:url "%s" }') % (uri)
cursor = self.conn.query(query, None) cursor = self.conn.query(query, None)
return not cursor.next(None) if cursor.next(None):
raise Exception("Query '%s' returned results" % query)
...@@ -36,7 +36,7 @@ class TestRemovableDevice(unittest.TestCase): ...@@ -36,7 +36,7 @@ class TestRemovableDevice(unittest.TestCase):
def assert_indexed(self, filename, extra=None): def assert_indexed(self, filename, extra=None):
uri = 'file://%s/%s' % (self.path, filename) uri = 'file://%s/%s' % (self.path, filename)
self.assertTrue(self.indexer.is_indexed(uri, extra)) self.indexer.assert_indexed(uri, extra)
def test_removable_device(self): def test_removable_device(self):
print('Please insert storage ...') print('Please insert storage ...')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment