check operators' balance

ringecosystem · Mar 6, 2024 · be511d1 · be511d1
1 parent 6955ebc
commit be511d1
Show file tree

Hide file tree

Showing 14 changed files with 251 additions and 67 deletions.
diff --git a/server/.gitignore → .gitignore b/server/.gitignore → .gitignore
diff --git a/server/README.md → README.md b/server/README.md → README.md
diff --git a/server/app.js b/server/app.js
@@ -25,6 +25,6 @@ export default async function (fastify, opts) {
   // define your routes in one of these
   fastify.register(AutoLoad, {
     dir: path.join(__dirname, 'routes'),
-    options: Object.assign({}, opts)
+    options: Object.assign({ prefix: '/api' }, opts)
   })
 }
diff --git a/server/config/chains.js b/server/config/chains.js
@@ -0,0 +1,153 @@
+const Chains = [
+  {
+    "name": "crab",
+    "id": 44,
+    "endpoint": "https://crab-rpc.darwinia.network",
+    "indexer": {
+      "ormp": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/ormpipe-crab",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "CRAB"
+  },
+  {
+    "name": "darwinia",
+    "id": 46,
+    "endpoint": "https://rpc.darwinia.network",
+    "indexer": {
+      "ormp": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/ormpipe-darwinia",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "RING"
+  },
+  {
+    "name": "arbitrum",
+    "id": 42161,
+    "endpoint": "https://arbitrum-one.publicnode.com",
+    "indexer": {
+      "ormp": "https://api.studio.thegraph.com/proxy/51152/ormpipe-arbitrum/version/latest",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "AETH"
+  },
+  {
+    "name": "ethereum",
+    "id": 1,
+    "endpoint": "https://ethereum.publicnode.com",
+    "indexer": {
+      "ormp": "https://api.studio.thegraph.com/proxy/51152/ormpipe-ethereum/version/latest",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "ETH"
+  },
+  {
+    "name": "polygon",
+    "id": 137,
+    "endpoint": "https://polygon-bor-rpc.publicnode.com",
+    "indexer": {
+      "ormp": "https://api.studio.thegraph.com/proxy/51152/ormpipe-polygon/version/latest",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "MATIC"
+  },
+  {
+    "name": "blast",
+    "id": 81457,
+    "endpoint": "https://rpc.blast.io",
+    "indexer": {
+      "ormp": "https://api.studio.thegraph.com/proxy/51152/ormpipe-blast/version/latest",
+      "signcribe": "https://thegraph-g2.darwinia.network/ormpipe/subgraphs/name/signcribe-darwinia"
+    },
+    "contract": {
+      "signcribe": "0x57dd62e0986a61a269c769b107a5a7952d73b7ed",
+      "relayer": "0x0000000000808fE9bDCc1d180EfbF5C53552a6b1",
+      "ormp": "0x00000000001523057a05d6293C1e5171eE33eE0A",
+      "oracle": "0x0000000003ebeF32D8f0ED406a5CA8805c80AFba",
+      "multisig": "0x000000000d60704384100A29efb6C9cf8cD72820"
+    },
+    "operator": {
+      "oracle": "0x178E699c9a6bB2Cd624557Fbd85ed219e6faBa77",
+      "relayer": "0x912D7601569cBc2DF8A7f0aaE50BFd18e8C64d05",
+    },
+    "symbol": "ETH"
+  }
+]
+
+function getChainById(id) {
+  for (const item of Chains) {
+    if(item.id == id) {
+      return item;
+    }
+  }
+  return null;
+}
+
+function getChainByName(name) {
+  for (const item of Chains) {
+    if(item.name == name) {
+      return item;
+    }
+  }
+  return null;
+}
+
+
+function getAllChains() {
+  return Chains;
+}
+
+export { getAllChains, getChainById, getChainByName };
diff --git a/server/package.json b/server/package.json
@@ -18,6 +18,7 @@
   "dependencies": {
     "@fastify/autoload": "^5.0.0",
     "@fastify/sensible": "^5.0.0",
+    "ethers": "^6.11.1",
     "fastify": "^4.26.1",
     "fastify-cli": "^6.1.1",
     "fastify-plugin": "^4.0.0"

diff --git a/server/plugins/README.md b/server/plugins/README.md
diff --git a/server/plugins/support.js b/server/plugins/support.js
diff --git a/server/routes/README.md b/server/routes/README.md
diff --git a/server/routes/balance/helper.js b/server/routes/balance/helper.js
@@ -0,0 +1,6 @@
+
+function unitToEth(num) {
+    return Number(num) / Math.pow(10, 18);
+}
+
+export { unitToEth }
diff --git a/server/routes/balance/index.js b/server/routes/balance/index.js
@@ -0,0 +1,24 @@
+import { ethers } from "ethers"
+import { getAllChains } from "../../config/chains.js"
+import { unitToEth } from "./helper.js";
+
+export default async function (fastify) {
+    fastify.get('/operators', async function () {
+        return await checkOperatorBalance()
+    })
+
+    async function checkOperatorBalance() {
+        const operatorInfo = {};
+        for (const chain of getAllChains()) {
+            const operatorBalance = {};
+            const provider = new ethers.JsonRpcProvider(chain.endpoint);
+            let relayerBalance = await provider.getBalance(chain.operator.relayer);
+            operatorBalance.relayer = unitToEth(relayerBalance);
+            let oracleBalance = await provider.getBalance(chain.operator.oracle);
+            operatorBalance.oracle = unitToEth(oracleBalance);
+            operatorBalance.symbol = chain.symbol;
+            operatorInfo[chain.name] = operatorBalance;
+        }
+        return operatorInfo;
+    }
+}
diff --git a/server/routes/example/index.js b/server/routes/example/index.js
diff --git a/server/routes/root.js b/server/routes/root.js
diff --git a/server/server.js b/server/server.js
@@ -13,9 +13,22 @@ import appService from './app.js'
 // Dotenv config
 dotenv.config()
 
+const LOG_LEVEL = process.env.LOG_LEVEL || 'info';
+const PORT = process.env.PORT || '8000';
+const LISTEN = process.env.LISTEN || '127.0.0.1'
+
 // Instantiate Fastify with some config
 const app = Fastify({
-  logger: true
+  logger: {
+    level: LOG_LEVEL,
+    transport: LOG_LEVEL == 'debug' ? {
+      target: 'pino-pretty',
+      options: {
+        translateTime: 'mm-dd HH:MM:ss',
+        ignore: 'pid,hostname'
+      }
+    } : null
+  }
 })
 
 // Register your application as a normal plugin.
@@ -24,7 +37,7 @@ app.register(appService)
 // delay is the number of milliseconds for the graceful close to finish
 const closeListeners = closeWithGrace({ delay: process.env.FASTIFY_CLOSE_GRACE_DELAY || 500 }, async function ({ signal, err, manual }) {
   if (err) {
-    app.log.error(err)
+    app.log.error(err, signal, manual)
   }
   await app.close()
 })
@@ -35,7 +48,7 @@ app.addHook('onClose', async (instance, done) => {
 })
 
 // Start listening.
-app.listen({ port: process.env.PORT || 3000 }, (err) => {
+app.listen({ port: PORT, host: LISTEN }, (err) => {
   if (err) {
     app.log.error(err)
     process.exit(1)