use crate::{Constructor, Event, Function};
use serde::{de::Error as SerdeError, Deserialize, Deserializer};
use serde_json::{value::from_value, Value};
#[derive(Clone, Debug, PartialEq)]
pub enum Operation {
Constructor(Constructor),
Function(Function),
Event(Event),
Fallback,
Receive,
}
impl<'a> Deserialize<'a> for Operation {
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where
D: Deserializer<'a>,
{
let v: Value = Deserialize::deserialize(deserializer)?;
let map = v.as_object().ok_or_else(|| SerdeError::custom("Invalid operation"))?;
let s = map.get("type").and_then(Value::as_str).ok_or_else(|| SerdeError::custom("Invalid operation type"))?;
fn sanitize_name(name: &mut String) {
if let Some(i) = name.find('(') {
name.truncate(i);
}
}
let result = match s {
"constructor" => from_value(v).map(Operation::Constructor),
"function" => from_value(v).map(|mut f: Function| {
sanitize_name(&mut f.name);
Operation::Function(f)
}),
"event" => from_value(v).map(|mut e: Event| {
sanitize_name(&mut e.name);
Operation::Event(e)
}),
"fallback" => Ok(Operation::Fallback),
"receive" => Ok(Operation::Receive),
other => Err(SerdeError::custom(format!("Invalid operation type {}.", other))),
};
result.map_err(|e| D::Error::custom(e.to_string()))
}
}
#[cfg(test)]
mod tests {
use super::Operation;
use crate::{Event, EventParam, Function, Param, ParamType, StateMutability};
use serde_json;
#[test]
fn deserialize_operation() {
let s = r#"{
"type":"function",
"inputs": [{
"name":"a",
"type":"address"
}],
"name":"foo",
"outputs": []
}"#;
let deserialized: Operation = serde_json::from_str(s).unwrap();
assert_eq!(
deserialized,
Operation::Function(Function {
name: "foo".to_owned(),
inputs: vec![Param { name: "a".to_owned(), kind: ParamType::Address }],
outputs: vec![],
constant: false,
state_mutability: StateMutability::NonPayable,
})
);
}
#[test]
fn deserialize_event_operation_with_tuple_array_input() {
let s = r#"{
"type":"event",
"inputs": [
{
"name":"a",
"type":"address",
"indexed":true
},
{
"components": [
{
"internalType": "address",
"name": "to",
"type": "address"
},
{
"internalType": "uint256",
"name": "value",
"type": "uint256"
},
{
"internalType": "bytes",
"name": "data",
"type": "bytes"
}
],
"indexed": false,
"internalType": "struct Action[]",
"name": "b",
"type": "tuple[]"
}
],
"name":"E",
"outputs": [],
"anonymous": false
}"#;
let deserialized: Operation = serde_json::from_str(s).unwrap();
assert_eq!(
deserialized,
Operation::Event(Event {
name: "E".to_owned(),
inputs: vec![
EventParam { name: "a".to_owned(), kind: ParamType::Address, indexed: true },
EventParam {
name: "b".to_owned(),
kind: ParamType::Array(Box::new(ParamType::Tuple(vec![
ParamType::Address,
ParamType::Uint(256),
ParamType::Bytes
]))),
indexed: false
},
],
anonymous: false,
})
);
}
#[test]
fn deserialize_sanitize_function_name() {
fn test_sanitize_function_name(name: &str, expected: &str) {
let s = format!(
r#"{{
"type":"function",
"inputs": [{{
"name":"a",
"type":"address"
}}],
"name":"{}",
"outputs": []
}}"#,
name
);
let deserialized: Operation = serde_json::from_str(&s).unwrap();
let function = match deserialized {
Operation::Function(f) => f,
_ => panic!("expected funciton"),
};
assert_eq!(function.name, expected);
}
test_sanitize_function_name("foo", "foo");
test_sanitize_function_name("foo()", "foo");
test_sanitize_function_name("()", "");
test_sanitize_function_name("", "");
}
#[test]
fn deserialize_sanitize_event_name() {
fn test_sanitize_event_name(name: &str, expected: &str) {
let s = format!(
r#"{{
"type":"event",
"inputs": [{{
"name":"a",
"type":"address",
"indexed":true
}}],
"name":"{}",
"outputs": [],
"anonymous": false
}}"#,
name
);
let deserialized: Operation = serde_json::from_str(&s).unwrap();
let event = match deserialized {
Operation::Event(e) => e,
_ => panic!("expected event!"),
};
assert_eq!(event.name, expected);
}
test_sanitize_event_name("foo", "foo");
test_sanitize_event_name("foo()", "foo");
test_sanitize_event_name("()", "");
test_sanitize_event_name("", "");
}
}