refactor: update engine dispatch and plan builders for serialisable plan types

Data plane dispatch (text, vector), enforcement, and engine handler modules
are updated for the renamed/restructured plan types introduced by the
PhysicalPlan serialisation work. Plan builders for graph, text, and vector
native dispatch are aligned to the new type paths.

Also update .gitignore for build artefacts introduced by the new gateway
and startup modules.

Author: farhan-syah

nodedb/src/control/server/native/dispatch/plan_builder/graph.rs

@@ -1,7 +1,5 @@
 //! Graph operation plan builders.
 
-use std::sync::Arc;
-
 use nodedb_types::protocol::TextFields;
 use sonic_rs;
 
@@ -22,7 +20,7 @@ pub(crate) fn build_rag_fusion(
         })?;
     Ok(PhysicalPlan::Graph(GraphOp::RagFusion {
         collection: collection.to_string(),
-        query_vector: Arc::from(query_vector.as_slice()),
+        query_vector: query_vector.clone(),
         vector_top_k: fields.vector_top_k.unwrap_or(20) as usize,
         edge_label: fields.edge_label.clone(),
         direction: parse_direction(fields.direction.as_deref()),

nodedb/src/control/server/native/dispatch/plan_builder/text.rs

@@ -1,7 +1,5 @@
 //! Text search plan builders.
 
-use std::sync::Arc;
-
 use nodedb_types::protocol::TextFields;
 
 use crate::bridge::envelope::PhysicalPlan;
@@ -49,7 +47,7 @@ pub(crate) fn build_hybrid_search(
 
     Ok(PhysicalPlan::Text(TextOp::HybridSearch {
         collection: collection.to_string(),
-        query_vector: Arc::from(query_vector.as_slice()),
+        query_vector: query_vector.clone(),
         query_text: query_text.clone(),
         top_k,
         ef_search,

nodedb/src/control/server/native/dispatch/plan_builder/vector.rs

@@ -1,7 +1,5 @@
 //! Vector engine plan builders.
 
-use std::sync::Arc;
-
 use nodedb_types::protocol::TextFields;
 
 use crate::bridge::envelope::PhysicalPlan;
@@ -20,7 +18,7 @@ pub(crate) fn build_search(fields: &TextFields, collection: &str) -> crate::Resu
 
     Ok(PhysicalPlan::Vector(VectorOp::Search {
         collection: collection.to_string(),
-        query_vector: Arc::from(query_vector.as_slice()),
+        query_vector: query_vector.clone(),
         top_k,
         ef_search,
         filter_bitmap: None,
@@ -93,7 +91,7 @@ pub(crate) fn build_multi_search(
 
     Ok(PhysicalPlan::Vector(VectorOp::MultiSearch {
         collection: collection.to_string(),
-        query_vector: Arc::from(query_vector.as_slice()),
+        query_vector: query_vector.clone(),
         top_k,
         ef_search,
         filter_bitmap: None,

nodedb/src/data/executor/dispatch/text.rs

@@ -40,7 +40,7 @@ impl CoreLoop {
                 *ef_search,
                 *fuzzy,
                 *vector_weight,
-                filter_bitmap.as_ref(),
+                filter_bitmap.as_deref(),
                 rls_filters,
             ),
         }

nodedb/src/data/executor/dispatch/vector.rs

@@ -47,7 +47,7 @@ impl CoreLoop {
                     query_vector,
                     top_k: *top_k,
                     ef_search: *ef_search,
-                    filter_bitmap: filter_bitmap.as_ref(),
+                    filter_bitmap: filter_bitmap.as_deref(),
                     rls_filters,
                 },
             ),
@@ -73,7 +73,7 @@ impl CoreLoop {
                     query_vector,
                     top_k: *top_k,
                     ef_search: *ef_search,
-                    filter_bitmap: filter_bitmap.as_ref(),
+                    filter_bitmap: filter_bitmap.as_deref(),
                     field_name,
                     rls_filters,
                 },

nodedb/src/data/executor/enforcement/retention.rs

@@ -48,14 +48,35 @@ pub fn check_delete_allowed(
 }
 
 /// Parsed retention duration with calendar-accurate units.
-#[derive(Debug, Clone, Copy, PartialEq, Eq)]
+#[derive(
+    Debug,
+    Clone,
+    Copy,
+    PartialEq,
+    Eq,
+    serde::Serialize,
+    serde::Deserialize,
+    zerompk::ToMessagePack,
+    zerompk::FromMessagePack,
+)]
 pub struct RetentionDuration {
     pub count: u32,
     pub unit: RetentionUnit,
 }
 
 /// Calendar-accurate duration units.
-#[derive(Debug, Clone, Copy, PartialEq, Eq)]
+#[derive(
+    Debug,
+    Clone,
+    Copy,
+    PartialEq,
+    Eq,
+    serde::Serialize,
+    serde::Deserialize,
+    zerompk::ToMessagePack,
+    zerompk::FromMessagePack,
+)]
+#[msgpack(c_enum)]
 pub enum RetentionUnit {
     Seconds,
     Minutes,

nodedb/src/data/executor/handlers/text_search.rs

@@ -92,7 +92,7 @@ impl CoreLoop {
         ef_search: usize,
         fuzzy: bool,
         vector_weight: f32,
-        filter_bitmap: Option<&std::sync::Arc<[u8]>>,
+        filter_bitmap: Option<&[u8]>,
         rls_filters: &[u8],
     ) -> Response {
         let scoped_coll = scoped_collection(tid, collection);

nodedb/src/data/executor/handlers/vector_search.rs

@@ -53,7 +53,7 @@ pub(in crate::data::executor) struct VectorSearchParams<'a> {
     pub query_vector: &'a [f32],
     pub top_k: usize,
     pub ef_search: usize,
-    pub filter_bitmap: Option<&'a std::sync::Arc<[u8]>>,
+    pub filter_bitmap: Option<&'a [u8]>,
     pub field_name: &'a str,
     /// RLS post-candidate filters. Applied after HNSW/IVF returns candidates.
     pub rls_filters: &'a [u8],
@@ -67,7 +67,7 @@ pub(in crate::data::executor) struct VectorMultiSearchParams<'a> {
     pub query_vector: &'a [f32],
     pub top_k: usize,
     pub ef_search: usize,
-    pub filter_bitmap: Option<&'a std::sync::Arc<[u8]>>,
+    pub filter_bitmap: Option<&'a [u8]>,
     /// RLS post-candidate filters (evaluated per-candidate after RRF fusion).
     pub rls_filters: &'a [u8],
 }
@@ -186,7 +186,7 @@ impl CoreLoop {
         ivf: &crate::engine::vector::ivf::IvfPqIndex,
         query_vector: &[f32],
         top_k: usize,
-        filter_bitmap: Option<&std::sync::Arc<[u8]>>,
+        filter_bitmap: Option<&[u8]>,
     ) -> Response {
         if ivf.is_empty() {
             return self.response_with_payload(task, b"[]".to_vec());

nodedb/src/engine/graph/algo/params.rs

@@ -11,7 +11,19 @@ use serde::{Deserialize, Serialize};
 /// Each variant maps to a standalone algorithm implementation under
 /// `src/engine/graph/algo/`. Used by `PhysicalPlan::GraphAlgo` to
 /// identify which algorithm to dispatch.
-#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
+#[derive(
+    Debug,
+    Clone,
+    Copy,
+    PartialEq,
+    Eq,
+    Hash,
+    Serialize,
+    Deserialize,
+    zerompk::ToMessagePack,
+    zerompk::FromMessagePack,
+)]
+#[msgpack(c_enum)]
 pub enum GraphAlgorithm {
     /// PageRank — link analysis (power iteration).
     PageRank,
@@ -110,7 +122,16 @@ pub enum AlgoColumnType {
 /// Each algorithm validates and extracts the parameters it needs,
 /// ignoring the rest. Unknown parameters are silently ignored rather
 /// than rejected — this allows forward-compatible DDL extensions.
-#[derive(Debug, Clone, Default, Serialize, Deserialize)]
+#[derive(
+    Debug,
+    Clone,
+    Default,
+    PartialEq,
+    Serialize,
+    Deserialize,
+    zerompk::ToMessagePack,
+    zerompk::FromMessagePack,
+)]
 pub struct AlgoParams {
     /// Target collection name.
     pub collection: String,

nodedb/src/engine/graph/traversal_options.rs

@@ -9,7 +9,16 @@ use serde::{Deserialize, Serialize};
 ///
 /// Controls fan-out limits, partial result handling, and visited node caps
 /// for scatter-gather graph queries across shards.
-#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+#[derive(
+    Debug,
+    Clone,
+    PartialEq,
+    Eq,
+    Serialize,
+    Deserialize,
+    zerompk::ToMessagePack,
+    zerompk::FromMessagePack,
+)]
 pub struct GraphTraversalOptions {
     /// Soft warning threshold (shards per hop).
     ///