#[macro_use]
extern crate lazy_static;

mod util;

use datafusion_common::ScalarValue;
use util::check::check_transform_evaluation;
use util::datasets::vega_json_dataset;

use vegafusion_core::spec::transform::filter::FilterTransformSpec;
use vegafusion_core::spec::transform::TransformSpec;
use vegafusion_runtime::expression::compiler::config::CompilationConfig;

#[test]
fn test_filter_valid() {
    let dataset = vega_json_dataset("penguins");
    let filter_spec = FilterTransformSpec {
        expr: "isValid(datum.Sex) && datum.Sex != '.'".to_string(),
        extra: Default::default(),
    };
    let transform_specs = vec![TransformSpec::Filter(filter_spec)];

    let comp_config = Default::default();
    let eq_config = Default::default();

    check_transform_evaluation(
        &dataset,
        transform_specs.as_slice(),
        &comp_config,
        &eq_config,
    );
}

#[test]
fn test_filter_signal_expression() {
    let dataset = vega_json_dataset("penguins");

    // Apply filter transform pipeline stage to remove Nulls and keep flipper lengths less than
    // threshold
    let filter_spec = FilterTransformSpec {
        expr: "isValid(datum.Sex) && isValid(datum['Flipper Length (mm)']) && datum['Flipper Length (mm)'] < threshold"
            .to_string(),
        extra: Default::default(),
    };
    let transform_specs = vec![TransformSpec::Filter(filter_spec)];

    let eq_config = Default::default();

    let threshold = 180.0;
    let comp_config = CompilationConfig {
        signal_scope: vec![("threshold".to_string(), ScalarValue::from(threshold))]
            .into_iter()
            .collect(),
        ..Default::default()
    };

    check_transform_evaluation(
        &dataset,
        transform_specs.as_slice(),
        &comp_config,
        &eq_config,
    );
}