# EVM RPC Canister — 从 IC 调用以太坊 ## 这是什么 EVM RPC 容器是一个 IC 系统容器，可通过 HTTPS 出局代理对以太坊和 EVM 兼容链的 JSON-RPC 调用。您的容器向 EVM RPC 容器发送请求，后者将请求分散到多个 RPC 提供程序，比较响应以达成共识，然后返回结果。默认提供商不需要 API 密钥。不需要桥梁或神谕。 ## 先决条件 * `icp-cli` >= 0.1.0 (`brew install dfinity/tap/icp-cli`) * 对于 Motoko：mops.toml 中的 `mops` 包管理器、`core = "2.0.0"` * 对于 Rust：`ic-cdk`、`candid`、`serde` * 容器中的周期（每个 RPC 调用都会消耗周期） ## 容器 ID 罐|身份证 |子网 ---|---|--- EVM RPC（主网）| `7hfb6-caaaa-aaaar-qadga-cai` | 34节点受托人 ## 支持的链链条| RpcServices 变体 |链号 ---|---|--- 以太坊主网 | `#EthMainnet` | 1 以太坊Sepolia | `#EthSepolia` | 11155111 仲裁一号 | `#ArbitrumOne` | 42161 基础主网 | `#BaseMainnet` | 8453 乐观主网 | `#OptimismMainnet` | 10 定制EVM链| `#自定义` |任何 ## RPC 提供者内置提供程序（默认不需要 API 密钥）：供应商|以太坊 |塞波利亚|仲裁|基地|乐观 ---|---|---|---|---|--- 炼金术 |是的 |是的 |是的 |是的 |是的安克尔 |是的 | - |是的 |是的 |是的布洛克Pi |是的 |是的 |是的 |是的 |是的云耀 |是的 | - | - | - | - 骆驼节点 |是的 | - |是的 |是的 |是的公共节点 |是的 |是的 |是的 |是的 |是的 ## 周期成本 **公式：** (5_912_000 + 60_000 * 节点 + 2400 * request_bytes + 800 * max_response_bytes) * 节点 * rpc_count 其中 `nodes` = 34（受托子网），`rpc_count` = 查询的提供商数量。 **实用指南：** 发送 10_000_000_000 个周期 (10B) 作为起始预算。未使用的周期将得到退款。典型的调用成本为 100M-1B 个周期（约 0.0001 美元-0.001 美元）。在致电之前使用“requestCost”获得准确的估计。 ## 破坏你的构建的错误 1. **没有发送足够的周期。** 每个 EVM RPC 调用都需要附加周期。如果发送的数据太少，调用会默默失败或陷入困境。从10B周期开始，验证后向下调整。 2. **忽略“不一致”结果变体。** 多提供者调用返回“#Consistent(result)”或“#Inconcient(results)”。如果提供商不同意，您会得到“不一致”。如果供应商意见不一致，请始终处理双臂或罐陷阱。 3. **使用错误的链变体。** `#EthMainnet` 适用于以太坊 L1。对于 Arbitrum，请使用“#ArbitrumOne”，对于 Base，请使用“#BaseMainnet”。使用错误的变体会查询错误的链。 4. **忘记可选配置的`null`。** 每个 RPC 方法的第二个参数是可选配置记录。传递“null”作为默认值。省略它会导致 Candid 类型不匹配。 5. **响应大小限制。** 大响应（例如，具有广泛过滤器的“eth_getLogs”）可能会超过最大响应大小。适当设置“max_response_bytes”，否则调用失败。 6. **调用`eth_sendRawTransaction`而不先签名。** EVM RPC 容器不会签署交易。您必须亲自签署交易（通过 IC 管理容器使用阈值 ECDSA）并传递原始签名字节。 7. **在 mo:core 中使用 `Cycles.add` 代替 `await (with Cycles = ...)`。** 在 mo:core 2.0 中，`Cycles.add` 不存在。使用“await (with Cycles = AMOUNT) canister.method(args)”附加周期。这是在 mo:core 中附加循环的唯一方法。 ## 实施 ### icp.yaml 配置 #### 选项 A：从主网拉取（建议用于生产）罐： evm_rpc：类型: 拉动编号：7hfb6-caaaa-aaaar-qadga-cai 后端：类型：元子主要：src/backend/main.mo 依赖项： -evm_rpc 然后运行： icp deps拉动 icp deps init evm_rpc --参数 '(record {})' icp deps部署 #### 选项 B：自定义 wasm（用于本地开发）罐： evm_rpc：类型：定制坦白：https://github.com/internet-computer-protocol/evm-rpc-canister/releases/latest/download/evm_rpc.did wasm：https://github.com/internet-computer-protocol/evm-rpc-canister/releases/latest/download/evm_rpc.wasm.gz 远程：身份证号： ic: 7hfb6-caaaa-aaaar-qadga-cai 后端：类型：元子主要：src/backend/main.mo 依赖项： -evm_rpc ### 元子 #### mops.toml [包装] 名称 =“evm-rpc-app” 版本=“0.1.0” [依赖项] 核心=“2.0.0” #### src/backend/main.mo — 获取 ETH 余额导入 EvmRpc“罐：evm_rpc”；导入运行时“mo：核心/运行时”；导入文本“mo：核心/文本”；持久演员{ // 获取以太坊主网上某个地址的 ETH 余额公共 func getEthBalance(地址: Text) : 异步文本 { 让服务= #EthMainnet(null); // 使用所有默认提供者让配置=空； // eth_call 通过原始 JSON-RPC 进行余额检查 let json = "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBalance\",\"params\":[\"" # 地址 # "\",\"latest\"],\"id\":1}"; 让 maxResponseBytes : Nat64 = 1000; // 首先获取准确的成本让cyclesResult =等待EvmRpc.requestCost(#EthMainnet(#PublicNode), json, maxResponseBytes); 让成本 = switch (cyclesResult) { 案例 (#Ok(c)) { c }; case (#Err(err)) { Runtime.trap("requestCost 失败: " # debug_show err) }; }; 让结果=等待（周期=成本）EvmRpc.request（ #EthMainnet(#PublicNode), json, 最大响应字节数）；开关（结果）{ 案例 (#Ok(响应)) { 响应 }; case (#Err(err)) { Runtime.trap("RPC 错误：" # debug_show err) }; } }; // 使用类型化 API 获取最新块公共 func getLatestBlock() : 异步 ?EvmRpc.Block { 让服务= #EthMainnet(null); 让配置=空；让结果=等待（周期= 10_000_000_000）EvmRpc.eth_getBlockByNumber（服务，配置， #最新）；开关（结果）{ case (#Constant(#Ok(block))) { ?block }; 案例（#一致（#Err（错误）））{ Runtime.trap(“错误：” # debug_show 错误); }; 案例（#不一致（_结果））{ Runtime.trap("提供者返回不一致的结果"); }; } }; // 读取 ERC-20 代币余额（例如以太坊上的 USDC） //balanceOf(地址)的函数选择器：0x70a08231 // 将地址填充到 32 字节（删除 0x 前缀，左侧用零填充）公共 func getErc20Balance(tokenContract : Text, walletAddress : Text) : async ?Text { 让服务= #EthMainnet(null); 让配置=空； // 编码：balanceOf(address) = 0x70a08231 + 地址填充为32字节 // walletAddress 应该类似于“0xABC...”——将 0x 和 left-pad 剥离为 64 个十六进制字符 let calldata = "0x70a08231000000000000000000000000" # stripHexPrefix(walletAddress); 让结果=等待（周期= 10_000_000_000）EvmRpc.eth_call（服务，配置， { 块=空；交易 = { to = ?tokenContract; 输入=？calldata； // 所有可选字段设置为 null 访问列表=空； blobVersionedHashes = null; 斑点=空；链ID = null; 来自=空；气体=空；天然气价格 = null; maxFeePerBlobGas = null; 最大费率 = null; maxPriorityFeePerGas = null；随机数=空；类型_=空；值=空； }; } ）；开关（结果）{ case (#Constant(#Ok(response))) { ?response }; 案例（#一致（#Err（错误）））{ Runtime.trap("eth_call 错误: " # debug_show 错误); }; 情况（#不一致（_））{ Runtime.trap("提供者的结果不一致"); }; } }; // Helper: 从十六进制字符串中去除“0x”前缀 func stripHexPrefix(hex : Text) : Text { 让 chars = hex.chars(); 开关 (chars.next(), chars.next()) { 案例（？“0”，？“x”）{ var 休息 = ""; for (c in chars) { rest #= Text.fromChar(c) }; 休息 }; 案例 _ { 十六进制 }; } }; // 发送已签名的原始交易公共 func sendRawTransaction(signedTxHex : Text) : 异步 ?EvmRpc.SendRawTransactionStatus { 让服务= #EthMainnet(null); 让配置=空；让结果=等待（周期= 10_000_000_000）EvmRpc.eth_sendRawTransaction（服务，配置，有符号的TxHex ）；开关（结果）{ case (#Constant(#Ok(status))) { ?status }; 案例（#一致（#Err（错误）））{ Runtime.trap("sendRawTransaction 错误：" # debug_show 错误); }; 情况（#不一致（_））{ Runtime.trap("结果不一致"); }; } }; // 获取交易收据公共 func getTransactionReceipt(txHash : Text) : 异步 ?EvmRpc.TransactionReceipt { 让服务= #EthMainnet(null); 让配置=空；让结果=等待（周期= 10_000_000_000）EvmRpc.eth_getTransactionReceipt（服务，配置，交易哈希值）；开关（结果）{ case (#Constant(#Ok(收据))) { 收据 }; 案例（#一致（#Err（错误）））{ Runtime.trap(“错误：” # debug_show 错误); }; 情况（#不一致（_））{ Runtime.trap("结果不一致"); }; } }; // 使用特定的提供商（而不是多提供商共识）公共 func getBalanceViaPublicNode(地址：文本) : 异步文本 { let json = "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBalance\",\"params\":[\"" # 地址 # "\",\"latest\"],\"id\":1}"; 让 maxResponseBytes : Nat64 = 1000; 让结果=等待（周期= 10_000_000_000）EvmRpc.request（ #EthMainnet(#PublicNode), // 单个特定提供商 json, 最大响应字节数）；开关（结果）{ 案例 (#Ok(响应)) { 响应 }; case (#Err(err)) { Runtime.trap("错误：" # debug_show err) }; } }; // 查询不同的链（Arbitrum）公共 func getArbitrumBlock() : 异步 ?EvmRpc.Block { 让结果=等待（周期= 10_000_000_000）EvmRpc.eth_getBlockByNumber（ #ArbitrumOne(null), // 仲裁一空， #最新）；开关（结果）{ case (#Constant(#Ok(block))) { ?block }; 案例（#一致（#Err（错误）））{ Runtime.trap(“错误：” # debug_show 错误); }; 情况（#不一致（_））{ Runtime.trap("结果不一致"); }; } }; // 使用自定义 RPC 端点公共 func getBalanceCustomRpc(地址：文本，rpcUrl：文本)：异步文本 { let json = "{\"jsonrpc\":\"2.0\",\"method\":\"eth_getBalance\",\"params\":[\"" # 地址 # "\",\"latest\"],\"id\":1}"; 让结果=等待（周期= 10_000_000_000）EvmRpc.request（ #Custom({ url = rpcUrl; headers = null }), json, 1000 ）；开关（结果）{ 案例 (#Ok(响应)) { 响应 }; case (#Err(err)) { Runtime.trap("错误：" # debug_show err) }; } }; }; ### 铁锈 #### Cargo.toml [包装] 名称 =“evm_rpc_backend” 版本=“0.1.0” 版本=“2021” [库] 板条箱类型 = ["cdylib"] [依赖项] ic-cdk =“0.19” 坦率=“0.10” serde = {版本=“1”，功能=[“派生”]} serde_json =“1” #### src/lib.rs 使用 candid::{CandidType, 反序列化, 主体}; 使用 ic_cdk::call::Call；使用 ic_cdk::update; const EVM_RPC_CANISTER: &str = "7hfb6-caaaa-aaaar-qadga-cai"; fn evm_rpc_id() -> 主体 { 主体::from_text(EVM_RPC_CANISTER).unwrap() } // -- 与 EVM RPC 容器 Candid 接口匹配的类型 -- #[derive(CandidType、反序列化、克隆、调试)] 枚举 RpcServices { EthMainnet(Option>), EthSepolia(选项>), ArbitrumOne(Option>), BaseMainnet(Option>), OptimismMainnet(Option>), 定制{ #[serde(重命名 = "chainId")] 链ID：u64，服务：Vec， }, } #[derive(CandidType、反序列化、克隆、调试)] 枚举 RpcService { 以太坊主网（以太坊主网服务）， EthSepolia(EthSepoliaService), ArbitrumOne(L2主网服务), 基础主网(L2主网服务), OptimismMainnet(L2MainnetService), 自定义（自定义RpcService），提供者(u64), } #[derive(CandidType、反序列化、克隆、调试)] 枚举 EthMainnetService { 炼金术，安克尔, 块Pi，云耀，骆驼，公共节点， } #[derive(CandidType、反序列化、克隆、调试)] 枚举 EthSepoliaService { 炼金术，安克尔, 块Pi，公共节点，塞波利亚, } #[derive(CandidType、反序列化、克隆、调试)] 枚举 L2MainnetService { 炼金术，安克尔, 块Pi，骆驼，公共节点， } #[derive(CandidType、反序列化、克隆、调试)] 结构 HttpHeader { 名称：字符串，值：字符串， } #[derive(CandidType、反序列化、克隆、调试)] 结构体 CustomRpcService { 网址：字符串，标头：选项>， } #[derive(CandidType、反序列化、克隆、调试)] 枚举块标签{ 最新，安全，最终确定，最早，待定，数字（坦率::Nat）， } #[derive(CandidType、反序列化、克隆、调试)] 枚举 MultiResult { 一致（RpcResult），不一致(Vec<(RpcService, RpcResult)>), } #[derive(CandidType、反序列化、克隆、调试)] 枚举 RpcResult { 好的（T），错误（RpcError）， } #[derive(CandidType、反序列化、克隆、调试)] 枚举 RpcError { 提供者错误（提供者错误）， HttpOutcallError(HttpOutcallError), JsonRpcError(JsonRpcError), 验证错误（验证错误）， } #[derive(CandidType、反序列化、克隆、调试)] 枚举提供者错误{ TooFewCycles { 预期：candid::Nat，收到：candid::Nat }, 缺少必需的提供者，找不到提供者，没有许可，无效RpcConfig（字符串）， } #[derive(CandidType、反序列化、克隆、调试)] 枚举拒绝代码 { 没有错误，罐错误，系统瞬态，目的地无效，未知，系统致命，罐拒绝， } #[derive(CandidType、反序列化、克隆、调试)] 枚举 HttpOutcallError { IcError { 代码：RejectionCode，消息：字符串 }，无效HttpJsonRpcResponse { 状态：u16，主体：字符串， #[serde(重命名=“解析错误”)] 解析错误：选项<字符串>， }, } #[derive(CandidType、反序列化、克隆、调试)] 结构JsonRpcError { 代码：i64，消息：字符串， } #[derive(CandidType、反序列化、克隆、调试)] 枚举验证错误{ 自定义（字符串），无效的十六进制（字符串）， } #[derive(CandidType、反序列化、克隆、调试)] 结构块{ #[serde(重命名 = "baseFeePerGas")] base_fee_per_gas: 选项, 编号：坦率::纳特，难度：选项, #[serde(重命名 = "extraData")] 额外数据：字符串， #[serde(重命名=“gasLimit”)] Gas_limit：坦率::Nat， #[serde(重命名=“gasUsed”)] Gas_used: 坦率::Nat, 哈希：字符串， #[serde(重命名=“logsBloom”)] Logs_bloom：字符串，矿工：字符串， #[serde(重命名=“mixHash”)] mix_hash：字符串，随机数：坦率::Nat， #[serde(重命名 = "parentHash")] 父哈希：字符串， #[serde(重命名=“receiptsRoot”)] 收据根：字符串， #[serde(重命名=“sha3Uncles”)] sha3_uncles：字符串，大小：坦率::Nat， #[serde(重命名=“stateRoot”)] state_root：字符串，时间戳：candid::Nat， #[serde(重命名=“总难度”)] 总难度：选项，交易：Vec, #[serde(重命名 = "transactionsRoot")] transactions_root：选项，叔叔：Vec， } #[derive(CandidType、反序列化、克隆、调试)] 枚举 SendRawTransactionStatus { 好的（选项<字符串>），随机数太低，随机数太高，资金不足， } // -- 通过原始 JSON-RPC 获取 ETH 余额 -- #[更新] async fn get_eth_balance(地址: String) -> String { 让 json = 格式！( r#"{{"jsonrpc":"2.0","method":"eth_getBalance","params":["{}","latest"],"id":1}}"#, 地址）；让 max_response_bytes: u64 = 1000; 让循环：u128 = 10_000_000_000； let (结果,): (结果 ,) = Call::unbounded_wait(evm_rpc_id(), "请求") .with_args(&( RpcService::EthMainnet(EthMainnetService::PublicNode), json, 最大响应字节数，）） .with_cycles(周期) .await .expect("无法调用 EVM RPC 容器") .candid_tuple() .expect("解码响应失败"); 比赛结果{ 好的（响应）=>响应， Err(err) => ic_cdk::trap(&format!("RPC 错误: {:?}", err)), } } // -- 通过类型化 API 获取最新区块 -- #[更新] async fn get_latest_block() -> 块 { 让循环：u128 = 10_000_000_000； let (结果,): (MultiResult,) = Call::unbounded_wait(evm_rpc_id(), "eth_getBlockByNumber") .with_args(&( RpcServices::EthMainnet（无），无::<()>, // 配置 BlockTag::最新，）） .with_cycles(周期) .await .expect("调用 eth_getBlockByNumber 失败") .candid_tuple() .expect("解码响应失败"); 比赛结果{ MultiResult::Constant(RpcResult::Ok(block)) => 块， MultiResult::Constant(RpcResult::Err(err)) => { ic_cdk::trap(&format!("RPC 错误: {:?}", err)) } MultiResult::不一致(_) => { ic_cdk::trap("提供者返回不一致的结果") } } } // -- 读取 ERC-20 余额 -- #[更新] async fn get_erc20_balance(token_contract: String, wallet_address: String) -> String { //balanceOf（地址）选择器：0x70a08231 // 将地址填充到 32 字节（剥离 0x，左侧填充零）让addr = wallet_address.trim_start_matches(“0x”); let calldata = format!("0x70a08231{:0>64}", addr); 让 json = 格式！( r#"{{"jsonrpc":"2.0","method":"eth_call","params":[{{"to":"{}","data":"{}"}},"latest"],"id":1}}"#, 代币合约、调用数据）；让循环：u128 = 10_000_000_000； let (结果,): (结果 ,) = Call::unbounded_wait(evm_rpc_id(), "请求") .with_args(&( RpcService::EthMainnet(EthMainnetService::PublicNode), json, 2048_u64, ）） .with_cycles(周期) .await .expect("无法调用 EVM RPC 容器") .candid_tuple() .expect("解码响应失败"); 比赛结果{ 好的（响应）=>响应， Err(err) => ic_cdk::trap(&format!("RPC 错误: {:?}", err)), } } // -- 发送签名的原始交易 -- #[更新] 异步 fn send_raw_transaction(signed_tx_hex: String) -> SendRawTransactionStatus { 让循环：u128 = 10_000_000_000； let (结果,): (MultiResult,) = Call::unbounded_wait(evm_rpc_id(), "eth_sendRawTransaction") .with_args(&( RpcServices::EthMainnet（无），无::<()>, 有符号的_tx_十六进制，）） .with_cycles(周期) .await .expect("调用 eth_sendRawTransaction 失败") .candid_tuple() .expect("解码响应失败"); 比赛结果{ MultiResult::Constant(RpcResult::Ok(status)) => 状态， MultiResult::Constant(RpcResult::Err(err)) => { ic_cdk::trap(&format!("RPC 错误: {:?}", err)) } MultiResult::不一致(_) => { ic_cdk::trap("提供者返回不一致的结果") } } } // -- 查询仲裁（不同链示例）-- #[更新] async fn get_arbitrum_block() -> 块 { 让循环：u128 = 10_000_000_000； let (结果,): (MultiResult,) = Call::unbounded_wait(evm_rpc_id(), "eth_getBlockByNumber") .with_args(&( RpcServices::ArbitrumOne（无），无::<()>, BlockTag::最新，）） .with_cycles(周期) .await .expect("调用 eth_getBlockByNumber 失败") .candid_tuple() .expect("解码响应失败"); 比赛结果{ MultiResult::Constant(RpcResult::Ok(block)) => 块， MultiResult::Constant(RpcResult::Err(err)) => { ic_cdk::trap(&format!("RPC 错误: {:?}", err)) } MultiResult::不一致(_) => { ic_cdk::trap("结果不一致") } } } ic_cdk::export_candid!(); ## 部署和测试 ### 本地发展 # 启动本地副本 icp网络启动-d # 拉取 EVM RPC 容器 icp deps拉动 icp deps init evm_rpc --参数 '(record {})' icp deps部署 # 部署你的后端 icp部署后端 ### 部署到主网 # 在主网上，EVM RPC 容器已部署。 # 您的容器由主体直接调用它。 icp部署后端-e ic ### 通过 icp CLI 测试 # 设置变量出口周期=10000000000 # 获取 ETH 余额（通过单一提供商的原始 JSON-RPC） icp 容器调用 evm_rpc 请求 '( 变体 { EthMainnet = 变体 { PublicNode } }, "{\"jsonrpc\":\"2.0\",\"方法\":\"eth_getBalance\",\"params\":[\"0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045\",\"最新\"],\"id\":1}", 1000 )' --with-cycles=$CYCLES # 获取最新区块（类型化API，多提供商） icp 容器调用 evm_rpc eth_getBlockByNumber '( 变体 { EthMainnet = null }, 空，变体 { 最新 } )' --with-cycles=$CYCLES # 获取交易收据 icp 容器调用 evm_rpc eth_getTransactionReceipt '( 变体 { EthMainnet = null }, 空， “0xdd5d4b18923d7aae953c7996d791118102e889bea37b48a651157a4890e4746f” )' --with-cycles=$CYCLES # 检查可用的提供者 icp 容器调用 evm_rpc getProviders # 打电话前预估费用 icp 容器调用 evm_rpc requestCost '( 变体 { EthMainnet = 变体 { PublicNode } }, "{\"jsonrpc\":\"2.0\",\"方法\":\"eth_getBalance\",\"params\":[\"0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045\",\"最新\"],\"id\":1}", 1000 )' ## 验证它是否有效 ### 检查 ETH 余额 icp 容器调用后端 get_eth_balance '("0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045")' # 预期：JSON 字符串，如 '{"jsonrpc":"2.0","id":1,"result":"0x..."}' # 结果是以 wei 为单位的余额（十六进制编码） ### 检查最新区块 icp 容器调用后端 get_latest_block # 预期：记录 { number = ...;哈希=“0x...”；时间戳= ...; ... } ### 检查 ERC-20 余额（USDC） # 以太坊上的 USDC 合约：0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48 icp 容器调用后端 get_erc20_balance '( “0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48”， “0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045” )' # 预期：带有十六进制编码的 uint256 余额的 JSON ### 验证周期退款在 RPC 调用之前和之后检查容器循环平衡： # 之前 icp 容器状态后端 -e ic # 拨打电话 icp 容器调用后端 get_eth_balance '("0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045")' -e ic # 之后 — 10B 预算中未使用的周期将被退还 icp 容器状态后端 -e ic

虚拟机远程过程调用

包含技能