@@ -61,7 +61,7 @@ def __init__(self, node_url: str):
6161 self .node_url : str = node_url
6262 self .connection : Optional [ClientConnection ] = None
6363 self ._listen_task : Optional [asyncio .Task ] = None
64- self ._subscriptions : Dict [int , NotificationHandler ] = {}
64+ self ._subscriptions : Dict [str , NotificationHandler ] = {}
6565 self ._message_id = 0
6666 self ._pending_responses : Dict [int , asyncio .Future ] = {}
6767 self ._on_chain_reorg : Optional [Callable [[ReorgNotification ], Any ]] = None
@@ -101,7 +101,7 @@ async def subscribe_new_heads(
101101 handler : Callable [[NewHeadsNotification ], Any ],
102102 block_hash : Optional [Union [Hash , LatestTag ]] = None ,
103103 block_number : Optional [Union [int , LatestTag ]] = None ,
104- ) -> int :
104+ ) -> str :
105105 """
106106 Creates a WebSocket stream which will fire events for new block headers.
107107
@@ -125,7 +125,7 @@ async def subscribe_events(
125125 keys : Optional [List [List [int ]]] = None ,
126126 block_hash : Optional [Union [Hash , LatestTag ]] = None ,
127127 block_number : Optional [Union [int , LatestTag ]] = None ,
128- ) -> int :
128+ ) -> str :
129129 """
130130 Creates a WebSocket stream which will fire events for new Starknet events with applied filters.
131131
@@ -160,7 +160,7 @@ async def subscribe_transaction_status(
160160 self ,
161161 handler : Callable [[TransactionStatusNotification ], Any ],
162162 transaction_hash : int ,
163- ) -> int :
163+ ) -> str :
164164 """
165165 Creates a WebSocket stream which at first fires an event with the current known transaction status, followed
166166 by events for every transaction status update.
@@ -181,7 +181,7 @@ async def subscribe_pending_transactions(
181181 handler : Callable [[PendingTransactionsNotification ], Any ],
182182 transaction_details : Optional [bool ] = None ,
183183 sender_address : Optional [List [int ]] = None ,
184- ) -> int :
184+ ) -> str :
185185 """
186186 Creates a WebSocket stream which will fire events when a new pending transaction is added.
187187 While there is no mempool, this notifies of transactions in the pending block.
@@ -226,7 +226,7 @@ def on_chain_reorg(self, handler: Callable[[ReorgNotification], Any]):
226226 """
227227 self ._on_chain_reorg = handler
228228
229- async def unsubscribe (self , subscription_id : int ) -> bool :
229+ async def unsubscribe (self , subscription_id : str ) -> bool :
230230 """
231231 Close a previously opened WebSocket stream, with the corresponding subscription id.
232232
@@ -250,7 +250,7 @@ async def _subscribe(
250250 handler : Callable [[Any ], Any ],
251251 method : str ,
252252 params : Optional [Dict [str , Any ]] = None ,
253- ) -> int :
253+ ) -> str :
254254 """ "
255255 Creates a WebSocket stream which will fire events on a specific action.
256256
0 commit comments