feat: initial network page

- note  the modal situation needs tidying up as it is currently messy
- failed deletion results in a slightly dodgy y/n modal where neither can do anything...

README.md

@@ -75,6 +75,7 @@ The following commands are supported:
 | `images`     | `image`     | Open the `Images` top level page     |
 | `containers` | `container` | Open the `Containers` top level page |
 | `volumes`    | `volume`    | Open the `Volumes` top level page    |
+| `networks`   | `network`   | Open the `Networks` top level page   |
 | `quit`       | `q`         | Close the application                |
 
 
@@ -126,6 +127,15 @@ The following actions are available on the Volumes page:
 | `Ctrl+d` | Delete the currently selected volume   |
 | `d`      | Describe the currently selected volume |
 
+#### Networks
+
+The following actions are available on the Volumes page:
+
+| Hotkey   | Action                                 |
+| -------- | -------------------------------------- |
+| `Ctrl+d` | Delete the currently selected volume   |
+| `d`      | Describe the currently selected volume |
+
 #### Logs
 
 The following actions are available on the Logs page:

src/callbacks/delete_network.rs

@@ -0,0 +1,23 @@
+use crate::{docker::network::DockerNetwork, traits::Callback};
+use async_trait::async_trait;
+use color_eyre::eyre::Result;
+
+#[derive(Debug)]
+pub struct DeleteNetwork {
+    docker: bollard::Docker,
+    network: DockerNetwork,
+}
+
+impl DeleteNetwork {
+    pub fn new(docker: bollard::Docker, network: DockerNetwork) -> Self {
+        Self { docker, network }
+    }
+}
+
+#[async_trait]
+impl Callback for DeleteNetwork {
+    async fn call(&self) -> Result<()> {
+        let _ = self.network.delete(&self.docker).await?;
+        Ok(())
+    }
+}

src/callbacks/empty_callable.rs

@@ -0,0 +1,25 @@
+use crate::traits::Callback;
+use async_trait::async_trait;
+use color_eyre::eyre::Result;
+
+#[derive(Debug)]
+pub struct EmptyCallable {}
+
+impl Default for EmptyCallable {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl EmptyCallable {
+    pub fn new() -> Self {
+        Self {}
+    }
+}
+
+#[async_trait]
+impl Callback for EmptyCallable {
+    async fn call(&self) -> Result<()> {
+        Ok(())
+    }
+}

src/callbacks/mod.rs

@@ -1,4 +1,6 @@
 pub mod delete_container;
 pub mod delete_image;
+pub mod delete_network;
 pub mod delete_volume;
+pub mod empty_callable;
 pub use delete_container::DeleteContainer;

src/components/command_input.rs

@@ -22,6 +22,8 @@ const CONTAINER: &str = "container";
 const CONTAINERS: &str = "containers";
 const VOLUME: &str = "volume";
 const VOLUMES: &str = "volumes";
+const NETWORK: &str = "network";
+const NETWORKS: &str = "networks";
 
 #[derive(Debug)]
 pub struct CommandInput {
@@ -33,7 +35,7 @@ pub struct CommandInput {
 impl CommandInput {
     pub fn new(tx: Sender<Message<Key, Transition>>, prompt: String) -> Self {
         let ac: Autocomplete = Autocomplete::from(vec![
-            QUIT, Q, IMAGE, IMAGES, CONTAINER, CONTAINERS, VOLUME, VOLUMES,
+            QUIT, Q, IMAGE, IMAGES, CONTAINER, CONTAINERS, VOLUME, VOLUMES, NETWORK, NETWORKS,
         ]);
         Self {
             tx,
@@ -93,6 +95,7 @@ impl CommandInput {
             IMAGE | IMAGES => Some(Transition::ToImagePage(AppContext::default())),
             CONTAINER | CONTAINERS => Some(Transition::ToContainerPage(AppContext::default())),
             VOLUME | VOLUMES => Some(Transition::ToVolumePage(AppContext::default())),
+            NETWORK | NETWORKS => Some(Transition::ToNetworkPage(AppContext::default())),
             _ => None,
         };
 

src/context.rs

@@ -1,6 +1,7 @@
 use crate::{
     docker::{
-        container::DockerContainer, image::DockerImage, traits::Describe, volume::DockerVolume,
+        container::DockerContainer, image::DockerImage, network::DockerNetwork, traits::Describe,
+        volume::DockerVolume,
     },
     events::Transition,
 };
@@ -17,6 +18,7 @@ pub struct AppContext {
     pub docker_container: Option<DockerContainer>,
     pub docker_image: Option<DockerImage>,
     pub docker_volume: Option<DockerVolume>,
+    pub docker_network: Option<DockerNetwork>,
     pub describable: Option<Box<dyn Describe>>,
 }
 

src/docker/mod.rs

@@ -1,6 +1,7 @@
 pub mod container;
 pub mod image;
 pub mod logs;
+pub mod network;
 pub mod traits;
 pub mod util;
 pub mod volume;

src/docker/network.rs

@@ -0,0 +1,68 @@
+use bollard::{
+    secret::{Network, NetworkContainer},
+};
+use color_eyre::eyre::{bail, Result};
+use serde::Serialize;
+use std::collections::HashMap;
+
+use super::traits::Describe;
+
+#[derive(Debug, Clone, PartialEq, Serialize)]
+pub struct DockerNetwork {
+    pub id: String,
+    pub name: String,
+    pub driver: String,
+    pub created_at: String,
+    pub scope: String,
+    pub internal: Option<bool>,
+    pub attachable: Option<bool>,
+    pub containers: Option<HashMap<String, NetworkContainer>>,
+}
+
+impl DockerNetwork {
+    pub fn from(v: Network) -> Self {
+        Self {
+            id: v.id.unwrap_or_default(),
+            name: v.name.unwrap_or_default(),
+            driver: v.driver.unwrap_or_default(),
+            created_at: v.created.unwrap_or_default(),
+            scope: v.scope.unwrap_or_default(),
+            internal: v.internal,
+            attachable: v.attachable,
+            containers: v.containers,
+        }
+    }
+
+    pub async fn list(docker: &bollard::Docker) -> Result<Vec<Self>> {
+        let networks = docker.list_networks::<String>(None).await?;
+        let mut network: Vec<Self> = networks.into_iter().map(Self::from).collect();
+
+        network.sort_by_key(|v| v.name.clone());
+
+        Ok(network)
+    }
+
+    pub async fn delete(&self, docker: &bollard::Docker) -> Result<()> {
+        docker.remove_network(&self.get_name()).await?;
+        Ok(())
+    }
+}
+
+impl Describe for DockerNetwork {
+    fn get_id(&self) -> String {
+        self.get_name()
+    }
+    fn get_name(&self) -> String {
+        self.name.clone()
+    }
+
+    fn describe(&self) -> Result<Vec<String>> {
+        let summary = match serde_yml::to_string(&self) {
+            Ok(s) => s,
+            Err(_) => {
+                bail!("failed to parse container summary")
+            }
+        };
+        Ok(summary.lines().map(String::from).collect())
+    }
+}

src/events/transition.rs

@@ -19,6 +19,7 @@ pub enum Transition {
     ToDescribeContainerPage(AppContext),
     ToAttach(AppContext),
     ToVolumePage(AppContext),
+    ToNetworkPage(AppContext),
 }
 
 pub async fn send_transition(

src/pages/mod.rs

@@ -3,4 +3,5 @@ pub mod containers;
 pub mod describe;
 pub mod images;
 pub mod logs;
-pub mod volume;
+pub mod networks;
+pub mod volumes;