forge/cmd/

selectors.rs

use alloy_primitives::hex;
use clap::Parser;
use comfy_table::{Table, modifiers::UTF8_ROUND_CORNERS, presets::ASCII_MARKDOWN};
use eyre::Result;
use foundry_cli::{
    opts::{BuildOpts, ProjectPathOpts},
    utils::{FoundryPathExt, LoadConfig, cache_local_signatures, cache_signatures_from_abis},
};
use foundry_common::{
    compile::{PathOrContractInfo, ProjectCompiler, compile_abi_project},
    selectors::{SelectorImportData, import_selectors},
    shell,
};
use foundry_compilers::{
    Project,
    artifacts::output_selection::{ContractOutputSelection, EvmOutputSelection, OutputSelection},
    info::ContractInfo,
    multi::MultiCompiler,
};
use std::{collections::BTreeMap, fs::canonicalize};

/// CLI arguments for `forge selectors`.
#[derive(Clone, Debug, Parser)]
pub enum SelectorsSubcommands {
    /// Check for selector collisions between contracts
    #[command(visible_alias = "co")]
    Collision {
        /// The first of the two contracts for which to look selector collisions for, in the form
        /// `(<path>:)?<contractname>`.
        first_contract: ContractInfo,

        /// The second of the two contracts for which to look selector collisions for, in the form
        /// `(<path>:)?<contractname>`.
        second_contract: ContractInfo,

        #[command(flatten)]
        build: Box<BuildOpts>,
    },

    /// Upload selectors to registry
    #[command(visible_alias = "up")]
    Upload {
        /// The name of the contract to upload selectors for.
        /// Can also be in form of `path:contract name`.
        #[arg(required_unless_present = "all")]
        contract: Option<PathOrContractInfo>,

        /// Upload selectors for all contracts in the project.
        #[arg(long, required_unless_present = "contract")]
        all: bool,

        #[command(flatten)]
        project_paths: ProjectPathOpts,
    },

    /// List selectors from current workspace
    #[command(visible_alias = "ls")]
    List {
        /// The name of the contract to list selectors for.
        #[arg(help = "The name of the contract to list selectors for.")]
        contract: Option<String>,

        #[command(flatten)]
        project_paths: ProjectPathOpts,

        #[arg(long, help = "Do not group the selectors by contract in separate tables.")]
        no_group: bool,
    },

    /// Find if a selector is present in the project
    #[command(visible_alias = "f")]
    Find {
        /// The selector to search for
        #[arg(help = "The selector to search for (with or without 0x prefix)")]
        selector: String,

        #[command(flatten)]
        project_paths: ProjectPathOpts,
    },

    /// Cache project selectors (enables trace with local contracts functions and events).
    #[command(visible_alias = "c")]
    Cache {
        #[arg(long, help = "Path to a folder containing additional abis to include in the cache")]
        extra_abis_path: Option<String>,
        #[command(flatten)]
        project_paths: ProjectPathOpts,
    },
}

impl SelectorsSubcommands {
    pub async fn run(self) -> Result<()> {
        match self {
            Self::Cache { project_paths, extra_abis_path } => {
                if let Some(extra_abis_path) = extra_abis_path {
                    sh_status!("Caching selectors for ABIs at {extra_abis_path}")?;
                    cache_signatures_from_abis(extra_abis_path)?;
                }

                sh_status!("Caching selectors for contracts in the project...")?;
                let mut project = project_from_paths(project_paths)?;
                let outcome =
                    compile_abi_project(&mut project, ProjectCompiler::new().quiet(true))?;
                cache_local_signatures(&outcome)?;
            }
            Self::Upload { contract, all, project_paths } => {
                let mut project = project_from_paths(project_paths)?;
                let output = if let Some(contract_info) = &contract {
                    let Some(contract_name) = contract_info.name() else {
                        eyre::bail!("No contract name provided.");
                    };

                    let target_path = contract_info
                        .path()
                        .map(Ok)
                        .unwrap_or_else(|| project.find_contract_path(contract_name))?;
                    compile_abi_project(&mut project, ProjectCompiler::new().files([target_path]))?
                } else {
                    compile_abi_project(&mut project, ProjectCompiler::new())?
                };
                let artifacts = if all {
                    output
                        .into_artifacts_with_files()
                        .filter(|(file, _, _)| {
                            let is_sources_path = file.starts_with(&project.paths.sources);
                            let is_test = file.is_sol_test();

                            is_sources_path && !is_test
                        })
                        .map(|(_, contract, artifact)| (contract, artifact))
                        .collect()
                } else {
                    let contract_info = contract.unwrap();
                    let contract = contract_info.name().unwrap().to_string();

                    let found_artifact = if let Some(path) = contract_info.path() {
                        output.find(project.root().join(path).as_path(), &contract)
                    } else {
                        output.find_first(&contract)
                    };

                    let artifact = found_artifact
                        .ok_or_else(|| {
                            eyre::eyre!(
                                "Could not find artifact `{contract}` in the compiled artifacts"
                            )
                        })?
                        .clone();
                    vec![(contract, artifact)]
                };

                let mut artifacts = artifacts.into_iter().peekable();
                while let Some((contract, artifact)) = artifacts.next() {
                    let abi = artifact.abi.ok_or_else(|| eyre::eyre!("Unable to fetch abi"))?;
                    if abi.functions.is_empty() && abi.events.is_empty() && abi.errors.is_empty() {
                        continue;
                    }

                    sh_status!("Uploading selectors for {contract}...")?;

                    // upload abi to selector database
                    import_selectors(SelectorImportData::Abi(vec![abi])).await?.describe();

                    if artifacts.peek().is_some() {
                        sh_println!()?
                    }
                }
            }
            Self::Collision { mut first_contract, mut second_contract, build } => {
                // Compile the project with the two contracts included
                let user_extra_output = !build.compiler.extra_output.is_empty()
                    || !build.compiler.extra_output_files.is_empty();
                let mut project = build.project()?;
                if !user_extra_output && !project.build_info {
                    project.no_artifacts = true;
                    project.update_output_selection(|selection| {
                        *selection = OutputSelection::common_output_selection([
                            ContractOutputSelection::Evm(EvmOutputSelection::MethodIdentifiers)
                                .to_string(),
                        ]);
                    });
                }
                let mut compiler = ProjectCompiler::new().quiet(true);

                if let Some(contract_path) = &mut first_contract.path {
                    let target_path = canonicalize(&*contract_path)?;
                    *contract_path = target_path.to_string_lossy().to_string();
                    compiler = compiler.files([target_path]);
                }
                if let Some(contract_path) = &mut second_contract.path {
                    let target_path = canonicalize(&*contract_path)?;
                    *contract_path = target_path.to_string_lossy().to_string();
                    compiler = compiler.files([target_path]);
                }

                let output = compiler.compile(&project)?;

                // Check method selectors for collisions
                let methods = |contract: &ContractInfo| -> eyre::Result<_> {
                    let artifact = output
                        .find_contract(contract)
                        .ok_or_else(|| eyre::eyre!("Could not find artifact for {contract}"))?;
                    artifact.method_identifiers.as_ref().ok_or_else(|| {
                        eyre::eyre!("Could not find method identifiers for {contract}")
                    })
                };
                let first_method_map = methods(&first_contract)?;
                let second_method_map = methods(&second_contract)?;

                let colliding_methods: Vec<(&String, &String, &String)> = first_method_map
                    .iter()
                    .filter_map(|(k1, v1)| {
                        second_method_map
                            .iter()
                            .find_map(|(k2, v2)| (**v2 == *v1).then_some((k2, v2)))
                            .map(|(k2, v2)| (v2, k1, k2))
                    })
                    .collect();

                if colliding_methods.is_empty() {
                    sh_println!("No colliding method selectors between the two contracts.")?;
                } else {
                    let mut table = Table::new();
                    if shell::is_markdown() {
                        table.load_preset(ASCII_MARKDOWN);
                    } else {
                        table.apply_modifier(UTF8_ROUND_CORNERS);
                    }
                    table.set_header([
                        String::from("Selector"),
                        first_contract.name,
                        second_contract.name,
                    ]);
                    for method in &colliding_methods {
                        #[allow(clippy::tuple_array_conversions)]
                        table.add_row(<[_; 3]>::from(*method));
                    }
                    sh_println!("{} collisions found:", colliding_methods.len())?;
                    sh_println!("\n{table}\n")?;
                }
            }
            Self::List { contract, project_paths, no_group } => {
                sh_status!("Listing selectors for contracts in the project...")?;
                let mut project = project_from_paths(project_paths)?;
                let outcome =
                    compile_abi_project(&mut project, ProjectCompiler::new().quiet(true))?;
                let artifacts = if let Some(contract) = contract {
                    let found_artifact = outcome.find_first(&contract);
                    let artifact = found_artifact
                        .ok_or_else(|| {
                            let candidates = outcome
                                .artifacts()
                                .map(|(name, _,)| name)
                                .collect::<Vec<_>>();
                            let suggestion = if let Some(suggestion) = foundry_cli::utils::did_you_mean(&contract, candidates).pop() {
                                format!("\nDid you mean `{suggestion}`?")
                            } else {
                                String::new()
                            };
                            eyre::eyre!(
                                "Could not find artifact `{contract}` in the compiled artifacts{suggestion}",
                            )
                        })?
                        .clone();
                    vec![(contract, artifact)]
                } else {
                    outcome
                        .into_artifacts_with_files()
                        .filter(|(file, _, _)| {
                            let is_sources_path = file.starts_with(&project.paths.sources);
                            let is_test = file.is_sol_test();

                            is_sources_path && !is_test
                        })
                        .map(|(_, contract, artifact)| (contract, artifact))
                        .collect()
                };

                let mut artifacts = artifacts.into_iter();

                #[derive(PartialEq, PartialOrd, Eq, Ord)]
                enum SelectorType {
                    Function,
                    Event,
                    Error,
                }
                impl std::fmt::Display for SelectorType {
                    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
                        match self {
                            Self::Function => write!(f, "Function"),
                            Self::Event => write!(f, "Event"),
                            Self::Error => write!(f, "Error"),
                        }
                    }
                }

                let mut selectors =
                    BTreeMap::<String, BTreeMap<SelectorType, Vec<(String, String)>>>::new();

                for (contract, artifact) in artifacts.by_ref() {
                    let abi = artifact.abi.ok_or_else(|| eyre::eyre!("Unable to fetch abi"))?;

                    let contract_selectors = selectors.entry(contract.clone()).or_default();

                    for func in abi.functions() {
                        let sig = func.signature();
                        let selector = func.selector();
                        contract_selectors
                            .entry(SelectorType::Function)
                            .or_default()
                            .push((hex::encode_prefixed(selector), sig));
                    }

                    for event in abi.events() {
                        let sig = event.signature();
                        let selector = event.selector();
                        contract_selectors
                            .entry(SelectorType::Event)
                            .or_default()
                            .push((hex::encode_prefixed(selector), sig));
                    }

                    for error in abi.errors() {
                        let sig = error.signature();
                        let selector = error.selector();
                        contract_selectors
                            .entry(SelectorType::Error)
                            .or_default()
                            .push((hex::encode_prefixed(selector), sig));
                    }
                }

                if no_group {
                    let mut table = Table::new();
                    if shell::is_markdown() {
                        table.load_preset(ASCII_MARKDOWN);
                    } else {
                        table.apply_modifier(UTF8_ROUND_CORNERS);
                    }
                    table.set_header(["Type", "Signature", "Selector", "Contract"]);

                    for (contract, contract_selectors) in selectors {
                        for (selector_type, selectors) in contract_selectors {
                            for (selector, sig) in selectors {
                                table.add_row([
                                    selector_type.to_string(),
                                    sig,
                                    selector,
                                    contract.clone(),
                                ]);
                            }
                        }
                    }

                    sh_println!("\n{table}")?;
                } else {
                    for (idx, (contract, contract_selectors)) in selectors.into_iter().enumerate() {
                        sh_println!("{}{contract}", if idx == 0 { "" } else { "\n" })?;
                        let mut table = Table::new();
                        if shell::is_markdown() {
                            table.load_preset(ASCII_MARKDOWN);
                        } else {
                            table.apply_modifier(UTF8_ROUND_CORNERS);
                        }
                        table.set_header(["Type", "Signature", "Selector"]);

                        for (selector_type, selectors) in contract_selectors {
                            for (selector, sig) in selectors {
                                table.add_row([selector_type.to_string(), sig, selector]);
                            }
                        }
                        sh_println!("\n{table}")?;
                    }
                }
            }

            Self::Find { selector, project_paths } => {
                sh_status!("Searching for selector {selector:?} in the project...")?;

                let mut project = project_from_paths(project_paths)?;
                let outcome =
                    compile_abi_project(&mut project, ProjectCompiler::new().quiet(true))?;
                let artifacts = outcome
                    .into_artifacts_with_files()
                    .filter(|(file, _, _)| {
                        let is_sources_path = file.starts_with(&project.paths.sources);
                        let is_test = file.is_sol_test();
                        is_sources_path && !is_test
                    })
                    .collect::<Vec<_>>();

                let mut table = Table::new();
                if shell::is_markdown() {
                    table.load_preset(ASCII_MARKDOWN);
                } else {
                    table.apply_modifier(UTF8_ROUND_CORNERS);
                }

                table.set_header(["Type", "Signature", "Selector", "Contract"]);

                let selector_str = selector.strip_prefix("0x").unwrap_or(selector.as_str());
                let selector_bytes = hex::decode(selector_str)?;

                for (_file, contract, artifact) in artifacts {
                    let abi = artifact.abi.ok_or_else(|| eyre::eyre!("Unable to fetch abi"))?;

                    for func in abi.functions() {
                        if func.selector().as_slice().starts_with(selector_bytes.as_slice()) {
                            table.add_row([
                                "Function",
                                &func.signature(),
                                &hex::encode_prefixed(func.selector()),
                                contract.as_str(),
                            ]);
                        }
                    }

                    for event in abi.events() {
                        if event.selector().as_slice().starts_with(selector_bytes.as_slice()) {
                            table.add_row([
                                "Event",
                                &event.signature(),
                                &hex::encode_prefixed(event.selector()),
                                contract.as_str(),
                            ]);
                        }
                    }

                    for error in abi.errors() {
                        if error.selector().as_slice().starts_with(selector_bytes.as_slice()) {
                            table.add_row([
                                "Error",
                                &error.signature(),
                                &hex::encode_prefixed(error.selector()),
                                contract.as_str(),
                            ]);
                        }
                    }
                }

                if table.row_count() > 0 {
                    sh_status!("Found {} instance(s)...", table.row_count())?;
                    sh_println!("\n{table}\n")?;
                } else {
                    return Err(eyre::eyre!("\nSelector not found in the project."));
                }
            }
        }
        Ok(())
    }
}

fn project_from_paths(project_paths: ProjectPathOpts) -> Result<Project<MultiCompiler>> {
    let config = BuildOpts { project_paths, ..Default::default() }.load_config()?;
    let mut project = config.project()?;
    if !project.build_info {
        project.no_artifacts = true;
    }
    Ok(project)
}