Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/tests/test_storage.py
Show First 20 Lines • Show All 568 Lines • ▼ Show 20 Lines | def test_content_add(self): | ||||
del expected_cont['data'] | del expected_cont['data'] | ||||
journal_objects = list(self.journal_writer.objects) | journal_objects = list(self.journal_writer.objects) | ||||
for (obj_type, obj) in journal_objects: | for (obj_type, obj) in journal_objects: | ||||
if 'ctime' in obj: | if 'ctime' in obj: | ||||
del obj['ctime'] | del obj['ctime'] | ||||
self.assertEqual(journal_objects, | self.assertEqual(journal_objects, | ||||
[('content', expected_cont)]) | [('content', expected_cont)]) | ||||
def test_content_get_missing(self): | |||||
cont = self.cont | |||||
self.storage.content_add([cont]) | |||||
results = list(self.storage.content_get( | |||||
[self.cont['sha1'], self.cont2['sha1']])) | |||||
self.assertEqual(results, | |||||
[{'sha1': cont['sha1'], 'data': cont['data']}, None]) | |||||
results = list(self.storage.content_get( | |||||
[self.cont2['sha1'], self.cont['sha1']])) | |||||
self.assertEqual(results, | |||||
[None, {'sha1': cont['sha1'], 'data': cont['data']}]) | |||||
def test_content_add_same_input(self): | def test_content_add_same_input(self): | ||||
cont = self.cont | cont = self.cont | ||||
actual_result = self.storage.content_add([cont, cont]) | actual_result = self.storage.content_add([cont, cont]) | ||||
self.assertEqual(actual_result, { | self.assertEqual(actual_result, { | ||||
'content:add': 1, | 'content:add': 1, | ||||
'content:add:bytes': cont['length'], | 'content:add:bytes': cont['length'], | ||||
'skipped_content:add': 0 | 'skipped_content:add': 0 | ||||
▲ Show 20 Lines • Show All 2,776 Lines • Show Last 20 Lines |