foundry_evm_core/
decode.rs
1use crate::abi::{console, Vm};
4use alloy_dyn_abi::JsonAbiExt;
5use alloy_json_abi::{Error, JsonAbi};
6use alloy_primitives::{hex, map::HashMap, Log, Selector};
7use alloy_sol_types::{
8 ContractError::Revert, RevertReason, RevertReason::ContractError, SolEventInterface,
9 SolInterface, SolValue,
10};
11use foundry_common::SELECTOR_LEN;
12use itertools::Itertools;
13use revm::interpreter::InstructionResult;
14use std::{fmt, sync::OnceLock};
15
16#[derive(Clone, Debug, PartialEq, Eq)]
18pub struct SkipReason(pub Option<String>);
19
20impl SkipReason {
21 pub fn decode(raw_result: &[u8]) -> Option<Self> {
23 raw_result.strip_prefix(crate::constants::MAGIC_SKIP).map(|reason| {
24 let reason = String::from_utf8_lossy(reason).into_owned();
25 Self((!reason.is_empty()).then_some(reason))
26 })
27 }
28
29 pub fn decode_self(s: &str) -> Option<Self> {
33 s.strip_prefix("skipped").map(|rest| Self(rest.strip_prefix(": ").map(ToString::to_string)))
34 }
35}
36
37impl fmt::Display for SkipReason {
38 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
39 f.write_str("skipped")?;
40 if let Some(reason) = &self.0 {
41 f.write_str(": ")?;
42 f.write_str(reason)?;
43 }
44 Ok(())
45 }
46}
47
48pub fn decode_console_logs(logs: &[Log]) -> Vec<String> {
50 logs.iter().filter_map(decode_console_log).collect()
51}
52
53pub fn decode_console_log(log: &Log) -> Option<String> {
58 console::ds::ConsoleEvents::decode_log(log, false).ok().map(|decoded| decoded.to_string())
59}
60
61#[derive(Clone, Debug, Default)]
63pub struct RevertDecoder {
64 pub errors: HashMap<Selector, Vec<Error>>,
66}
67
68impl Default for &RevertDecoder {
69 fn default() -> Self {
70 static EMPTY: OnceLock<RevertDecoder> = OnceLock::new();
71 EMPTY.get_or_init(RevertDecoder::new)
72 }
73}
74
75impl RevertDecoder {
76 pub fn new() -> Self {
78 Self::default()
79 }
80
81 pub fn with_abis<'a>(mut self, abi: impl IntoIterator<Item = &'a JsonAbi>) -> Self {
85 self.extend_from_abis(abi);
86 self
87 }
88
89 pub fn with_abi(mut self, abi: &JsonAbi) -> Self {
93 self.extend_from_abi(abi);
94 self
95 }
96
97 pub fn with_abi_opt(mut self, abi: Option<&JsonAbi>) -> Self {
101 if let Some(abi) = abi {
102 self.extend_from_abi(abi);
103 }
104 self
105 }
106
107 pub fn extend_from_abis<'a>(&mut self, abi: impl IntoIterator<Item = &'a JsonAbi>) {
109 for abi in abi {
110 self.extend_from_abi(abi);
111 }
112 }
113
114 pub fn extend_from_abi(&mut self, abi: &JsonAbi) {
116 for error in abi.errors() {
117 self.push_error(error.clone());
118 }
119 }
120
121 pub fn push_error(&mut self, error: Error) {
123 self.errors.entry(error.selector()).or_default().push(error);
124 }
125
126 pub fn decode(&self, err: &[u8], status: Option<InstructionResult>) -> String {
131 self.maybe_decode(err, status).unwrap_or_else(|| {
132 if err.is_empty() {
133 "<empty revert data>".to_string()
134 } else {
135 trimmed_hex(err)
136 }
137 })
138 }
139
140 pub fn maybe_decode(&self, err: &[u8], status: Option<InstructionResult>) -> Option<String> {
144 if let Some(reason) = SkipReason::decode(err) {
145 return Some(reason.to_string());
146 }
147
148 if let Some(ContractError(Revert(revert))) = RevertReason::decode(err) {
150 return Some(revert.reason);
151 }
152
153 if let Ok(e) = alloy_sol_types::ContractError::<Vm::VmErrors>::abi_decode(err, false) {
155 return Some(e.to_string());
156 }
157
158 let string_decoded = decode_as_non_empty_string(err);
159
160 if let Some((selector, data)) = err.split_first_chunk::<SELECTOR_LEN>() {
161 if let Some(errors) = self.errors.get(selector) {
163 for error in errors {
164 if let Ok(decoded) = error.abi_decode_input(data, false) {
167 return Some(format!(
168 "{}({})",
169 error.name,
170 decoded.iter().map(foundry_common::fmt::format_token).format(", ")
171 ));
172 }
173 }
174 }
175
176 if string_decoded.is_some() {
177 return string_decoded
178 }
179
180 return Some({
182 let mut s = format!("custom error {}", hex::encode_prefixed(selector));
183 if !data.is_empty() {
184 s.push_str(": ");
185 match std::str::from_utf8(data) {
186 Ok(data) => s.push_str(data),
187 Err(_) => s.push_str(&hex::encode(data)),
188 }
189 }
190 s
191 })
192 }
193
194 if string_decoded.is_some() {
195 return string_decoded
196 }
197
198 if let Some(status) = status {
199 if !status.is_ok() {
200 return Some(format!("EvmError: {status:?}"));
201 }
202 }
203 if err.is_empty() {
204 None
205 } else {
206 Some(format!("custom error bytes {}", hex::encode_prefixed(err)))
207 }
208 }
209}
210
211fn decode_as_non_empty_string(err: &[u8]) -> Option<String> {
213 if let Ok(s) = String::abi_decode(err, true) {
215 if !s.is_empty() {
216 return Some(s);
217 }
218 }
219
220 if err.is_ascii() {
222 let msg = std::str::from_utf8(err).unwrap().to_string();
223 if !msg.is_empty() {
224 return Some(msg);
225 }
226 }
227
228 None
229}
230
231fn trimmed_hex(s: &[u8]) -> String {
232 let n = 32;
233 if s.len() <= n {
234 hex::encode(s)
235 } else {
236 format!(
237 "{}…{} ({} bytes)",
238 &hex::encode(&s[..n / 2]),
239 &hex::encode(&s[s.len() - n / 2..]),
240 s.len(),
241 )
242 }
243}
244
245#[cfg(test)]
246mod tests {
247 use super::*;
248 #[test]
249 fn test_trimmed_hex() {
250 assert_eq!(trimmed_hex(&hex::decode("1234567890").unwrap()), "1234567890");
251 assert_eq!(
252 trimmed_hex(&hex::decode("492077697368207275737420737570706F72746564206869676865722D6B696E646564207479706573").unwrap()),
253 "49207769736820727573742073757070…6865722d6b696e646564207479706573 (41 bytes)"
254 );
255 }
256}