fix(tesseract): Filters over proxy time dimensions

Author: waralexrom

rust/cubesqlplanner/cubesqlplanner/src/planner/filter/base_filter.rs

@@ -25,6 +25,7 @@ pub struct BaseFilter {
     filter_type: FilterType,
     filter_operator: FilterOperator,
     values: Vec<Option<String>>,
+    is_over_date_range: bool,
     use_raw_values: bool,
     templates: FilterTemplates,
 }
@@ -51,11 +52,31 @@ impl BaseFilter {
         } else {
             vec![]
         };
+
+        //Check if we have proxy time dimension as input 
+        let symbol_to_check = if let Ok(time_dimension) = member_evaluator.as_time_dimension() {
+            time_dimension.base_symbol().clone()
+        } else {
+            member_evaluator.clone()
+        };
+
+        let resolved_ref = symbol_to_check.resolve_reference_chain();
+        let is_over_date_range = if resolved_ref.as_time_dimension().is_ok() {
+            true
+        } else {
+            false
+        };
+        
+
+            
+        
+
         Ok(Rc::new(Self {
             query_tools,
             member_evaluator,
             filter_type,
             filter_operator,
+            is_over_date_range,
             values,
             templates,
             use_raw_values: false,
@@ -72,6 +93,7 @@ impl BaseFilter {
             query_tools: self.query_tools.clone(),
             member_evaluator: self.member_evaluator.clone(),
             filter_type: self.filter_type.clone(),
+            is_over_date_range: self.is_over_date_range,
             filter_operator,
             values,
             templates: self.templates.clone(),
@@ -131,6 +153,11 @@ impl BaseFilter {
                 context.clone(),
                 plan_templates,
             )?;
+            let member_sql = if self.is_over_date_range {
+                plan_templates.base_tools().time_stamp_cast(member_sql.clone())?
+            } else {
+                member_sql
+            };
             let filters_context = context.filters_context();
 
             let res = match self.filter_operator {
@@ -234,7 +261,7 @@ impl BaseFilter {
         if self.is_array_value() {
             self.templates.in_where(
                 member_sql.to_string(),
-                self.filter_and_allocate_values(),
+                self.filter_and_allocate_values()?,
                 need_null_check,
             )
         } else if self.is_values_contains_null() {
@@ -254,7 +281,7 @@ impl BaseFilter {
         if self.is_array_value() {
             self.templates.not_in_where(
                 member_sql.to_string(),
-                self.filter_and_allocate_values(),
+                self.filter_and_allocate_values()?,
                 need_null_check,
             )
         } else if self.is_values_contains_null() {
@@ -433,7 +460,7 @@ impl BaseFilter {
         let need_null_check = self.is_need_null_chek(false);
         self.templates.in_where(
             member_sql.to_string(),
-            self.filter_and_allocate_values(),
+            self.filter_and_allocate_values()?,
             need_null_check,
         )
     }
@@ -446,7 +473,7 @@ impl BaseFilter {
         let need_null_check = self.is_need_null_chek(true);
         self.templates.not_in_where(
             member_sql.to_string(),
-            self.filter_and_allocate_values(),
+            self.filter_and_allocate_values()?,
             need_null_check,
         )
     }
@@ -558,7 +585,7 @@ impl BaseFilter {
         start_wild: bool,
         end_wild: bool,
     ) -> Result<String, CubeError> {
-        let values = self.filter_and_allocate_values();
+        let values = self.filter_and_allocate_values()?;
         let like_parts = values
             .into_iter()
             .map(|v| {
@@ -655,8 +682,12 @@ impl BaseFilter {
         QueryDateTimeHelper::format_to_date(date, self.query_tools.clone())
     }
 
-    fn allocate_param(&self, param: &str) -> String {
-        self.query_tools.allocate_param(param)
+    fn allocate_param(&self, param: &str) -> Result<String, CubeError> {
+        if self.is_over_date_range {
+            self.allocate_timestamp_param(param, false)
+        } else {
+            Ok(self.query_tools.allocate_param(param))
+        }
     }
 
     fn allocate_timestamp_param(
@@ -682,7 +713,7 @@ impl BaseFilter {
             )))
         } else {
             if let Some(value) = &self.values[0] {
-                Ok(self.allocate_param(value))
+                self.allocate_param(value)
             } else {
                 Ok("NULL".to_string())
             }
@@ -730,10 +761,10 @@ impl BaseFilter {
         self.values.len() > 1
     }
 
-    fn filter_and_allocate_values(&self) -> Vec<String> {
+    fn filter_and_allocate_values(&self) -> Result<Vec<String>, CubeError> {
         self.values
             .iter()
             .filter_map(|v| v.as_ref().map(|v| self.allocate_param(&v)))
-            .collect::<Vec<_>>()
+            .collect::<Result<Vec<_>, _>>()
     }
 }