Validating port

Author: Joker666

src/main.rs

@@ -189,6 +189,7 @@ fn get_ruku_config(log: &Logger, repo: &str, server_config: &ServerConfig) -> Ru
         std::process::exit(1);
     });
 
+    // Validate the config
     match config.validate() {
         Ok(_) => (),
         Err(e) => {

src/model.rs

@@ -1,5 +1,9 @@
+use bollard::container::ListContainersOptions;
+use bollard::Docker;
+use futures::executor::block_on;
 use port_selector::is_free;
 use serde::Deserialize;
+use std::collections::HashMap;
 use validator::{Validate, ValidationError};
 
 #[derive(Debug, Validate, Deserialize)]
@@ -56,8 +60,28 @@ fn validate_providers(providers: &[String]) -> Result<(), ValidationError> {
 }
 
 fn validate_port(port: u16) -> Result<(), ValidationError> {
+    // First check if the port is being used by our own container
+    if let Ok(docker) = Docker::connect_with_local_defaults() {
+        let mut filters = HashMap::new();
+        filters.insert("publish".to_string(), vec![port.to_string()]);
+
+        let options = Some(ListContainersOptions {
+            all: true,
+            filters,
+            ..Default::default()
+        });
+
+        if let Ok(containers) = block_on(docker.list_containers(options)) {
+            // If we found containers using this port, it's okay - we'll handle it in the Container::run
+            if !containers.is_empty() {
+                return Ok(());
+            }
+        }
+    }
+
+    // If we get here, check if the port is free for other applications
     if !is_free(port) {
-        return Err(ValidationError::new("port is already in use"));
+        return Err(ValidationError::new("port is already in use by another application"));
     }
     Ok(())
 }