pipeline/etl/value/
array.rsuse crate::error::{Error, Result};
use crate::etl::value::Value;
#[derive(Debug, Clone, PartialEq, Default)]
pub struct Array {
pub values: Vec<Value>,
}
impl Array {
pub fn new() -> Self {
Array { values: vec![] }
}
}
impl std::fmt::Display for Array {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
let values = self
.values
.iter()
.map(|v| v.to_string())
.collect::<Vec<String>>()
.join(", ");
write!(f, "[{}]", values)
}
}
impl std::ops::Deref for Array {
type Target = Vec<Value>;
fn deref(&self) -> &Self::Target {
&self.values
}
}
impl std::ops::DerefMut for Array {
fn deref_mut(&mut self) -> &mut Self::Target {
&mut self.values
}
}
impl IntoIterator for Array {
type Item = Value;
type IntoIter = std::vec::IntoIter<Value>;
fn into_iter(self) -> Self::IntoIter {
self.values.into_iter()
}
}
impl From<Vec<Value>> for Array {
fn from(values: Vec<Value>) -> Self {
Array { values }
}
}
impl TryFrom<Vec<serde_json::Value>> for Array {
type Error = Error;
fn try_from(value: Vec<serde_json::Value>) -> Result<Self> {
let values = value
.into_iter()
.map(|v| v.try_into())
.collect::<Result<Vec<_>>>()?;
Ok(Array { values })
}
}