Function docker_events

packages/app/src-tauri/src/docker.rs:105–149

(app_handle: tauri::AppHandle)

#[command]
pub async fn docker_events(app_handle: tauri::AppHandle) -> Result<(), String> {
    let docker = get_docker().await?;
    let mut last_hash = String::new();

    tokio::spawn(async move {
        let mut interval = tokio::time::interval(Duration::from_millis(REFRESH_INTERVAL));

        loop {
            interval.tick().await;
            // Handle containers
            match get_containers(&docker).await {
                Ok(containers) => {
                    // Only emit if data changed
                    let new_hash = format!("{:?}", containers);
                    if new_hash != last_hash {
                        last_hash = new_hash;
                        let payload = (String::from("docker:containers"), &containers);
                        if let Err(e) = app_handle.emit("docker:containers", payload) {
                            eprintln!("Failed to emit containers event: {}", e);
                        }
                        // Extract and emit stacks with event name
                        let stacks: Vec<String> =
                            extract_projects(&containers).into_iter().collect();
                        let payload = (String::from("docker:stacks"), stacks);
                        if let Err(e) = app_handle.emit("docker:stacks", payload) {
                            eprintln!("Failed to emit stacks event: {}", e);
                        }

                        // Emit networks
                        let payload = (
                            String::from("docker:networks"),
                            list_networks().await.unwrap(),
                        );
                        if let Err(e) = app_handle.emit("docker:networks", payload) {
                            eprintln!("Failed to emit networks event: {}", e);
                        }
                    }
                }
                Err(e) => eprintln!("Failed to connect to Docker: {}", e),
            }
        }
    });

    Ok(())
}