ferrodock 1.8.0

A fast, native container manager for Docker, written in Rust.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

//! Docker Compose projects, reconstructed from container labels.
//!
//! Compose has no API of its own in the Engine: it labels every container it
//! creates. Grouping containers by those labels gives us the projects.

use std::collections::BTreeMap;

use super::ContainerInfo;

#[derive(Debug, Clone, PartialEq)]
pub struct ComposeProject {
    pub name: String,
    pub working_dir: String,
    pub config_files: Vec<String>,
    /// The project's containers, sorted by service name.
    pub containers: Vec<ContainerInfo>,
}

impl ComposeProject {
    pub fn running(&self) -> usize {
        self.containers.iter().filter(|c| c.is_active()).count()
    }

    /// Distinct service names, in order.
    pub fn services(&self) -> Vec<&str> {
        let mut services: Vec<&str> = self
            .containers
            .iter()
            .filter_map(|c| c.compose.as_ref().map(|l| l.service.as_str()))
            .collect();
        services.dedup();
        services
    }
}

/// Groups the containers that belong to Compose projects, sorted by
/// project name. Containers outside any project are ignored.
pub fn group_projects(containers: &[ContainerInfo]) -> Vec<ComposeProject> {
    let mut projects: BTreeMap<&str, ComposeProject> = BTreeMap::new();
    for container in containers {
        let Some(labels) = &container.compose else {
            continue;
        };
        let project = projects
            .entry(labels.project.as_str())
            .or_insert_with(|| ComposeProject {
                name: labels.project.clone(),
                working_dir: labels.working_dir.clone(),
                config_files: labels
                    .config_files
                    .split(',')
                    .map(str::trim)
                    .filter(|f| !f.is_empty())
                    .map(str::to_owned)
                    .collect(),
                containers: Vec::new(),
            });
        project.containers.push(container.clone());
    }
    let mut projects: Vec<ComposeProject> = projects.into_values().collect();
    for project in &mut projects {
        project.containers.sort_by_cached_key(|c| {
            let service = c.compose.as_ref().map(|l| l.service.clone());
            (service, c.name.clone())
        });
    }
    projects
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::docker::containers::ComposeLabels;

    fn container(name: &str, state: &str, compose: Option<(&str, &str)>) -> ContainerInfo {
        ContainerInfo {
            id: format!("{name}-id"),
            name: name.into(),
            image: String::new(),
            image_id: String::new(),
            command: String::new(),
            state: state.into(),
            status: String::new(),
            created: 0,
            ports: Vec::new(),
            ip_addresses: Vec::new(),
            networks: Vec::new(),
            mounts: Vec::new(),
            volumes: Vec::new(),
            compose: compose.map(|(project, service)| ComposeLabels {
                project: project.into(),
                service: service.into(),
                working_dir: "/srv/shop".into(),
                config_files: "/srv/shop/compose.yaml, /srv/shop/compose.override.yaml".into(),
            }),
        }
    }

    #[test]
    fn groups_by_project_and_ignores_loose_containers() {
        let projects = group_projects(&[
            container("shop-web-1", "running", Some(("shop", "web"))),
            container("loose", "running", None),
            container("shop-db-1", "exited", Some(("shop", "db"))),
            container("blog-app-1", "running", Some(("blog", "app"))),
        ]);
        let names: Vec<&str> = projects.iter().map(|p| p.name.as_str()).collect();
        assert_eq!(names, vec!["blog", "shop"]);

        let shop = &projects[1];
        assert_eq!(shop.services(), vec!["db", "web"]);
        assert_eq!(shop.running(), 1);
        assert_eq!(
            shop.config_files,
            vec!["/srv/shop/compose.yaml", "/srv/shop/compose.override.yaml"]
        );
    }
}