diff --git a/relayer-cli/.env.dist b/relayer-cli/.env.dist index b2df5802..8df04ca2 100644 --- a/relayer-cli/.env.dist +++ b/relayer-cli/.env.dist @@ -8,6 +8,10 @@ VEAINBOX_ARBSEPOLIA_TO_CHIADO_ADDRESS=0xAb53e341121448Ae259Da8fa17f216Cb0e21199C VEAOUTBOX_ARBSEPOLIA_TO_SEPOLIA_ADDRESS=0x906dE43dBef27639b1688Ac46532a16dc07Ce410 VEAOUTBOX_ARBSEPOLIA_TO_CHIADO_ADDRESS=0xAb53e341121448Ae259Da8fa17f216Cb0e21199C +# Subgraph endpoints, Example: "85918/vea-inbox-arb-sepolia-devnet/version/latest" +VEAINBOX_ARBSEPOLIA_TO_SEPOLIA_SUBGRAPH=11111/your-subgraph/version/your-version +VEAINBOX_ARBSEPOLIA_TO_CHIADO_SUBGRAPH=11111/your-subgraph/version/your-version + TRANSACTION_BATCHER_CONTRACT_ADDRESS_SEPOLIA=0xe7953da7751063d0a41ba727c32c762d3523ade8 TRANSACTION_BATCHER_CONTRACT_ADDRESS_CHIADO=0xcC0a08D4BCC5f91ee9a1587608f7a2975EA75d73 diff --git a/relayer-cli/src/consts/bridgeRoutes.ts b/relayer-cli/src/consts/bridgeRoutes.ts new file mode 100644 index 00000000..920914df --- /dev/null +++ b/relayer-cli/src/consts/bridgeRoutes.ts @@ -0,0 +1,45 @@ +// File for handling contants and configurations +require("dotenv").config(); + +interface IBridge { + chainId: number; + veaInbox: string; + veaOutbox: string; + batcher: string; + rpcOutbox: string; +} + +// Using destination chainId to get the route configuration. +const bridges: { [chainId: number]: IBridge } = { + 11155111: { + chainId: 11155111, + veaInbox: process.env.VEAINBOX_ARBSEPOLIA_TO_SEPOLIA_ADDRESS, + veaOutbox: process.env.VEAOUTBOX_ARBSEPOLIA_TO_SEPOLIA_ADDRESS, + batcher: process.env.TRANSACTION_BATCHER_CONTRACT_ADDRESS_SEPOLIA, + rpcOutbox: process.env.RPC_SEPOLIA, + }, + 10200: { + chainId: 10200, + veaInbox: process.env.VEAINBOX_ARBSEPOLIA_TO_CHIADO_ADDRESS, + veaOutbox: process.env.VEAOUTBOX_ARBSEPOLIA_TO_CHIADO_ADDRESS, + batcher: process.env.TRANSACTION_BATCHER_CONTRACT_ADDRESS_CHIADO, + rpcOutbox: process.env.RPC_CHIADO, + }, +}; + +const getBridgeConfig = (chainId: number): IBridge | undefined => { + return bridges[chainId]; +}; + +const getInboxSubgraph = (chainId: number): string => { + switch (chainId) { + case 11155111: + return process.env.VEAINBOX_ARBSEPOLIA_TO_SEPOLIA_SUBGRAPH; + case 10200: + return process.env.VEAINBOX_ARBSEPOLIA_TO_SEPOLIA_SUBGRAPH; + default: + throw new Error("Invalid chainid"); + } +}; + +export { getBridgeConfig, getInboxSubgraph }; diff --git a/relayer-cli/src/devnetRelayExample.ts b/relayer-cli/src/devnetRelayExample.ts index 988ec222..a11292ed 100644 --- a/relayer-cli/src/devnetRelayExample.ts +++ b/relayer-cli/src/devnetRelayExample.ts @@ -1,6 +1,5 @@ import { relayAllFrom } from "./utils/relay"; import * as fs from "fs"; -require("dotenv").config(); // let chain_ids = [5, 10200]; let chain_ids = [11155111]; diff --git a/relayer-cli/src/state/11155111.json b/relayer-cli/src/state/11155111.json new file mode 100644 index 00000000..387cca5d --- /dev/null +++ b/relayer-cli/src/state/11155111.json @@ -0,0 +1,4 @@ +{ + "ts": 1725086460, + "nonce": "6" +} diff --git a/relayer-cli/src/utils/proof.ts b/relayer-cli/src/utils/proof.ts index 4f5a4483..15d0765e 100644 --- a/relayer-cli/src/utils/proof.ts +++ b/relayer-cli/src/utils/proof.ts @@ -1,11 +1,12 @@ import request from "graphql-request"; +import { getInboxSubgraph } from "../consts/bridgeRoutes"; const getMessageDataToRelay = async (chainid: number, nonce: number) => { try { - const subgraph = getSubgraph(chainid); + const subgraph = getInboxSubgraph(chainid); const result = await request( - `https://api.studio.thegraph.com/query/85918/${subgraph}/version/latest`, + `https://api.studio.thegraph.com/query/${subgraph}`, `{ messageSents(first: 5, where: {nonce: ${nonce}}) { nonce @@ -37,9 +38,9 @@ const getProofAtCount = async (chainid: number, nonce: number, count: number): P query += "}"; try { - const subgraph = getSubgraph(chainid); + const subgraph = getInboxSubgraph(chainid); - const result = await request(`https://api.studio.thegraph.com/query/85918/${subgraph}/version/latest`, query); + const result = await request(`https://api.studio.thegraph.com/query/${subgraph}`, query); const proof = []; @@ -75,13 +76,4 @@ const getProofIndices = (nonce: number, count: number) => { return proof; }; -const getSubgraph = (chainid: number): string => { - switch (chainid) { - case 11155111: - return "vea-inbox-arb-sepolia-devnet"; - default: - throw new Error("Invalid chainid"); - } -}; - -export { getProofAtCount, getSubgraph, getMessageDataToRelay }; +export { getProofAtCount, getMessageDataToRelay }; diff --git a/relayer-cli/src/utils/relay.ts b/relayer-cli/src/utils/relay.ts index d2085c24..88e54fe6 100644 --- a/relayer-cli/src/utils/relay.ts +++ b/relayer-cli/src/utils/relay.ts @@ -1,7 +1,8 @@ -import { getProofAtCount, getMessageDataToRelay, getSubgraph } from "./proof"; +import { getProofAtCount, getMessageDataToRelay } from "./proof"; import { getVeaOutboxArbToEth } from "./ethers"; import request from "graphql-request"; -import { VeaInboxArbToEth, VeaOutboxArbToEth } from "@kleros/vea-contracts/typechain-types"; +import { VeaOutboxArbToEth } from "@kleros/vea-contracts/typechain-types"; +import { getBridgeConfig, getInboxSubgraph } from "../consts/bridgeRoutes"; const fs = require("fs"); require("dotenv").config(); @@ -10,22 +11,12 @@ const Web3 = require("web3"); const _batchedSend = require("web3-batched-send"); const _contract = require("@kleros/vea-contracts/deployments/sepolia/VeaOutboxArbToEthDevnet.json"); -const getParams = (chainid: number): [string, string, string] => { - if (chainid !== 11155111) throw new Error("Invalid chainid"); - - return [ - process.env.TRANSACTION_BATCHER_CONTRACT_ADDRESS_SEPOLIA, - process.env.VEAOUTBOX_ARBSEPOLIA_TO_SEPOLIA_ADDRESS, - process.env.RPC_SEPOLIA, - ]; -}; - const getCount = async (veaOutbox: VeaOutboxArbToEth, chainid: number): Promise => { - const subgraph = getSubgraph(chainid); + const subgraph = getInboxSubgraph(chainid); const stateRoot = await veaOutbox.stateRoot(); const result = await request( - `https://api.studio.thegraph.com/query/85918/${subgraph}/version/latest`, + `https://api.studio.thegraph.com/query/${subgraph}`, `{ snapshotSaveds(first: 1, where: { stateRoot: "${stateRoot}" }) { count @@ -39,9 +30,9 @@ const getCount = async (veaOutbox: VeaOutboxArbToEth, chainid: number): Promise< }; const relay = async (chainid: number, nonce: number) => { - const [TRANSACTION_BATCHER_CONTRACT_ADDRESS, VEAOUTBOX_ADDRESS, RPC_VEAOUTBOX] = getParams(chainid); + const routeParams = getBridgeConfig(chainid); - const veaOutbox = getVeaOutboxArbToEth(VEAOUTBOX_ADDRESS, process.env.PRIVATE_KEY, RPC_VEAOUTBOX); + const veaOutbox = getVeaOutboxArbToEth(routeParams.veaOutbox, process.env.PRIVATE_KEY, routeParams.rpcOutbox); const count = await getCount(veaOutbox, chainid); const proof = await getProofAtCount(chainid, nonce, count); @@ -52,13 +43,13 @@ const relay = async (chainid: number, nonce: number) => { }; const relayBatch = async (chainid: number, nonce: number, iterations: number) => { - const [TRANSACTION_BATCHER_CONTRACT_ADDRESS, VEAOUTBOX_ADDRESS, RPC_VEAOUTBOX] = getParams(chainid); + const routeParams = getBridgeConfig(chainid); - const web3 = new Web3(RPC_VEAOUTBOX); - const batchedSend = _batchedSend(web3, TRANSACTION_BATCHER_CONTRACT_ADDRESS, process.env.PRIVATE_KEY, 0); + const web3 = new Web3(routeParams.rpcOutbox); + const batchedSend = _batchedSend(web3, routeParams.rpcOutbox, process.env.PRIVATE_KEY, 0); - const contract = new web3.eth.Contract(_contract.abi, VEAOUTBOX_ADDRESS); - const veaOutbox = getVeaOutboxArbToEth(VEAOUTBOX_ADDRESS, process.env.PRIVATE_KEY, RPC_VEAOUTBOX); + const contract = new web3.eth.Contract(_contract.abi, routeParams.veaOutbox); + const veaOutbox = getVeaOutboxArbToEth(routeParams.veaOutbox, process.env.PRIVATE_KEY, routeParams.rpcOutbox); const count = await getCount(veaOutbox, chainid); let txns = []; @@ -73,24 +64,23 @@ const relayBatch = async (chainid: number, nonce: number, iterations: number) => }); } - console.log(txns); await batchedSend(txns); }; const relayAllFrom = async (chainid: number, nonce: number, msgSender: string): Promise => { - const [TRANSACTION_BATCHER_CONTRACT_ADDRESS, VEAOUTBOX_ADDRESS, RPC_VEAOUTBOX] = getParams(chainid); + const routeParams = getBridgeConfig(chainid); - const web3 = new Web3(RPC_VEAOUTBOX); + const web3 = new Web3(routeParams.rpcOutbox); const batchedSend = _batchedSend( web3, // Your web3 object. // The address of the transaction batcher contract you wish to use. The addresses for the different networks are listed below. If the one you need is missing, feel free to deploy it yourself and make a PR to save the address here for others to use. - TRANSACTION_BATCHER_CONTRACT_ADDRESS, + routeParams.batcher, process.env.PRIVATE_KEY, // The private key of the account you want to send transactions from. 0 // The debounce timeout period in milliseconds in which transactions are batched. ); - const contract = new web3.eth.Contract(_contract.abi, VEAOUTBOX_ADDRESS); - const veaOutbox = getVeaOutboxArbToEth(VEAOUTBOX_ADDRESS, process.env.PRIVATE_KEY, RPC_VEAOUTBOX); + const contract = new web3.eth.Contract(_contract.abi, routeParams.veaOutbox); + const veaOutbox = getVeaOutboxArbToEth(routeParams.veaOutbox, process.env.PRIVATE_KEY, routeParams.rpcOutbox); const count = await getCount(veaOutbox, chainid); if (!count) return null; @@ -116,10 +106,10 @@ const relayAllFrom = async (chainid: number, nonce: number, msgSender: string): const getNonceFrom = async (chainid: number, nonce: number, msgSender: string) => { try { - const subgraph = getSubgraph(chainid); + const subgraph = getInboxSubgraph(chainid); const result = await request( - `https://api.studio.thegraph.com/query/85918/${subgraph}/version/latest`, + `https://api.studio.thegraph.com/query/${subgraph}`, `{ messageSents(first: 1000, where: {nonce_gte: ${nonce}, msgSender_: {id: "${msgSender}"}}, orderBy: nonce, orderDirection: asc) { nonce