use super::*;
impl<N: Network> Serialize for FinalizeOperation<N> {
fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
match serializer.is_human_readable() {
true => {
match self {
Self::InitializeMapping(mapping_id) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 2)?;
operation.serialize_field("type", "initialize_mapping")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.end()
}
Self::InsertKeyValue(mapping_id, key_id, value_id) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 4)?;
operation.serialize_field("type", "insert_key_value")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.serialize_field("key_id", key_id)?;
operation.serialize_field("value_id", value_id)?;
operation.end()
}
Self::UpdateKeyValue(mapping_id, index, key_id, value_id) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 5)?;
operation.serialize_field("type", "update_key_value")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.serialize_field("index", index)?;
operation.serialize_field("key_id", key_id)?;
operation.serialize_field("value_id", value_id)?;
operation.end()
}
Self::RemoveKeyValue(mapping_id, index) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 3)?;
operation.serialize_field("type", "remove_key_value")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.serialize_field("index", index)?;
operation.end()
}
Self::ReplaceMapping(mapping_id) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 2)?;
operation.serialize_field("type", "replace_mapping")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.end()
}
Self::RemoveMapping(mapping_id) => {
let mut operation = serializer.serialize_struct("FinalizeOperation", 2)?;
operation.serialize_field("type", "remove_mapping")?;
operation.serialize_field("mapping_id", mapping_id)?;
operation.end()
}
}
}
false => ToBytesSerializer::serialize_with_size_encoding(self, serializer),
}
}
}
impl<'de, N: Network> Deserialize<'de> for FinalizeOperation<N> {
fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
match deserializer.is_human_readable() {
true => {
let mut operation = serde_json::Value::deserialize(deserializer)?;
let finalize_operation = match operation.get("type").and_then(|t| t.as_str()) {
Some("initialize_mapping") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
Self::InitializeMapping(mapping_id)
}
Some("insert_key_value") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
let key_id = DeserializeExt::take_from_value::<D>(&mut operation, "key_id")?;
let value_id = DeserializeExt::take_from_value::<D>(&mut operation, "value_id")?;
Self::InsertKeyValue(mapping_id, key_id, value_id)
}
Some("update_key_value") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
let index = DeserializeExt::take_from_value::<D>(&mut operation, "index")?;
let key_id = DeserializeExt::take_from_value::<D>(&mut operation, "key_id")?;
let value_id = DeserializeExt::take_from_value::<D>(&mut operation, "value_id")?;
Self::UpdateKeyValue(mapping_id, index, key_id, value_id)
}
Some("remove_key_value") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
let index = DeserializeExt::take_from_value::<D>(&mut operation, "index")?;
Self::RemoveKeyValue(mapping_id, index)
}
Some("replace_mapping") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
Self::ReplaceMapping(mapping_id)
}
Some("remove_mapping") => {
let mapping_id = DeserializeExt::take_from_value::<D>(&mut operation, "mapping_id")?;
Self::RemoveMapping(mapping_id)
}
_ => return Err(de::Error::custom("Invalid finalize operation type")),
};
Ok(finalize_operation)
}
false => FromBytesDeserializer::<Self>::deserialize_with_size_encoding(deserializer, "finalize operations"),
}
}
}
#[cfg(test)]
mod tests {
use super::*;
fn check_serde_json<
T: Serialize + for<'a> Deserialize<'a> + Debug + Display + PartialEq + Eq + FromStr + ToBytes + FromBytes,
>(
expected: T,
) {
let expected_string = expected.to_string();
let candidate_string = serde_json::to_string(&expected).unwrap();
let candidate = serde_json::from_str::<T>(&candidate_string).unwrap();
assert_eq!(expected, candidate);
assert_eq!(expected_string, candidate_string);
assert_eq!(expected_string, candidate.to_string());
assert_eq!(expected, T::from_str(&expected_string).unwrap_or_else(|_| panic!("FromStr: {expected_string}")));
assert_eq!(expected, serde_json::from_str(&candidate_string).unwrap());
}
fn check_bincode<
T: Serialize + for<'a> Deserialize<'a> + Debug + Display + PartialEq + Eq + FromStr + ToBytes + FromBytes,
>(
expected: T,
) {
let expected_bytes = expected.to_bytes_le().unwrap();
let expected_bytes_with_size_encoding = bincode::serialize(&expected).unwrap();
assert_eq!(&expected_bytes[..], &expected_bytes_with_size_encoding[8..]);
assert_eq!(expected, T::read_le(&expected_bytes[..]).unwrap());
assert_eq!(expected, bincode::deserialize(&expected_bytes_with_size_encoding[..]).unwrap());
}
#[test]
fn test_serde_json() {
for finalize in crate::logic::finalize_operation::test_helpers::sample_finalize_operations() {
check_serde_json(finalize);
}
}
#[test]
fn test_bincode() {
for finalize in crate::logic::finalize_operation::test_helpers::sample_finalize_operations() {
check_bincode(finalize);
}
}
}