use std::fmt;
use serde::de::DeserializeSeed;
use serde::de::Deserializer;
use serde::de::Error as DeError;
use serde::de::MapAccess;
use serde::de::Visitor;
use super::metadata_wire_v1::MetadataWireV1;
pub(crate) struct MetadataWireV1Seed<S> {
values: S,
}
impl<S> MetadataWireV1Seed<S> {
pub(crate) const fn new(values: S) -> Self {
Self { values }
}
}
impl<'de, S> DeserializeSeed<'de> for MetadataWireV1Seed<S>
where
S: DeserializeSeed<'de>,
{
type Value = MetadataWireV1<S::Value>;
fn deserialize<D>(self, deserializer: D) -> Result<Self::Value, D::Error>
where
D: Deserializer<'de>,
{
struct MetadataWireVisitor<S> {
values: Option<S>,
}
impl<'de, S> Visitor<'de> for MetadataWireVisitor<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"))?,
})
}
}
deserializer.deserialize_struct(
"MetadataWireV1",
&["version", "values"],
MetadataWireVisitor {
values: Some(self.values),
},
)
}
}