greentic-setup 0.4.28

//! Admin API request/response types for bundle lifecycle management.
//!
//! These types define the contract between the admin API and consumers.
//! The actual HTTP routing is implemented in the consuming crate
//! (e.g. greentic-operator), which maps these to Axum handlers.

use std::path::PathBuf;

use serde::{Deserialize, Serialize};
use serde_json::Value;

use crate::plan::{PackRemoveSelection, TenantSelection};

// ── Bundle deployment ───────────────────────────────────────────────────────

/// Request to deploy a new bundle or upgrade an existing one.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleDeployRequest {
    /// Target bundle path on the server.
    pub bundle_path: PathBuf,
    /// Optional display name for the bundle.
    #[serde(default)]
    pub bundle_name: Option<String>,
    /// Pack references to resolve and install.
    #[serde(default)]
    pub pack_refs: Vec<String>,
    /// Tenant selections with allow rules.
    #[serde(default)]
    pub tenants: Vec<TenantSelection>,
    /// Pre-collected QA answers (provider_id → answers map).
    #[serde(default)]
    pub answers: Value,
    /// If true, only plan without executing.
    #[serde(default)]
    pub dry_run: bool,
}

/// Request to remove components from a bundle.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleRemoveRequest {
    /// Target bundle path.
    pub bundle_path: PathBuf,
    /// Packs to remove.
    #[serde(default)]
    pub packs: Vec<PackRemoveSelection>,
    /// Provider IDs to remove.
    #[serde(default)]
    pub providers: Vec<String>,
    /// Tenants/teams to remove.
    #[serde(default)]
    pub tenants: Vec<TenantSelection>,
    /// If true, only plan without executing.
    #[serde(default)]
    pub dry_run: bool,
}

// ── QA setup ────────────────────────────────────────────────────────────────

/// Request to get the QA FormSpec for a pack.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct QaSpecRequest {
    /// Bundle path.
    pub bundle_path: PathBuf,
    /// Provider ID to get spec for.
    pub provider_id: String,
    /// Locale for i18n resolution.
    #[serde(default = "default_locale")]
    pub locale: String,
}

/// Request to validate QA answers against a FormSpec.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct QaValidateRequest {
    /// Bundle path.
    pub bundle_path: PathBuf,
    /// Provider ID.
    pub provider_id: String,
    /// Answers to validate.
    pub answers: Value,
}

/// Request to submit and persist QA answers.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct QaSubmitRequest {
    /// Bundle path.
    pub bundle_path: PathBuf,
    /// Provider ID.
    pub provider_id: String,
    /// Tenant ID.
    pub tenant: String,
    /// Team ID.
    #[serde(default)]
    pub team: Option<String>,
    /// Answers to persist.
    pub answers: Value,
    /// Whether to trigger a hot reload after persisting.
    #[serde(default)]
    pub reload: bool,
}

// ── Responses ───────────────────────────────────────────────────────────────

/// Generic admin API response wrapper.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AdminResponse<T: Serialize> {
    pub success: bool,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub data: Option<T>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub error: Option<String>,
}

impl<T: Serialize> AdminResponse<T> {
    pub fn ok(data: T) -> Self {
        Self {
            success: true,
            data: Some(data),
            error: None,
        }
    }

    pub fn err(message: impl Into<String>) -> Self {
        Self {
            success: false,
            data: None,
            error: Some(message.into()),
        }
    }
}

/// Bundle status information.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleStatusResponse {
    pub bundle_path: PathBuf,
    pub status: BundleStatus,
    pub pack_count: usize,
    pub tenant_count: usize,
    pub provider_count: usize,
}

/// Bundle lifecycle status.
#[derive(Clone, Copy, Debug, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum BundleStatus {
    Active,
    Inactive,
    Deploying,
    Stopping,
    Removing,
    Error,
}

/// Response listing all managed bundles.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleListResponse {
    pub bundles: Vec<BundleStatusResponse>,
}

/// Request to start a bundle runtime.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleStartRequest {
    pub bundle_path: PathBuf,
}

/// Request to stop a bundle runtime.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleStopRequest {
    pub bundle_path: PathBuf,
}

/// Request to update a bundle (add/upgrade packs, tenants).
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct BundleUpdateRequest {
    /// Target bundle path.
    pub bundle_path: PathBuf,
    /// Pack references to add or upgrade.
    #[serde(default)]
    pub pack_refs: Vec<String>,
    /// Tenant selections.
    #[serde(default)]
    pub tenants: Vec<TenantSelection>,
    /// Pre-collected QA answers.
    #[serde(default)]
    pub answers: Value,
    /// If true, only plan without executing.
    #[serde(default)]
    pub dry_run: bool,
}

/// A single admin client entry.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AdminClientEntry {
    pub client_cn: String,
}

/// Response listing admin clients.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AdminClientListResponse {
    pub admins: Vec<AdminClientEntry>,
}

/// Request to add an admin client.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AdminClientAddRequest {
    pub bundle_path: PathBuf,
    pub client_cn: String,
}

/// Request to remove an admin client.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AdminClientRemoveRequest {
    pub bundle_path: PathBuf,
    pub client_cn: String,
}

/// Unified admin request type for routing.
#[derive(Clone, Debug, Serialize, Deserialize)]
#[serde(tag = "action", rename_all = "snake_case")]
pub enum AdminRequest {
    Deploy(BundleDeployRequest),
    Remove(BundleRemoveRequest),
    QaSpec(QaSpecRequest),
    QaValidate(QaValidateRequest),
    QaSubmit(QaSubmitRequest),
    Status { bundle_path: PathBuf },
    List,
}

fn default_locale() -> String {
    "en".to_string()
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn admin_response_ok() {
        let resp = AdminResponse::ok("hello");
        assert!(resp.success);
        assert_eq!(resp.data.unwrap(), "hello");
        assert!(resp.error.is_none());
    }

    #[test]
    fn admin_response_err() {
        let resp = AdminResponse::<()>::err("bad request");
        assert!(!resp.success);
        assert!(resp.data.is_none());
        assert_eq!(resp.error.unwrap(), "bad request");
    }

    #[test]
    fn deploy_request_serde_roundtrip() {
        let req = BundleDeployRequest {
            bundle_path: PathBuf::from("/tmp/bundle"),
            bundle_name: Some("test".into()),
            pack_refs: vec!["oci://test:latest".into()],
            tenants: vec![],
            answers: Value::Object(Default::default()),
            dry_run: false,
        };
        let json = serde_json::to_string(&req).unwrap();
        let parsed: BundleDeployRequest = serde_json::from_str(&json).unwrap();
        assert_eq!(parsed.bundle_path, PathBuf::from("/tmp/bundle"));
    }

    #[test]
    fn admin_request_tagged_enum() {
        let json = r#"{"action":"list"}"#;
        let req: AdminRequest = serde_json::from_str(json).unwrap();
        assert!(matches!(req, AdminRequest::List));
    }

    #[test]
    fn bundle_status_serde() {
        let status = BundleStatus::Active;
        let json = serde_json::to_string(&status).unwrap();
        assert_eq!(json, "\"active\"");
    }
}