LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

use a non-default port for streaming test so it can run with a live instance

Browse source
This commit is contained in:
Victor Shyba 2022-10-28 19:44:40 -03:00
parent 2bea8f58e0
commit 9dc617f8e0
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
tests/integration/datanetwork/test_file_commands.py
View file

@ -21,6 +21,7 @@ class FileCommands(CommandTestCase):
def __init__(self, *a, **kw): def __init__(self, *a, **kw):
super().__init__(*a, **kw) super().__init__(*a, **kw)
self.skip_libtorrent = False self.skip_libtorrent = False
self.streaming_port = 60818
async def add_forever(self): async def add_forever(self):
while True: while True:
@ -56,11 +57,11 @@ class FileCommands(CommandTestCase):
return tx, btih return tx, btih
async def assert_torrent_streaming_works(self, btih): async def assert_torrent_streaming_works(self, btih):
url = f'http://{self.daemon.conf.streaming_host}:{self.daemon.conf.streaming_port}/get/torrent' url = f'http://{self.daemon.conf.streaming_host}:{self.streaming_port}/get/torrent'
if self.daemon.streaming_runner.server is None: if self.daemon.streaming_runner.server is None:
await self.daemon.streaming_runner.setup() await self.daemon.streaming_runner.setup()
site = aiohttp.web.TCPSite(self.daemon.streaming_runner, self.daemon.conf.streaming_host, site = aiohttp.web.TCPSite(self.daemon.streaming_runner, self.daemon.conf.streaming_host,
self.daemon.conf.streaming_port) self.streaming_port)
await site.start() await site.start()
async with aiohttp_request('get', url) as req: async with aiohttp_request('get', url) as req:
self.assertEqual(req.headers.get('Content-Type'), 'application/octet-stream') self.assertEqual(req.headers.get('Content-Type'), 'application/octet-stream')