Feat/rpc handler

package.json

@@ -32,6 +32,7 @@
     "@octokit/webhooks": "^13.1.0",
     "@sinclair/typebox": "^0.32.5",
     "@supabase/supabase-js": "2.42.0",
+    "@ubiquity-dao/rpc-handler": "^1.1.0",
     "@uniswap/permit2-sdk": "^1.2.0",
     "dotenv": "^16.4.4",
     "ethers": "6.11.1",

src/adapters/supabase/helpers/user.ts

@@ -3,6 +3,9 @@ import { SupabaseClient } from "@supabase/supabase-js";
 import { Super } from "./supabase";
 import { Context } from "../../../types/context";
 
+const FAILED_TO_GET_USER = "Failed to get user";
+const SUCCESSFULLY_FETCHED_USER = "Successfully fetched user";
+
 export class User extends Super {
   constructor(supabase: SupabaseClient<Database>, context: Context) {
     super(supabase, context);
@@ -51,5 +54,3 @@ export class User extends Super {
   }
 }
 
-const FAILED_TO_GET_USER = "Failed to get user";
-const SUCCESSFULLY_FETCHED_USER = "Successfully fetched user";

src/handlers/generate-erc20-permit.ts

@@ -3,7 +3,7 @@ import { ethers, keccak256, MaxInt256, parseUnits, toUtf8Bytes } from "ethers";
 import { Context, Logger } from "../types/context";
 import { PermitReward, TokenType } from "../types";
 import { decryptKeys } from "../utils/keys";
-import { getPayoutConfigByNetworkId } from "../utils/payoutConfigByNetworkId";
+import { getFastestProvider } from "../utils/get-fastest-provider";
 
 export interface Payload {
   evmNetworkId: number;
@@ -63,24 +63,21 @@ export async function generateErc20PermitSignature(contextOrPayload: Context | P
     throw new Error(errorMessage);
   }
 
-  const { rpc } = getPayoutConfigByNetworkId(_evmNetworkId);
+  const provider = await getFastestProvider(_evmNetworkId);
+  if (!provider) {
+    _logger.error("Provider is not defined");
+    throw new Error("Provider is not defined");
+  }
+
   const { privateKey } = await decryptKeys(_evmPrivateEncrypted);
   if (!privateKey) {
     const errorMessage = "Private key is not defined";
     _logger.fatal(errorMessage);
     throw new Error(errorMessage);
   }
 
-  let provider;
   let adminWallet;
   let tokenDecimals;
-  try {
-    provider = new ethers.JsonRpcProvider(rpc);
-  } catch (error) {
-    const errorMessage = `Failed to instantiate provider: ${error}`;
-    _logger.debug(errorMessage);
-    throw new Error(errorMessage);
-  }
 
   try {
     adminWallet = new ethers.Wallet(privateKey, provider);

src/handlers/generate-erc721-permit.ts

@@ -3,7 +3,7 @@ import { ethers, keccak256, toUtf8Bytes } from "ethers";
 import { Context, Logger } from "../types/context";
 import { PermitReward, TokenType } from "../types";
 import { isIssueEvent } from "../types/typeguards";
-import { getPayoutConfigByNetworkId } from "../utils/payoutConfigByNetworkId";
+import { getFastestProvider } from "../utils/get-fastest-provider";
 
 interface Erc721PermitSignatureData {
   beneficiary: string;
@@ -95,11 +95,11 @@ export async function generateErc721PermitSignature(
     _walletAddress = walletAddress;
   }
 
-  const { rpc } = getPayoutConfigByNetworkId(_evmNetworkId);
+  const provider = await getFastestProvider(_evmNetworkId);
 
-  if (!rpc) {
-    _logger.error("RPC is not defined");
-    throw new Error("RPC is not defined");
+  if (!provider) {
+    _logger.error("Provider is not defined");
+    throw new Error("Provider is not defined");
   }
 
   if (!_nftContractAddress) {
@@ -108,14 +108,7 @@ export async function generateErc721PermitSignature(
     throw new Error(errorMessage);
   }
 
-  let provider;
   let adminWallet;
-  try {
-    provider = new ethers.JsonRpcProvider(rpc);
-  } catch (error) {
-    _logger.error("Failed to instantiate provider", error);
-    throw new Error("Failed to instantiate provider");
-  }
 
   try {
     adminWallet = new ethers.Wallet(_nftMinterPrivateKey, provider);

src/utils/get-fastest-provider.ts

@@ -0,0 +1,26 @@
+// @ts-expect-error - no types
+import { RPCHandler, HandlerConstructorConfig } from "@ubiquity-dao/rpc-handler"
+import { JsonRpcProvider } from "ethers";
+
+function getHandler(networkId: number | string) {
+  const config = {
+    networkId,
+    autoStorage: false,
+    cacheRefreshCycles: 5,
+    rpcTimeout: 1500,
+    networkName: null,
+    runtimeRpcs: null,
+    networkRpcs: null,
+  };
+
+  return new RPCHandler(config as HandlerConstructorConfig)
+}
+
+export async function getFastestProvider(networkId: number | string): Promise<JsonRpcProvider> {
+  try {
+    const handler = getHandler(networkId)
+    return await handler.getFastestRpcProvider()
+  } catch (e) {
+    throw new Error(`Failed to get fastest provider for networkId: ${networkId}`)
+  }
+}

tests/generate-erc721-permit.test.ts

@@ -112,7 +112,7 @@ describe("generateErc721PermitSignature", () => {
 
   it("should throw an error if RPC is not defined", async () => {
     context.config.evmNetworkId = 123;
-    await expect(generateErc721PermitSignature(context, "123", "contribution")).rejects.toThrow("No config" + " setup for evmNetworkId: 123");
+    await expect(generateErc721PermitSignature(context, "123", "contribution")).rejects.toThrow("Failed to get fastest provider for networkId: 123");
   });
 
   it("should throw an error if NFT minter private key is not defined", async () => {