chore: fix async raises warnings

ethers/providers/jsonrpc/subscriptions.nim

@@ -24,6 +24,14 @@ type
 
 {.push raises:[].}
 
+template convertErrorsToSubscriptionError(body) =
+  try:
+    body
+  except CancelledError as error:
+    raise error
+  except CatchableError as error:
+    raise error.toErr(SubscriptionError)
+
 template `or`(a: JsonNode, b: typed): JsonNode =
   if a.isNil: b else: a
 
@@ -56,22 +64,22 @@ proc setMethodHandler(
 method subscribeBlocks*(subscriptions: JsonRpcSubscriptions,
                         onBlock: BlockHandler):
                        Future[JsonNode]
-                       {.async, base, raises: [CancelledError].} =
+                       {.async: (raises: [SubscriptionError, CancelledError]), base,.} =
   raiseAssert "not implemented"
 
 method subscribeLogs*(subscriptions: JsonRpcSubscriptions,
                       filter: EventFilter,
                       onLog: LogHandler):
                      Future[JsonNode]
-                     {.async, base.} =
+                     {.async: (raises: [SubscriptionError, CancelledError]), base.} =
   raiseAssert "not implemented"
 
 method unsubscribe*(subscriptions: JsonRpcSubscriptions,
                     id: JsonNode)
-                   {.async, base.} =
+                   {.async: (raises: [SubscriptionError, CancelledError]), base.} =
   raiseAssert "not implemented"
 
-method close*(subscriptions: JsonRpcSubscriptions) {.async, base.} =
+method close*(subscriptions: JsonRpcSubscriptions) {.async: (raises: [SubscriptionError, CancelledError]), base.} =
   let ids = toSeq subscriptions.callbacks.keys
   for id in ids:
     await subscriptions.unsubscribe(id)
@@ -102,7 +110,7 @@ proc new*(_: type JsonRpcSubscriptions,
 method subscribeBlocks(subscriptions: WebSocketSubscriptions,
                        onBlock: BlockHandler):
                       Future[JsonNode]
-                      {.async, raises: [].} =
+                      {.async: (raises: [SubscriptionError, CancelledError]).} =
   proc callback(id: JsonNode, argumentsResult: ?!JsonNode) {.raises: [].} =
     without arguments =? argumentsResult, error:
       onBlock(failure(Block, error.toErr(SubscriptionError)))
@@ -111,15 +119,16 @@ method subscribeBlocks(subscriptions: WebSocketSubscriptions,
     let res = Block.fromJson(arguments{"result"}).mapFailure(SubscriptionError)
     onBlock(res)
 
-  let id = await subscriptions.client.eth_subscribe("newHeads")
+  convertErrorsToSubscriptionError:
-  subscriptions.callbacks[id] = callback
+    let id = await subscriptions.client.eth_subscribe("newHeads")
-  return id
+    subscriptions.callbacks[id] = callback
+    return id
 
 method subscribeLogs(subscriptions: WebSocketSubscriptions,
                      filter: EventFilter,
                      onLog: LogHandler):
                     Future[JsonNode]
-                    {.async.} =
+                    {.async: (raises: [SubscriptionError, CancelledError]).} =
   proc callback(id: JsonNode, argumentsResult: ?!JsonNode) =
     without arguments =? argumentsResult, error:
       onLog(failure(Log, error.toErr(SubscriptionError)))
@@ -128,15 +137,17 @@ method subscribeLogs(subscriptions: WebSocketSubscriptions,
     let res = Log.fromJson(arguments{"result"}).mapFailure(SubscriptionError)
     onLog(res)
 
-  let id = await subscriptions.client.eth_subscribe("logs", filter)
+  convertErrorsToSubscriptionError:
-  subscriptions.callbacks[id] = callback
+    let id = await subscriptions.client.eth_subscribe("logs", filter)
-  return id
+    subscriptions.callbacks[id] = callback
+    return id
 
 method unsubscribe*(subscriptions: WebSocketSubscriptions,
                    id: JsonNode)
-                  {.async.} =
+                  {.async: (raises: [SubscriptionError, CancelledError]).} =
-  subscriptions.callbacks.del(id)
+  convertErrorsToSubscriptionError:
-  discard await subscriptions.client.eth_unsubscribe(id)
+    subscriptions.callbacks.del(id)
+    discard await subscriptions.client.eth_unsubscribe(id)
 
 # Polling
 
@@ -235,7 +246,7 @@ method close*(subscriptions: PollingSubscriptions) {.async.} =
 method subscribeBlocks(subscriptions: PollingSubscriptions,
                        onBlock: BlockHandler):
                       Future[JsonNode]
-                      {.async, raises:[CancelledError].} =
+                      {.async: (raises: [SubscriptionError, CancelledError]).} =
 
   proc getBlock(hash: BlockHash) {.async: (raises:[]).} =
     try:
@@ -255,16 +266,17 @@ method subscribeBlocks(subscriptions: PollingSubscriptions,
     if hash =? BlockHash.fromJson(change):
       asyncSpawn getBlock(hash)
 
-  let id = await subscriptions.client.eth_newBlockFilter()
+  convertErrorsToSubscriptionError:
-  subscriptions.callbacks[id] = callback
+    let id = await subscriptions.client.eth_newBlockFilter()
-  subscriptions.subscriptionMapping[id] = id
+    subscriptions.callbacks[id] = callback
-  return id
+    subscriptions.subscriptionMapping[id] = id
+    return id
 
 method subscribeLogs(subscriptions: PollingSubscriptions,
                      filter: EventFilter,
                      onLog: LogHandler):
                     Future[JsonNode]
-                    {.async.} =
+                    {.async: (raises: [SubscriptionError, CancelledError]).} =
 
   proc callback(id: JsonNode, argumentsResult: ?!JsonNode) =
     without arguments =? argumentsResult, error:
@@ -274,15 +286,16 @@ method subscribeLogs(subscriptions: PollingSubscriptions,
     let res = Log.fromJson(arguments).mapFailure(SubscriptionError)
     onLog(res)
 
-  let id = await subscriptions.client.eth_newFilter(filter)
+  convertErrorsToSubscriptionError:
-  subscriptions.callbacks[id] = callback
+    let id = await subscriptions.client.eth_newFilter(filter)
-  subscriptions.logFilters[id] = filter
+    subscriptions.callbacks[id] = callback
-  subscriptions.subscriptionMapping[id] = id
+    subscriptions.logFilters[id] = filter
-  return id
+    subscriptions.subscriptionMapping[id] = id
+    return id
 
 method unsubscribe*(subscriptions: PollingSubscriptions,
                    id: JsonNode)
-                  {.async.} =
+                  {.async: (raises: [SubscriptionError, CancelledError]).} =
   try:
     subscriptions.logFilters.del(id)
     subscriptions.callbacks.del(id)

testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim

@@ -1,5 +1,4 @@
 import std/os
-import std/sequtils
 import std/importutils
 import pkg/asynctest
 import pkg/serde