Method evaluate_array_mutation

nodedb/src/control/server/sync/shape/registry.rs:198–220

Evaluate an array op against all active shapes. Returns a list of `(session_id, shape_id)` pairs for `ShapeType::Array` shapes that match the mutation. The caller then pushes `ArrayDeltaMsg` frames to the matching sessions. This is a sibling of [`evaluate_mutation`] rather than a refactor so that the existing document/vector matching path is not disturbed.

(
        &self,
        tenant_id: u64,
        array_name: &str,
        coord: &[u64],
    )

    /// This is a sibling of [`evaluate_mutation`] rather than a refactor so
    /// that the existing document/vector matching path is not disturbed.
    pub fn evaluate_array_mutation(
        &self,
        tenant_id: u64,
        array_name: &str,
        coord: &[u64],
    ) -> Vec<(String, ShapeId)> {
        let sessions =
            crate::control::lock_utils::read_or_recover(self.sessions.read(), "shape_sessions");
        let mut matches = Vec::new();

        for (session_id, client) in sessions.iter() {
            if client.tenant_id != tenant_id {
                continue;
            }
            for (shape_id, shape) in &client.shapes {
                if shape.matches_array_op(array_name, coord) {
                    matches.push((session_id.clone(), shape_id.clone()));
                }
            }
        }

        matches
    }

    /// Get a shape definition by session + shape_id.
    pub fn get_shape(&self, session_id: &str, shape_id: &str) -> Option<ShapeDefinition> {