Handle 'usurped' error from substrate

Author: thewhaleking

async_substrate_interface/async_substrate.py

@@ -3987,6 +3987,15 @@ async def result_handler(message: dict, subscription_id) -> tuple[dict, bool]:
                 message_result = {
                     k.lower(): v for k, v in message["params"]["result"].items()
                 }
+                if "usurped" in message_result:
+                    logger.error(
+                        f"Subscription {subscription_id} usurped: {message_result}"
+                    )
+                    async with self.ws as ws:
+                        await ws.unsubscribe(subscription_id)
+                    raise SubstrateRequestException(
+                        f"Subscription {subscription_id} usurped: {message_result}"
+                    )
 
                 if "finalized" in message_result and wait_for_finalization:
                     logger.debug("Extrinsic finalized. Unsubscribing.")
@@ -3998,7 +4007,7 @@ async def result_handler(message: dict, subscription_id) -> tuple[dict, bool]:
                         "finalized": True,
                     }, True
                 elif (
-                    any(x in message_result for x in ["inblock", "inBlock"])
+                    "inblock" in message_result
                     and wait_for_inclusion
                     and not wait_for_finalization
                 ):

async_substrate_interface/sync_substrate.py

@@ -3170,6 +3170,15 @@ def result_handler(message: dict, subscription_id) -> tuple[dict, bool]:
                     k.lower(): v for k, v in message["params"]["result"].items()
                 }
 
+                if "usurped" in message_result:
+                    logger.error(
+                        f"Subscription {subscription_id} usurped: {message_result}"
+                    )
+                    self.rpc_request("author_unwatchExtrinsic", [subscription_id])
+                    raise SubstrateRequestException(
+                        f"Subscription {subscription_id} usurped: {message_result}"
+                    )
+
                 if "finalized" in message_result and wait_for_finalization:
                     # Created as a task because we don't actually care about the result
                     # TODO change this logic