Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

passing get, file list and file delete tests

Browse source
This commit is contained in:
Lex Berezhny 2019-02-12 11:30:40 -05:00
parent 5e509c9fd6
commit 396c49f7c6
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
tests/integration/test_file_commands.py
View file

@ -10,7 +10,7 @@ class FileCommands(CommandTestCase):
await self.make_claim('foo', '0.01') await self.make_claim('foo', '0.01')
await self.make_claim('foo2', '0.01') await self.make_claim('foo2', '0.01')
file1, file2 = self.daemon.jsonrpc_file_list() file1, file2 = self.daemon.jsonrpc_file_list('claim_name')
self.assertEqual(file1['claim_name'], 'foo') self.assertEqual(file1['claim_name'], 'foo')
self.assertEqual(file2['claim_name'], 'foo2') self.assertEqual(file2['claim_name'], 'foo2')

4
tests/integration/testcase.py
View file

@ -24,6 +24,7 @@ from lbrynet.extras.daemon.ComponentManager import ComponentManager
from lbrynet.extras.daemon.storage import SQLiteStorage from lbrynet.extras.daemon.storage import SQLiteStorage
from lbrynet.blob.blob_manager import BlobFileManager from lbrynet.blob.blob_manager import BlobFileManager
from lbrynet.stream.reflector.server import ReflectorServer from lbrynet.stream.reflector.server import ReflectorServer
from lbrynet.blob_exchange.server import BlobServer
class ExchangeRateManager: class ExchangeRateManager:
@ -113,6 +114,9 @@ class CommandTestCase(IntegrationTestCase):
self.server_storage = SQLiteStorage(Config(), ':memory:') self.server_storage = SQLiteStorage(Config(), ':memory:')
await self.server_storage.open() await self.server_storage.open()
self.server_blob_manager = BlobFileManager(self.loop, server_tmp_dir, self.server_storage) self.server_blob_manager = BlobFileManager(self.loop, server_tmp_dir, self.server_storage)
self.server = BlobServer(self.loop, self.server_blob_manager, 'bQEaw42GXsgCAGio1nxFncJSyRmnztSCjP')
self.server.start_server(5567, '127.0.0.1')
await self.server.started_listening.wait()
self.reflector = ReflectorServer(self.server_blob_manager) self.reflector = ReflectorServer(self.server_blob_manager)
self.reflector.start_server(5566, '127.0.0.1') self.reflector.start_server(5566, '127.0.0.1')