Function save_settings_record

crates/openshell-server/src/grpc/policy.rs:3768–3812

(
    store: &Store,
    object_type: &str,
    name: &str,
    settings: &StoredSettings,
)

}

async fn save_settings_record(
    store: &Store,
    object_type: &str,
    name: &str,
    settings: &StoredSettings,
) -> Result<(), Status> {
    use crate::persistence::WriteCondition;

    let payload = serde_json::to_vec(settings)
        .map_err(|e| Status::internal(format!("encode settings payload failed: {e}")))?;

    let (id, condition) = if settings.resource_version == 0 {
        // Create new settings (resource_version 0 means never persisted)
        (uuid::Uuid::new_v4().to_string(), WriteCondition::MustCreate)
    } else {
        // Update existing with CAS on the version from when it was loaded
        // Fetch the record to get the stable ID
        let existing = store
            .get_by_name(object_type, name)
            .await
            .map_err(|e| Status::internal(format!("fetch settings for CAS failed: {e}")))?
            .ok_or_else(|| Status::not_found("settings disappeared since load"))?;

        (
            existing.id,
            WriteCondition::MatchResourceVersion(settings.resource_version),
        )
    };

    // Single-attempt CAS write
    store
        .put_if(object_type, &id, name, &payload, None, condition)
        .await
        .map_err(|e| match e {
            crate::persistence::PersistenceError::Conflict { .. } => {
                Status::aborted("settings were modified concurrently; please retry")
            }
            crate::persistence::PersistenceError::UniqueViolation { .. } => {
                Status::aborted("settings were created concurrently; please retry")
            }
            other => super::persistence_error_to_status(other, "persist settings"),
        })?;

    Ok(())
}

fn decode_policy_from_global_settings(
    global: &StoredSettings,