Raise only for non-unique provided sub labels; create unique default labels:

- If a user does not provide a subscription label, they likely don't care
  about tracking via a label. Create unique default labels for each
  subscription.

- If a user provides a subscription label, but it is not unique, raise an
  error.

Author: fselmo

newsfragments/3594.bugfix.rst

@@ -0,0 +1 @@
+Don't raise on non-unique default subscription labels (no label provided). Only raise if a non-unique custom label is explicitly set for a subscription.

tests/core/subscriptions/test_subscription_manager.py

@@ -40,19 +40,42 @@ async def subscription_manager():
 
 
 @pytest.mark.asyncio
-async def test_subscription_manager_raises_for_sub_with_the_same_label(
+async def test_subscription_default_labels_are_unique(subscription_manager):
+    sub1 = NewHeadsSubscription()
+    sub2 = NewHeadsSubscription()
+    sub3 = NewHeadsSubscription()
+    sub4 = NewHeadsSubscription()
+
+    await subscription_manager.subscribe([sub1, sub2, sub3, sub4])
+
+    assert sub1.label != sub2.label != sub3.label != sub4.label
+    assert sub1.label == "NewHeadsSubscription('newHeads',)"
+    assert sub2.label == "NewHeadsSubscription('newHeads',)#2"
+    assert sub3.label == "NewHeadsSubscription('newHeads',)#3"
+    assert sub4.label == "NewHeadsSubscription('newHeads',)#4"
+
+    # assert no issues unsubscribing
+    await subscription_manager.unsubscribe_all()
+
+    assert subscription_manager.subscriptions == []
+    assert subscription_manager._subscription_container.subscriptions == []
+    assert subscription_manager._subscription_container.subscriptions_by_id == {}
+    assert subscription_manager._subscription_container.subscriptions_by_label == {}
+
+
+@pytest.mark.asyncio
+async def test_subscription_manager_raises_for_new_subs_with_the_same_custom_label(
     subscription_manager,
 ):
     sub1 = NewHeadsSubscription(label="foo")
-    await subscription_manager.subscribe(sub1)
+    sub2 = LogsSubscription(label="foo")
 
     with pytest.raises(
         Web3ValueError,
         match="Subscription label already exists. Subscriptions must have unique "
         "labels.\n    label: foo",
     ):
-        sub2 = LogsSubscription(label="foo")
-        await subscription_manager.subscribe(sub2)
+        await subscription_manager.subscribe([sub1, sub2])
 
     # make sure the subscription was subscribed to and not added to the manager
     assert subscription_manager.subscriptions == [sub1]

web3/providers/persistent/subscription_manager.py

@@ -69,6 +69,23 @@ def _add_subscription(self, subscription: EthSubscription[Any]) -> None:
     def _remove_subscription(self, subscription: EthSubscription[Any]) -> None:
         self._subscription_container.remove_subscription(subscription)
 
+    def _validate_and_normalize_label(self, subscription: EthSubscription[Any]) -> None:
+        if subscription.label == subscription._default_label:
+            # if no custom label was provided, generate a unique label
+            i = 2
+            while self.get_by_label(subscription._label) is not None:
+                subscription._label = f"{subscription._default_label}#{i}"
+                i += 1
+        else:
+            if (
+                subscription._label
+                in self._subscription_container.subscriptions_by_label
+            ):
+                raise Web3ValueError(
+                    "Subscription label already exists. Subscriptions must have unique "
+                    f"labels.\n    label: {subscription._label}"
+                )
+
     @property
     def subscriptions(self) -> List[EthSubscription[Any]]:
         return self._subscription_container.subscriptions
@@ -100,16 +117,8 @@ async def subscribe(
         :return:
         """
         if isinstance(subscriptions, EthSubscription):
-            if (
-                subscriptions.label
-                in self._subscription_container.subscriptions_by_label
-            ):
-                raise Web3ValueError(
-                    "Subscription label already exists. Subscriptions must have "
-                    f"unique labels.\n    label: {subscriptions.label}"
-                )
-
             subscriptions.manager = self
+            self._validate_and_normalize_label(subscriptions)
             sub_id = await self._w3.eth._subscribe(*subscriptions.subscription_params)
             subscriptions._id = sub_id
             self._add_subscription(subscriptions)

web3/utils/subscriptions.py

@@ -114,6 +114,10 @@ def __init__(
         self._label = label
         self.handler_call_count = 0
 
+    @property
+    def _default_label(self) -> str:
+        return f"{self.__class__.__name__}{self.subscription_params}"
+
     @classmethod
     def _create_type_aware_subscription(
         cls,
@@ -170,7 +174,7 @@ def subscription_params(self) -> Sequence[Any]:
     @property
     def label(self) -> str:
         if not self._label:
-            self._label = f"{self.__class__.__name__}{self.subscription_params}"
+            self._label = self._default_label
         return self._label
 
     @property