Method put_scoped_message

crates/openshell-server/src/persistence/mod.rs:343–368

Insert or update a protobuf message under an application-owned scope.

(
        &self,
        message: &T,
        scope: &str,
    )

    /// Insert or update a protobuf message under an application-owned scope.
    pub async fn put_scoped_message<
        T: Message + ObjectType + ObjectId + ObjectName + ObjectLabels,
    >(
        &self,
        message: &T,
        scope: &str,
    ) -> PersistenceResult<()> {
        let labels_map = message.object_labels();
        let labels_json = if labels_map.as_ref().is_none_or(HashMap::is_empty) {
            None
        } else {
            Some(serde_json::to_string(&labels_map).map_err(|e| {
                PersistenceError::Encode(format!("failed to serialize labels: {e}"))
            })?)
        };

        self.put_scoped(
            T::object_type(),
            message.object_id(),
            message.object_name(),
            scope,
            &message.encode_to_vec(),
            labels_json.as_deref(),
        )
        .await
    }

    /// Fetch and decode a protobuf message by id.
    pub async fn get_message<T: Message + Default + ObjectType + SetResourceVersion>(