From c9fac27b667c78b4187eeda7579ee7978602d522 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Wed, 29 Jun 2022 12:33:00 -0400 Subject: [PATCH] test resolving different streams for a channel using short urls --- .../integration/takeovers/test_resolve_command.py | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/tests/integration/takeovers/test_resolve_command.py b/tests/integration/takeovers/test_resolve_command.py index 5ffe18224..d27ef5734 100644 --- a/tests/integration/takeovers/test_resolve_command.py +++ b/tests/integration/takeovers/test_resolve_command.py @@ -215,6 +215,21 @@ class ResolveCommand(BaseResolveTestCase): await self.assertResolvesToClaimId(f'@abc#{colliding_claim_ids[1][:17]}', colliding_claim_ids[1]) await self.assertResolvesToClaimId(f'@abc#{colliding_claim_ids[1]}', colliding_claim_ids[1]) + # test resolving different streams for a channel using short urls + self.get_claim_id( + await self.stream_create('foo1', '0.01', channel_id=colliding_claim_ids[0]) + ) + self.get_claim_id( + await self.stream_create('foo2', '0.01', channel_id=colliding_claim_ids[0]) + ) + duplicated_resolved = list(( + await self.ledger.resolve([], [ + f'@abc#{colliding_claim_ids[0][:2]}/foo1', f'@abc#{colliding_claim_ids[0][:2]}/foo2' + ]) + ).values()) + self.assertEqual('foo1', duplicated_resolved[0].normalized_name) + self.assertEqual('foo2', duplicated_resolved[1].normalized_name) + async def test_abandon_channel_and_claims_in_same_tx(self): channel_id = self.get_claim_id( await self.channel_create('@abc', '0.01')