Bungee chains #422
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -139,3 +139,5 @@ HYPEREVM_RPC=' ' | |
| SEI_RPC=' ' | ||
|
|
||
| PLASMA_RPC=' ' | ||
|
|
||
| MONAD_RPC=' ' | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,147 @@ | ||
| import { config as dotenvConfig } from "dotenv"; | ||
| import { | ||
| ChainSlug, | ||
| DeploymentAddresses, | ||
| IntegrationTypes, | ||
| getAllAddresses, | ||
| } from "../../src"; | ||
| import { mode } from "../deploy/config/config"; | ||
| import SingleCapacitorArtifact from "../../out/SingleCapacitor.sol/SingleCapacitor.json"; | ||
| import { getProviderFromChainSlug } from "../constants"; | ||
| import { ethers } from "ethers"; | ||
|
|
||
| dotenvConfig(); | ||
|
|
||
| /** | ||
| * Usage | ||
| * | ||
| * --source Specify the source chain slug. | ||
| * This flag is required. | ||
| * Eg. npx --source=1 --destination=10 --startblock=12345 --endblock=12456 ts-node scripts/admin/get-outbound-txs.ts | ||
| * | ||
| * --destination Specify the destination chain slug. | ||
| * This flag is required. | ||
| * | ||
| * --startblock Specify the start block number. | ||
| * This flag is required. | ||
| * | ||
| * --endblock Specify the end block number. | ||
| * This flag is required. | ||
| */ | ||
|
|
||
| const sourceChainSlug = process.env.npm_config_source; | ||
| if (!sourceChainSlug) { | ||
| console.error("Error: source flag is required"); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const destinationChainSlug = process.env.npm_config_destination; | ||
| if (!destinationChainSlug) { | ||
| console.error("Error: destination flag is required"); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const startBlock = process.env.npm_config_startblock; | ||
| if (!startBlock) { | ||
| console.error("Error: startblock flag is required"); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const endBlock = process.env.npm_config_endblock; | ||
| if (!endBlock) { | ||
| console.error("Error: endblock flag is required"); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const addresses: DeploymentAddresses = getAllAddresses(mode); | ||
|
|
||
| export const main = async () => { | ||
| const sourceChain = sourceChainSlug; | ||
| const destinationChain = destinationChainSlug; | ||
|
|
||
| console.log(`\nProcessing path: ${sourceChain} -> ${destinationChain}\n`); | ||
|
|
||
| // Get addresses from prod_addresses.json | ||
| const sourceAddresses = addresses[sourceChain]; | ||
| if (!sourceAddresses) { | ||
| console.error(`Error: No addresses found for source chain ${sourceChain}`); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const integration = sourceAddresses.integrations?.[destinationChain]; | ||
| if (!integration) { | ||
| console.error( | ||
| `Error: No integration found for ${sourceChain} -> ${destinationChain}` | ||
| ); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| // Get FAST integration addresses (switchboard, socket, capacitor) | ||
| const fastIntegration = integration[IntegrationTypes.fast]; | ||
| if (!fastIntegration) { | ||
| console.error( | ||
| `Error: No FAST integration found for ${sourceChain} -> ${destinationChain}` | ||
| ); | ||
| process.exit(1); | ||
| } | ||
|
|
||
| const switchboardAddress = fastIntegration.switchboard; | ||
| const capacitorAddress = fastIntegration.capacitor; | ||
| const socketAddress = sourceAddresses.Socket; | ||
|
|
||
| console.log("Addresses:"); | ||
| console.log(` Switchboard: ${switchboardAddress}`); | ||
| console.log(` Socket: ${socketAddress}`); | ||
| console.log(` Capacitor: ${capacitorAddress}\n`); | ||
|
|
||
| // Get provider and query events | ||
| const provider = getProviderFromChainSlug(parseInt(sourceChain) as ChainSlug); | ||
|
|
||
| const capacitorContract = new ethers.Contract( | ||
| capacitorAddress, | ||
| SingleCapacitorArtifact.abi, | ||
| provider | ||
| ); | ||
|
|
||
| const fromBlock = parseInt(startBlock); | ||
| const toBlock = parseInt(endBlock); | ||
|
|
||
| console.log(`Querying events from block ${fromBlock} to ${toBlock}\n`); | ||
|
|
||
| // Query MessageAdded events in chunks of 5000 blocks | ||
| const CHUNK_SIZE = 5000; | ||
| const messageAddedEvents = []; | ||
|
|
||
| for (let currentBlock = fromBlock; currentBlock <= toBlock; currentBlock += CHUNK_SIZE) { | ||
| const chunkEnd = Math.min(currentBlock + CHUNK_SIZE - 1, toBlock); | ||
| console.log(`Querying chunk: ${currentBlock} to ${chunkEnd}`); | ||
|
|
||
| const events = await capacitorContract.queryFilter( | ||
| capacitorContract.filters.MessageAdded(), | ||
| currentBlock, | ||
| chunkEnd | ||
| ); | ||
|
|
||
| messageAddedEvents.push(...events); | ||
| } | ||
|
|
||
| console.log(`Found ${messageAddedEvents.length} outbound transactions:\n`); | ||
|
|
||
| for (const event of messageAddedEvents) { | ||
| console.log(`Block: ${event.blockNumber}`); | ||
| console.log(` Transaction Hash: ${event.transactionHash}`); | ||
| console.log(` Packed Message: ${event.args?.packedMessage}`); | ||
| console.log(` Packet Count: ${event.args?.packetCount?.toString()}`); | ||
| console.log(` Root Hash: ${event.args?.newRootHash}`); | ||
| console.log(""); | ||
| } | ||
|
|
||
| console.log("Script completed."); | ||
| }; | ||
|
|
||
| main() | ||
| .then(() => process.exit(0)) | ||
| .catch((error: Error) => { | ||
| console.error(error); | ||
| process.exit(1); | ||
| }); | ||
|
Comment on lines
+1
to
+147
There was a problem hiding this comment. 🛠️ Refactor suggestion | 🟠 Major Eliminate code duplication with get-seal-events.ts. This script shares ~95% identical code with Consider creating a shared helper like: // scripts/admin/utils/query-events.ts
export async function queryEventsForPath(
sourceChain: ChainSlug,
destinationChain: ChainSlug,
startBlock: number,
endBlock: number,
contractType: 'Socket' | 'SingleCapacitor',
eventName: string
) {
// Common logic here
}Then both scripts become simple wrappers: // get-outbound-txs.ts
const result = await queryEventsForPath(
sourceChain,
destinationChain,
startBlock,
endBlock,
'SingleCapacitor',
'MessageAdded'
);🤖 Prompt for AI Agents |
||
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Validate and convert chain slugs to numbers immediately after extraction.
The env vars are strings but need to be numeric ChainSlug values. Convert and validate them right after extraction to fail fast and ensure type safety throughout the script.
Apply this diff:
const sourceChainSlug = process.env.npm_config_source; if (!sourceChainSlug) { console.error("Error: source flag is required"); process.exit(1); } +const sourceChainSlugNum = parseInt(sourceChainSlug); +if (isNaN(sourceChainSlugNum)) { + console.error(`Error: source must be a valid number, got: ${sourceChainSlug}`); + process.exit(1); +} const destinationChainSlug = process.env.npm_config_destination; if (!destinationChainSlug) { console.error("Error: destination flag is required"); process.exit(1); } +const destinationChainSlugNum = parseInt(destinationChainSlug); +if (isNaN(destinationChainSlugNum)) { + console.error(`Error: destination must be a valid number, got: ${destinationChainSlug}`); + process.exit(1); +}Then update lines 59-60 and 98 to use the numeric versions:
🤖 Prompt for AI Agents