dockworker 0.16.0

use crate::container::Config;
use chrono::offset::FixedOffset;
use chrono::DateTime;
use serde::de::{DeserializeOwned, Deserializer};
use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use std::{fmt, result};

fn null_to_default<'de, D, T>(de: D) -> Result<T, D::Error>
where
    D: Deserializer<'de>,
    T: DeserializeOwned + Default,
{
    let actual: Option<T> = Option::deserialize(de)?;
    Ok(actual.unwrap_or_default())
}

#[derive(Debug, Clone, Serialize, Deserialize)]
#[allow(non_snake_case)]
pub struct FoundImage {
    pub description: String,
    pub is_official: bool,
    pub is_automated: bool,
    pub name: String,
    pub star_count: u32,
}

#[derive(Debug, Clone, Serialize, Deserialize, Default)]
#[allow(non_snake_case)]
pub struct ImageFilters {
    #[serde(rename = "is-automated")]
    #[serde(skip_serializing_if = "Option::is_none")]
    #[serde(with = "format::boolopt_as_strlist")]
    pub is_automated: Option<bool>,
    #[serde(rename = "is-official")]
    #[serde(skip_serializing_if = "Option::is_none")]
    #[serde(with = "format::boolopt_as_strlist")]
    pub is_official: Option<bool>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub stars: Option<u64>,
}

impl ImageFilters {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn is_automated(&mut self, is_automated: bool) -> &mut Self {
        self.is_automated = Some(is_automated);
        self
    }

    pub fn is_official(&mut self, is_official: bool) -> &mut Self {
        self.is_official = Some(is_official);
        self
    }

    pub fn stars(&mut self, stars: u64) -> &mut Self {
        self.stars = Some(stars);
        self
    }
}

#[derive(Debug, Clone, Serialize, Deserialize)]
#[allow(non_snake_case)]
pub struct SummaryImage {
    pub Id: String,
    pub ParentId: String,
    #[serde(deserialize_with = "null_to_default")]
    pub RepoTags: Vec<String>,
    #[serde(deserialize_with = "null_to_default", default = "Vec::default")]
    pub RepoDigests: Vec<String>,
    pub Created: u64,
    pub Size: i64,
    #[serde(default = "i64::default")]
    pub SharedSize: i64,
    #[deprecated]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub VirtualSize: Option<i64>,
    #[serde(default = "i64::default")]
    pub Containers: i64,
}

/// Type of /images/{}/json api
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[allow(non_snake_case)]
pub struct Image {
    pub Id: String,
    pub RepoTags: Vec<String>,
    pub RepoDigests: Vec<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub Parent: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub Comment: Option<String>,
    #[serde(with = "format::datetime_rfc3339")]
    // https://github.com/moby/moby/blob/611b23c1a0e9a9f440165a331964923fd1116256/daemon/images/image_inspect.go#L72
    pub Created: DateTime<FixedOffset>,
    #[deprecated]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub Container: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub DockerVersion: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub Author: Option<String>,
    pub Config: Config,
    pub Architecture: String,
    pub Os: String,
    pub Size: i64,
    #[deprecated]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub VirtualSize: Option<i64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub GraphDriver: Option<GraphDriver>,
    pub RootFS: RootFS,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[allow(non_snake_case)]
pub struct GraphDriver {
    pub Name: String,
    #[serde(deserialize_with = "null_to_default")]
    pub Data: HashMap<String, String>,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[allow(non_snake_case)]
pub struct RootFS {
    pub Type: String,
    pub Layers: Vec<String>,
    #[serde(default = "Default::default")]
    pub BaseLayer: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ImageStatus {
    pub status: Option<String>,
    pub error: Option<String>,
}

#[derive(Debug, Clone, PartialEq, PartialOrd, Serialize, Deserialize)]
pub struct ImageId {
    id: String,
}

impl From<String> for ImageId {
    fn from(id: String) -> Self {
        Self { id }
    }
}

impl fmt::Display for ImageId {
    fn fmt(&self, f: &mut fmt::Formatter) -> result::Result<(), fmt::Error> {
        self.id.fmt(f)
    }
}

impl ImageId {
    pub fn new<S: Into<String>>(id: S) -> Self {
        Self { id: id.into() }
    }

    pub fn id(&self) -> &str {
        &self.id
    }
}

pub mod format {
    use serde::de::{self, Deserialize, Deserializer};
    use serde::Serializer;

    pub mod boolopt_as_strlist {
        use super::*;

        pub fn serialize<S>(opt: &Option<bool>, serializer: S) -> Result<S::Ok, S::Error>
        where
            S: Serializer,
        {
            if let Some(b) = opt {
                serializer.serialize_some(&[&b.to_string()])
            } else {
                serializer.serialize_none()
            }
        }

        pub fn deserialize<'de, D>(de: D) -> Result<Option<bool>, D::Error>
        where
            D: Deserializer<'de>,
        {
            let sopt = Option::<Vec<String>>::deserialize(de)?;
            if let Some(s) = sopt {
                if s.len() == 1 {
                    match s[0].parse::<bool>() {
                        Ok(b) => Ok(Some(b)),
                        Err(_) => Err(de::Error::invalid_value(
                            de::Unexpected::Str(&s[0]),
                            &r#"string represents bool"#,
                        )),
                    }
                } else {
                    Err(de::Error::invalid_length(s.len(), &"bool string singleton"))
                }
            } else {
                Ok(None)
            }
        }
    }

    pub mod datetime_rfc3339 {
        use super::*;
        use chrono::offset::FixedOffset;
        use chrono::DateTime;

        pub fn serialize<S>(dt: &DateTime<FixedOffset>, serializer: S) -> Result<S::Ok, S::Error>
        where
            S: Serializer,
        {
            let str = dt.to_rfc3339();
            serializer.serialize_str(&str)
        }

        pub fn deserialize<'de, D>(de: D) -> Result<DateTime<FixedOffset>, D::Error>
        where
            D: Deserializer<'de>,
        {
            let str = String::deserialize(de)?;
            DateTime::parse_from_rfc3339(&str).map_err(de::Error::custom)
        }
    }
}