use std::fmt;
use serde::de::DeserializeSeed;
use serde::de::Error as DeError;
use serde::de::MapAccess;
use serde::de::Visitor;
use super::super::metadata_wire_v1::MetadataWireV1;
pub(in crate::wire) struct MetadataWireV1Visitor<S> {
pub(in crate::wire) values: Option<S>,
}
impl<'de, S> Visitor<'de> for MetadataWireV1Visitor<S>
where
S: DeserializeSeed<'de>,
{
type Value = MetadataWireV1<S::Value>;
fn expecting(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
formatter.write_str("a strict metadata V1 envelope")
}
fn visit_map<A>(mut self, mut map: A) -> Result<Self::Value, A::Error>
where
A: MapAccess<'de>,
{
let mut version = None;
let mut values = None;
while let Some(key) = map.next_key::<String>()? {
match key.as_str() {
"version" => {
if version.is_some() {
return Err(DeError::duplicate_field("version"));
}
version = Some(map.next_value::<u8>()?);
}
"values" => {
if values.is_some() {
return Err(DeError::duplicate_field("values"));
}
let seed = self.values.take().expect("metadata values seed is consumed once");
values = Some(map.next_value_seed(seed)?);
}
_ => {
return Err(DeError::unknown_field(&key, &["version", "values"]));
}
}
}
Ok(MetadataWireV1 {
version: version.ok_or_else(|| DeError::missing_field("version"))?,
values: values.ok_or_else(|| DeError::missing_field("values"))?,
})
}
}