use crate::{Constructor, Event, Function};
use serde::de::Error as SerdeError;
use serde::{Deserialize, Deserializer};
use serde_json::value::from_value;
use serde_json::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::{Function, StateMutability, Param, ParamType};
use serde_json;
#[test]
fn deserialize_operation() {
let s = r#"{
"type":"function",
"inputs": [{
"name":"a",
"type":"address"
}],
"name":"foo",
"outputs": [],
"stateMutability": "nonpayable"
}"#;
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![],
state_mutability: StateMutability::Nonpayable,
})
);
}
#[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": [],
"stateMutability": "payable"
}}"#,
name
);
let deserialized: Operation = serde_json::from_str(&s).unwrap();
let function = match deserialized {
Operation::Function(f) => f,
_ => panic!("expected funciton"),
};
assert_eq!(function.state_mutability, StateMutability::Payable);
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("", "");
}
}