From be5ab0f3075888bd12e608100f2aef499bac3c2d Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Wed, 13 Feb 2019 22:45:05 -0300 Subject: [PATCH] test get retry --- tests/integration/test_file_commands.py | 42 +++++++++++++++++++++++-- 1 file changed, 39 insertions(+), 3 deletions(-) diff --git a/tests/integration/test_file_commands.py b/tests/integration/test_file_commands.py index a8800fd25..9f660d051 100644 --- a/tests/integration/test_file_commands.py +++ b/tests/integration/test_file_commands.py @@ -70,6 +70,7 @@ class FileCommands(CommandTestCase): async def test_incomplete_downloads_erases_output_file_on_stop(self): claim = await self.make_claim('foo', '0.01') sd_hash = claim['output']['value']['stream']['source']['source'] + file_info = self.daemon.jsonrpc_file_list()[0] await self.daemon.jsonrpc_file_delete(claim_name='foo') all_except_sd = [ blob_hash for blob_hash in self.server.blob_manager.completed_blob_hashes if blob_hash != sd_hash @@ -78,7 +79,42 @@ class FileCommands(CommandTestCase): resp = await self.daemon.jsonrpc_get('lbry://foo', timeout=2) self.assertIn('error', resp) + self.assertFalse(os.path.isfile(os.path.join(self.daemon.conf.download_dir, file_info['file_name']))) + + async def test_incomplete_downloads_retry(self): + claim = await self.make_claim('foo', '0.01') + sd_hash = claim['output']['value']['stream']['source']['source'] + await self.daemon.jsonrpc_file_delete(claim_name='foo') + all_except_sd = [ + blob_hash for blob_hash in self.server.blob_manager.completed_blob_hashes if blob_hash != sd_hash + ] + + # backup server blobs + for blob_hash in all_except_sd: + blob = self.server_blob_manager.get_blob(blob_hash) + os.rename(blob.file_path, blob.file_path + '__') + + # erase all except sd blob + await self.server.blob_manager.delete_blobs(all_except_sd) + + # fails, as expected + resp = await self.daemon.jsonrpc_get('lbry://foo', timeout=2) + self.assertIn('error', resp) + self.assertEqual(len(self.daemon.jsonrpc_file_list()), 1) + self.assertEqual('stopped', self.daemon.jsonrpc_file_list()[0]['status']) + + # recover blobs + for blob_hash in all_except_sd: + blob = self.server_blob_manager.get_blob(blob_hash) + os.rename(blob.file_path + '__', blob.file_path) + self.server_blob_manager.blobs.clear() + await self.server_blob_manager.blob_completed(self.server_blob_manager.get_blob(blob_hash)) + resp = await self.daemon.jsonrpc_get('lbry://foo', timeout=2) + await asyncio.wait_for(self.wait_files_to_complete(), timeout=5) + self.assertNotIn('error', resp) file_info = self.daemon.jsonrpc_file_list()[0] - self.assertTrue(os.path.isfile(os.path.join(file_info['download_path']))) - await self.daemon.jsonrpc_file_set_status('stop', sd_hash=sd_hash) - self.assertFalse(os.path.isfile(os.path.join(file_info['download_path']))) + self.assertEqual(file_info['blobs_completed'], file_info['blobs_in_stream']) + + async def wait_files_to_complete(self): + while self.daemon.jsonrpc_file_list(status='running'): + await asyncio.sleep(0.01)