Fix deployment API and Kubernetes service

- Fixed env_vars field name in frontend (envVars -> env_vars)
- Fixed API base URL to use localhost for development
- Updated documentation page structure and content
- Improved Kubernetes service logging and error handling
- Fixed deployment handler to pass correct env_vars format
- Added migration file for desired_replicas column
- Cleaned up verbose Kubernetes logging output
- Fixed update_deployment_env_vars to properly update existing deployments

Author: secus

apps/container-engine-frontend/src/api/api.ts

@@ -3,6 +3,9 @@ import axios from 'axios';
 // Base API configuration
 const API_BASE_URL = import.meta.env.VITE_API_BASE_URL || window.location.origin;
 // const API_BASE_URL = import.meta.env.VITE_API_BASE_URL || "http://localhost:3000";
+// const API_BASE_URL = "https://decenter.run";
+
+
 
 
 // Create axios instance with default config

apps/container-engine-frontend/src/pages/DocumentationPage.tsx

@@ -76,7 +76,7 @@ const NewDeploymentPage: React.FC = () => {
         app_name,
         image,
         port,
-        envVars: formattedEnvVars,
+        env_vars: formattedEnvVars,
         replicas,
       });
 

apps/container-engine-frontend/src/pages/NewDeploymentPage.tsx

@@ -50,15 +50,13 @@ pub async fn create_deployment(
     );
 
     // Convert optional fields to JSON
-    let env_vars_for_job = payload.env_vars.clone();
     let env_vars_value = payload.env_vars.unwrap_or_default();
     let env_vars_json = serde_json::to_value(&env_vars_value)?;
     let resources = Some(serde_json::to_value(payload.resources.unwrap_or_default())?);
     let health_check = payload
         .health_check
         .map(|hc| serde_json::to_value(hc))
         .transpose()?;
-
     sqlx::query!(
         r#"
             INSERT INTO deployments (
@@ -86,14 +84,16 @@ pub async fn create_deployment(
     )
     .execute(&state.db.pool)
     .await?;
+    
+
     // TODO: Implement Kubernetes deployment logic here
     let job = DeploymentJob::new(
         deployment_id,
         user.user_id,
         payload.app_name.clone(),
         payload.image.clone(),
         payload.port,
-        env_vars_for_job,
+        Some(env_vars_value), // Pass the actual HashMap instead of Option
         payload.replicas,
         resources,
         health_check,

migrations/20241015000001_add_desired_replicas.sql

@@ -429,23 +429,23 @@ impl DeploymentWorker {
                 )
                 .await
                 {
-                    // Call user webhooks for successful start
+                    error!("Failed to update deployment status to running: {}", e);
+                    // Call user webhooks for failed start (database update failed)
                     self.call_user_webhooks(
                         job.user_id,
-                        crate::user::webhook_models::WebhookEvent::DeploymentStarted,
+                        crate::user::webhook_models::WebhookEvent::DeploymentStartFailed,
                         &job,
                     )
                     .await;
-                    error!("Failed to update deployment status to running: {}", e);
                 } else {
-                    // Call user webhooks for failed start
+                    // Successfully started deployment
+                    // Call user webhooks for successful start
                     self.call_user_webhooks(
                         job.user_id,
-                        crate::user::webhook_models::WebhookEvent::DeploymentStartFailed,
+                        crate::user::webhook_models::WebhookEvent::DeploymentStarted,
                         &job,
                     )
                     .await;
-                    // Successfully started deployment
                 }
             }
             Err(e) => {
@@ -458,6 +458,13 @@ impl DeploymentWorker {
                     Some(&format!("Start failed: {}", e)),
                 )
                 .await;
+                // Call user webhooks for failed start (K8s scale failed)
+                self.call_user_webhooks(
+                    job.user_id,
+                    crate::user::webhook_models::WebhookEvent::DeploymentStartFailed,
+                    &job,
+                )
+                .await;
             }
         }
     }
@@ -478,11 +485,14 @@ impl DeploymentWorker {
         // Scale to 0 replicas
         match k8s_service.scale_deployment(&job.deployment_id, 0).await {
             Ok(_) => {
-                if let Err(e) = sqlx::query!(
-                    "UPDATE deployments SET status = 'stopped', replicas = 0, updated_at = NOW() WHERE id = $1",
-                    job.deployment_id
+                // Only update status, keep replicas unchanged for restart
+                if let Err(e) = Self::update_deployment_status(
+                    &self.db_pool,
+                    job.deployment_id,
+                    "stopped",
+                    None,
+                    None,
                 )
-                .execute(&self.db_pool)
                 .await
                 {
                      // Call user webhooks for failed stop