getBalance

Author: chirag-parmar

nimbus_verified_proxy/libverifproxy/example.c

@@ -15,7 +15,7 @@
 static bool waitOver = true;
 
 void onBlockNumber(Context *ctx, int status, char *res) {
-  printf("response: %s\n", res);
+  printf("Blocknumber: %s\n", res);
   freeResponse(res);
 }
 
@@ -27,11 +27,17 @@ void onStart(Context *ctx, int status, char *res) {
   freeResponse(res);
 }
 
+void onBalance(Context *ctx, int status, char *res) {
+  printf("Balance: %s\n", res);
+  freeResponse(res);
+}
+
 void waitIsOver(Context *ctx, int status, char *res) {
   printf("waiting finished successfully\n");
   printf("status: %d\n", status);
 
   eth_blockNumber(ctx, onBlockNumber);
+  eth_getBalance(ctx, "0x954a86C613fd1fBaC9C7A43a071A68254C75E4AC", "latest", onBalance);
   waitOver = true;
 
   freeResponse(res);
@@ -44,8 +50,8 @@ int main() {
   char* jsonConfig =
     "{"
     "\"eth2Network\": \"mainnet\","
-    "\"trustedBlockRoot\": \"0xdd8db7bfd8c96c993a4cb78e0e6607cf1dcca3f379764388248c63d2bc40443b\","
-    "\"backendUrl\": \"https://eth.llamarpc.com\","
+    "\"trustedBlockRoot\": \"0xd9e4f5b2e7a8e50f9348a1890114ae522d3771ddfb44d8b7e7e2978c21869e91\","
+    "\"backendUrl\": \"https://eth.blockrazor.xyz\","
     "\"beaconApiUrls\": \"http://testing.mainnet.beacon-api.nimbus.team,http://www.lightclientdata.org\","
     "\"logLevel\": \"FATAL\","
     "\"logStdout\": \"None\""

nimbus_verified_proxy/libverifproxy/verifproxy.h

@@ -36,6 +36,7 @@ ETH_RESULT_USE_CHECK Context *createAsyncTaskContext();
 
 typedef void (*CallBackProc) (Context *ctx, int status, char *res);
 
+void eth_getBalance(Context *ctx, char *address, char *blockTag, CallBackProc onBalance);
 void eth_blockNumber(Context *ctx, CallBackProc cb);
 void freeResponse(char *res);
 void freeContext(Context *ctx);

nimbus_verified_proxy/libverifproxy/verifproxy.nim

@@ -10,9 +10,10 @@ import
   json_serialization,
   chronos,
   eth/net/nat,
-  std/[atomics, locks, json, net],
+  std/[atomics, locks, json, net, strutils],
   beacon_chain/spec/[digest, network],
   beacon_chain/nimbus_binary_common,
+  web3/[eth_api_types, conversions],
   ../engine/types,
   ../engine/engine,
   ../lc/lc,
@@ -88,12 +89,12 @@ proc alloc(str: string): cstring =
   ret[str.len] = '\0'
   return ret
 
-proc eth_blockNumber(ctx: ptr Context, cb: CallBackProc) {.exported.} =
+# NOTE: this is not the C callback. This is just a callback for the future
+template callbackToC(ctx: ptr Context, cb: CallBackProc, asyncCall: untyped) =
   let task = createTask(cb)
-
   ctx.tasks.add(task)
 
-  let fut = ctx.frontend.eth_blockNumber()
+  let fut = asyncCall
 
   fut.addCallback proc(_: pointer) {.gcsafe.} =
     if fut.cancelled():
@@ -109,6 +110,30 @@ proc eth_blockNumber(ctx: ptr Context, cb: CallBackProc) {.exported.} =
       task.status = 0
       task.finished = true
 
+proc eth_blockNumber(ctx: ptr Context, cb: CallBackProc) {.exported.} =
+  callbackToC(ctx, cb):
+    ctx.frontend.eth_blockNumber()
+
+proc eth_getBalance(
+    ctx: ptr Context, address: cstring, blockTag: cstring, cb: CallBackProc
+) {.exported.} =
+  let
+    addressTyped =
+      try:
+        Address.fromHex($address)
+      except ValueError as e:
+        cb(ctx, -3, alloc(e.msg))
+        return
+
+    blockTagTyped =
+      try:
+        BlockTag(kind: bidNumber, number: Quantity(parseBiggestUInt($blockTag)))
+      except ValueError:
+        BlockTag(kind: bidAlias, alias: $blockTag)
+
+  callbackToC(ctx, cb):
+    ctx.frontend.eth_getBalance(addressTyped, blockTagTyped)
+
 proc pollAsyncTaskEngine(ctx: ptr Context) {.exported.} =
   var delList: seq[int] = @[]
 
@@ -254,7 +279,7 @@ proc startVerifProxy(
       task.finished = true
       task.status = -1
     else:
-      task.response = "success"
+      task.response = "success" #result is void hence we just provide a string
       task.status = 0
       task.finished = true