Struct streamson_lib::strategy::convert::Convert

pub struct Convert { /* fields omitted */ }

Processes data from input and triggers handlers

Implementations

impl Convert

pub fn new() -> Self

Creates a new Convert

It should replace a parts of the JSON using custom bytes data are read.

pub fn add_matcher(
    &mut self,
    matcher: Box<dyn MatchMaker>,
    handlers: Vec<Arc<Mutex<dyn Handler>>>
)

Adds a mathcher and a handler to Convert

Arguments

• matcher - matcher which matches the path
• handlers - funtions which should be run to convert the data

Example

use streamson_lib::{strategy, matcher, handler, path::Path};
use std::sync::{Arc, Mutex};

let mut convert = strategy::Convert::new();

let matcher = matcher::Simple::new(r#"{"list"}[]"#).unwrap();
convert.add_matcher(
    Box::new(matcher),
    vec![Arc::new(Mutex::new(handler::Replace::new(vec![b'"', b'*', b'*', b'*', b'"'])))],
);

pub fn process(&mut self, input: &[u8]) -> Result<Vec<Vec<u8>>, General>

Processes input data

Arguments

• input - input data

Returns

• `Ok(_) processing passed, more data might be needed
• Err(_) when input is not correct json

Example

use streamson_lib::{strategy, handler, matcher, path::Path};
use std::sync::{Arc, Mutex};

let mut convert = strategy::Convert::new();
let matcher = matcher::Simple::new(r#"{"password"}"#).unwrap();
convert.add_matcher(
    Box::new(matcher),
    vec![Arc::new(Mutex::new(handler::Replace::new(vec![b'"', b'*', b'*', b'*', b'"'])))],
);

let data = convert.process(br#"{"password": "secret"}"#).unwrap();
for part in data {
    // Do something with converted data
}

Errors

If parsing logic finds that JSON is not valid, it returns error::General.

Trait Implementations

impl Default for Convert

pub fn default() -> Self

Returns the "default value" for a type.