diff --git a/tests/integration/test_claim_commands.py b/tests/integration/test_claim_commands.py index 5933781e1..34add9fe5 100644 --- a/tests/integration/test_claim_commands.py +++ b/tests/integration/test_claim_commands.py @@ -628,6 +628,7 @@ class StreamCommands(ClaimTestCase): }] fixed_values['thumbnail'] = {'url': fixed_values.pop('thumbnail_url')} fixed_values['release_time'] = str(values['release_time']) + fixed_values['stream_type'] = 'binary' fixed_values['source'] = { 'hash': '56bf5dbae43f77a63d075b0f2ae9c7c3e3098db93779c7f9840da0f4db9c2f8c8454f4edd1373e2b64ee2e68350d916e', 'media_type': 'application/octet-stream', @@ -651,6 +652,7 @@ class StreamCommands(ClaimTestCase): stream = tx['outputs'][0]['value'] self.assertEqual( stream, { + 'stream_type': 'binary', 'source': { 'size': '3', 'media_type': 'application/octet-stream', @@ -669,6 +671,7 @@ class StreamCommands(ClaimTestCase): fixed_values['source']['sd_hash'] = stream['source']['sd_hash'] self.assertEqual( stream, { + 'stream_type': 'binary', 'source': { 'size': '3', 'media_type': 'application/octet-stream', diff --git a/tests/integration/test_resolve_command.py b/tests/integration/test_resolve_command.py index 2594908b1..430a0f6c3 100644 --- a/tests/integration/test_resolve_command.py +++ b/tests/integration/test_resolve_command.py @@ -168,6 +168,7 @@ class ResolveCommand(CommandTestCase): async def test_abandoned_channel_with_signed_claims(self): channel = (await self.channel_create('@abc', '1.0'))['outputs'][0] orphan_claim = await self.stream_create('on-channel-claim', '0.0001', channel_id=channel['claim_id']) + abandoned_channel_id = channel['claim_id'] await self.channel_abandon(txid=channel['txid'], nout=0) channel = (await self.channel_create('@abc', '1.0'))['outputs'][0] orphan_claim_id = orphan_claim['outputs'][0]['claim_id'] @@ -178,11 +179,13 @@ class ResolveCommand(CommandTestCase): self.assertEqual(response, { 'lbry://@abc/on-channel-claim': {'error': 'lbry://@abc/on-channel-claim did not resolve to a claim'} }) - response = await self.resolve('lbry://on-channel-claim') - self.assertNotIn('is_channel_signature_valid', response['lbry://on-channel-claim']) + response = (await self.resolve('lbry://on-channel-claim'))['lbry://on-channel-claim'] + self.assertFalse(response['is_channel_signature_valid']) + self.assertEqual({'channel_id': abandoned_channel_id}, response['signing_channel']) direct_uri = 'lbry://on-channel-claim#' + orphan_claim_id - response = await self.resolve(direct_uri) - self.assertNotIn('is_channel_signature_valid', response[direct_uri]) + response = (await self.resolve(direct_uri))[direct_uri] + self.assertFalse(response['is_channel_signature_valid']) + self.assertEqual({'channel_id': abandoned_channel_id}, response['signing_channel']) await self.stream_abandon(claim_id=orphan_claim_id) uri = 'lbry://@abc/on-channel-claim'