FIX: webtransport

Author: BryanFRD

certificats.bat

@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCyssrTpejMltyB
+26TFLtF/yftX5NF2rv4BIVHhdfe0LuIjqw6qCI4U0QAkQizrvYOd4d6HUZJX+lC2
+CRcA0GDzuEiWSB/yUolUNpFH45HHUhOU4sjN/e+wHQNXv4WompYtLnzSV00S4d1J
+6e1NWEQOIv8gD6Mj79/qLQ7jJVuics2ZCzYxWtNf3RZYw+VVmGgsjEZD5zJ3oIzY
+uv8PjifiNnPxh8pIKS9N8HffL00NXIVUIebUUKVXm2XnzyC7IPqUp0HuFRRhe4C9
+BLlOBgO3u+85/QBj4Zp5+wCctX59kgCvnMNFyIxLOaAZqUoCpB5UG1WrHxvwVK3t
+0Dn/4bODAgMBAAECggEABt+7z6JtLxmKh/BECVXAt1K0uW/S4ubeXHrEpJCeI68+
+AbM90CqeFIzpnXtyMOtMWdFrdvcbUwkM+8Ojv+NEJ3vqRuWlXPPx1mx28DX/0JQG
+rs5+fPYMt1CWZVS3toGjzz8fjBPRoi1QDtzRxQzlKUoNWFVhqCs9CMwM643vVXNW
+kGAkRuITSuWcuMvZUyALvbf4pAI5yKLKWfYiRMIwNzwhC0MMMVKc/C+PDcmzwHeO
+9CTG6A8dfQ5F4q/yzpRHQzV/+Bibz07BGhDlecEo8VhpHZdM43QD2fvs2GtsHAv5
+oKNrHq/77Y9Xf43347XJJIsrDxeqER9DGThveWiRqQKBgQDCzQ0wx/qzcWjJFHyu
+3S8C0vXn5lmhV5Os1XGDUhR+xftg5gzuBzPjWW0HJ1lg5Vb3OAt5Yx8DDHrg2U+m
+I+1ZGJlMYcDp0EkphHDTd2lxv1zJxkIZ5QngRauQNi1UcTKeNVJNzPFx5DdFstTp
+kLECZfgKEDpcrnwcRBFxfGvPrQKBgQDq1q9BhmHVTBce0XjbYqScg441V61FSJxc
+vN2d+O91LUFxi595ATTVeF4l8b4BDs55UqVMjr3qk9vhQ+21by75x+8sHrNtSsRs
+3md3ff+B+dvmmCSp5Z44h2X/8/WuAwWMdLN7p9iQWEHqZ+Y0NAn43PHh3j9Pk8LQ
+xrvEkaw17wKBgHDRFnmQ57Vy0c/aqJcRC//js3y5YGFbefAXsWTvbWU6PeqRcR2N
+WFSr3sPM2yuNxr7oW2TSrgwy9xsvX7yFhBkccPPWjUYcVbLQvBMMTioNPKyywGeE
+ySJ01vZvGfOUl08e7GqYbaCbHhOkjUAzhwAvk+YoHdS9TK2GEmAaQcoFAoGAJcLD
+h3u+O3fyt8fi8RPZeDlHIpioid11Fwxfbkla57KRNVrIF8Lz5edm7B8E+FKTLLr3
+TWoea5u+3Wf4zxXDrfJSKPv+yfIdx4uzg2lFLncovtlz+8WqPVi4NAHcXVCrEbyq
+J5YDoqIuZyyxvW8os1WDp1f/QiJ2Tu/FvYPW9w0CgYAfEao3CQKixSdv+XD3WgEr
+09OHHolezrMOpxUlVkrboR2/BGK7MrUVTxQ1w3hgcjkkXAlKs6IiWmSWeUBJjE7O
+XnqQV97Ph6Y+DEiP4tZ5kJVISX9MVi2MZv7z/VkvvdXBjzslJ6Pz7rpBaz23UPyY
+pSFaxYQQrPVXga2NXdrc/A==
+-----END PRIVATE KEY-----

localhost-key.pem

@@ -0,0 +1,24 @@
+-----BEGIN CERTIFICATE-----
+MIIEDDCCAnSgAwIBAgIQUSdvDZnhEZgnkmBdLaRuuTANBgkqhkiG9w0BAQsFADBf
+MR4wHAYDVQQKExVta2NlcnQgZGV2ZWxvcG1lbnQgQ0ExGjAYBgNVBAsMEUJSWUFO
+XEJyeWFuQEJyeWFuMSEwHwYDVQQDDBhta2NlcnQgQlJZQU5cQnJ5YW5AQnJ5YW4w
+HhcNMjUwMjIwMTk1NjU1WhcNMjcwNTIwMTg1NjU1WjBFMScwJQYDVQQKEx5ta2Nl
+cnQgZGV2ZWxvcG1lbnQgY2VydGlmaWNhdGUxGjAYBgNVBAsMEUJSWUFOXEJyeWFu
+QEJyeWFuMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAsrLK06XozJbc
+gdukxS7Rf8n7V+TRdq7+ASFR4XX3tC7iI6sOqgiOFNEAJEIs672DneHeh1GSV/pQ
+tgkXANBg87hIlkgf8lKJVDaRR+ORx1ITlOLIzf3vsB0DV7+FqJqWLS580ldNEuHd
+SentTVhEDiL/IA+jI+/f6i0O4yVbonLNmQs2MVrTX90WWMPlVZhoLIxGQ+cyd6CM
+2Lr/D44n4jZz8YfKSCkvTfB33y9NDVyFVCHm1FClV5tl588guyD6lKdB7hUUYXuA
+vQS5TgYDt7vvOf0AY+GaefsAnLV+fZIAr5zDRciMSzmgGalKAqQeVBtVqx8b8FSt
+7dA5/+GzgwIDAQABo14wXDAOBgNVHQ8BAf8EBAMCBaAwEwYDVR0lBAwwCgYIKwYB
+BQUHAwEwHwYDVR0jBBgwFoAUR1Gg4yrNJkNHXWmSx5vocseQ+pgwFAYDVR0RBA0w
+C4IJbG9jYWxob3N0MA0GCSqGSIb3DQEBCwUAA4IBgQBn2zbLwtWhau+X01+jCGdo
+S/QZ7C4D3MdNnFVXvEUOJw7pW7XXMYKf8/FZyVByV27/b8bNYkipC2ySiWsY85Gy
+4MmeCdCOBJnhEF1I4LfGUdNRJInkSITj/14SGdMKL+R5Q1AemnNBtu/DBQ7hn4ha
+K9G9m7qqoKrG9/EkTDA/NKcW60hPk3VXazo4UW1r6xx7+NWtafCS12srB1eSNno9
+bn39HnVpaID5lSgXrmlIHShB3Jyids2OuDKUggl6y2mDcjdnqp5tm2CwHYsATu43
+pkpbpt9C0892jMToV5CUNY5PdICHS0haEyNNThfy4edqyZSuKf1HnfNHd9QK1zzi
+pYfLKCHR6nVVpC5pcK5scPl4YBkwtsINisEYyoT2mGwBZmX/WAn3sbJ4lPWj78oR
+yoThY5BjguXryuXkRttKm9lKeR6M5DAHCuuPJzFLyagwBuFdsz+9TM+9Y8n4JVFK
+lJ+XoqmriQ+TxMgoRH4cAqsBa9cpAgwwYLH8gnWO8Ss=
+-----END CERTIFICATE-----

localhost.pem

@@ -1,46 +1,17 @@
-mod routes;
-mod controllers;
 mod errors;
 mod webtransport;
 mod services;
 
-use axum::http::{HeaderValue, Method};
-use routes::setup_routes;
 use rustls::crypto::{ring::default_provider, CryptoProvider};
-use tower_http::cors::{AllowOrigin, CorsLayer};
 
 #[tokio::main]
 async fn main() {
     env_logger::builder().filter_level(log::LevelFilter::Info).init();
     CryptoProvider::install_default(default_provider())
         .expect("Failed to install default crypto provider");
 
-    let cors = CorsLayer::new()
-        .allow_methods(vec![Method::GET, Method::POST, Method::PUT, Method::DELETE])
-        .allow_origin(AllowOrigin::list([
-            HeaderValue::from_str("https://admin.bryan-ferrando.fr").unwrap(),
-            HeaderValue::from_str("http://localhost:5173").unwrap()
-        ]));
-    
-    let app = setup_routes()
-        .layer(cors);
-    
-    tokio::spawn(async move {
-        match webtransport::start_webtransport().await {
-            Ok(_) => log::info!("WebTransport server stopped"),
-            Err(e) => log::error!("WebTransport server failed: {:?}", e)
-        };
-    });
-    
-    tokio::spawn(async move {
-        match webtransport::start_client().await {
-            Ok(_) => log::info!("WebTransport client stopped"),
-            Err(e) => log::error!("WebTransport client failed: {:?}", e)
-        };
-    });
-    
-    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
-    log::info!("Listening on {}", listener.local_addr().unwrap());
-    
-    axum::serve(listener, app).await.unwrap();
+    match webtransport::start_webtransport().await {
+        Ok(_) => log::info!("WebTransport server stopped"),
+        Err(e) => log::error!("WebTransport server failed: {:?}", e)
+    };
 }

src/controllers/docker.rs

@@ -1,9 +1,44 @@
-use bollard::{errors::Error, secret::{ContainerInspectResponse, ContainerSummary}, Docker};
+use bollard::{errors::Error, secret::{ContainerInspectResponse, ContainerSummary}, system::EventsOptions, Docker};
+use futures::StreamExt;
+use serde_json::json;
+use tokio::sync::broadcast;
 
 pub fn get_docker_client() -> Result<Docker, Error> {
     Docker::connect_with_socket_defaults()
 }
 
+pub async fn listen_docker_events(tx: broadcast::Sender<String>) {
+    let docker = match get_docker_client() {
+        Ok(docker) => docker,
+        Err(error) => {
+            log::error!("Failed to connect to Docker: {:?}", error);
+            return;
+        }
+    };
+    
+    let options = Some(EventsOptions::<String>::default());
+    let mut events = docker.events(options);
+    
+    while let Some(event) = events.next().await {
+        match event {
+            Ok(event) => {
+                let event_str = json!(event).to_string();
+                log::info!("Docker event: [{:?}:{:?}]", event.action, event.typ);
+                
+                match tx.send(event_str){
+                    Ok(_) => {},
+                    Err(error) => {
+                        log::error!("Failed to send Docker event: {:?}", error);
+                    }
+                };
+            }
+            Err(error) => {
+                log::error!("Failed to receive Docker event: {:?}", error);
+            }
+        }
+    }
+}
+
 pub async fn ping() -> i8 {
     let docker = get_docker_client();