feat: added block handler to handle indexing of reserve balance

docker-compose.yml

@@ -37,6 +37,7 @@ services:
       - --db-schema=app
       - --workers=4
       - --batch-size=30
+      - --unsafe
       # - --log-level=debug
       # - --unfinalized-blocks=true
     healthcheck:

package.json

@@ -46,6 +46,7 @@
   "dependencies": {
     "@subql/types-cosmos": "^3.2.3",
     "@types/node": "^17.0.21",
+    "cross-fetch": "^4.0.0",
     "pino": "^7.8.0",
     "ts-proto": "^1.112.1",
     "tslib": "^2.3.1"

project.ts

@@ -64,12 +64,12 @@ const project: CosmosProject = {
       mapping: {
         file: "./dist/index.js",
         handlers: [
-          // {
-          //     Using block handlers slows your project down as they can be executed with each and every block.
-          //     Only use if you need to
-          //     handler: 'handleEvent',
-          //     kind: CosmosHandlerKind.Block,
-          // },
+          {
+            // Using block handlers slows your project down as they can be executed with each and every block.
+            // Only use if you need to
+            handler: 'handleBlock',
+            kind: CosmosHandlerKind.Block,
+          },
           // {
           //   handler: "handleEvent",
           //   kind: CosmosHandlerKind.Event,

schema.graphql

@@ -260,3 +260,11 @@ type ReserveMetrics @entity {
   totalFeeMinted: BigInt!
   allocations: [ReserveAllocationMetrics] @derivedFrom(field: "reserveMetrics")
 }
+
+type ReserveBalance @entity {
+  id: ID!
+  blockHeight: BigInt!
+  address: String!
+  balance: BigInt!
+  denomination: String!
+}

src/mappings/mappingHandlers.ts

@@ -16,8 +16,9 @@ import {
   VaultManagerMetricsDaily,
   PsmMetricDaily,
   ReserveAllocationMetricsDaily,
+  ReserveBalance,
 } from "../types";
-import { CosmosEvent } from "@subql/types-cosmos";
+import { CosmosEvent, CosmosBlock } from "@subql/types-cosmos";
 import {
   b64encode,
   b64decode,
@@ -26,6 +27,7 @@ import {
   extractBrand,
   resolveBrandNamesAndValues,
   dateToDayKey,
+  fetch,
 } from "./utils";
 
 import { EVENT_TYPES, STORE_KEY, VSTORAGE_VALUE, KEY_KEY, VALUE_KEY } from "./constants";
@@ -40,6 +42,22 @@ BigInt.prototype.toJSON = function () {
   return this.toString();
 };
 
+const API_ENDPOINT = 'https://main-a.api.agoric.net:443'
+
+export async function handleBlock(block: CosmosBlock): Promise<void> {
+  const moduleAccounts = await fetch(`${API_ENDPOINT}/cosmos/auth/v1beta1/module_accounts`);
+
+  const reserveAccount = moduleAccounts.accounts.find((account: any) => account.name === 'vbank/reserve');
+  const reserveAccountAddress = reserveAccount.base_account.address;
+
+  const reserveAccountBalances = await fetch(`${API_ENDPOINT}/cosmos/bank/v1beta1/balances/${reserveAccountAddress}`);
+
+  const istBalance = reserveAccountBalances.balances.find((balance: any) => balance.denom === "uist")
+
+  const record = new ReserveBalance(block.block.id, BigInt(block.header.height), reserveAccountAddress, BigInt(istBalance.amount), 'uist');
+  await record.save();
+}
+
 export async function handleStateChangeEvent(cosmosEvent: CosmosEvent): Promise<void> {
   const { event, block } = cosmosEvent;
 

src/mappings/utils.ts

@@ -1,3 +1,5 @@
+import crossFetch from 'cross-fetch';
+
 export function extractBrand(str: string): string {
   return str.replace("Alleged: ", "").replace(" brand", "");
 }
@@ -95,3 +97,15 @@ export function dateToDayKey(timestamp: any): number {
   const day = date.getUTCDate().toString().padStart(2, "0");
   return parseInt(`${year}${month}${day}`);
 }
+
+export const fetch = async (url: string) => {
+  const response = await crossFetch(url);
+
+  if (response.status >= 400) {
+    const errorText = await response.text();
+    throw new Error(`Status: ${response.status} -- ${errorText}`);
+  }
+
+  const responseJson = await response.json();
+  return responseJson;
+}