format

Author: chirag-parmar

nimbus_verified_proxy/rpc/receipts.nim

@@ -84,7 +84,9 @@ proc getReceipts*(
 
   await vp.getReceipts(header, numberTag)
 
-proc resolveFilterTags*(vp: VerifiedRpcProxy, filter: FilterOptions): Result[FilterOptions, string] =
+proc resolveFilterTags*(
+    vp: VerifiedRpcProxy, filter: FilterOptions
+): Result[FilterOptions, string] =
   if filter.blockHash.isSome():
     return ok(filter)
   let
@@ -106,9 +108,8 @@ proc resolveFilterTags*(vp: VerifiedRpcProxy, filter: FilterOptions): Result[Fil
   )
 
 proc verifyLogs*(
-   vp: VerifiedRpcProxy, filter: FilterOptions, logObjs: seq[LogObject]
+    vp: VerifiedRpcProxy, filter: FilterOptions, logObjs: seq[LogObject]
 ): Future[Result[void, string]] {.async.} =
-
   # store block hashes contains the logs so that we can batch receipt requests
   var
     prevBlockHash: Hash32
@@ -139,7 +140,9 @@ proc verifyLogs*(
 
   ok()
 
-proc getLogs*(vp: VerifiedRpcProxy, filter: FilterOptions): Future[Result[seq[LogObject], string]] {.async.} =
+proc getLogs*(
+    vp: VerifiedRpcProxy, filter: FilterOptions
+): Future[Result[seq[LogObject], string]] {.async.} =
   let
     resolvedFilter = vp.resolveFilterTags(filter).valueOr:
       return err(error)

nimbus_verified_proxy/rpc/rpc_eth_api.nim

@@ -272,17 +272,16 @@ proc installEthApiHandlers*(vp: VerifiedRpcProxy) =
     raise newException(ValueError, "receipt couldn't be verified")
 
   vp.proxy.rpc("eth_getLogs") do(filterOptions: FilterOptions) -> seq[LogObject]:
-   (await vp.getLogs(filterOptions)).valueOr:
+    (await vp.getLogs(filterOptions)).valueOr:
       raise newException(ValueError, error)
 
   vp.proxy.rpc("eth_newFilter") do(filterOptions: FilterOptions) -> string:
-    let
-      id =
-        try:
-          # filter is not resolved when storing only while fetching
-          await vp.rpcClient.eth_newFilter(filterOptions)
-        except CatchableError as e:
-          raise newException(ValueError, e.msg)
+    let id =
+      try:
+        # filter is not resolved when storing only while fetching
+        await vp.rpcClient.eth_newFilter(filterOptions)
+      except CatchableError as e:
+        raise newException(ValueError, e.msg)
 
     vp.filterStore[id] = filterOptions
     return id

nimbus_verified_proxy/rpc_api_backend.nim

@@ -7,7 +7,12 @@
 
 {.push raises: [], gcsafe.}
 
-import json_rpc/[rpcproxy, rpcclient], web3/[eth_api, eth_api_types], stint, std/json, ./types
+import
+  json_rpc/[rpcproxy, rpcclient],
+  web3/[eth_api, eth_api_types],
+  stint,
+  std/json,
+  ./types
 
 proc initNetworkApiBackend*(vp: VerifiedRpcProxy): EthApiBackend =
   let
@@ -64,9 +69,7 @@ proc initNetworkApiBackend*(vp: VerifiedRpcProxy): EthApiBackend =
     ): Future[string] {.async: (raw: true).} =
       vp.proxy.getClient.eth_newFilter(filterOptions)
 
-    uninstallFilterProc = proc(
-        filterId: string
-    ): Future[bool] {.async: (raw: true).} =
+    uninstallFilterProc = proc(filterId: string): Future[bool] {.async: (raw: true).} =
       vp.proxy.getClient.eth_uninstallFilter(filterId)
 
     getFilterChangesProc = proc(
@@ -87,5 +90,5 @@ proc initNetworkApiBackend*(vp: VerifiedRpcProxy): EthApiBackend =
     eth_getTransactionReceipt: getTransactionReceiptProc,
     eth_newFilter: newFilterProc,
     eth_uninstallFilter: uninstallFilterProc,
-    eth_getFilterChanges: getFilterChangesProc
+    eth_getFilterChanges: getFilterChangesProc,
   )

nimbus_verified_proxy/types.nim

@@ -56,7 +56,6 @@ type
   UninstallFilterProc = proc(filterId: string): Future[bool] {.async.}
   GetFilterChangesProc = proc(filterid: string): Future[JsonNode] {.async.}
 
-
   EthApiBackend* = object
     eth_chainId*: ChainIdProc
     eth_getBlockByHash*: GetBlockByHashProc