Method execute_convert_collection

nodedb/src/data/executor/handlers/convert.rs:26–75

Execute a collection conversion. - `TO document` / `TO kv`: no re-encoding needed. Catalog update on Control Plane. - `TO strict`: re-encode each document as a Binary Tuple using the provided schema. Documents that fail validation are skipped and counted as errors.

(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        target_type: &str,
        schema_json: &str,
    )

    /// - `TO strict`: re-encode each document as a Binary Tuple using the provided
    ///   schema. Documents that fail validation are skipped and counted as errors.
    pub(in crate::data::executor) fn execute_convert_collection(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        target_type: &str,
        schema_json: &str,
    ) -> Response {
        tracing::debug!(
            core = self.core_id,
            %collection,
            target_type,
            "converting collection"
        );

        match target_type {
            "document_strict" => self.convert_to_strict(task, tid, collection, schema_json),
            "document_schemaless" | "kv" => {
                // No re-encoding needed — sparse engine stores raw MessagePack bytes
                // regardless of collection type. Catalog type update handled by
                // Control Plane after this returns.
                let count = self
                    .sparse
                    .scan_documents(tid, collection, usize::MAX)
                    .map(|docs| docs.len() as u64)
                    .unwrap_or(0);

                let result = serde_json::json!({
                    "converted": count,
                    "target_type": target_type,
                    "collection": collection,
                });
                match response_codec::encode_json(&result) {
                    Ok(payload) => self.response_with_payload(task, payload),
                    Err(e) => self.response_error(
                        task,
                        ErrorCode::Internal {
                            detail: e.to_string(),
                        },
                    ),
                }
            }
            other => self.response_error(
                task,
                ErrorCode::Internal {
                    detail: format!("unsupported conversion target: {other}"),
                },
            ),
        }
    }

    /// Convert to strict mode: re-encode each document as a Binary Tuple.
    fn convert_to_strict(