Merge pull request #1 from rsksmart/feat/add-rootstock

Add Rootstock

Author: jonathansmirnoff

.env.example

@@ -5,6 +5,8 @@ INFURA_IPFS_PASS=
 ALCHEMY_ARBITRUM_API_KEY=
 ALCHEMY_SEPOLIA_API_KEY=
 ALCHEMY_OPTIMISM_GOERLI_API_KEY=
+ROOTSTOCK_TESTNET_API_KEY=
+ROOTSTOCK_API_KEY=
 #POLLING_INTERVAL=60000
 #DISABLE_LISTENER=true
 #REQUEST_DELAY=500 # How many ms to wait before making a request to RPC (useful for free plans)

Dockerfile

@@ -7,6 +7,8 @@ ENV INFURA_API_KEY=${INFURA_API_KEY}
 ENV ALCHEMY_ARBITRUM_API_KEY=${ALCHEMY_ARBITRUM_API_KEY}
 ENV ALCHEMY_SEPOLIA_API_KEY=${ALCHEMY_SEPOLIA_API_KEY}
 ENV ALCHEMY_OPTIMISM_GOERLI_API_KEY=${ALCHEMY_OPTIMISM_GOERLI_API_KEY}
+ENV ROOTSTOCK_TESTNET_API_KEY=${ROOTSTOCK_TESTNET_API_KEY}
+ENV ROOTSTOCK_API_KEY=${ROOTSTOCK_API_KEY}
 ENV CHAIN_ID=${CHAIN_ID}
 
 COPY . .

README.md

@@ -21,6 +21,8 @@ INFURA_IPFS_PASS=
 ALCHEMY_ARBITRUM_API_KEY=
 ALCHEMY_SEPOLIA_API_KEY=
 ALCHEMY_OPTIMISM_GOERLI_API_KEY=
+ROOTSTOCK_TESTNET_API_KEY=
+ROOTSTOCK_API_KEY=
 #POLLING_INTERVAL=60000
 #DISABLE_LISTENER=true
 #REQUEST_DELAY=500 # How many ms to wait before making a request to RPC (useful for free plans)

graph.ts

@@ -4,7 +4,12 @@ import {
   applyResolversEnhanceMap,
   ResolversEnhanceMap,
 } from "@generated/type-graphql";
-import { AuthChecker, Authorized, buildSchema } from "type-graphql";
+import {
+  AuthChecker,
+  Authorized,
+  buildSchema,
+  UseMiddleware,
+} from "type-graphql";
 import { ApolloServer } from "apollo-server";
 import { prisma } from "./db.server";
 
@@ -14,7 +19,20 @@ export async function startGraph() {
   const resolversEnhanceMap: ResolversEnhanceMap = {
     Attestation: {
       attestation: [Authorized()],
-      attestations: [Authorized()],
+      attestations: [
+        Authorized(),
+        UseMiddleware(async (action, next) => {
+          // Get the current args
+          const args = action.args as any;
+
+          if (!args.take) {
+            args.take = 100;
+          }
+
+          // Call the next middleware or resolver
+          return next();
+        }),
+      ],
       findFirstAttestation: [Authorized()],
       aggregateAttestation: [Authorized()],
       createOneAttestation: [Authorized(["ADMIN"])],

scripts/updateForTxId.ts

@@ -6,18 +6,33 @@ import { updateDbFromEthTransaction } from "../utils";
 const input = process.argv[2];
 
 if (!input) {
-  console.error("Please provide a transaction id or a comma-separated list of transaction ids");
+  console.error(
+    "Please provide a transaction id or a comma-separated list of transaction ids"
+  );
   process.exit(1);
 }
 
-const txids = input.split(',').map(txid => txid.trim());
+const txids = input.split(",").map((txid) => txid.trim());
 
-Promise.all(txids.map(updateDbFromEthTransaction))
+async function processSequentially() {
+  for (const txid of txids) {
+    try {
+      await updateDbFromEthTransaction(txid);
+      console.log(`Successfully processed transaction: ${txid}`);
+    } catch (error) {
+      console.error(`Error processing transaction ${txid}:`, error);
+
+      process.exit(1);
+    }
+  }
+}
+
+processSequentially()
   .then(() => {
-    console.log("Success");
+    console.log("All transactions processed");
     process.exit(0);
   })
   .catch((e) => {
-    console.error("Error", e);
+    console.error("Unexpected error:", e);
     process.exit(1);
-  });
+  });

utils.ts

@@ -17,6 +17,9 @@ const requestDelay = process.env.REQUEST_DELAY
 
 const limit = pLimit(5);
 
+// Add a constant for maximum retries
+const MAX_RETRIES = 5;
+
 export type EASChainConfig = {
   chainId: number;
   chainName: string;
@@ -158,16 +161,27 @@ export const EAS_CHAIN_CONFIGS: EASChainConfig[] = [
     etherscanURL: "https://lineascan.build/",
     rpcProvider: `https://linea-mainnet.infura.io/v3/${process.env.INFURA_LINEA_API_KEY}`,
   },
+  // {
+  //   chainId: 80001,
+  //   chainName: "polygon-mumbai",
+  //   subdomain: "polygon-mumbai.",
+  //   version: "1.2.0",
+  //   contractAddress: "0xaEF4103A04090071165F78D45D83A0C0782c2B2a",
+  //   schemaRegistryAddress: "0x55D26f9ae0203EF95494AE4C170eD35f4Cf77797",
+  //   contractStartBlock: 41442300,
+  //   etherscanURL: "https://mumbai.polygonscan.com/",
+  //   rpcProvider: `https://polygon-mumbai.infura.io/v3/${process.env.INFURA_API_KEY}`,
+  // },
   {
-    chainId: 80001,
-    chainName: "polygon-mumbai",
-    subdomain: "polygon-mumbai.",
-    version: "1.2.0",
-    contractAddress: "0xaEF4103A04090071165F78D45D83A0C0782c2B2a",
-    schemaRegistryAddress: "0x55D26f9ae0203EF95494AE4C170eD35f4Cf77797",
-    contractStartBlock: 41442300,
-    etherscanURL: "https://mumbai.polygonscan.com/",
-    rpcProvider: `https://polygon-mumbai.infura.io/v3/${process.env.INFURA_API_KEY}`,
+    chainId: 80002,
+    chainName: "polygon-amoy",
+    subdomain: "polygon-amoy.",
+    version: "1.3.0",
+    contractAddress: "0xb101275a60d8bfb14529C421899aD7CA1Ae5B5Fc",
+    schemaRegistryAddress: "0x23c5701A1BDa89C61d181BD79E5203c730708AE7",
+    contractStartBlock: 7372405,
+    etherscanURL: "https://amoy.polygonscan.com/",
+    rpcProvider: `https://restless-palpable-mountain.matic-amoy.quiknode.pro/${process.env.QUICKNODE_POLYGON_AMOY_API_KEY}/`,
   },
   {
     chainId: 137,
@@ -224,6 +238,28 @@ export const EAS_CHAIN_CONFIGS: EASChainConfig[] = [
     etherscanURL: "https://explorer.zksync.io",
     rpcProvider: `https://mainnet.era.zksync.io`,
   },
+  {
+    chainId: 31,
+    chainName: "rootstock-testnet",
+    subdomain: "rootstock-testnet.",
+    version: "1.3.0",
+    contractAddress: "0xc300aeEaDd60999933468738c9F5D7e9C0671e1c",
+    schemaRegistryAddress: "0x679c62956cD2801AbAbF80e9D430f18859Eea2d5",
+    contractStartBlock: 5457123,
+    etherscanURL: "https://rootstock-testnet.blockscout.com/",
+    rpcProvider: `https://rpc.testnet.rootstock.io/${process.env.ROOTSTOCK_TESTNET_API_KEY}`,
+  },
+  {
+    chainId: 30,
+    chainName: "rootstock",
+    subdomain: "rootstock.",
+    version: "1.3.0",
+    contractAddress: "0x54C0726E9d2D57Bc37AD52c7E219A3229e0eE963",
+    schemaRegistryAddress: "0xeF29675d82CC5967069d6d9C17F2719f67728F5B",
+    contractStartBlock: 6635587,
+    etherscanURL: "https://rootstock.blockscout.com/",
+    rpcProvider: `https://rpc.mainnet.rootstock.io/${process.env.ROOTSTOCK_API_KEY}`,
+  },
 ];
 
 const activeChainConfig = EAS_CHAIN_CONFIGS.find(
@@ -300,6 +336,13 @@ export async function getFormattedAttestationFromLog(
   let tries = 1;
 
   do {
+    if (tries > MAX_RETRIES) {
+      console.log(
+        `Max retries reached for log ${log.transactionHash}. Skipping...`
+      );
+      return null; // Exit the loop and return null after max retries
+    }
+
     [
       UID,
       schemaUID,
@@ -369,6 +412,13 @@ export async function getFormattedSchemaFromLog(
   let tries = 1;
 
   do {
+    if (tries > MAX_RETRIES) {
+      console.log(
+        `Max retries reached for schema log ${log.transactionHash}. Skipping...`
+      );
+      throw new Error("Max retries reached while fetching schema.");
+    }
+
     [UID, resolver, revocable, schema] = await schemaContract.getSchema(
       log.topics[1]
     );
@@ -471,6 +521,8 @@ export async function createAttestationsForLogs(logs: ethers.providers.Log[]) {
         await prisma.attestation.create({ data: attestation });
         await processCreatedAttestation(attestation);
       }
+    } else {
+      console.log("Skipped creating attestation due to max retries.");
     }
   }
 }