use crate::models;
use serde::{Deserialize, Serialize};
#[derive(Clone, Default, Debug, PartialEq)]
pub struct ClusterConfigCreateConfigRequest {
pub clustername: String,
pub nodeid: Option<i64>,
pub token_coefficient: Option<i64>,
pub votes: Option<i64>,
pub links: Option<std::collections::HashMap<u32, models::PveLinkField>>,
}
impl ClusterConfigCreateConfigRequest {
pub fn new(clustername: String) -> ClusterConfigCreateConfigRequest {
ClusterConfigCreateConfigRequest {
clustername,
nodeid: None,
token_coefficient: None,
votes: None,
links: None,
}
}
}
impl serde::Serialize for ClusterConfigCreateConfigRequest {
fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
use serde::ser::Error;
let mut map = serde_json::Map::new();
{
let _v = serde_json::to_value(&self.clustername).map_err(Error::custom)?;
if !_v.is_null() {
map.insert("clustername".to_string(), _v);
}
}
{
let _v = serde_json::to_value(&self.nodeid).map_err(Error::custom)?;
if !_v.is_null() {
map.insert("nodeid".to_string(), _v);
}
}
{
let _v = serde_json::to_value(&self.token_coefficient).map_err(Error::custom)?;
if !_v.is_null() {
map.insert("token-coefficient".to_string(), _v);
}
}
{
let _v = serde_json::to_value(&self.votes).map_err(Error::custom)?;
if !_v.is_null() {
map.insert("votes".to_string(), _v);
}
}
if let Some(ref _m) = self.links {
for (_idx, _val) in _m.iter() {
map.insert(format!("link{}", _idx), serde_json::to_value(_val).map_err(Error::custom)?);
}
}
serde_json::Value::Object(map).serialize(serializer)
}
}
impl<'de> serde::Deserialize<'de> for ClusterConfigCreateConfigRequest {
fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
use serde::de::Error;
let mut raw: serde_json::Map<String, serde_json::Value> =
serde::Deserialize::deserialize(deserializer)?;
let mut __links: std::collections::HashMap<u32, models::PveLinkField> = std::collections::HashMap::new();
{
let _prefix = "link";
let _keys: Vec<String> = raw.keys()
.filter(|k| {
if let Some(_suffix) = k.strip_prefix(_prefix) {
!_suffix.is_empty() && _suffix.chars().all(|c| c.is_ascii_digit())
} else {
false
}
})
.cloned()
.collect();
for _key in _keys {
let _suffix = _key.strip_prefix(_prefix).unwrap();
let _idx: u32 = _suffix.parse().map_err(Error::custom)?;
let _value = raw.remove(&_key).unwrap();
let _item: models::PveLinkField = serde_json::from_value(_value).map_err(Error::custom)?;
__links.insert(_idx, _item);
}
}
Ok(ClusterConfigCreateConfigRequest {
clustername: serde_json::from_value(raw.remove("clustername").unwrap_or(serde_json::Value::Null)).map_err(Error::custom)?,
nodeid: serde_json::from_value(raw.remove("nodeid").unwrap_or(serde_json::Value::Null)).map_err(Error::custom)?,
token_coefficient: serde_json::from_value(raw.remove("token-coefficient").unwrap_or(serde_json::Value::Null)).map_err(Error::custom)?,
votes: serde_json::from_value(raw.remove("votes").unwrap_or(serde_json::Value::Null)).map_err(Error::custom)?,
links: if __links.is_empty() { None } else { Some(__links) },
})
}
}