feat: Implement container metrics and management features

- Added new API endpoints and client methods for retrieving detailed container metrics, including CPU and memory usage.
- Introduced UI components for displaying container metrics, logs, and configurations, enhancing the user experience in managing containers.
- Updated the container management workflow to support starting, stopping, and restarting containers through a new action dialog.
- Enhanced the environment dashboard to integrate container management features, allowing users to view and interact with their containers seamlessly.
- Improved logging and error handling for container actions, ensuring better visibility and reliability during operations.

Author: dviejokfs

.github/workflows/release.yml

@@ -34,7 +34,9 @@ jobs:
           targets: x86_64-unknown-linux-gnu
 
       - name: Install wasm-pack
-        run: curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+        run: |
+          curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+          echo "$HOME/.cargo/bin" >> $GITHUB_PATH
 
       - name: Cache dependencies
         uses: Swatinem/rust-cache@v2
@@ -109,7 +111,9 @@ jobs:
           targets: x86_64-apple-darwin
 
       - name: Install wasm-pack
-        run: curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+        run: |
+          curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+          echo "$HOME/.cargo/bin" >> $GITHUB_PATH
 
       - name: Cache dependencies
         uses: Swatinem/rust-cache@v2
@@ -184,7 +188,9 @@ jobs:
           targets: aarch64-apple-darwin
 
       - name: Install wasm-pack
-        run: curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+        run: |
+          curl https://rustwasm.org/wasm-pack/installer/init.sh -sSf | sh
+          echo "$HOME/.cargo/bin" >> $GITHUB_PATH
 
       - name: Cache dependencies
         uses: Swatinem/rust-cache@v2

crates/temps-analytics-session-replay/src/handlers/handler.rs

@@ -15,7 +15,7 @@ use std::sync::Arc;
 use temps_core::error_builder::ErrorBuilder;
 use temps_core::problemdetails::Problem;
 use temps_core::RequestMetadata;
-use tracing::info;
+use tracing::debug;
 use utoipa::{OpenApi, ToSchema};
 
 /// OpenAPI documentation for session replay endpoints
@@ -379,7 +379,7 @@ pub async fn get_project_session_replays(
     State(state): State<Arc<AppState>>,
     Query(query): Query<GetProjectSessionReplaysQuery>,
 ) -> Result<Json<GetProjectSessionReplaysResponse>, Problem> {
-    info!("Getting session replays for project: {}", query.project_id);
+    debug!("Getting session replays for project: {}", query.project_id);
 
     let page = query.page.unwrap_or(1);
     let per_page = query.per_page.unwrap_or(50).min(100); // Cap at 100 items per page
@@ -424,7 +424,7 @@ pub async fn get_visitor_sessions(
     Path(visitor_id): Path<i32>,
     Query(query): Query<GetVisitorSessionsQuery>,
 ) -> Result<Json<GetVisitorSessionsResponse>, Problem> {
-    info!("Getting session replays for visitor: {}", visitor_id);
+    debug!("Getting session replays for visitor: {}", visitor_id);
 
     let page = query.page.unwrap_or(1);
     let per_page = query.per_page.unwrap_or(50).min(100); // Cap at 100 items per page
@@ -469,7 +469,7 @@ pub async fn get_session_replay(
     State(state): State<Arc<AppState>>,
     Path((visitor_id, session_id)): Path<(i32, i32)>,
 ) -> Result<Json<GetSessionReplayResponse>, Problem> {
-    info!(
+    debug!(
         "Getting session replay: {} for visitor: {}",
         session_id, visitor_id
     );
@@ -505,7 +505,7 @@ pub async fn get_session_replay_events(
     State(state): State<Arc<AppState>>,
     Path((visitor_id, session_id)): Path<(i32, i32)>,
 ) -> Result<Json<SessionReplayWithEventsDto>, Problem> {
-    info!(
+    debug!(
         "Getting session replay events: {} for visitor: {}",
         session_id, visitor_id
     );
@@ -541,7 +541,7 @@ pub async fn update_session_duration(
     Path((visitor_id, session_id)): Path<(i32, String)>,
     Json(request): Json<UpdateSessionDurationRequest>,
 ) -> Result<Json<UpdateSessionDurationResponse>, Problem> {
-    info!(
+    debug!(
         "Updating duration for session: {} for visitor: {}",
         session_id, visitor_id
     );
@@ -577,7 +577,7 @@ pub async fn delete_session_replay(
     State(state): State<Arc<AppState>>,
     Path((visitor_id, session_id)): Path<(i32, String)>,
 ) -> Result<StatusCode, Problem> {
-    info!(
+    debug!(
         "Deleting session replay: {} for visitor: {}",
         session_id, visitor_id
     );
@@ -614,7 +614,7 @@ pub async fn add_events(
     Path((visitor_id, session_id)): Path<(i32, String)>,
     Json(request): Json<AddEventsRequest>,
 ) -> Result<Json<AddEventsResponse>, Problem> {
-    info!(
+    debug!(
         "Adding events to session: {} for visitor: {}",
         session_id, visitor_id
     );
@@ -649,7 +649,7 @@ pub async fn init_session_replay(
     Extension(metadata): Extension<RequestMetadata>,
     Json(request): Json<SessionReplayInitRequest>,
 ) -> Result<(StatusCode, Json<SessionReplayInitResponse>), Problem> {
-    info!(
+    debug!(
         "Initializing session replay for session: {}",
         request.session_id
     );
@@ -668,7 +668,7 @@ pub async fn init_session_replay(
                 let environment_id = route_info.environment.as_ref().map(|e| e.id);
                 let deployment_id = route_info.deployment.as_ref().map(|d| d.id);
 
-                info!(
+                debug!(
                     "Resolved host {} to project={}, env={:?}, deploy={:?}",
                     metadata.host, project_id, environment_id, deployment_id
                 );
@@ -715,7 +715,7 @@ pub async fn init_session_replay(
         .await
     {
         Ok(session_id) => {
-            info!("Successfully initialized session replay: {}", session_id);
+            debug!("Successfully initialized session replay: {}", session_id);
             Ok((
                 StatusCode::CREATED,
                 Json(SessionReplayInitResponse {
@@ -745,7 +745,7 @@ pub async fn add_session_replay_events(
     State(state): State<Arc<AppState>>,
     Json(request): Json<SessionReplayEventsRequest>,
 ) -> Result<Json<AddEventsResponse>, Problem> {
-    info!(
+    debug!(
         "Adding events to session replay for session: {}",
         request.session_id
     );
@@ -756,7 +756,7 @@ pub async fn add_session_replay_events(
         .await
     {
         Ok(event_count) => {
-            info!(
+            debug!(
                 "Successfully added {} events to session: {}",
                 event_count, request.session_id
             );

crates/temps-deployer/src/docker.rs

@@ -983,6 +983,106 @@ impl ContainerDeployer for DockerRuntime {
         })
     }
 
+    async fn get_container_stats(
+        &self,
+        container_id: &str,
+    ) -> Result<crate::ContainerStats, DeployerError> {
+        use bollard::query_parameters::StatsOptions;
+
+        // Get container info first to get the name
+        let container_info = self.get_container_info(container_id).await?;
+
+        // Get stats from Docker - stream but take only first stat and close
+        let mut stats_stream = self.docker.stats(
+            container_id,
+            Some(StatsOptions {
+                stream: false,  // Only get one stat, don't stream
+                one_shot: true, // Return immediately after first stat
+            }),
+        );
+
+        // Take the first stat
+        let stats_data = stats_stream
+            .try_next()
+            .await
+            .map_err(|e| DeployerError::Other(format!("Failed to get container stats: {}", e)))?
+            .ok_or_else(|| DeployerError::Other("No stats available".to_string()))?;
+
+        // Extract CPU percentage
+        let cpu_percent = if let (Some(cpu), Some(system)) = (
+            stats_data
+                .cpu_stats
+                .as_ref()
+                .and_then(|cs| cs.cpu_usage.as_ref()),
+            stats_data
+                .cpu_stats
+                .as_ref()
+                .and_then(|cs| cs.system_cpu_usage),
+        ) {
+            let cpu_total = cpu.total_usage.unwrap_or(0);
+            if system > 0 && cpu_total > 0 {
+                let cpu_delta = cpu_total as f64;
+                let system_delta = system as f64;
+                let num_cpus = stats_data
+                    .cpu_stats
+                    .as_ref()
+                    .and_then(|cs| cs.online_cpus)
+                    .unwrap_or(1) as f64;
+                ((cpu_delta / system_delta) * num_cpus * 100.0)
+                    .min(100.0)
+                    .max(0.0)
+            } else {
+                0.0
+            }
+        } else {
+            0.0
+        };
+
+        // Extract memory stats
+        let memory_stats = stats_data.memory_stats.as_ref();
+        let memory_bytes = memory_stats.and_then(|ms| ms.usage).unwrap_or(0) as u64;
+        let memory_limit_bytes = memory_stats.and_then(|ms| ms.limit).map(|l| l as u64);
+
+        let memory_percent = if let Some(limit) = memory_limit_bytes {
+            if limit > 0 {
+                Some(
+                    ((memory_bytes as f64 / limit as f64) * 100.0)
+                        .min(100.0)
+                        .max(0.0),
+                )
+            } else {
+                None
+            }
+        } else {
+            None
+        };
+
+        // Extract network stats
+        let default_networks = Default::default();
+        let networks_stats = stats_data.networks.as_ref().unwrap_or(&default_networks);
+        let (network_rx_bytes, network_tx_bytes) =
+            if let Some(net_stat) = networks_stats.values().next() {
+                (
+                    net_stat.rx_bytes.unwrap_or(0) as u64,
+                    net_stat.tx_bytes.unwrap_or(0) as u64,
+                )
+            } else {
+                (0, 0)
+            };
+
+        Ok(crate::ContainerStats {
+            container_id: container_info.container_id,
+            container_name: container_info.container_name,
+            cpu_percent,
+            memory_bytes,
+            memory_limit_bytes,
+            memory_percent,
+            network_rx_bytes,
+            network_tx_bytes,
+            timestamp: chrono::Utc::now(),
+        })
+    }
+
     async fn list_containers(&self) -> Result<Vec<ContainerInfo>, DeployerError> {
         let containers = self
             .docker

crates/temps-deployer/src/lib.rs

@@ -163,6 +163,27 @@ pub struct ContainerInfo {
     pub environment_vars: HashMap<String, String>,
 }
 
+/// Container performance statistics (CPU, memory, network)
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct ContainerStats {
+    pub container_id: String,
+    pub container_name: String,
+    /// CPU usage percentage (0-100)
+    pub cpu_percent: f64,
+    /// Memory usage in bytes
+    pub memory_bytes: u64,
+    /// Memory limit in bytes (if set)
+    pub memory_limit_bytes: Option<u64>,
+    /// Memory usage percentage (0-100) if limit is set
+    pub memory_percent: Option<f64>,
+    /// Network bytes received
+    pub network_rx_bytes: u64,
+    /// Network bytes transmitted
+    pub network_tx_bytes: u64,
+    /// Timestamp of metrics collection
+    pub timestamp: UtcDateTime,
+}
+
 /// Configuration for stopping containers
 #[derive(Debug, Clone)]
 pub struct ContainerStopSpec {
@@ -330,6 +351,12 @@ pub trait ContainerDeployer: Send + Sync {
     /// Get container information
     async fn get_container_info(&self, container_id: &str) -> Result<ContainerInfo, DeployerError>;
 
+    /// Get container performance metrics (CPU, memory, network)
+    async fn get_container_stats(
+        &self,
+        container_id: &str,
+    ) -> Result<ContainerStats, DeployerError>;
+
     /// List running containers
     async fn list_containers(&self) -> Result<Vec<ContainerInfo>, DeployerError>;