docktopus 0.3.0

TBD
Documentation 
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
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

mod common;

use bollard::container::ListContainersOptions;
use common::{is_docker_running, with_docker_cleanup};
use docktopus::DockerBuilder;
use docktopus::config::{DockerCommand, DockerfileConfig};
use futures_util::TryStreamExt;
use std::collections::HashMap;
use std::time::Duration;

#[tokio::test]
async fn test_dockerfile_deployment() -> color_eyre::Result<()> {
    with_docker_cleanup(|test_id| {
        Box::pin(async move {
            if !is_docker_running() {
                println!("Skipping test: Docker is not running");
                return Ok(());
            }

            let builder = DockerBuilder::new().await?;
            let network_name = format!("test-network-{}", test_id);

            let mut network_labels = HashMap::new();
            network_labels.insert("test_id".to_string(), test_id.to_string());

            // Create network with retry mechanism
            builder
                .create_network_with_retry(
                    &network_name,
                    3,
                    Duration::from_secs(2),
                    Some(network_labels),
                )
                .await?;

            // Pull alpine image first
            println!("Pulling alpine image...");
            builder
                .client()
                .create_image(
                    Some(bollard::image::CreateImageOptions {
                        from_image: "alpine",
                        tag: "latest",
                        ..Default::default()
                    }),
                    None,
                    None,
                )
                .try_collect::<Vec<_>>()
                .await?;
            println!("Image pull complete");

            // Create a simple test Dockerfile config
            let config = DockerfileConfig {
                base_image: "alpine:latest".to_string(),
                commands: vec![
                    DockerCommand::Run {
                        command: "echo 'test' > /test.txt".to_string(),
                    },
                    DockerCommand::Label {
                        labels: {
                            let mut labels = HashMap::new();
                            labels.insert("test_id".to_string(), test_id.to_string());
                            labels
                        },
                    },
                    DockerCommand::Cmd {
                        command: vec!["sleep".to_string(), "30".to_string()], // Keep container running
                    },
                ],
            };

            let tag = format!("test-dockerfile-{}", test_id);
            println!("Building image with tag: {}", tag);

            // Deploy using our config with network
            let container_id = builder
                .deploy_dockerfile(&config, &tag, None, None, Some(network_name.clone()), None)
                .await?;
            println!("Container created with ID: {}", container_id);

            // Add a small delay after creation
            tokio::time::sleep(Duration::from_millis(100)).await;

            // Verify container is running
            let mut filters = std::collections::HashMap::new();
            filters.insert("id".to_string(), vec![container_id.clone()]);
            filters.insert("label".to_string(), vec![format!("test_id={}", test_id)]);

            let mut retries = 5;
            let mut container_running = false;
            while retries > 0 {
                println!("Checking container state, attempt {}", 6 - retries);
                if let Ok(containers) = builder
                    .client()
                    .list_containers(Some(ListContainersOptions {
                        all: true,
                        filters: filters.clone(),
                        ..Default::default()
                    }))
                    .await
                {
                    if containers.is_empty() {
                        println!("No containers found matching filters");
                    } else {
                        println!("Container found and running");
                        container_running = true;
                        break;
                    }
                } else {
                    println!("Error listing containers");
                }
                retries -= 1;
                tokio::time::sleep(Duration::from_millis(500)).await;
            }

            // If container not running, get more details
            if !container_running {
                println!("Container not found with filters. Checking container inspect...");
                if let Ok(inspect) = builder
                    .client()
                    .inspect_container(&container_id, None)
                    .await
                {
                    println!("Container inspect result: {:?}", inspect);
                } else {
                    println!("Failed to inspect container");
                }
            }

            assert!(container_running, "Container should be running");

            Ok(())
        })
    })
    .await
}