Method execute_spatial_delete

nodedb/src/data/executor/handlers/spatial_sync.rs:152–198

Remove a document's geometry from the per-field R-tree and the sparse document store on behalf of a Lite client. Keyed by the same hex-encoded surrogate used at insert time. A delete of a non-existent surrogate is a no-op (idempotent). Fails fast if the sparse store delete returns an error (other than "not found", which the sparse engine surfaces as `Ok`).

(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        field: &str,
        surrogate: Surrogate,
    )

    /// Fails fast if the sparse store delete returns an error (other than
    /// "not found", which the sparse engine surfaces as `Ok`).
    pub(in crate::data::executor) fn execute_spatial_delete(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        field: &str,
        surrogate: Surrogate,
    ) -> Response {
        let doc_id = surrogate_to_doc_id(surrogate);

        debug!(
            core = self.core_id,
            %collection,
            %field,
            doc_id = %doc_id,
            surrogate = surrogate.as_u32(),
            "spatial sync: delete geometry"
        );

        if let Err(e) = self.sparse.delete(tid, collection, &doc_id) {
            error!(
                core = self.core_id,
                %collection,
                doc_id = %doc_id,
                error = %e,
                "spatial sync: sparse document delete failed"
            );
            return self.response_error(task, e);
        }

        let tenant_id = TenantId::new(tid);
        let spatial_key = (tenant_id, collection.to_string(), field.to_string());
        let entry_id = fnv1a_hash(doc_id.as_bytes());
        let doc_map_key = (
            tenant_id,
            collection.to_string(),
            field.to_string(),
            entry_id,
        );

        if let Some(rtree) = self.spatial_indexes.get_mut(&spatial_key) {
            rtree.delete(entry_id);
        }
        self.spatial_doc_map.remove(&doc_map_key);

        self.response_ok(task)
    }
}

/// Convert a `Geometry` into a `nodedb_types::Value` for msgpack serialisation.