generic.rs

use async_trait::async_trait;
use stackable_operator::{client::Client, v2::types::kubernetes::NamespaceName};

use super::{FromTrinoCatalogError, ToCatalogConfig, config::CatalogConfig};
use crate::{
    controller::dereference::TrinoCatalogName,
    crd::catalog::generic::{GenericConnector, Property},
};

#[async_trait]
impl ToCatalogConfig for GenericConnector {
    async fn to_catalog_config(
        &self,
        catalog_name: &TrinoCatalogName,
        _catalog_namespace: &NamespaceName,
        _client: &Client,
        _trino_version: u16,
    ) -> Result<CatalogConfig, FromTrinoCatalogError> {
        let connector_name = &self.connector_name;
        let mut config = CatalogConfig::new(catalog_name, connector_name);

        for (property_name, property) in &self.properties {
            match property {
                Property::Value(value) => config.add_property(property_name, value),
                Property::ValueFromSecret {
                    secret_key_selector,
                } => {
                    config.add_env_property_from_secret(property_name, secret_key_selector.clone())
                }
                Property::ValueFromConfigMap {
                    config_map_key_selector,
                } => config.add_env_property_from_config_map(
                    property_name,
                    config_map_key_selector.clone(),
                ),
            }
        }

        Ok(config)
    }
}