Struct BlackBoxProcessor 

pub struct BlackBoxProcessor { /* private fields */ }

True DOMless processor with schema-based filtering

Implementations

impl BlackBoxProcessor

pub fn new( input_schema: Vec<String>, output_schema: Vec<String>, ) -> BlackBoxProcessor

Create a new DOMless processor with adaptive processing

pub fn new_unfiltered() -> BlackBoxProcessor

Create a processor without schema filtering (legacy mode)

pub fn process(&mut self, input: &str) -> Result<String, DsonError>

Process input JSON through DOMless filtering and operations

Errors

Returns an error if JSON parsing fails or processing encounters an issue

pub fn apply_operations( &mut self, operations: &[DsonOperation], ) -> Result<(), DsonError>

Apply a sequence of operations to the processor

Errors

Returns an error if any operation fails

pub fn apply_operations_canonical( &mut self, operations: &[DsonOperation], ) -> Result<(), DsonError>

Apply operations with canonical optimization and batching

Errors

Returns an error if canonical processing or operation application fails

pub fn process_with_operations( &mut self, input: &str, operations: &[DsonOperation], ) -> Result<String, DsonError>

Process input with a specific set of operations

Errors

Returns an error if parsing or processing fails

pub fn process_with_operations_canonical( &mut self, input: &str, operations: &[DsonOperation], ) -> Result<String, DsonError>

Process input with operations using canonical optimization

Errors

Returns an error if parsing or processing fails

pub fn read_field( &self, field_path: &str, ) -> Result<Option<Node<'static>>, DsonError>

Read a field from the tape at given path

Errors

Returns an error if field navigation fails

pub fn read_field_value( &self, field_path: &str, ) -> Result<Option<OperationValue>, DsonError>

Read a field value directly as OperationValue (avoids Node conversion overhead)

This is the fast path for reading values - converts tape Node directly to OperationValue

Errors

Returns an error if field navigation fails.

pub fn write_field( &mut self, field_path: &str, value: Node<'static>, ) -> Result<(), DsonError>

Write a field to the tape (tracks as modification for later serialization)

Errors

Returns an error if field modification fails

pub fn advance_field(&self) -> Result<bool, DsonError>

Advance to next field in object - returns true if more fields exist

Errors

Returns an error if navigation fails

pub fn push_record(&mut self, record: Node<'static>) -> Result<(), DsonError>

Push a new record to array (tracks for later serialization)

Errors

Returns an error if record addition fails

pub fn advance_array_index(&self) -> Result<bool, DsonError>

Advance to next array index - returns true if more elements exist

Errors

Returns an error if navigation fails

pub fn input_schema(&self) -> Vec<String>

Get input schema paths

pub fn output_schema(&self) -> Vec<String>

Get output schema paths

pub fn apply_operation( &mut self, operation: &DsonOperation, ) -> Result<(), DsonError>

Apply a DSON operation to the processor

Errors

Returns an error if the operation cannot be applied

pub fn generate_output(&self) -> Result<String, DsonError>

Generate final JSON output based on modifications and deletions

Errors

Returns an error if output generation fails.

pub const fn modifications(&self) -> &AHashMap<String, OperationValue>

Get the current modifications map (for inspection)

pub const fn deletions(&self) -> &AHashSet<String>

Get the current deletions set (for inspection)

pub const fn determine_processing_mode( &self, document_size: usize, operation_count: usize, ) -> ProcessingMode

Determine optimal processing mode based on document and operation characteristics

pub fn process_adaptive( &mut self, input: &str, operations: &[DsonOperation], ) -> Result<String, DsonError>

Process with adaptive mode selection

Errors

Returns an error if processing fails

pub fn apply_operation_to_value_cached( &mut self, value: &mut Value, operation: &DsonOperation, ) -> Result<(), DsonError>

Apply operation directly to serde_json::Value using cached parsed paths.

Errors

Returns an error if the operation cannot be applied

pub fn apply_operation_to_value_parsed( &mut self, value: &mut Value, operation: &DsonOperation, parsed: &ParsedPath, ) -> Result<(), DsonError>

Apply operation directly to serde_json::Value using a pre-parsed path.

Errors

Returns an error if the operation cannot be applied

Trait Implementations

impl Default for BlackBoxProcessor

fn default() -> BlackBoxProcessor

Returns the “default value” for a type.