Function create_provider_record

crates/openshell-server/src/grpc/provider.rs:66–145

(
    store: &Store,
    mut provider: Provider,
)

}

pub(super) async fn create_provider_record(
    store: &Store,
    mut provider: Provider,
) -> Result<Provider, Status> {
    use crate::persistence::{ObjectName, current_time_ms};

    // Initialize metadata if not present
    if provider.metadata.is_none() {
        let now_ms = current_time_ms();
        provider.metadata = Some(openshell_core::proto::datamodel::v1::ObjectMeta {
            id: uuid::Uuid::new_v4().to_string(),
            name: generate_name(),
            created_at_ms: now_ms,
            labels: std::collections::HashMap::new(),
            resource_version: 0,
        });
    }

    // Auto-generate name if empty
    if let Some(metadata) = provider.metadata.as_mut() {
        if metadata.name.is_empty() {
            metadata.name = generate_name();
        }
        if metadata.id.is_empty() {
            metadata.id = uuid::Uuid::new_v4().to_string();
        }
    }

    // Ensure metadata is present and valid (must be non-None with non-empty id/name)
    super::validation::validate_object_metadata(provider.metadata.as_ref(), "provider")?;

    if provider.r#type.trim().is_empty() {
        return Err(Status::invalid_argument("provider.type is required"));
    }
    if provider.credentials.is_empty()
        && !provider_type_allows_empty_credentials(store, &provider.r#type).await?
    {
        return Err(Status::invalid_argument(
            "provider.credentials must not be empty",
        ));
    }

    // Validate field sizes before any I/O.
    validate_provider_fields(&provider)?;

    // Generate UUID for database row and update metadata.id to match
    let provider_id = uuid::Uuid::new_v4().to_string();
    let mut provider = provider;
    if let Some(metadata) = provider.metadata.as_mut() {
        metadata.id.clone_from(&provider_id);
    }

    // Create with MustCreate condition to prevent duplicate creation race
    let result = store
        .put_if(
            Provider::object_type(),
            &provider_id,
            provider.object_name(),